feat: guardian and guardian_ninja schemas

lib/katana/accounts/user.ex

@@ -13,6 +13,8 @@ defmodule Katana.Accounts.User do
     field :name, :string
     field :email, :string
 
+    has_one :guardian, Katana.Guardians.Guardian, foreign_key: :user_id
+
     field :password, :string, virtual: true, redact: true
     field :hashed_password, :string, redact: true
     field :current_password, :string, virtual: true, redact: true

lib/katana/guardians.ex

@@ -0,0 +1,149 @@
+defmodule Katana.Guardians do
+  @moduledoc """
+  The Guardians context, including links between Guardians and Ninjas.
+  """
+
+  import Ecto.Query, warn: false
+  alias Katana.Repo
+
+  alias Katana.Guardians.Guardian
+  alias Katana.GuardiansNinjas.GuardianNinja
+  alias Katana.Ninjas.Ninja
+
+  # --------------------
+  # Guardians CRUD
+  # --------------------
+
+  @doc """
+  Returns the list of guardians.
+  """
+  def list_guardians do
+    Repo.all(Guardian)
+  end
+
+  @doc """
+  Gets a single guardian.
+  """
+  def get_guardian!(id), do: Repo.get!(Guardian, id)
+
+  @doc """
+  Creates a guardian.
+  """
+  def create_guardian(attrs \\ %{}) do
+    %Guardian{}
+    |> Guardian.changeset(attrs)
+    |> Repo.insert()
+  end
+
+  @doc """
+  Updates a guardian.
+  """
+  def update_guardian(%Guardian{} = guardian, attrs) do
+    guardian
+    |> Guardian.changeset(attrs)
+    |> Repo.update()
+  end
+
+  @doc """
+  Deletes a guardian.
+  """
+  def delete_guardian(%Guardian{} = guardian) do
+    Repo.delete(guardian)
+  end
+
+  @doc """
+  Returns an `%Ecto.Changeset{}` for tracking guardian changes.
+  """
+  def change_guardian(%Guardian{} = guardian, attrs \\ %{}) do
+    Guardian.changeset(guardian, attrs)
+  end
+
+  # --------------------
+  # GuardianNinja join table CRUD
+  # --------------------
+
+  @doc """
+  Returns the list of guardian_ninjas.
+  """
+  def list_guardian_ninjas do
+    Repo.all(GuardianNinja)
+  end
+
+  @doc """
+  Gets a single guardian_ninja.
+  """
+  def get_guardian_ninja!(id), do: Repo.get!(GuardianNinja, id)
+
+  @doc """
+  Creates a guardian_ninja link.
+  """
+  def create_guardian_ninja(attrs \\ %{}) do
+    %GuardianNinja{}
+    |> GuardianNinja.changeset(attrs)
+    |> Repo.insert()
+  end
+
+  @doc """
+  Updates a guardian_ninja link.
+  """
+  def update_guardian_ninja(%GuardianNinja{} = guardian_ninja, attrs) do
+    guardian_ninja
+    |> GuardianNinja.changeset(attrs)
+    |> Repo.update()
+  end
+
+  @doc """
+  Deletes a guardian_ninja link.
+  """
+  def delete_guardian_ninja(%GuardianNinja{} = guardian_ninja) do
+    Repo.delete(guardian_ninja)
+  end
+
+  @doc """
+  Returns an `%Ecto.Changeset{}` for tracking guardian_ninja changes.
+  """
+  def change_guardian_ninja(%GuardianNinja{} = guardian_ninja, attrs \\ %{}) do
+    GuardianNinja.changeset(guardian_ninja, attrs)
+  end
+
+  # --------------------
+  # Custom Queries
+  # --------------------
+
+  @doc """
+  Returns all Guardians linked to a given Ninja id.
+  """
+  def get_guardians_for_ninja(ninja_id) do
+    query =
+      from gn in GuardianNinja,
+        where: gn.ninja_id == ^ninja_id,
+        join: g in Guardian,
+        on: g.id == gn.guardian_id,
+        select: g
+
+    Repo.all(query)
+  end
+
+  @doc """
+  Returns all Ninjas linked to a given Guardian id.
+  """
+  def get_ninjas_for_guardian(guardian_id) do
+    query =
+      from gn in GuardianNinja,
+        where: gn.guardian_id == ^guardian_id,
+        join: n in Ninja,
+        on: n.id == gn.ninja_id,
+        select: n
+
+    Repo.all(query)
+  end
+
+  @doc """
+  Creates a link between a Guardian and a Ninja.
+  """
+  def link_guardian_and_ninja(guardian_id, ninja_id) do
+    %GuardianNinja{}
+    |> GuardianNinja.changeset(%{guardian_id: guardian_id, ninja_id: ninja_id})
+    |> Repo.insert()
+  end
+end

lib/katana/guardians/guardian.ex

@@ -0,0 +1,20 @@
+defmodule Katana.Guardians.Guardian do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:id, :binary_id, autogenerate: true}
+  @foreign_key_type :binary_id
+  schema "guardians" do
+    field :phone, :string
+
+    belongs_to :user, Katana.Accounts.User, type: :binary_id
+
+    timestamps(type: :utc_datetime)
+  end
+
+  def changeset(guardian, attrs) do
+    guardian
+    |> cast(attrs, [:phone, :user_id])
+    |> validate_required([:phone, :user_id])
+  end
+end

lib/katana/guardians/guardians_ninjas.ex

@@ -0,0 +1,20 @@
+defmodule Katana.GuardiansNinjas.GuardianNinja do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:id, :binary_id, autogenerate: true}
+  @foreign_key_type :binary_id
+  schema "guardian_ninja" do
+    field :ninja_id, :binary_id
+    field :guardian_id, :binary_id
+
+    timestamps(type: :utc_datetime)
+  end
+
+  @doc false
+  def changeset(guardian_ninja, attrs) do
+    guardian_ninja
+    |> cast(attrs, [:ninja_id, :guardian_id])
+    |> validate_required([:ninja_id, :guardian_id])
+  end
+end

lib/katana/guardians_ninjas/guardian_ninja.ex

@@ -0,0 +1,20 @@
+defmodule Katana.GuardiansNinjas.GuardianNinja do
+  use Ecto.Schema
+  import Ecto.Changeset
+
+  @primary_key {:id, :binary_id, autogenerate: true}
+  @foreign_key_type :binary_id
+  schema "guardian_ninja" do
+    field :ninja_id, :binary_id
+    field :guardian_id, :binary_id
+
+    timestamps(type: :utc_datetime)
+  end
+
+  @doc false
+  def changeset(guardian_ninja, attrs) do
+    guardian_ninja
+    |> cast(attrs, [:ninja_id, :guardian_id])
+    |> validate_required([:ninja_id, :guardian_id])
+  end
+end

lib/katana/ninjas.ex

@@ -4,16 +4,34 @@ defmodule Katana.Ninjas do
   """
 
   import Ecto.Query, warn: false
+  alias Ecto.Multi
   alias Katana.Repo
+
   alias Katana.Ninjas.Ninja
+  alias Katana.GuardiansNinjas.GuardianNinja
 
   @doc """
-  Creates a ninja.
+  Creates a ninja **and** links it to a guardian via GuardianNinja.
+
+  Expects attrs to contain `:guardian_id`.
   """
-  def create_ninja(attrs \\ %{}) do
-    %Ninja{}
-    |> Ninja.changeset(attrs)
-    |> Repo.insert()
+  def create_ninja(%{guardian_id: guardian_id} = attrs) do
+    Multi.new()
+    |> Multi.insert(:ninja, Ninja.changeset(%Ninja{}, attrs))
+    |> Multi.run(:guardian_ninja, fn _repo, %{ninja: ninja} ->
+      %GuardianNinja{}
+      |> GuardianNinja.changeset(%{guardian_id: guardian_id, ninja_id: ninja.id})
+      |> Repo.insert()
+    end)
+    |> Repo.transaction()
+    |> case do
+      {:ok, %{ninja: ninja}} -> {:ok, ninja}
+      {:error, _step, changeset, _changes} -> {:error, changeset}
+    end
+  end
+
+  def create_ninja(_attrs) do
+    {:error, "guardian_id is required when creating a ninja"}
   end
 
   @doc """
@@ -45,6 +63,20 @@ defmodule Katana.Ninjas do
     Repo.delete(ninja)
   end
 
+  @doc """
+  Returns all ninjas linked to a given guardian.
+  """
+  def get_ninjas_for_guardian(guardian_id) do
+    query =
+      from gn in GuardianNinja,
+        where: gn.guardian_id == ^guardian_id,
+        join: n in Ninja,
+        on: n.id == gn.ninja_id,
+        select: n
+
+    Repo.all(query)
+  end
+
   @doc """
   Returns an `%Ecto.Changeset{}` for tracking ninja changes.
   """

mix.exs

@@ -74,6 +74,7 @@ defmodule Katana.MixProject do
 
       # test
       {:floki, ">= 0.30.0", only: :test},
+      {:faker, "~> 0.18", only: [:dev, :test]},
 
       # i18n
       {:gettext, "~> 0.26"},

mix.lock

@@ -9,6 +9,7 @@
   "ecto_sql": {:hex, :ecto_sql, "3.13.2", "a07d2461d84107b3d037097c822ffdd36ed69d1cf7c0f70e12a3d1decf04e2e1", [:mix], [{:db_connection, "~> 2.4.1 or ~> 2.5", [hex: :db_connection, repo: "hexpm", optional: false]}, {:ecto, "~> 3.13.0", [hex: :ecto, repo: "hexpm", optional: false]}, {:myxql, "~> 0.7", [hex: :myxql, repo: "hexpm", optional: true]}, {:postgrex, "~> 0.19 or ~> 1.0", [hex: :postgrex, repo: "hexpm", optional: true]}, {:tds, "~> 2.1.1 or ~> 2.2", [hex: :tds, repo: "hexpm", optional: true]}, {:telemetry, "~> 0.4.0 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "539274ab0ecf1a0078a6a72ef3465629e4d6018a3028095dc90f60a19c371717"},
   "elixir_make": {:hex, :elixir_make, "0.9.0", "6484b3cd8c0cee58f09f05ecaf1a140a8c97670671a6a0e7ab4dc326c3109726", [:mix], [], "hexpm", "db23d4fd8b757462ad02f8aa73431a426fe6671c80b200d9710caf3d1dd0ffdb"},
   "expo": {:hex, :expo, "1.1.0", "f7b9ed7fb5745ebe1eeedf3d6f29226c5dd52897ac67c0f8af62a07e661e5c75", [:mix], [], "hexpm", "fbadf93f4700fb44c331362177bdca9eeb8097e8b0ef525c9cc501cb9917c960"},
+  "faker": {:hex, :faker, "0.18.0", "943e479319a22ea4e8e39e8e076b81c02827d9302f3d32726c5bf82f430e6e14", [:mix], [], "hexpm", "bfbdd83958d78e2788e99ec9317c4816e651ad05e24cfd1196ce5db5b3e81797"},
   "file_system": {:hex, :file_system, "1.1.0", "08d232062284546c6c34426997dd7ef6ec9f8bbd090eb91780283c9016840e8f", [:mix], [], "hexpm", "bfcf81244f416871f2a2e15c1b515287faa5db9c6bcf290222206d120b3d43f6"},
   "finch": {:hex, :finch, "0.20.0", "5330aefb6b010f424dcbbc4615d914e9e3deae40095e73ab0c1bb0968933cadf", [:mix], [{:mime, "~> 1.0 or ~> 2.0", [hex: :mime, repo: "hexpm", optional: false]}, {:mint, "~> 1.6.2 or ~> 1.7", [hex: :mint, repo: "hexpm", optional: false]}, {:nimble_options, "~> 0.4 or ~> 1.0", [hex: :nimble_options, repo: "hexpm", optional: false]}, {:nimble_pool, "~> 1.1", [hex: :nimble_pool, repo: "hexpm", optional: false]}, {:telemetry, "~> 0.4 or ~> 1.0", [hex: :telemetry, repo: "hexpm", optional: false]}], "hexpm", "2658131a74d051aabfcba936093c903b8e89da9a1b63e430bee62045fa9b2ee2"},
   "floki": {:hex, :floki, "0.38.0", "62b642386fa3f2f90713f6e231da0fa3256e41ef1089f83b6ceac7a3fd3abf33", [:mix], [], "hexpm", "a5943ee91e93fb2d635b612caf5508e36d37548e84928463ef9dd986f0d1abd9"},

priv/repo/migrations/20250820140556_create_guardians.exs

@@ -0,0 +1,15 @@
+defmodule Katana.Repo.Migrations.CreateGuardians do
+  use Ecto.Migration
+
+  def change do
+    create table(:guardians, primary_key: false) do
+      add :id, :binary_id, primary_key: true
+      add :phone, :string
+      add :user_id, references(:users, type: :binary_id, on_delete: :delete_all), null: false
+
+      timestamps(type: :utc_datetime)
+    end
+
+    create unique_index(:guardians, [:user_id])
+  end
+end

priv/repo/migrations/20250821015859_create_guardian_ninja.exs

@@ -0,0 +1,19 @@
+defmodule Katana.Repo.Migrations.CreateGuardianNinja do
+  use Ecto.Migration
+
+  def change do
+    create table(:guardian_ninja, primary_key: false) do
+      add :id, :binary_id, primary_key: true
+      add :ninja_id, references(:ninjas, type: :binary_id, on_delete: :delete_all), null: false
+
+      add :guardian_id, references(:guardians, type: :binary_id, on_delete: :delete_all),
+        null: false
+
+      timestamps(type: :utc_datetime)
+    end
+
+    create index(:guardian_ninja, [:ninja_id])
+    create index(:guardian_ninja, [:guardian_id])
+    create unique_index(:guardian_ninja, [:ninja_id, :guardian_id])
+  end
+end

priv/repo/migrations/20250802183304_create_users_auth_tables.exs → priv/repo/migrations/20250821090708_create_users_auth_tables.exs

@@ -10,6 +10,9 @@ defmodule Katana.Repo.Migrations.CreateUsersAuthTables do
       add :name, :string, null: false
       add :email, :citext, null: false
 
+      add :guardian_id, references(:guardians, type: :binary_id, on_delete: :delete_all),
+        null: false
+
       add :hashed_password, :string, null: false
 
       add :confirmed_at, :utc_datetime

priv/repo/seeds.exs

@@ -8,9 +8,10 @@ defmodule Katana.Repo.Seeds do
 
   def run do
     [
-      "accounts.exs",
       "locations.exs",
-      "ninjas.exs"
+      "guardians.exs",
+      "ninjas.exs",
+      "accounts.exs"
     ]
     |> Enum.each(fn file ->
       Code.require_file("#{@seeds_dir}/#{file}")