add prompt payout connect job

Author: zcesur

config/config.exs

@@ -34,6 +34,7 @@ config :algora, Oban,
     notify_bounty: 1,
     notify_tip_intent: 1,
     notify_claim: 1,
+    prompt_payout_connect: 10,
     transfers: 1,
     activity_notifier: 1,
     activity_mailer: 1

lib/algora/bounties/jobs/prompt_payout_connect.ex

@@ -0,0 +1,52 @@
+defmodule Algora.Bounties.Jobs.PromptPayoutConnect do
+  @moduledoc false
+  use Oban.Worker, queue: :prompt_payout_connect
+
+  alias Algora.Github
+
+  require Logger
+
+  # TODO: confirm these urls
+  defp signup_url, do: "#{AlgoraWeb.Endpoint.url()}"
+  defp connect_url, do: "#{AlgoraWeb.Endpoint.url()}/user/transactions"
+  defp body, do: "💵 To receive payouts, [sign up on Algora](#{signup_url()}) and [connect with Stripe](#{connect_url()})."
+
+  @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"ticket_ref" => ticket_ref, "installation_id" => 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
+
+  @impl Oban.Worker
+  def perform(%Oban.Job{args: %{"ticket_ref" => ticket_ref, "installation_id" => installation_id}}) do
+    ticket_ref = %{
+      owner: ticket_ref["owner"],
+      repo: ticket_ref["repo"],
+      number: ticket_ref["number"]
+    }
+
+    with {:ok, token} <- Github.get_installation_token(installation_id) do
+      Github.create_issue_comment(
+        token,
+        ticket_ref["owner"],
+        ticket_ref["repo"],
+        ticket_ref["number"],
+        body()
+      )
+    end
+  end
+end

lib/algora_web/controllers/webhooks/stripe_controller.ex

@@ -4,6 +4,7 @@ defmodule AlgoraWeb.Webhooks.StripeController do
   import Ecto.Changeset
   import Ecto.Query
 
+  alias Algora.Bounties
   alias Algora.Payments
   alias Algora.Payments.Customer
   alias Algora.Payments.Jobs.ExecutePendingTransfers
@@ -40,15 +41,24 @@ defmodule AlgoraWeb.Webhooks.StripeController do
           case Payments.fetch_active_account(user_id) do
             {:ok, _account} ->
               case %{user_id: user_id}
-                   |> ExecutePendingTransfers.new()
+                   |> Payments.Jobs.ExecutePendingTransfers.new()
                    |> Oban.insert() do
                 {:ok, _job} -> {:cont, :ok}
                 error -> {:halt, error}
               end
 
             {:error, :not_found} ->
-              # TODO: notify user to connect payout account
-              {:cont, :ok}
+              # TODO:
+              installation_id = 0
+              # TODO:
+              ticket_ref = %{"owner" => "", "repo" => "", "number" => 0}
+
+              case %{installation_id: installation_id, ticket_ref: ticket_ref}
+                   |> Bounties.Jobs.PromptPayoutConnect.new()
+                   |> Oban.insert() do
+                {:ok, _job} -> {:cont, :ok}
+                error -> {:halt, error}
+              end
           end
         end)