add end to end ach items

Author: suejung-sentry

api/internal/owner/serializers.py

@@ -108,8 +108,17 @@ class StripeCardSerializer(serializers.Serializer):
     last4 = serializers.CharField()
 
 
+class StripeUSBankAccountSerializer(serializers.Serializer):
+    account_holder_type = serializers.CharField()
+    account_type = serializers.CharField()
+    bank_name = serializers.CharField()
+    last4 = serializers.CharField()
+    routing_number = serializers.CharField()
+
+
 class StripePaymentMethodSerializer(serializers.Serializer):
     card = StripeCardSerializer(read_only=True)
+    us_bank_account = StripeUSBankAccountSerializer(read_only=True)
     billing_details = serializers.JSONField(read_only=True)
 
 

api/internal/owner/views.py

@@ -85,7 +85,8 @@ def update_email(self, request, *args, **kwargs):
             raise ValidationError(detail="No new_email sent")
         owner = self.get_object()
         billing = BillingService(requesting_user=request.current_owner)
-        billing.update_email_address(owner, new_email)
+        should_propagate = request.data.get("should_propagate_to_payment_methods", False)
+        billing.update_email_address(owner, new_email, should_propagate_to_payment_methods=should_propagate)
         return Response(self.get_serializer(owner).data)
 
     @action(detail=False, methods=["patch"])

billing/views.py

@@ -312,6 +312,7 @@ def customer_subscription_created(self, subscription: stripe.Subscription) -> No
         self._log_updated([owner])
 
     def customer_subscription_updated(self, subscription: stripe.Subscription) -> None:
+        print("CUSTOMER SUBSCRIPTION UPDATED", subscription)
         owners: QuerySet[Owner] = Owner.objects.filter(
             stripe_subscription_id=subscription.id,
             stripe_customer_id=subscription.customer,
@@ -408,6 +409,8 @@ def customer_subscription_updated(self, subscription: stripe.Subscription) -> No
         )
 
     def customer_updated(self, customer: stripe.Customer) -> None:
+        print("CUSTOMER UPDATED", customer)
+
         new_default_payment_method = customer["invoice_settings"][
             "default_payment_method"
         ]

codecov/settings_base.py

@@ -98,9 +98,7 @@
     "setup", "graphql", "query_cost_threshold", default=10000
 )
 
-GRAPHQL_RATE_LIMIT_ENABLED = get_config(
-    "setup", "graphql", "rate_limit_enabled", default=True
-)
+GRAPHQL_RATE_LIMIT_ENABLED = get_config("setup", "graphql", "rate_limit_enabled", default=True)
 
 GRAPHQL_RATE_LIMIT_RPM = get_config("setup", "graphql", "rate_limit_rpm", default=300)
 
@@ -428,6 +426,8 @@
 SHELTER_PUBSUB_PROJECT_ID = get_config("setup", "shelter", "pubsub_project_id")
 SHELTER_PUBSUB_SYNC_REPO_TOPIC_ID = get_config("setup", "shelter", "sync_repo_topic_id")
 
+STRIPE_PAYMENT_METHOD_CONFIGURATION_ID = get_config("setup", "stripe", "payment_method_configuration", default=None)
+
 # Allows to do migrations from another module
 MIGRATION_MODULES = {
     "codecov_auth": "shared.django_apps.codecov_auth.migrations",

graphql_api/types/invoice/invoice.graphql

@@ -43,6 +43,14 @@ type Card {
   last4: String
 }
 
+type BankAccount {
+  accountHolderType: String
+  accountType: String
+  bankName: String
+  last4: String
+  routingNumber: String
+}
+
 type BillingDetails {
   address: Address
   email: String

services/billing.py

@@ -516,8 +516,8 @@ def create_checkout_session(self, owner: Owner, desired_plan):
         )
 
         session = stripe.checkout.Session.create(
+            payment_method_configuration=settings.STRIPE_PAYMENT_METHOD_CONFIGURATION_ID,
             billing_address_collection="required",
-            payment_method_types=["card"],
             payment_method_collection="if_required",
             client_reference_id=str(owner.ownerid),
             success_url=success_url,
@@ -601,7 +601,7 @@ def update_payment_method(self, owner: Owner, payment_method):
         )
 
     @_log_stripe_error
-    def update_email_address(self, owner: Owner, email_address: str):
+    def update_email_address(self, owner: Owner, email_address: str, should_propagate_to_payment_methods: bool = False):
         if not re.fullmatch(r"[^@]+@[^@]+\.[^@]+", email_address):
             return None
 
@@ -616,6 +616,27 @@ def update_email_address(self, owner: Owner, email_address: str):
             f"Stripe successfully updated email address for owner {owner.ownerid} by user #{self.requesting_user.ownerid}"
         )
 
+        if should_propagate_to_payment_methods:
+            try:
+                default_payment_method = stripe.Customer.retrieve(
+                    owner.stripe_customer_id
+                ).invoice_settings.default_payment_method
+
+                stripe.PaymentMethod.modify(
+                    default_payment_method,
+                    billing_details={"email": email_address},
+                )
+                log.info(
+                    f"Stripe successfully updated billing email for payment method {default_payment_method}"
+                )
+            except Exception:
+                log.error(
+                    "Unable to update billing email for payment method",
+                    extra=dict(
+                        payment_method=default_payment_method,
+                    ),
+                )
+
     @_log_stripe_error
     def update_billing_address(self, owner: Owner, name, billing_address):
         log.info(f"Stripe update billing address for owner {owner.ownerid}")
@@ -786,14 +807,14 @@ def update_payment_method(self, owner, payment_method):
         """
         return self.payment_service.update_payment_method(owner, payment_method)
 
-    def update_email_address(self, owner: Owner, email_address: str):
+    def update_email_address(self, owner: Owner, email_address: str, should_propagate_to_payment_methods: bool = False):
         """
         Takes an owner and a new email. Email is a string coming directly from
         the front-end. If the owner has a payment id and if it's a valid email,
         the payment service will update the email address in the upstream service.
         Otherwise returns None.
         """
-        return self.payment_service.update_email_address(owner, email_address)
+        return self.payment_service.update_email_address(owner, email_address, should_propagate_to_payment_methods)
 
     def update_billing_address(self, owner: Owner, name: str, billing_address):
         """