handle release flow

Author: zcesur

lib/algora/psp/psp.ex

@@ -130,6 +130,7 @@ defmodule Algora.PSP do
 
     @type t :: Stripe.PaymentIntent.t()
     def create(params), do: Algora.PSP.client(__MODULE__).create(params)
+    def capture(id, params \\ %{}), do: Algora.PSP.client(__MODULE__).capture(id, params)
   end
 
   @type setup_intent :: Algora.PSP.SetupIntent.t()

lib/algora_web/controllers/webhooks/stripe_controller.ex

@@ -49,17 +49,16 @@ defmodule AlgoraWeb.Webhooks.StripeController do
 
   defp process_event(
          %Stripe.Event{
-           type: "charge.succeeded",
+           type: type,
            data: %{object: %Stripe.Charge{metadata: %{"version" => @metadata_version, "group_id" => group_id}}}
          } = event
        )
-       when is_binary(group_id) do
+       when type in ["charge.succeeded", "charge.captured"] and is_binary(group_id) do
     process_charge_succeeded(event, group_id)
   end
 
-  defp process_event(
-         %Stripe.Event{type: "charge.succeeded", data: %{object: %Stripe.Charge{invoice: invoice_id}}} = event
-       ) do
+  defp process_event(%Stripe.Event{type: type, data: %{object: %Stripe.Charge{invoice: invoice_id}}} = event)
+       when type in ["charge.succeeded", "charge.captured"] do
     with {:ok, invoice} <- Algora.PSP.Invoice.retrieve(invoice_id),
          %{"version" => @metadata_version, "group_id" => group_id} <- invoice.metadata do
       process_charge_succeeded(event, group_id)
@@ -129,10 +128,13 @@ defmodule AlgoraWeb.Webhooks.StripeController do
   end
 
   defp process_charge_succeeded(
-         %Stripe.Event{type: "charge.succeeded", data: %{object: %Stripe.Charge{id: charge_id, captured: captured}}},
+         %Stripe.Event{
+           type: type,
+           data: %{object: %Stripe.Charge{id: charge_id, captured: captured, payment_intent: payment_intent_id}}
+         },
          group_id
        )
-       when is_binary(group_id) do
+       when type in ["charge.succeeded", "charge.captured"] and is_binary(group_id) do
     Repo.transact(fn ->
       status = if captured, do: :succeeded, else: :requires_capture
       succeeded_at = if captured, do: DateTime.utc_now()
@@ -144,7 +146,8 @@ defmodule AlgoraWeb.Webhooks.StripeController do
             succeeded_at: succeeded_at,
             provider: "stripe",
             provider_id: charge_id,
-            provider_charge_id: charge_id
+            provider_charge_id: charge_id,
+            provider_payment_intent_id: payment_intent_id
           ]
         )
 

lib/algora_web/live/contract_live.ex

@@ -117,6 +117,7 @@ defmodule AlgoraWeb.ContractLive do
 
     if connected?(socket) do
       Chat.subscribe(thread.id)
+      Payments.subscribe()
     end
 
     share_url =
@@ -173,6 +174,10 @@ defmodule AlgoraWeb.ContractLive do
     {:noreply, socket}
   end
 
+  def handle_info(:payments_updated, socket) do
+    {:noreply, assign_transactions(socket)}
+  end
+
   @impl true
   def handle_event("send_message", %{"message" => content}, socket) do
     {:ok, message} =
@@ -245,6 +250,19 @@ defmodule AlgoraWeb.ContractLive do
     end
   end
 
+  @impl true
+  def handle_event("release_funds", %{"payment_intent_id" => payment_intent_id}, socket) do
+    case Algora.PSP.PaymentIntent.capture(payment_intent_id) do
+      {:ok, payment_intent} ->
+        dbg(payment_intent)
+        {:noreply, put_flash(socket, :info, "Funds released!")}
+
+      {:error, reason} ->
+        Logger.error("Failed to capture payment intent: #{inspect(reason)}")
+        {:noreply, put_flash(socket, :error, "Something went wrong")}
+    end
+  end
+
   @impl true
   def handle_event(_event, _params, socket) do
     {:noreply, socket}
@@ -385,7 +403,21 @@ defmodule AlgoraWeb.ContractLive do
                             </div>
                           </td>
                           <td class="whitespace-nowrap px-6 py-4 text-sm">
-                            {description(transaction)}
+                            <div class="flex flex-col items-start gap-2">
+                              {description(transaction)}
+                              <.button
+                                :if={
+                                  transaction.type == :charge and
+                                    transaction.status == :requires_capture
+                                }
+                                size="sm"
+                                phx-click="release_funds"
+                                phx-disable-with="Releasing..."
+                                phx-value-payment_intent_id={transaction.provider_payment_intent_id}
+                              >
+                                Release funds
+                              </.button>
+                            </div>
                           </td>
                           <td class="font-display whitespace-nowrap px-6 py-4 text-right font-medium tabular-nums">
                             <%= case transaction_direction(transaction.type) do %>