Hook up connect with external account, change service so it associates the two on create

Author: begedin

lib/code_corps/stripe_service/adapters/stripe_external_account.ex

@@ -7,13 +7,14 @@ defmodule CodeCorps.StripeService.Adapters.StripeExternalAccountAdapter do
     :routing_number, :status
   ]
 
-  def to_params(%Stripe.ExternalAccount{} = bank_account) do
+  def to_params(%Stripe.ExternalAccount{} = bank_account, stripe_connect_account_id \\ nil) do
     params =
       bank_account
       |> Map.from_struct
       |> Map.take(@stripe_attributes)
       |> rename(:id, :id_from_stripe)
       |> rename(:account, :account_id_from_stripe)
+      |> Map.put(:stripe_connect_account_id, stripe_connect_account_id)
 
     {:ok, params}
   end

lib/code_corps/stripe_service/stripe_connect_external_account_service.ex

@@ -1,16 +1,24 @@
 defmodule CodeCorps.StripeService.StripeConnectExternalAccountService do
-  alias CodeCorps.{Repo, StripeExternalAccount}
+  alias CodeCorps.{Repo, StripeConnectAccount, StripeExternalAccount}
   alias CodeCorps.StripeService.Adapters.StripeExternalAccountAdapter
 
   @api Application.get_env(:code_corps, :stripe)
 
   def create(id_from_stripe, account_id_from_stripe) do
-    with {:ok, %Stripe.ExternalAccount{} = bank_account} <- @api.ExternalAccount.retrieve(id_from_stripe, connect_account: account_id_from_stripe),
-         {:ok, params} <- StripeExternalAccountAdapter.to_params(bank_account)
+    with {:ok, %Stripe.ExternalAccount{} = external_account} <- @api.ExternalAccount.retrieve(id_from_stripe, connect_account: account_id_from_stripe),
+         {:ok, %StripeConnectAccount{} = connect_account} <- get_connect_account(account_id_from_stripe),
+         {:ok, params} <- StripeExternalAccountAdapter.to_params(external_account, connect_account.id)
     do
       %StripeExternalAccount{}
       |> StripeExternalAccount.changeset(params)
       |> Repo.insert
     end
   end
+
+  defp get_connect_account(account_id_from_stripe) do
+    case Repo.get_by(StripeConnectAccount, id_from_stripe: account_id_from_stripe) do
+      nil -> {:error, :not_found}
+      record -> {:ok, record}
+    end
+  end
 end

priv/repo/migrations/20170104113708_add_stripe_connect_account_reference_to_external_accounts.exs

@@ -0,0 +1,9 @@
+defmodule CodeCorps.Repo.Migrations.AddStripeConnectAccountReferenceToExternalAccounts do
+  use Ecto.Migration
+
+  def change do
+    alter table(:stripe_external_accounts) do
+      add :stripe_connect_account_id, references(:stripe_connect_accounts)
+    end
+  end
+end

test/controllers/stripe_connect_events_controller_test.exs

@@ -147,6 +147,9 @@ defmodule CodeCorps.StripeConnectEventsControllerTest do
       event = event_for(@bank_account, "account.external_account.created")
       path = stripe_connect_events_path(conn, :create)
 
+      # we expect the event to be associated with an account, so it must be created
+      insert(:stripe_connect_account, id_from_stripe: @bank_account["account"])
+
       assert conn |> post(path, event) |> response(200)
 
       wait_for_supervisor
@@ -157,6 +160,20 @@ defmodule CodeCorps.StripeConnectEventsControllerTest do
       created_account = Repo.one(StripeExternalAccount)
       assert created_account
     end
+
+    test "errors out event if no associated connect account", %{conn: conn} do
+      event = event_for(@bank_account, "account.external_account.created")
+      path = stripe_connect_events_path(conn, :create)
+
+      assert conn |> post(path, event) |> response(200)
+
+      wait_for_supervisor
+
+      event = Repo.one(StripeEvent)
+      assert event.status == "errored"
+
+      assert [] == Repo.all(StripeExternalAccount)
+    end
   end
 
   describe "any event" do

test/lib/code_corps/stripe_service/adapters/stripe_external_account_test.exs

@@ -3,7 +3,7 @@ defmodule CodeCorps.StripeService.Adapters.StripeExternalAccountTestAdapter do
 
   import CodeCorps.StripeService.Adapters.StripeExternalAccountAdapter, only: [to_params: 1]
 
-  @stripe_connect_account %Stripe.ExternalAccount{
+  @stripe_external_account %Stripe.ExternalAccount{
     id: "ba_19SSZG2eZvKYlo2CXnmzYU5H",
     object: "bank_account",
     account: "acct_1032D82eZvKYlo2C",
@@ -32,12 +32,13 @@ defmodule CodeCorps.StripeService.Adapters.StripeExternalAccountTestAdapter do
     fingerprint: "1JWtPxqbdX5Gamtc",
     last4: "6789",
     routing_number: "110000000",
-    status: "new"
+    status: "new",
+    stripe_connect_account_id: nil
   }
 
   describe "to_params/2" do
     test "converts from stripe map to local properly" do
-      {:ok, result} = to_params(@stripe_connect_account)
+      {:ok, result} = to_params(@stripe_external_account)
       assert result == @local_map
     end
   end

test/lib/code_corps/stripe_service/stripe_connect_external_account_service_test.exs

@@ -10,10 +10,20 @@ defmodule CodeCorps.StripeService.StripeConnectExternalAccountServiceTest do
       id_from_stripe = "ba_testing123"
       account_id_from_stripe = "acct_123"
 
-      {:ok, %CodeCorps.StripeExternalAccount{} = bank_account} =
+      connect_account = insert(:stripe_connect_account, id_from_stripe: account_id_from_stripe)
+
+      {:ok, %CodeCorps.StripeExternalAccount{} = external_account} =
         StripeConnectExternalAccountService.create(id_from_stripe, account_id_from_stripe)
 
-      assert bank_account.id_from_stripe == id_from_stripe
+      assert external_account.id_from_stripe == id_from_stripe
+      assert external_account.stripe_connect_account_id == connect_account.id
+    end
+
+    test "returns {:error, :not_found} if there's no associated stripe connect account" do
+      id_from_stripe = "ba_testing123"
+      account_id_from_stripe = "acct_123"
+
+      assert {:error, :not_found} == StripeConnectExternalAccountService.create(id_from_stripe, account_id_from_stripe)
     end
   end
 end

test/support/factories.ex

@@ -153,13 +153,20 @@ defmodule CodeCorps.Factories do
 
   def stripe_event_factory do
     %CodeCorps.StripeEvent{
-    endpoint: sequence(:endpoint, fn(_) -> Enum.random(~w{ connect platform }) end),
+      endpoint: sequence(:endpoint, fn(_) -> Enum.random(~w{ connect platform }) end),
       id_from_stripe: sequence(:id_from_stripe, &"stripe_id_#{&1}"),
       status: sequence(:status, fn(_) -> Enum.random(~w{ unprocessed processed errored }) end),
       type: "test.type"
     }
   end
 
+  def stripe_external_account_factory do
+    %CodeCorps.StripeExternalAccount{
+      account_id_from_stripe: sequence(:id_from_stripe, &"stripe_id_#{&1}"),
+      id_from_stripe: sequence(:id_from_stripe, &"stripe_id_#{&1}")
+    }
+  end
+
   def stripe_file_upload_factory do
     %CodeCorps.StripeFileUpload{
       id_from_stripe: sequence(:id_from_stripe, &"stripe_id_#{&1}"),

test/views/stripe_connect_account_view_test.exs

@@ -19,6 +19,8 @@ defmodule CodeCorps.StripeConnectAccountViewTest do
       "data" => %{
         "attributes" => %{
           "bank-account-status" => "pending_requirement",
+          "bank-account-last4" => nil,
+          "bank-account-routing-number" => nil,
           "business-name" => account.business_name,
           "business-url" => account.business_url,
           "can-accept-donations" => true,
@@ -308,4 +310,16 @@ defmodule CodeCorps.StripeConnectAccountViewTest do
       assert rendered_json["data"]["attributes"]["bank-account-status"] == "verified"
     end
   end
+
+  describe "external account fields" do
+    test "render if there is an associated external account" do
+      account = insert(:stripe_connect_account)
+      insert(:stripe_external_account, last4: "ABCD", routing_number: "123456", stripe_connect_account: account)
+
+      rendered_json = render(CodeCorps.StripeConnectAccountView, "show.json-api", data: account)
+
+      assert rendered_json["data"]["attributes"]["bank-account-last4"] == "ABCD"
+      assert rendered_json["data"]["attributes"]["bank-account-routing-number"] == "123456"
+    end
+  end
 end

web/models/stripe_connect_account.ex

@@ -71,6 +71,7 @@ defmodule CodeCorps.StripeConnectAccount do
     field :verification_fields_needed, {:array, :string}, default: []
 
     belongs_to :organization, CodeCorps.Organization
+    has_one :stripe_external_account, CodeCorps.StripeExternalAccount
 
     timestamps()
   end

web/models/stripe_external_account.ex

@@ -15,12 +15,15 @@ defmodule CodeCorps.StripeExternalAccount do
     field :routing_number, :string
     field :status, :string
 
+    belongs_to :stripe_connect_account, CodeCorps.StripeConnectAccount
+
     timestamps()
   end
 
   @create_params [
     :id_from_stripe, :account_id_from_stripe, :account_holder_name, :account_holder_type, :bank_name,
-    :country, :currency, :default_for_currency, :fingerprint, :last4, :routing_number, :status
+    :country, :currency, :default_for_currency, :fingerprint, :last4, :routing_number, :status,
+    :stripe_connect_account_id
   ]
 
   @required_create_params [:id_from_stripe, :account_id_from_stripe]
@@ -32,5 +35,6 @@ defmodule CodeCorps.StripeExternalAccount do
     struct
     |> cast(params, @create_params)
     |> validate_required(@required_create_params)
+    |> assoc_constraint(:stripe_connect_account)
   end
 end