add events and tasks

Author: zcesur

lib/algora/cloud.ex

@@ -53,6 +53,10 @@ defmodule Algora.Cloud do
     call(AlgoraCloud.Talent.Jobs.SendCompanyLikeEmail, :send, [attrs])
   end
 
+  def create_admin_task(attrs) do
+    call(AlgoraCloud.AdminTasks, :create_admin_task, [attrs])
+  end
+
   def start do
     call(AlgoraCloud, :start, [])
   end

lib/algora_web/live/onboarding/org.ex

@@ -43,14 +43,43 @@ defmodule AlgoraWeb.Onboarding.OrgLive do
   def handle_event("submit", %{"form" => params}, socket) do
     case %Form{} |> Form.changeset(params) |> Ecto.Changeset.apply_action(:save) do
       {:ok, data} ->
+        # Create alert for immediate notification
         Algora.Activities.alert(Jason.encode!(data), :critical)
+
+        # Create admin task for welcoming the user
+        create_welcome_task(data)
+
         {:noreply, put_flash(socket, :info, "Thanks for submitting your JD! We'll follow up soon")}
 
       {:error, changeset} ->
         {:noreply, assign(socket, form: to_form(changeset))}
     end
   end
 
+  defp create_welcome_task(data) do
+    task_attrs = %{
+      type: "user_welcome",
+      payload: %{
+        email: data.email,
+        job_description: data.job_description,
+        candidate_description: data.candidate_description,
+        comp_range: data.comp_range,
+        submitted_at: DateTime.utc_now(),
+        source: "jd_submission"
+      },
+      seq: 0,
+      origin_id: Nanoid.generate()
+    }
+
+    case Algora.Cloud.create_admin_task(task_attrs) do
+      {:ok, _task} ->
+        Logger.info("Created welcome task for #{data.email}")
+
+      {:error, changeset} ->
+        Logger.error("Failed to create welcome task: #{inspect(changeset)}")
+    end
+  end
+
   @impl true
   def render(assigns) do
     ~H"""

priv/repo/migrations/20250917150527_create_admin_tasks.exs

@@ -0,0 +1,27 @@
+defmodule Algora.Repo.Migrations.CreateAdminTasks do
+  use Ecto.Migration
+
+  def change do
+    create table(:admin_tasks, primary_key: false) do
+      add :id, :string, primary_key: true
+      add :type, :string, null: false
+      add :completed_at, :utc_datetime_usec
+      add :discarded_at, :utc_datetime_usec
+      add :payload, :map, null: false
+      add :origin_id, :string
+      add :seq, :integer
+      add :logs, {:array, :map}, default: []
+      add :pinned, :boolean, default: false
+
+      timestamps()
+    end
+
+    create index(:admin_tasks, [:type])
+    create index(:admin_tasks, [:origin_id])
+    create index(:admin_tasks, [:seq])
+    create index(:admin_tasks, [:completed_at])
+    create index(:admin_tasks, [:discarded_at])
+    create index(:admin_tasks, [:pinned])
+    create index(:admin_tasks, [:inserted_at])
+  end
+end

priv/repo/migrations/20250917151007_create_events.exs

@@ -0,0 +1,20 @@
+defmodule Algora.Repo.Migrations.CreateEvents do
+  use Ecto.Migration
+
+  def change do
+    create table(:events, primary_key: false) do
+      add :id, :string, primary_key: true
+      add :type, :string, null: false
+      add :payload, :map
+      add :origin_id, :string, null: false
+      add :seq, :integer, null: false
+
+      timestamps(type: :utc_datetime_usec)
+    end
+
+    create index(:events, [:type])
+    create index(:events, [:origin_id])
+    create index(:events, [:origin_id, :seq])
+    create index(:events, [:inserted_at])
+  end
+end