minor fixes

Author: zcesur

lib/algora/payments/jobs/execute_pending_transfers.ex

@@ -7,7 +7,7 @@ defmodule Algora.Payments.Jobs.ExecutePendingTransfers do
   alias Algora.Payments
 
   @impl Oban.Worker
-  def perform(%Oban.Job{args: %{user_id: user_id}}) do
+  def perform(%Oban.Job{args: %{"user_id" => user_id}}) do
     Payments.execute_pending_transfers(user_id)
   end
 end

lib/algora/payments/payments.ex

@@ -289,6 +289,7 @@ defmodule Algora.Payments do
   defp initialize_and_execute_transfer(user_id, pending_amount, account) do
     with {:ok, transaction} <- initialize_transfer(user_id, pending_amount),
          {:ok, transfer} <- execute_transfer(transaction, account) do
+      broadcast()
       {:ok, transfer}
     else
       error ->

lib/algora_web/controllers/webhooks/stripe_controller.ex

@@ -48,6 +48,7 @@ defmodule AlgoraWeb.Webhooks.StripeController do
       with {count, _} when count > 0 <- update_result,
            :ok <- jobs_result do
         Payments.broadcast()
+        {:ok, nil}
       else
         {:error, reason} ->
           Logger.error("Failed to update transactions: #{inspect(reason)}")