rename Repo.transact into tx to avoid conflicts

zcesur · zcesur · commit 607800f99dba · 2025-08-08T14:17:41.000+03:00
diff --git a/lib/algora/accounts/accounts.ex b/lib/algora/accounts/accounts.ex
@@ -320,7 +320,7 @@ defmodule Algora.Accounts do
     github_user = Repo.get_by(User, provider: "github", provider_id: to_string(info["id"]))
     email_user = Repo.get_by(User, email: primary_email)
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       Repo.delete_all(from(i in Identity, where: i.provider == "github" and i.provider_id == ^to_string(info["id"])))
 
       with true <- github_user && github_user.id != user.id,
diff --git a/lib/algora/bounties/bounties.ex b/lib/algora/bounties/bounties.ex
@@ -135,7 +135,7 @@ defmodule Algora.Bounties do
     command_id = opts[:command_id]
     shared_with = opts[:shared_with] || []
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, %{installation_id: installation_id, token: token}} <-
              Workspace.resolve_installation_and_token(opts[:installation_id], repo_owner, creator),
            {:ok, ticket} <- Workspace.ensure_ticket(token, repo_owner, repo_name, number),
@@ -213,7 +213,7 @@ defmodule Algora.Bounties do
   def create_bounty(%{creator: creator, owner: owner, amount: amount, title: title, description: description}, opts) do
     shared_with = opts[:shared_with] || []
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, ticket} <-
              %Ticket{type: :issue}
              |> Ticket.changeset(%{title: title, description: description})
@@ -564,7 +564,7 @@ defmodule Algora.Bounties do
         },
         opts \\ []
       ) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, %{installation_id: installation_id, token: token}} <-
              Workspace.resolve_installation_and_token(opts[:installation_id], source_repo_owner, user),
            {:ok, target} <- Workspace.ensure_ticket(token, target_repo_owner, target_repo_name, target_number),
@@ -733,7 +733,7 @@ defmodule Algora.Bounties do
         ) ::
           {:ok, String.t()} | {:error, atom()}
   def create_tip(%{creator: creator, owner: owner, recipient: recipient, amount: amount}, opts \\ []) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       case do_create_tip(%{creator: creator, owner: owner, recipient: recipient, amount: amount}, opts) do
         {:ok, tip} ->
           create_payment_session(
@@ -957,7 +957,7 @@ defmodule Algora.Bounties do
 
     bounty_id = if bounty = opts[:bounty], do: bounty.id
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, _charge} <-
              initialize_charge(%{
                id: Nanoid.generate(),
@@ -1019,7 +1019,7 @@ defmodule Algora.Bounties do
 
     bounty_id = if bounty = opts[:bounty], do: bounty.id
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, _charge} <-
              initialize_charge(%{
                id: Nanoid.generate(),
@@ -1588,7 +1588,7 @@ defmodule Algora.Bounties do
 
   @spec delete_bounty(Bounty.t()) :: {:ok, Bounty.t()} | {:error, Ecto.Changeset.t()}
   def delete_bounty(%Bounty{} = bounty) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, updated_bounty} <-
              bounty
              |> Bounty.changeset(%{status: :cancelled})
diff --git a/lib/algora/contracts/contracts.ex b/lib/algora/contracts/contracts.ex
@@ -363,7 +363,7 @@ defmodule Algora.Contracts do
       amount: transfer_amount
     }
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, charge} <- maybe_initialize_charge(charge_params),
            {:ok, debit} <- initialize_debit(debit_params),
            {:ok, credit} <- initialize_credit(credit_params),
diff --git a/lib/algora/integrations/github/poller/deliveries.ex b/lib/algora/integrations/github/poller/deliveries.ex
@@ -103,7 +103,7 @@ defmodule Algora.Github.Poller.Deliveries do
   defp process_batch([], state), do: {:ok, state.cursor}
 
   defp process_batch(deliveries, state) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with :ok <- process_deliveries(deliveries, state) do
         update_last_polled(state.cursor, List.first(deliveries))
       end
diff --git a/lib/algora/integrations/github/poller/search.ex b/lib/algora/integrations/github/poller/search.ex
@@ -109,7 +109,7 @@ defmodule Algora.Github.Poller.Search do
   defp process_batch([], state), do: {:ok, state.cursor}
 
   defp process_batch(tickets, state) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with :ok <- process_tickets(tickets, state) do
         timestamps =
           tickets
diff --git a/lib/algora/jobs/jobs.ex b/lib/algora/jobs/jobs.ex
@@ -137,7 +137,7 @@ defmodule Algora.Jobs do
 
     job_posting = Repo.preload(job_posting, :user)
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, _charge} <-
              %Transaction{}
              |> change(%{
diff --git a/lib/algora/matches/matches.ex b/lib/algora/matches/matches.ex
@@ -147,7 +147,7 @@ defmodule Algora.Matches do
         }
       end)
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       # Delete existing matches for this job posting
       Repo.delete_all(
         from(m in JobMatch,
diff --git a/lib/algora/organizations/organizations.ex b/lib/algora/organizations/organizations.ex
@@ -57,7 +57,7 @@ defmodule Algora.Organizations do
         org -> org.handle
       end
 
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       {:ok, user} =
         case Repo.get_by(User, email: params.user.email) do
           nil ->
@@ -352,7 +352,7 @@ defmodule Algora.Organizations do
          {:ok, owner} <- Workspace.ensure_user(token, repo_owner),
          {:ok, _contributors} <- Workspace.ensure_contributors(token, repo),
          {:ok, tech_stack} <- Workspace.ensure_repo_tech_stack(token, repo) do
-      Repo.transact(fn _ ->
+      Repo.tx(fn _ ->
         with {:ok, org} <-
                Repo.insert(%User{
                  type: :organization,
diff --git a/lib/algora/payments/payments.ex b/lib/algora/payments/payments.ex
@@ -478,7 +478,7 @@ defmodule Algora.Payments do
 
   @spec enqueue_pending_transfers(user_id :: String.t()) :: {:ok, nil} | {:error, term()}
   def enqueue_pending_transfers(user_id) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       with {:ok, _account} <- fetch_active_account(user_id),
            credits = list_payable_credits(user_id),
            :ok <-
@@ -590,7 +590,7 @@ defmodule Algora.Payments do
         %Stripe.Charge{id: charge_id, captured: false, payment_intent: payment_intent_id},
         group_id
       ) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       Repo.update_all(from(t in Transaction, where: t.group_id == ^group_id, where: t.type == :charge),
         set: [
           status: :requires_capture,
@@ -611,7 +611,7 @@ defmodule Algora.Payments do
         %Stripe.Charge{id: charge_id, captured: true, payment_intent: payment_intent_id},
         group_id
       ) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       Repo.update_all(from(t in Transaction, where: t.group_id == ^group_id, where: t.type == :charge),
         set: [
           status: :succeeded,
@@ -642,7 +642,7 @@ defmodule Algora.Payments do
         %Stripe.Charge{id: charge_id, captured: true, payment_intent: payment_intent_id},
         group_id
       ) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       {_, txs} =
         Repo.update_all(from(t in Transaction, where: t.group_id == ^group_id, select: t),
           set: [
@@ -771,7 +771,7 @@ defmodule Algora.Payments do
         amount,
         recipient
       ) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       tx = Repo.get_by(Transaction, group_id: group_id, type: :charge, status: :succeeded)
 
       user = Repo.get_by(User, id: tx.user_id)
diff --git a/lib/algora/repo.ex b/lib/algora/repo.ex
@@ -53,8 +53,8 @@ defmodule Algora.Repo do
     fetch_one(query, opts)
   end
 
-  @spec transact(fun(), Keyword.t()) :: term()
-  def transact(fun, opts \\ []) do
+  @spec tx(fun(), Keyword.t()) :: term()
+  def tx(fun, opts \\ []) do
     transaction(
       fn repo ->
         result =
diff --git a/lib/algora/workspace/workspace.ex b/lib/algora/workspace/workspace.ex
@@ -499,7 +499,7 @@ defmodule Algora.Workspace do
       [] ->
         with {:ok, contributors} <-
                Github.list_repository_contributors(token, repository.user.provider_login, repository.name) do
-          Repo.transact(fn ->
+          Repo.tx(fn ->
             Enum.reduce_while(contributors, {:ok, []}, fn contributor, {:ok, acc} ->
               case create_contributor_from_github(repository, contributor) do
                 {:ok, created} -> {:cont, {:ok, [created | acc]}}
@@ -915,7 +915,7 @@ defmodule Algora.Workspace do
   end
 
   def ensure_users(token, provider_logins) do
-    Repo.transact(fn ->
+    Repo.tx(fn ->
       provider_logins
       |> Enum.map(&ensure_user(token, &1))
       |> Enum.reduce_while({:ok, []}, fn
diff --git a/priv/repo/seeds.exs b/priv/repo/seeds.exs
@@ -299,7 +299,7 @@ for user <- [aly, big_head, jian_yang, john] do
   credit_id = Nanoid.generate()
   amount = Money.new!(Enum.random(1..10) * 10_000, :USD)
 
-  Repo.transact(fn ->
+  Repo.tx(fn ->
     insert!(:transaction, %{
       id: debit_id,
       linked_transaction_id: credit_id,
@@ -462,7 +462,7 @@ for {repo_name, issues} <- repos do
             net_paid = Money.mult!(bounty.amount, Decimal.mult(share, pct_paid))
 
             # Create transaction pairs for paid claims
-            Repo.transact(fn ->
+            Repo.tx(fn ->
               insert!(:transaction, %{
                 id: debit_id,
                 linked_transaction_id: credit_id,
diff --git a/test/algora/contracts_test.exs b/test/algora/contracts_test.exs
@@ -311,7 +311,7 @@ defmodule Algora.ContractsTest do
   #     assert Decimal.equal?(fee_data.current_fee, Decimal.new("0.19"))
   #     assert fee_data.progress == Decimal.new("0.00")
 
-  #     Repo.transact(fn ->
+  #     Repo.tx(fn ->
   #       debit_id = Nanoid.generate()
   #       credit_id = Nanoid.generate()
 
diff --git a/test/algora/repo_test.exs b/test/algora/repo_test.exs
@@ -10,7 +10,7 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       {:ok, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, updated_user} = user |> Ecto.Changeset.change(%{email: "success@example.com"}) |> Repo.update()
           {:ok, updated_user}
         end)
@@ -25,7 +25,7 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       {:ok, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, _updated_user} = user |> Ecto.Changeset.change(%{email: "ok@example.com"}) |> Repo.update()
           :ok
         end)
@@ -41,7 +41,7 @@ defmodule Algora.RepoTest do
 
       # Test plain error atom
       {:error, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, _updated_user} = user |> Ecto.Changeset.change(%{email: "error@example.com"}) |> Repo.update()
           :error
         end)
@@ -51,7 +51,7 @@ defmodule Algora.RepoTest do
 
       # Test error tuple
       {:error, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, _updated_user} = user |> Ecto.Changeset.change(%{email: "error_tuple@example.com"}) |> Repo.update()
           {:error, "reason"}
         end)
@@ -61,7 +61,7 @@ defmodule Algora.RepoTest do
 
       # Test unexpected return value
       {:error, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, _updated_user} = user |> Ecto.Changeset.change(%{email: "unexpected@example.com"}) |> Repo.update()
           "unexpected"
         end)
@@ -75,7 +75,7 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       assert_raise RuntimeError, "boom", fn ->
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, _updated_user} = user |> Ecto.Changeset.change(%{email: "raised@example.com"}) |> Repo.update()
           raise "boom"
         end)
@@ -89,11 +89,11 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       {:ok, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, user1} = user |> Ecto.Changeset.change(%{email: "outer@example.com"}) |> Repo.update()
 
           {:ok, user2} =
-            Repo.transact(fn _repo ->
+            Repo.tx(fn _repo ->
               user1 |> Ecto.Changeset.change(%{email: "inner@example.com"}) |> Repo.update()
             end)
 
@@ -110,10 +110,10 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       {:error, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, user1} = user |> Ecto.Changeset.change(%{email: "outer@example.com"}) |> Repo.update()
 
-          Repo.transact(fn _repo ->
+          Repo.tx(fn _repo ->
             {:ok, _user2} = user1 |> Ecto.Changeset.change(%{email: "inner@example.com"}) |> Repo.update()
             {:error, :inner_failed}
           end)
@@ -130,11 +130,11 @@ defmodule Algora.RepoTest do
       original_email = user.email
 
       {:error, result} =
-        Repo.transact(fn _repo ->
+        Repo.tx(fn _repo ->
           {:ok, user1} = user |> Ecto.Changeset.change(%{email: "outer@example.com"}) |> Repo.update()
 
           {:ok, _user2} =
-            Repo.transact(fn _repo ->
+            Repo.tx(fn _repo ->
               user1 |> Ecto.Changeset.change(%{email: "inner@example.com"}) |> Repo.update()
             end)
 

Original file line number	Diff line number	Diff line change
`@@ -363,7 +363,7 @@ defmodule Algora.Contracts do`
`363`	`363`	`amount: transfer_amount`
`364`	`364`	`}`
`365`	`365`
`366`		`- Repo.transact(fn ->`
	`366`	`+ Repo.tx(fn ->`
`367`	`367`	`with {:ok, charge} <- maybe_initialize_charge(charge_params),`
`368`	`368`	`{:ok, debit} <- initialize_debit(debit_params),`
`369`	`369`	`{:ok, credit} <- initialize_credit(credit_params),`
Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,7 @@ defmodule Algora.Matches do`
`147`	`147`	`}`
`148`	`148`	`end)`
`149`	`149`
`150`		`- Repo.transact(fn ->`
	`150`	`+ Repo.tx(fn ->`
`151`	`151`	`# Delete existing matches for this job posting`
`152`	`152`	`Repo.delete_all(`
`153`	`153`	`from(m in JobMatch,`