feat: implement Oban worker for sending campaign emails with bulk enqueueing from the admin interface

Author: zcesur

lib/algora/activities/jobs/send_campaign_email.ex

@@ -0,0 +1,16 @@
+defmodule Algora.Activities.Jobs.SendCampaignEmail do
+  @moduledoc """
+  Oban worker for sending campaign emails with duplicate prevention.
+  """
+  use Oban.Worker, queue: :campaign_emails, unique: [period: :infinity, fields: [:args]]
+
+  alias AlgoraWeb.Admin.CampaignLive
+
+  @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"recipient" => recipient, "subject" => subject, "template_params" => template_params}}) do
+    recipient = for {key, val} <- recipient, into: %{}, do: {String.to_atom(key), val}
+    template_params = for {key, val} <- template_params, into: [], do: {String.to_atom(key), val}
+
+    CampaignLive.deliver_email(recipient, subject, template_params)
+  end
+end

lib/algora_web/live/admin/campaign_live.ex

@@ -5,6 +5,7 @@ defmodule AlgoraWeb.Admin.CampaignLive do
 
   import Ecto.Changeset
 
+  alias Algora.Activities.Jobs.SendCampaignEmail
   alias Algora.Mailer
   alias AlgoraWeb.LocalStore
   alias Swoosh.Email
@@ -87,6 +88,29 @@ defmodule AlgoraWeb.Admin.CampaignLive do
     end
   end
 
+  @impl true
+  def handle_event("send_all", _params, socket) do
+    subject = get_change(socket.assigns.form.source, :subject)
+    template = get_change(socket.assigns.form.source, :template)
+
+    jobs =
+      Enum.map(socket.assigns.csv_data, fn recipient ->
+        %{
+          recipient: recipient,
+          subject: subject,
+          template_params: [markdown: render_preview(template, recipient), img: "#{recipient["repo_owner"]}.png"]
+        }
+      end)
+
+    case Oban.insert_all(SendCampaignEmail, jobs) do
+      {:ok, _jobs} ->
+        {:noreply, put_flash(socket, :info, "Enqueued #{length(jobs)} emails for sending")}
+
+      {:error, _} ->
+        {:noreply, put_flash(socket, :error, "Failed to enqueue emails")}
+    end
+  end
+
   @impl true
   def render(assigns) do
     ~H"""
@@ -143,6 +167,11 @@ defmodule AlgoraWeb.Admin.CampaignLive do
 
           <div>
             <div class="-mx-4 overflow-x-auto">
+              <div class="flex justify-end mb-4">
+                <.button type="button" phx-click="send_all">
+                  Send to {length(@csv_data)} Recipients
+                </.button>
+              </div>
               <.table id="csv-data" rows={@csv_data}>
                 <:col :let={row} :for={key <- Map.keys(List.first(@csv_data) || %{})} label={key}>
                   {row[key]}