impl payment flow

Author: zcesur

lib/algora/jobs/jobs.ex

@@ -48,9 +48,9 @@ defmodule Algora.Jobs do
   defp maybe_limit(query, nil), do: query
   defp maybe_limit(query, limit), do: limit(query, ^limit)
 
-  @spec create_payment_session(JobPosting.t(), Money.t()) ::
+  @spec create_payment_session(User.t() | nil, JobPosting.t(), Money.t()) ::
           {:ok, String.t()} | {:error, atom()}
-  def create_payment_session(job_posting, amount) do
+  def create_payment_session(user, job_posting, amount) do
     line_items = [
       %LineItem{
         amount: amount,
@@ -66,20 +66,17 @@ defmodule Algora.Jobs do
     gross_amount = LineItem.gross_amount(line_items)
     group_id = Nanoid.generate()
 
+    job_posting = Repo.preload(job_posting, :user)
+
     Repo.transact(fn ->
-      with {:ok, user} <-
-             Accounts.get_or_register_user(job_posting.email, %{
-               type: :organization,
-               display_name: job_posting.company_name
-             }),
-           {:ok, _charge} <-
+      with {:ok, _charge} <-
              %Transaction{}
              |> change(%{
                id: Nanoid.generate(),
                provider: "stripe",
                type: :charge,
                status: :initialized,
-               user_id: user.id,
+               user_id: if(user, do: user.id),
                job_id: job_posting.id,
                gross_amount: gross_amount,
                net_amount: gross_amount,
@@ -101,8 +98,9 @@ defmodule Algora.Jobs do
                  description: "Job posting - #{job_posting.company_name}",
                  metadata: %{"version" => Payments.metadata_version(), "group_id" => group_id}
                },
-               success_url: "#{AlgoraWeb.Endpoint.url()}/jobs?status=paid",
-               cancel_url: "#{AlgoraWeb.Endpoint.url()}/jobs?status=canceled"
+               success_url:
+                 "#{AlgoraWeb.Endpoint.url()}/#{job_posting.user.handle}/jobs/#{job_posting.id}/applicants?status=paid",
+               cancel_url: "#{AlgoraWeb.Endpoint.url()}/#{job_posting.user.handle}/jobs/#{job_posting.id}/applicants"
              ) do
         {:ok, session.url}
       end

lib/algora/payments/payments.ex

@@ -35,7 +35,7 @@ defmodule Algora.Payments do
   end
 
   @spec create_stripe_session(
-          user :: User.t(),
+          user :: User.t() | nil,
           line_items :: [PSP.Session.line_item_data()],
           payment_intent_data :: PSP.Session.payment_intent_data(),
           opts :: [
@@ -44,7 +44,29 @@ defmodule Algora.Payments do
           ]
         ) ::
           {:ok, PSP.session()} | {:error, PSP.error()}
-  def create_stripe_session(user, line_items, payment_intent_data, opts \\ []) do
+  def create_stripe_session(user, line_items, payment_intent_data, opts \\ [])
+
+  def create_stripe_session(nil, line_items, payment_intent_data, opts) do
+    opts = %{
+      mode: "payment",
+      billing_address_collection: "required",
+      line_items: line_items,
+      success_url: opts[:success_url] || "#{AlgoraWeb.Endpoint.url()}/payment/success",
+      cancel_url: opts[:cancel_url] || "#{AlgoraWeb.Endpoint.url()}/payment/canceled",
+      payment_intent_data: payment_intent_data
+    }
+
+    opts =
+      if payment_intent_data[:capture_method] == :manual do
+        opts
+      else
+        Map.put(opts, :invoice_creation, %{enabled: true})
+      end
+
+    PSP.Session.create(opts)
+  end
+
+  def create_stripe_session(user, line_items, payment_intent_data, opts) do
     with {:ok, customer} <- fetch_or_create_customer(user) do
       opts = %{
         mode: "payment",
@@ -657,10 +679,16 @@ defmodule Algora.Payments do
       Repo.update_all(from(c in Claim, where: c.id in ^claim_ids), set: [status: :approved])
 
       {_, job_postings} =
-        Repo.update_all(from(j in JobPosting, where: j.id in ^job_ids, select: j), set: [status: :processing])
+        Repo.update_all(from(j in JobPosting, where: j.id in ^job_ids, select: j), set: [status: :active])
+
+      job_postings = Repo.preload(job_postings, :user)
+
+      Repo.update_all(from(u in User, where: u.id in ^Enum.map(job_postings, & &1.user_id)),
+        set: [hiring_subscription: :active]
+      )
 
       for job <- job_postings do
-        Algora.Admin.alert("Job payment received! #{job.company_name} #{job.email} #{job.url}", :info)
+        Algora.Admin.alert("Job payment received! #{job.company_name} #{job.email} #{job.url}", :critical)
       end
 
       auto_txs =

lib/algora_web/live/org/job_live.ex

@@ -100,7 +100,14 @@ defmodule AlgoraWeb.Org.JobLive do
   end
 
   @impl true
-  def handle_params(%{"tab" => tab}, _uri, socket) do
+  def handle_params(%{"tab" => tab} = params, _uri, socket) do
+    socket =
+      if params["status"] == "paid" do
+        put_flash(socket, :info, "Your annual subscription has been activated!")
+      else
+        socket
+      end
+
     {:noreply, assign(socket, :current_tab, tab)}
   end
 
@@ -661,9 +668,9 @@ defmodule AlgoraWeb.Org.JobLive do
 
   @impl true
   def handle_event("process_payment", %{"payment" => %{"payment_type" => "stripe"}}, socket) do
-    # Mock data for demonstration
     case Jobs.create_payment_session(
-           %{socket.assigns.job | email: socket.assigns.current_user.email},
+           socket.assigns.current_user,
+           socket.assigns.job,
            socket.assigns.current_org.subscription_price
          ) do
       {:ok, url} ->