Add collaborators

lib/atomic/accounts.ex

@@ -350,4 +350,100 @@ defmodule Atomic.Accounts do
       {:error, :user, changeset, _} -> {:error, changeset}
     end
   end
+
+  alias Atomic.Accounts.Collaborator
+
+  @doc """
+  Returns the list of collaborators.
+
+  ## Examples
+
+      iex> list_collaborators()
+      [%Collaborator{}, ...]
+
+  """
+  def list_collaborators do
+    Repo.all(Collaborator)
+  end
+
+  @doc """
+  Gets a single collaborator.
+
+  Raises `Ecto.NoResultsError` if the Collaborator does not exist.
+
+  ## Examples
+
+      iex> get_collaborator!(123)
+      %Collaborator{}
+
+      iex> get_collaborator!(456)
+      ** (Ecto.NoResultsError)
+
+  """
+  def get_collaborator!(id), do: Repo.get!(Collaborator, id)
+
+  @doc """
+  Creates a collaborator.
+
+  ## Examples
+
+      iex> create_collaborator(%{field: value})
+      {:ok, %Collaborator{}}
+
+      iex> create_collaborator(%{field: bad_value})
+      {:error, %Ecto.Changeset{}}
+
+  """
+  def create_collaborator(attrs \\ %{}) do
+    %Collaborator{}
+    |> Collaborator.changeset(attrs)
+    |> Repo.insert()
+  end
+
+  @doc """
+  Updates a collaborator.
+
+  ## Examples
+
+      iex> update_collaborator(collaborator, %{field: new_value})
+      {:ok, %Collaborator{}}
+
+      iex> update_collaborator(collaborator, %{field: bad_value})
+      {:error, %Ecto.Changeset{}}
+
+  """
+  def update_collaborator(%Collaborator{} = collaborator, attrs) do
+    collaborator
+    |> Collaborator.changeset(attrs)
+    |> Repo.update()
+  end
+
+  @doc """
+  Deletes a collaborator.
+
+  ## Examples
+
+      iex> delete_collaborator(collaborator)
+      {:ok, %Collaborator{}}
+
+      iex> delete_collaborator(collaborator)
+      {:error, %Ecto.Changeset{}}
+
+  """
+  def delete_collaborator(%Collaborator{} = collaborator) do
+    Repo.delete(collaborator)
+  end
+
+  @doc """
+  Returns an `%Ecto.Changeset{}` for tracking collaborator changes.
+
+  ## Examples
+
+      iex> change_collaborator(collaborator)
+      %Ecto.Changeset{data: %Collaborator{}}
+
+  """
+  def change_collaborator(%Collaborator{} = collaborator, attrs \\ %{}) do
+    Collaborator.changeset(collaborator, attrs)
+  end
 end

lib/atomic/accounts/collaborator.ex

@@ -0,0 +1,20 @@
+defmodule Atomic.Accounts.Collaborator do
+  use Atomic.Schema
+  alias Atomic.Departments.Department
+  alias Atomic.Accounts.User
+  alias Atomic.Users.CollaboratorDepartment
+
+  @required_fields ~w(name organization_id user_id)a
+  schema "collaborators" do
+    many_to_many :departments, Department, join_through: CollaboratorDepartment
+    belongs_to :user, User
+    timestamps()
+  end
+
+  @doc false
+  def changeset(collaborator, attrs) do
+    collaborator
+    |> cast(attrs, @required_fields)
+    |> validate_required(@required_fields)
+  end
+end

lib/atomic/accounts/collaborator_department.ex

@@ -0,0 +1,30 @@
+defmodule Atomic.Users.CollaboratorDepartment do
+  @moduledoc """
+    An activity speaker
+  """
+  use Atomic.Schema
+
+  alias Atomic.Departments.Department
+  alias Atomic.Accounts.Collaborator
+
+  @required_fields ~w(collaborator_id department_id)a
+
+  schema "collaborator_departments" do
+    belongs_to :collaborator, Collaborator
+    belongs_to :department, Department
+
+    timestamps()
+  end
+
+  def changeset(collaborator_departments, attrs) do
+    collaborator_departments
+    |> cast(attrs, @required_fields)
+    |> validate_required(@required_fields)
+  end
+
+  def create_changeset(collaborator_departments, attrs) do
+    collaborator_departments
+    |> cast(attrs, @required_fields)
+    |> validate_required(@required_fields)
+  end
+end

lib/atomic/accounts/user.ex

@@ -5,7 +5,7 @@ defmodule Atomic.Accounts.User do
   use Atomic.Schema
 
   alias Atomic.Activities.Enrollment
-
+  alias Atomic.Accounts.Collaborator
   @roles ~w(admin staff student)a
 
   schema "users" do
@@ -15,8 +15,8 @@ defmodule Atomic.Accounts.User do
     field :confirmed_at, :naive_datetime
 
     field :role, Ecto.Enum, values: @roles
-
     has_many :enrollments, Enrollment
+    has_one :collaborator, Collaborator, on_replace: :delete_if_exists, on_delete: :delete_all
 
     timestamps()
   end

lib/atomic/departments/department.ex

@@ -5,6 +5,8 @@ defmodule Atomic.Departments.Department do
   use Atomic.Schema
 
   alias Atomic.Activities.Activity
+  alias Atomic.Accounts.Collaborator
+  alias Atomic.Users.CollaboratorDepartment
 
   @required_fields ~w(name)a
 

priv/repo/migrations/20230114142345_create_collaborators.exs

@@ -0,0 +1,13 @@
+defmodule Atomic.Repo.Migrations.CreateCollaborators do
+  use Ecto.Migration
+
+  def change do
+    create table(:collaborators, primary_key: false) do
+      add :id, :binary_id, primary_key: true
+      add :user_id, references(:users, on_delete: :nothing, type: :binary_id)
+      timestamps()
+    end
+
+    create unique_index(:collaborators, [:user_id])
+  end
+end

priv/repo/migrations/20230114142351_create_collaborator_departments.exs

@@ -0,0 +1,14 @@
+defmodule Atomic.Repo.Migrations.CreateCollaboratorDepartments do
+  use Ecto.Migration
+
+  def change do
+    create table(:collaborator_departments, primary_key: false) do
+      add :id, :binary_id, primary_key: true
+
+      add :collaborator_id, references(:collaborators, on_delete: :nothing, type: :binary_id)
+      add :department_id, references(:departments, on_delete: :nothing, type: :binary_id)
+
+      timestamps()
+    end
+  end
+end

test/atomic/accounts_test.exs

@@ -505,4 +505,60 @@ defmodule Atomic.AccountsTest do
       refute inspect(%User{password: "123456"}) =~ "password: \"123456\""
     end
   end
+
+  describe "collaborators" do
+    alias Atomic.Accounts.Collaborator
+
+    import Atomic.AccountsFixtures
+
+    @invalid_attrs %{}
+
+    test "list_collaborators/0 returns all collaborators" do
+      collaborator = collaborator_fixture()
+      assert Accounts.list_collaborators() == [collaborator]
+    end
+
+    test "get_collaborator!/1 returns the collaborator with given id" do
+      collaborator = collaborator_fixture()
+      assert Accounts.get_collaborator!(collaborator.id) == collaborator
+    end
+
+    test "create_collaborator/1 with valid data creates a collaborator" do
+      valid_attrs = %{}
+
+      assert {:ok, %Collaborator{} = collaborator} = Accounts.create_collaborator(valid_attrs)
+    end
+
+    test "create_collaborator/1 with invalid data returns error changeset" do
+      assert {:error, %Ecto.Changeset{}} = Accounts.create_collaborator(@invalid_attrs)
+    end
+
+    test "update_collaborator/2 with valid data updates the collaborator" do
+      collaborator = collaborator_fixture()
+      update_attrs = %{}
+
+      assert {:ok, %Collaborator{} = collaborator} =
+               Accounts.update_collaborator(collaborator, update_attrs)
+    end
+
+    test "update_collaborator/2 with invalid data returns error changeset" do
+      collaborator = collaborator_fixture()
+
+      assert {:error, %Ecto.Changeset{}} =
+               Accounts.update_collaborator(collaborator, @invalid_attrs)
+
+      assert collaborator == Accounts.get_collaborator!(collaborator.id)
+    end
+
+    test "delete_collaborator/1 deletes the collaborator" do
+      collaborator = collaborator_fixture()
+      assert {:ok, %Collaborator{}} = Accounts.delete_collaborator(collaborator)
+      assert_raise Ecto.NoResultsError, fn -> Accounts.get_collaborator!(collaborator.id) end
+    end
+
+    test "change_collaborator/1 returns a collaborator changeset" do
+      collaborator = collaborator_fixture()
+      assert %Ecto.Changeset{} = Accounts.change_collaborator(collaborator)
+    end
+  end
 end

test/support/fixtures/accounts_fixtures.ex

@@ -28,4 +28,16 @@ defmodule Atomic.AccountsFixtures do
     [_, token | _] = String.split(captured_email.text_body, "[TOKEN]")
     token
   end
+
+  @doc """
+  Generate a collaborator.
+  """
+  def collaborator_fixture(attrs \\ %{}) do
+    {:ok, collaborator} =
+      attrs
+      |> Enum.into(%{})
+      |> Atomic.Accounts.create_collaborator()
+
+    collaborator
+  end
 end