Add read-only jobs view with optional filters

server/lib/orcasite/notifications/changes/extract_notification_instance_meta.ex

@@ -24,6 +24,7 @@ defmodule Orcasite.Notifications.Changes.ExtractNotificationInstanceMeta do
  {:get_notif, Notifications.get(Notification, changeset.arguments.notification)} do
  changeset
  |> Ash.Changeset.change_attribute(:meta, %{
+ email: Map.get(subscription.meta, "email"),
  subscriber_name: Map.get(subscription.meta, "name"),
  channel: Map.get(subscription.meta, "channel"),
  event_type: notification.event_type,

server/lib/orcasite/notifications/registry.ex

@@ -10,5 +10,6 @@ defmodule Orcasite.Notifications.Registry do
  entry Orcasite.Notifications.Subscription
  entry Orcasite.Notifications.NotificationInstance
  entry Orcasite.Notifications.Token
+ entry Orcasite.Notifications.Job
  end
 end

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

@@ -0,0 +1,124 @@
+defmodule Orcasite.Notifications.Job do
+ use Ash.Resource,
+ extensions: [AshAdmin.Resource, AshGraphql.Resource],
+ data_layer: AshPostgres.DataLayer
+
+ @states [:available, :scheduled, :executing, :retryable, :completed, :discarded, :cancelled]
+
+ postgres do
+ table "oban_jobs"
+ repo Orcasite.Repo
+ migrate? false
+ end
+
+ attributes do
+ integer_primary_key :id
+
+ attribute :state, :atom do
+ constraints one_of: @states
+
+ writable? false
+ end
+
+ attribute :queue, :string, writable?: false
+ attribute :worker, :string, writable?: false
+ attribute :args, :map, writable?: false
+ attribute :errors, {:array, :map}, writable?: false
+ attribute :attempt, :integer, writable?: false
+ attribute :max_attempts, :integer, writable?: false
+
+ attribute :inserted_at, :utc_datetime, writable?: false
+ attribute :scheduled_at, :utc_datetime, writable?: false
+ attribute :attempted_at, :utc_datetime, writable?: false
+ attribute :completed_at, :utc_datetime, writable?: false
+ attribute :cancelled_at, :utc_datetime, writable?: false
+ attribute :discarded_at, :utc_datetime, writable?: false
+
+ attribute :attempted_by, {:array, :string}, writable?: false
+ attribute :priority, :integer, writable?: false
+ attribute :tags, {:array, :string}, writable?: false
+ attribute :meta, :map, writable?: false
+ end
+
+ actions do
+ defaults [:read]
+
+ read :index do
+ pagination do
+ offset? true
+ countable true
+ default_limit 100
+ end
+
+ argument :state, :atom do
+ constraints one_of: @states
+ end
+
+ argument :notification_id, :string
+ argument :subscription_id, :string
+ argument :email, :string
+ argument :node, :string
+
+ argument :event_type, :atom do
+ constraints one_of: Orcasite.Notifications.Event.types()
+ end
+
+ filter expr(
+ if(is_nil(^arg(:notification_id)),
+ do: true,
+ else: args[:notification_id] == ^arg(:notification_id)
+ ) and
+ if(is_nil(^arg(:subscription_id)),
+ do: true,
+ else: args[:subscription_id] == ^arg(:subscription_id)
+ ) and
+ if(is_nil(^arg(:email)),
+ do: true,
+ else: args[:meta][:email] == ^arg(:email)
+ ) and
+ if(is_nil(^arg(:node)),
+ do: true,
+ else: args[:meta][:node] == ^arg(:node)
+ ) and
+ if(is_nil(^arg(:event_type)),
+ do: true,
+ else: args[:meta][:event_type] == ^arg(:event_type)
+ ) and
+ if(is_nil(^arg(:state)),
+ do: true,
+ else: state == ^arg(:state)
+ )
+ )
+ end
+ end
+
+ admin do
+ table_columns [
+ :id,
+ :state,
+ :args,
+ :attempt,
+ :max_attempts,
+ :inserted_at,
+ :scheduled_at,
+ :completed_at,
+ :tags
+ ]
+
+ format_fields args: {__MODULE__, :fetch_meta, []},
+ meta: {Jason, :encode!, []},
+ inserted_at: {Calendar, :strftime, ["%m/%d %H:%M:%S %Z"]},
+ scheduled_at: {Calendar, :strftime, ["%m/%d %H:%M:%S %Z"]},
+ completed_at: {Calendar, :strftime, ["%m/%d %H:%M:%S %Z"]}
+ end
+
+ preparations do
+ prepare build(sort: [inserted_at: :desc])
+ end
+
+ def fetch_meta(args) do
+ args
+ |> Map.get("meta")
+ |> Jason.encode!()
+ end
+end

server/mix.exs

@@ -47,7 +47,7 @@ defmodule Orcasite.Mixfile do
  {:phoenix_ecto, "~> 4.4"},
  {:ecto_sql, "~> 3.6"},
  {:postgrex, ">= 0.0.0"},
- {:phoenix_html, "~> 3.3"},
+ {:phoenix_html, "~> 4.0"},
  {:phoenix_live_reload, "~> 1.2", only: :dev},
  {:phoenix_live_view, "~> 0.20.0"},
  {:phoenix_live_dashboard, "~> 0.8.0"},
@@ -57,12 +57,12 @@ defmodule Orcasite.Mixfile do
  {:finch, "~> 0.13"},
  {:floki, ">= 0.30.0", only: :test},
  {:gettext, "~> 0.20"},
- {:plug_cowboy, "~> 2.5"},
+ {:plug_cowboy, "~> 2.7"},
  {:plug, "~> 1.7"},
  {:absinthe, "~> 1.7"},
  {:absinthe_plug, "~> 1.5"},
  # Provides helper functions for easy batching of Ecto associations
- {:dataloader, "~> 1.0.0"},
+ {:dataloader, "~> 2.0"},
  # Algorithm used by Comeonin to hash password
  {:bcrypt_elixir, "~> 3.0"},
  # JSON parser, works with Absinthe out of the box
@@ -71,24 +71,24 @@ defmodule Orcasite.Mixfile do
  {:geo_postgis, "~> 3.0"},
  {:jason, "~> 1.2"},
  # Reverse proxy for proxying to nextjs app
- {:reverse_proxy_plug, "~> 2.1"},
+ {:reverse_proxy_plug, "~> 2.3.0"},
  {:httpoison, "~> 2.2"},
- {:corsica, "~> 1.0"},
+ {:corsica, "~> 2.1"},
  {:telemetry_metrics, "~> 0.6"},
  {:telemetry_poller, "~> 1.0"},
  {:ash, "~> 2.6", override: true},
- {:ash_admin, "~> 0.10.0"},
+ {:ash_admin, github: "ash-project/ash_admin", branch: "main"},
  {:ash_postgres, "~> 1.3"},
  {:heroicons, "~> 0.5"},
  {:oban, "~> 2.14"},
  {:gen_smtp, "~> 1.0"},
  {:ash_authentication, "~> 3.12.0"},
- {:ash_authentication_phoenix, "~> 1.9.0"},
+ {:ash_authentication_phoenix, "~> 1.9.3"},
  {:syn, "~> 3.3"},
  {:mjml, "~> 3.0.1"},
  {:zappa, github: "skanderm/zappa", branch: "master"},
  {:ash_uuid, "~> 0.4"},
- {:ash_graphql, "~> 0.26.6"},
+ {:ash_graphql, "~> 0.27.0"},
  {:ash_json_api, "~> 0.34.0"},
  {:open_api_spex, "~> 3.16"},
  {:redoc_ui_plug, "~> 0.2.1"},