refactor: email sync changes

lib/mv/accounts/user/changes/override_member_email_on_link.ex

@@ -1,30 +0,0 @@
-defmodule Mv.Accounts.User.Changes.OverrideMemberEmailOnLink do
-  @moduledoc """
-  Overrides member email with user email when linking.
-  User.email is the source of truth when a link is established.
-  """
-  use Ash.Resource.Change
-  alias Mv.EmailSync.{Helpers, Loader}
-
-  @impl true
-  def change(changeset, _opts, context) do
-    if Map.get(context, :syncing_email, false) do
-      changeset
-    else
-      override_email(changeset)
-    end
-  end
-
-  defp override_email(changeset) do
-    Ash.Changeset.around_transaction(changeset, fn cs, callback ->
-      result = callback.(cs)
-
-      with {:ok, user} <- Helpers.extract_record(result),
-           linked_member <- Loader.get_linked_member(user) do
-        Helpers.sync_email_to_linked_record(result, linked_member, user.email)
-      else
-        _ -> result
-      end
-    end)
-  end
-end

lib/mv/accounts/user/changes/sync_email_to_member.ex

@@ -1,32 +0,0 @@
-defmodule Mv.Accounts.User.Changes.SyncEmailToMember do
-  @moduledoc """
-  Synchronizes user email changes to the linked member.
-  Uses `around_transaction` for atomicity - both updates in the same transaction.
-  """
-  use Ash.Resource.Change
-  alias Mv.EmailSync.{Helpers, Loader}
-
-  @impl true
-  def change(changeset, _opts, context) do
-    cond do
-      Map.get(context, :syncing_email, false) -> changeset
-      not Ash.Changeset.changing_attribute?(changeset, :email) -> changeset
-      true -> sync_email(changeset)
-    end
-  end
-
-  defp sync_email(changeset) do
-    new_email = Ash.Changeset.get_attribute(changeset, :email)
-
-    Ash.Changeset.around_transaction(changeset, fn cs, callback ->
-      result = callback.(cs)
-
-      with {:ok, user} <- Helpers.extract_record(result),
-           linked_member <- Loader.get_linked_member(user) do
-        Helpers.sync_email_to_linked_record(result, linked_member, new_email)
-      else
-        _ -> result
-      end
-    end)
-  end
-end

lib/mv/email_sync/changes/sync_member_email_to_user.ex

@@ -1,17 +1,22 @@
-defmodule Mv.Membership.Member.Changes.SyncEmailToUser do
+defmodule Mv.EmailSync.Changes.SyncMemberEmailToUser do
   @moduledoc """
-  Synchronizes member email changes to the linked user.
-  Uses `around_transaction` for atomicity - both updates in the same transaction.
+  Synchronizes Member.email → User.email
+
+  Trigger conditions are configured in resources via `where` clauses:
+  - Member resource: Use `where: [changing(:email)]`
+
+  Used by Member resource for bidirectional email sync.
   """
   use Ash.Resource.Change
   alias Mv.EmailSync.{Helpers, Loader}
 
   @impl true
   def change(changeset, _opts, context) do
-    cond do
-      Map.get(context, :syncing_email, false) -> changeset
-      not Ash.Changeset.changing_attribute?(changeset, :email) -> changeset
-      true -> sync_email(changeset)
+    # Only recursion protection needed - trigger logic is in `where` clauses
+    if Map.get(context, :syncing_email, false) do
+      changeset
+    else
+      sync_email(changeset)
     end
   end
 

lib/mv/email_sync/changes/sync_user_email_to_member.ex

@@ -0,0 +1,62 @@
+defmodule Mv.EmailSync.Changes.SyncUserEmailToMember do
+  @moduledoc """
+  Synchronizes User.email → Member.email
+  User.email is always the source of truth.
+
+  Trigger conditions are configured in resources via `where` clauses:
+  - User resource: Use `where: [changing(:email)]` or `where: any([changing(:email), changing(:member)])`
+  - Member resource: Use `where: [changing(:user)]`
+
+  Can be used by both User and Member resources.
+  """
+  use Ash.Resource.Change
+  alias Mv.EmailSync.{Helpers, Loader}
+
+  @impl true
+  def change(changeset, _opts, context) do
+    # Only recursion protection needed - trigger logic is in `where` clauses
+    if Map.get(context, :syncing_email, false) do
+      changeset
+    else
+      sync_email(changeset)
+    end
+  end
+
+  defp sync_email(changeset) do
+    Ash.Changeset.around_transaction(changeset, fn cs, callback ->
+      result = callback.(cs)
+
+      with {:ok, record} <- Helpers.extract_record(result),
+           {:ok, user, member} <- get_user_and_member(record) do
+        # When called from Member-side, we need to update the member in the result
+        # When called from User-side, we update the linked member in DB only
+        case record do
+          %Mv.Membership.Member{} ->
+            # Member-side: Override member email in result with user email
+            Helpers.override_with_linked_email(result, user.email)
+
+          %Mv.Accounts.User{} ->
+            # User-side: Sync user email to linked member in DB
+            Helpers.sync_email_to_linked_record(result, member, user.email)
+        end
+      else
+        _ -> result
+      end
+    end)
+  end
+
+  # Retrieves user and member - works for both resource types
+  defp get_user_and_member(%Mv.Accounts.User{} = user) do
+    case Loader.get_linked_member(user) do
+      nil -> {:error, :no_member}
+      member -> {:ok, user, member}
+    end
+  end
+
+  defp get_user_and_member(%Mv.Membership.Member{} = member) do
+    case Loader.load_linked_user!(member) do
+      {:ok, user} -> {:ok, user, member}
+      error -> error
+    end
+  end
+end

lib/mv/membership/member/changes/override_email_from_user_on_link.ex

@@ -1,30 +0,0 @@
-defmodule Mv.Membership.Member.Changes.OverrideEmailFromUserOnLink do
-  @moduledoc """
-  Overrides member email with user email when linking.
-  User.email is the source of truth when a link is established.
-  """
-  use Ash.Resource.Change
-  alias Mv.EmailSync.{Helpers, Loader}
-
-  @impl true
-  def change(changeset, _opts, context) do
-    if Map.get(context, :syncing_email, false) do
-      changeset
-    else
-      override_email(changeset)
-    end
-  end
-
-  defp override_email(changeset) do
-    Ash.Changeset.around_transaction(changeset, fn cs, callback ->
-      result = callback.(cs)
-
-      with {:ok, member} <- Helpers.extract_record(result),
-           {:ok, user} <- Loader.load_linked_user!(member) do
-        Helpers.override_with_linked_email(result, user.email)
-      else
-        _ -> result
-      end
-    end)
-  end
-end