add job to notify transfer

Author: zcesur

.iex.exs

@@ -18,6 +18,7 @@ alias Algora.Payments.Customer
 alias Algora.Payments.PaymentMethod
 alias Algora.Payments.Transaction
 alias Algora.Repo
+alias Algora.Workspace.Ticket
 
 IEx.configure(inspect: [charlists: :as_lists, limit: :infinity], auto_reload: true)
 

config/config.exs

@@ -37,7 +37,8 @@ config :algora, Oban,
     prompt_payout_connect: 10,
     transfers: 1,
     activity_notifier: 1,
-    activity_mailer: 1
+    activity_mailer: 1,
+    notify_transfer: 100
   ]
 
 # Configures the mailer

lib/algora/bounties/jobs/notify_transfer.ex

@@ -0,0 +1,74 @@
+defmodule Algora.Bounties.Jobs.NotifyTransfer do
+  @moduledoc false
+  use Oban.Worker, queue: :notify_transfer
+
+  import Ecto.Query
+
+  alias Algora.Bounties.Ticket
+  alias Algora.Github
+  alias Algora.Payments.Transaction
+  alias Algora.Repo
+  alias Algora.Workspace.Ticket
+
+  require Logger
+
+  @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"transaction_id" => transaction_id}}) do
+    with {:ok, ticket} <-
+           Repo.fetch_one(
+             from t in Ticket,
+               left_join: bounty in assoc(t, :bounties),
+               left_join: tip in assoc(t, :tips),
+               left_join: tx in Transaction,
+               on: tx.bounty_id == bounty.id or tx.tip_id == tip.id,
+               join: repo in assoc(t, :repository),
+               join: user in assoc(repo, :user),
+               where: tx.id == ^transaction_id,
+               select_merge: %{
+                 repository: %{repo | user: user}
+               }
+           ),
+         ticket_ref = %{
+           owner: ticket.repository.user.provider_login,
+           repo: ticket.repository.name,
+           number: ticket.number
+         },
+         {:ok, transaction} <-
+           Repo.fetch_one(
+             from tx in Transaction,
+               join: user in assoc(tx, :user),
+               where: tx.id == ^transaction_id,
+               where: tx.type == :transfer,
+               select_merge: %{user: user}
+           ) do
+      installation = Repo.get(Installation, connected_user_id: ticket.repository.user.id)
+      body = "🎉🎈 @#{transaction.user.provider_login} has been awarded **#{transaction.net_amount}**! 🎈🎊"
+
+      do_perform(ticket_ref, body, installation)
+    end
+  end
+
+  defp do_perform(ticket_ref, body, nil) do
+    if Github.pat_enabled() do
+      Github.create_issue_comment(
+        Github.pat(),
+        ticket_ref["owner"],
+        ticket_ref["repo"],
+        ticket_ref["number"],
+        body
+      )
+    else
+      Logger.info("""
+      Github.create_issue_comment(Github.pat(), "#{ticket_ref["owner"]}", "#{ticket_ref["repo"]}", #{ticket_ref["number"]},
+             \"\"\"
+             #{body}
+             \"\"\")
+      """)
+    end
+  end
+
+  defp do_perform(ticket_ref, body, installation) do
+    {:ok, token} = Github.get_installation_token(installation.id)
+    Github.create_issue_comment(token, ticket_ref["owner"], ticket_ref["repo"], ticket_ref["number"], body)
+  end
+end

lib/algora/workspace/schemas/ticket.ex

@@ -19,6 +19,7 @@ defmodule Algora.Workspace.Ticket do
 
     belongs_to :repository, Algora.Workspace.Repository
     has_many :bounties, Algora.Bounties.Bounty
+    has_many :tips, Algora.Bounties.Tip
 
     has_many :activities, {"ticket_activities", Activity}, foreign_key: :assoc_id
 

lib/algora_web/controllers/webhooks/stripe_controller.ex

@@ -82,8 +82,8 @@ defmodule AlgoraWeb.Webhooks.StripeController do
         data: %{object: %Stripe.Transfer{metadata: %{"version" => @metadata_version}} = transfer}
       }) do
     with {:ok, transaction} <- Repo.fetch_by(Transaction, provider: "stripe", provider_id: transfer.id),
-         {:ok, _transaction} <- maybe_update_transaction(transaction, transfer) do
-      # TODO: notify user
+         {:ok, _transaction} <- maybe_update_transaction(transaction, transfer),
+         {:ok, _job} <- Oban.insert(Bounties.Jobs.NotifyTransfer.new(%{transaction_id: transaction.id})) do
       Payments.broadcast()
       {:ok, nil}
     else

test/algora_web/controllers/webhooks/stripe_controller_test.exs

@@ -130,6 +130,8 @@ defmodule AlgoraWeb.Webhooks.StripeControllerTest do
       updated_tx = Repo.get(Transaction, transaction.id)
       assert updated_tx.status == :succeeded
       assert updated_tx.succeeded_at != nil
+
+      assert_enqueued(worker: Bounties.Jobs.NotifyTransfer, args: %{transaction_id: transaction.id})
     end
   end