Moderator notifications

server/config/config.exs

@@ -108,6 +108,7 @@ config :spark, :formatter,
       :authentication,
       :token,
       :policies,
+      :field_policies,
       :actions,
       :admin,
       :json_api,

server/lib/orcasite/notifications.ex

@@ -1,5 +1,5 @@
 defmodule Orcasite.Notifications do
-  use Ash.Api, extensions: [AshAdmin.Api, AshJsonApi.Api]
+  use Ash.Api, extensions: [AshAdmin.Api, AshJsonApi.Api, AshGraphql.Api]
 
   resources do
     registry Orcasite.Notifications.Registry
@@ -12,4 +12,7 @@ defmodule Orcasite.Notifications do
   json_api do
     log_errors? true
   end
+
+  graphql do
+  end
 end

server/lib/orcasite/notifications/resources/notification.ex

@@ -1,26 +1,31 @@
 defmodule Orcasite.Notifications.Notification do
   use Ash.Resource,
-    extensions: [AshAdmin.Resource],
-    data_layer: AshPostgres.DataLayer
+    extensions: [AshAdmin.Resource, AshGraphql.Resource],
+    data_layer: AshPostgres.DataLayer,
+    authorizers: [Ash.Policy.Authorizer]
 
   alias Orcasite.Notifications.{Event, NotificationInstance, Subscription}
 
   postgres do
     table "notifications"
     repo Orcasite.Repo
+
+    custom_indexes do
+      index [:meta], using: "gin"
+    end
   end
 
   attributes do
     uuid_primary_key :id
 
-    attribute :meta, :map
+    attribute :meta, :map, default: %{}
     attribute :active, :boolean, default: true
 
     attribute :event_type, :atom do
       constraints one_of: Event.types()
     end
 
-    create_timestamp :inserted_at
+    create_timestamp :inserted_at, private?: false, writable?: false
     update_timestamp :updated_at
   end
 
@@ -34,24 +39,16 @@ defmodule Orcasite.Notifications.Notification do
     end
   end
 
-  code_interface do
-    define_for Orcasite.Notifications
-
-    define :notify_new_detection,
-      action: :notify_new_detection,
-      args: [:detection_id, :node, :description, :listener_count, :candidate_id]
-
-    define :notify_confirmed_candidate,
-      action: :notify_confirmed_candidate,
-      args: [:candidate_id, :node]
-  end
+  policies do
+    bypass actor_attribute_equals(:admin, true) do
+      authorize_if always()
+    end
 
-  resource do
-    description """
-    Notification for a specific event type. Once created, all Subscriptions that match this Notification's
-    event type (new detection, confirmed candidate, etc.) will be notified using the Subscription's particular
-    channel settings (email, browser notification, webhooks).
-    """
+    bypass actor_attribute_equals(:moderator, true) do
+      authorize_if action(:notify_confirmed_candidate)
+      authorize_if action(:cancel_notification)
+      authorize_if action(:for_candidate)
+    end
   end
 
   actions do
@@ -64,7 +61,31 @@ defmodule Orcasite.Notifications.Notification do
       manual Orcasite.Notifications.ManualReadNotificationsSince
     end
 
+    read :for_candidate do
+      prepare build(sort: [inserted_at: :desc])
+      argument :candidate_id, :string, allow_nil?: false
+
+      argument :event_type, :atom do
+        constraints one_of: Event.types()
+      end
+
+      argument :active, :boolean
+
+      filter expr(
+               fragment("(? @> ?)", meta, expr(%{candidate_id: ^arg(:candidate_id)})) and
+                 if(not is_nil(^arg(:event_type)),
+                   do: event_type == ^arg(:event_type),
+                   else: true
+                 ) and
+                 if(not is_nil(^arg(:active)),
+                   do: active == ^arg(:active),
+                   else: true
+                 )
+             )
+    end
+
     update :cancel_notification do
+      accept []
       change set_attribute(:active, false)
 
       change fn changeset, _context ->
@@ -84,9 +105,8 @@ defmodule Orcasite.Notifications.Notification do
 
     create :notify_confirmed_candidate do
       description "Create a notification for confirmed candidate (i.e. detection group)"
-      accept [:candidate_id]
-      argument :candidate_id, :string
-      argument :node, :string, allow_nil?: false
+      accept [:candidate_id, :message]
+      argument :candidate_id, :string, allow_nil?: false
 
       argument :message, :string do
         description """
@@ -100,10 +120,19 @@ defmodule Orcasite.Notifications.Notification do
       change set_attribute(:event_type, :confirmed_candidate)
 
       change fn changeset, _context ->
+        candidate_id =
+          Ash.Changeset.get_argument(changeset, :candidate_id)
+          |> IO.inspect(label: "candidate id")
+
+        candidate =
+          Orcasite.Radio.Candidate
+          |> Orcasite.Radio.get(candidate_id)
+          |> Orcasite.Radio.load!(:feed)
+
         changeset
         |> Ash.Changeset.change_attribute(:meta, %{
-          candidate_id: Ash.Changeset.get_argument(changeset, :candidate_id),
-          node: Ash.Changeset.get_argument(changeset, :node),
+          candidate_id: candidate_id,
+          node: candidate.feed.slug,
           message: Ash.Changeset.get_argument(changeset, :message)
         })
       end
@@ -134,6 +163,36 @@ defmodule Orcasite.Notifications.Notification do
     end
   end
 
+  code_interface do
+    define_for Orcasite.Notifications
+
+    define :notify_new_detection,
+      action: :notify_new_detection,
+      args: [:detection_id, :node, :description, :listener_count, :candidate_id]
+
+    define :notify_confirmed_candidate,
+      action: :notify_confirmed_candidate,
+      args: [:candidate_id]
+  end
+
+  resource do
+    description """
+    Notification for a specific event type. Once created, all Subscriptions that match this Notification's
+    event type (new detection, confirmed candidate, etc.) will be notified using the Subscription's particular
+    channel settings (email, browser notification, webhooks).
+    """
+  end
+
+  admin do
+    table_columns [:id, :meta, :event_type, :inserted_at]
+
+    format_fields meta: {Jason, :encode!, []}
+
+    form do
+      field :event_type, type: :default
+    end
+  end
+
   changes do
     change fn changeset, _context ->
              changeset
@@ -162,13 +221,16 @@ defmodule Orcasite.Notifications.Notification do
            on: :create
   end
 
-  admin do
-    table_columns [:id, :meta, :event_type, :inserted_at]
+  graphql do
+    type :notification
 
-    format_fields meta: {Jason, :encode!, []}
+    queries do
+      list :notifications_for_candidate, :for_candidate
+    end
 
-    form do
-      field :event_type, type: :default
+    mutations do
+      create :notify_confirmed_candidate, :notify_confirmed_candidate
+      update :cancel_notification, :cancel_notification
     end
   end
 end

server/lib/orcasite/notifications/resources/notification_instance.ex

@@ -9,7 +9,7 @@ defmodule Orcasite.Notifications.NotificationInstance do
   attributes do
     uuid_primary_key :id
 
-    attribute :meta, :map
+    attribute :meta, :map, default: %{}
 
     attribute :channel, :atom do
       constraints one_of: [:email]

server/lib/orcasite/notifications/resources/subscriber.ex

@@ -8,6 +8,10 @@ defmodule Orcasite.Notifications.Subscriber do
   postgres do
     table "subscribers"
     repo Orcasite.Repo
+
+    custom_indexes do
+      index [:meta], using: "gin"
+    end
   end
 
   identities do
@@ -24,7 +28,7 @@ defmodule Orcasite.Notifications.Subscriber do
       constraints one_of: [:individual, :organization]
     end
 
-    attribute :meta, :map
+    attribute :meta, :map, default: %{}
 
     create_timestamp :inserted_at
     update_timestamp :updated_at
@@ -39,12 +43,6 @@ defmodule Orcasite.Notifications.Subscriber do
     define :by_email, args: [:email]
   end
 
-  resource do
-    description """
-    A subscriber object. Can relate to an individual, an organization, a newsletter, or an admin.
-    """
-  end
-
   authentication do
     api Orcasite.Notifications
 
@@ -78,6 +76,12 @@ defmodule Orcasite.Notifications.Subscriber do
     end
   end
 
+  resource do
+    description """
+    A subscriber object. Can relate to an individual, an organization, a newsletter, or an admin.
+    """
+  end
+
   actions do
     defaults [:create, :read, :update, :destroy]
 

server/lib/orcasite/notifications/resources/subscription.ex

@@ -8,13 +8,48 @@ defmodule Orcasite.Notifications.Subscription do
   postgres do
     table "subscriptions"
     repo Orcasite.Repo
+
+    custom_indexes do
+      index [:meta], using: "gin"
+    end
   end
 
   identities do
     # Needed by magic_token. Primary key doesn't show up as an identity otherwise
     identity :id, [:id]
   end
 
+  attributes do
+    uuid_primary_key :id
+
+    attribute :name, :string
+    attribute :meta, :map, default: %{}
+
+    attribute :active, :boolean, default: true
+
+    attribute :event_type, :atom do
+      constraints one_of: Event.types()
+    end
+
+    attribute :last_notified_at, :utc_datetime_usec
+
+    create_timestamp :inserted_at
+    update_timestamp :updated_at
+  end
+
+  relationships do
+    belongs_to :subscriber, Subscriber
+    has_many :notification_instances, NotificationInstance
+
+    many_to_many :notifications, Notification do
+      through NotificationInstance
+      source_attribute_on_join_resource :subscription_id
+      destination_attribute_on_join_resource :notification_id
+    end
+
+    belongs_to :last_notification, Notification
+  end
+
   authentication do
     api Orcasite.Notifications
 
@@ -48,37 +83,6 @@ defmodule Orcasite.Notifications.Subscription do
     end
   end
 
-  attributes do
-    uuid_primary_key :id
-
-    attribute :name, :string
-    attribute :meta, :map
-
-    attribute :active, :boolean, default: true
-
-    attribute :event_type, :atom do
-      constraints one_of: Event.types()
-    end
-
-    attribute :last_notified_at, :utc_datetime_usec
-
-    create_timestamp :inserted_at
-    update_timestamp :updated_at
-  end
-
-  relationships do
-    belongs_to :subscriber, Subscriber
-    has_many :notification_instances, NotificationInstance
-
-    many_to_many :notifications, Notification do
-      through NotificationInstance
-      source_attribute_on_join_resource :subscription_id
-      destination_attribute_on_join_resource :notification_id
-    end
-
-    belongs_to :last_notification, Notification
-  end
-
   code_interface do
     define_for Orcasite.Notifications