feat: stripe connect integration for payouts

config/config.example.toml

@@ -487,7 +487,7 @@ debit = { currency = "USD" }
 
 [connector_customer]
 connector_list = "gocardless,stax,stripe"
-payout_connector_list = "wise"
+payout_connector_list = "stripe,wise"
 
 [bank_config.online_banking_fpx]
 adyen.banks = "affin_bank,agro_bank,alliance_bank,am_bank,bank_islam,bank_muamalat,bank_rakyat,bank_simpanan_nasional,cimb_bank,hong_leong_bank,hsbc_bank,kuwait_finance_house,maybank,ocbc_bank,public_bank,rhb_bank,standard_chartered_bank,uob_bank"

config/development.toml

@@ -474,7 +474,7 @@ payme = { payment_method = "card" }
 
 [connector_customer]
 connector_list = "gocardless,stax,stripe"
-payout_connector_list = "wise"
+payout_connector_list = "stripe,wise"
 
 [dummy_connector]
 enabled = true

config/docker_compose.toml

@@ -395,7 +395,7 @@ connector_list = "stripe,adyen,cybersource"
 
 [connector_customer]
 connector_list = "gocardless,stax,stripe"
-payout_connector_list = "wise"
+payout_connector_list = "stripe,wise"
 
 [multiple_api_version_supported_connectors]
 supported_connectors = "braintree"

crates/api_models/src/enums.rs

@@ -154,6 +154,10 @@ impl Connector {
     pub fn supports_access_token_for_payout(&self, payout_method: PayoutType) -> bool {
         matches!((self, payout_method), (Self::Paypal, _))
     }
+    #[cfg(feature = "payouts")]
+    pub fn supports_vendor_disburse_account_create_for_payout(&self) -> bool {
+        matches!(self, Self::Stripe)
+    }
     pub fn supports_access_token(&self, payment_method: PaymentMethod) -> bool {
         matches!(
             (self, payment_method),
@@ -338,6 +342,7 @@ pub enum AuthenticationConnectors {
 #[strum(serialize_all = "snake_case")]
 pub enum PayoutConnectors {
     Adyen,
+    Stripe,
     Wise,
     Paypal,
 }
@@ -347,6 +352,7 @@ impl From<PayoutConnectors> for RoutableConnectors {
     fn from(value: PayoutConnectors) -> Self {
         match value {
             PayoutConnectors::Adyen => Self::Adyen,
+            PayoutConnectors::Stripe => Self::Stripe,
             PayoutConnectors::Wise => Self::Wise,
             PayoutConnectors::Paypal => Self::Paypal,
         }
@@ -358,6 +364,7 @@ impl From<PayoutConnectors> for Connector {
     fn from(value: PayoutConnectors) -> Self {
         match value {
             PayoutConnectors::Adyen => Self::Adyen,
+            PayoutConnectors::Stripe => Self::Stripe,
             PayoutConnectors::Wise => Self::Wise,
             PayoutConnectors::Paypal => Self::Paypal,
         }
@@ -370,6 +377,7 @@ impl TryFrom<Connector> for PayoutConnectors {
     fn try_from(value: Connector) -> Result<Self, Self::Error> {
         match value {
             Connector::Adyen => Ok(Self::Adyen),
+            Connector::Stripe => Ok(Self::Stripe),
             Connector::Wise => Ok(Self::Wise),
             Connector::Paypal => Ok(Self::Paypal),
             _ => Err(format!("Invalid payout connector {}", value)),

crates/api_models/src/payouts.rs

@@ -446,6 +446,7 @@ pub struct PayoutAttemptResponse {
 #[derive(Default, Debug, Clone, Deserialize, ToSchema)]
 pub struct PayoutRetrieveBody {
     pub force_sync: Option<bool>,
+    pub merchant_id: Option<String>,
 }
 
 #[derive(Default, Debug, Serialize, ToSchema, Clone, Deserialize)]
@@ -464,6 +465,9 @@ pub struct PayoutRetrieveRequest {
     /// (defaults to false)
     #[schema(value_type = Option<bool>, default = false, example = true)]
     pub force_sync: Option<bool>,
+
+    /// The identifier for the Merchant Account.
+    pub merchant_id: Option<String>,
 }
 
 #[derive(Default, Debug, Serialize, ToSchema, Clone, Deserialize)]
@@ -479,6 +483,43 @@ pub struct PayoutActionRequest {
     pub payout_id: String,
 }
 
+#[derive(Default, Debug, ToSchema, Clone, Deserialize)]
+pub struct PayoutVendorAccountDetails {
+    pub vendor_details: PayoutVendorDetails,
+    pub individual_details: PayoutIndividualDetails,
+}
+
+#[derive(Default, Debug, Serialize, ToSchema, Clone, Deserialize)]
+pub struct PayoutVendorDetails {
+    pub account_type: String,
+    pub business_type: String,
+    pub business_profile_mcc: Option<i32>,
+    pub business_profile_url: Option<String>,
+    pub business_profile_name: Option<Secret<String>>,
+    pub company_address_line1: Option<Secret<String>>,
+    pub company_address_line2: Option<Secret<String>>,
+    pub company_address_postal_code: Option<Secret<String>>,
+    pub company_address_city: Option<Secret<String>>,
+    pub company_address_state: Option<Secret<String>>,
+    pub company_phone: Option<Secret<String>>,
+    pub company_tax_id: Option<Secret<String>>,
+    pub company_owners_provided: Option<bool>,
+    pub capabilities_card_payments: Option<bool>,
+    pub capabilities_transfers: Option<bool>,
+}
+
+#[derive(Default, Debug, Serialize, ToSchema, Clone, Deserialize)]
+pub struct PayoutIndividualDetails {
+    pub tos_acceptance_date: Option<i64>,
+    pub tos_acceptance_ip: Option<Secret<String>>,
+    pub individual_dob_day: Option<Secret<String>>,
+    pub individual_dob_month: Option<Secret<String>>,
+    pub individual_dob_year: Option<Secret<String>>,
+    pub individual_id_number: Option<Secret<String>>,
+    pub individual_ssn_last_4: Option<Secret<String>>,
+    pub external_account_account_holder_type: Option<String>,
+}
+
 #[derive(Clone, Debug, serde::Deserialize, ToSchema, serde::Serialize)]
 #[serde(deny_unknown_fields)]
 pub struct PayoutListConstraints {

crates/common_enums/src/enums.rs

@@ -2113,6 +2113,7 @@ pub enum PayoutStatus {
     RequiresCreation,
     RequiresPayoutMethodData,
     RequiresFulfillment,
+    RequiresVendorAccountCreation,
 }
 
 #[derive(

crates/common_utils/src/consts.rs

@@ -28,6 +28,9 @@ pub fn default_payments_list_limit() -> u32 {
     10
 }
 
+/// Average delay (in seconds) between account onboarding's API response and the changes to actually reflect at Stripe's end
+pub const STRIPE_ACCOUNT_ONBOARDING_DELAY_IN_SECONDS: i64 = 15;
+
 /// Maximum limit for payment link list get api
 pub const PAYMENTS_LINK_LIST_LIMIT: u32 = 100;
 

crates/connector_configs/src/connector.rs

@@ -161,6 +161,8 @@ pub struct ConnectorConfig {
     pub rapyd: Option<ConnectorTomlConfig>,
     pub shift4: Option<ConnectorTomlConfig>,
     pub stripe: Option<ConnectorTomlConfig>,
+    #[cfg(feature = "payouts")]
+    pub stripe_payout: Option<ConnectorTomlConfig>,
     pub signifyd: Option<ConnectorTomlConfig>,
     pub trustpay: Option<ConnectorTomlConfig>,
     pub threedsecureio: Option<ConnectorTomlConfig>,
@@ -214,6 +216,7 @@ impl ConnectorConfig {
         let connector_data = Self::new()?;
         match connector {
             PayoutConnectors::Adyen => Ok(connector_data.adyen_payout),
+            PayoutConnectors::Stripe => Ok(connector_data.stripe_payout),
             PayoutConnectors::Wise => Ok(connector_data.wise_payout),
             PayoutConnectors::Paypal => Ok(connector_data.paypal),
         }

crates/connector_configs/toml/development.toml

@@ -2580,6 +2580,12 @@ api_key = "Adyen API Key (Payout creation)"
 api_secret = "Adyen Key (Payout submission)"
 key1 = "Adyen Account Id"
 
+[stripe_payout]
+[[stripe_payout.bank_transfer]]
+  payment_method_type = "ach"
+[stripe_payout.connector_auth.HeaderKey]
+api_key = "Stripe API Key"
+
 [wise_payout]
 [[wise_payout.bank_transfer]]
   payment_method_type = "ach"

crates/connector_configs/toml/sandbox.toml

@@ -2582,6 +2582,12 @@ api_key = "Adyen API Key (Payout creation)"
 api_secret = "Adyen Key (Payout submission)"
 key1 = "Adyen Account Id"
 
+[stripe_payout]
+[[stripe_payout.bank_transfer]]
+  payment_method_type = "ach"
+[stripe_payout.connector_auth.HeaderKey]
+api_key = "Stripe API Key"
+
 [wise_payout]
 [[wise_payout.bank_transfer]]
   payment_method_type = "ach"

crates/data_models/src/payouts/payouts.rs

@@ -89,6 +89,7 @@ pub struct Payouts {
     pub attempt_count: i16,
     pub profile_id: String,
     pub status: storage_enums::PayoutStatus,
+    pub confirm: Option<bool>,
 }
 
 #[derive(Clone, Debug, Eq, PartialEq)]
@@ -110,9 +111,10 @@ pub struct PayoutsNew {
     pub metadata: Option<pii::SecretSerdeValue>,
     pub created_at: Option<PrimitiveDateTime>,
     pub last_modified_at: Option<PrimitiveDateTime>,
+    pub attempt_count: i16,
     pub profile_id: String,
     pub status: storage_enums::PayoutStatus,
-    pub attempt_count: i16,
+    pub confirm: Option<bool>,
 }
 
 impl Default for PayoutsNew {
@@ -137,9 +139,10 @@ impl Default for PayoutsNew {
             metadata: Option::default(),
             created_at: Some(now),
             last_modified_at: Some(now),
+            attempt_count: 1,
             profile_id: String::default(),
             status: storage_enums::PayoutStatus::default(),
-            attempt_count: 1,
+            confirm: None,
         }
     }
 }
@@ -158,6 +161,7 @@ pub enum PayoutsUpdate {
         metadata: Option<pii::SecretSerdeValue>,
         profile_id: Option<String>,
         status: Option<storage_enums::PayoutStatus>,
+        confirm: Option<bool>,
     },
     PayoutMethodIdUpdate {
         payout_method_id: String,
@@ -188,6 +192,7 @@ pub struct PayoutsUpdateInternal {
     pub profile_id: Option<String>,
     pub status: Option<storage_enums::PayoutStatus>,
     pub attempt_count: Option<i16>,
+    pub confirm: Option<bool>,
 }
 
 impl From<PayoutsUpdate> for PayoutsUpdateInternal {
@@ -205,6 +210,7 @@ impl From<PayoutsUpdate> for PayoutsUpdateInternal {
                 metadata,
                 profile_id,
                 status,
+                confirm,
             } => Self {
                 amount: Some(amount),
                 destination_currency: Some(destination_currency),
@@ -217,6 +223,7 @@ impl From<PayoutsUpdate> for PayoutsUpdateInternal {
                 metadata,
                 profile_id,
                 status,
+                confirm,
                 ..Default::default()
             },
             PayoutsUpdate::PayoutMethodIdUpdate { payout_method_id } => Self {

crates/diesel_models/src/payouts.rs

@@ -32,6 +32,7 @@ pub struct Payouts {
     pub attempt_count: i16,
     pub profile_id: String,
     pub status: storage_enums::PayoutStatus,
+    pub confirm: Option<bool>,
 }
 
 #[derive(
@@ -67,9 +68,10 @@ pub struct PayoutsNew {
     pub created_at: Option<PrimitiveDateTime>,
     #[serde(default, with = "common_utils::custom_serde::iso8601::option")]
     pub last_modified_at: Option<PrimitiveDateTime>,
+    pub attempt_count: i16,
     pub profile_id: String,
     pub status: storage_enums::PayoutStatus,
-    pub attempt_count: i16,
+    pub confirm: Option<bool>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -86,6 +88,7 @@ pub enum PayoutsUpdate {
         metadata: Option<pii::SecretSerdeValue>,
         profile_id: Option<String>,
         status: Option<storage_enums::PayoutStatus>,
+        confirm: Option<bool>,
     },
     PayoutMethodIdUpdate {
         payout_method_id: String,
@@ -118,6 +121,7 @@ pub struct PayoutsUpdateInternal {
     pub status: Option<storage_enums::PayoutStatus>,
     pub last_modified_at: PrimitiveDateTime,
     pub attempt_count: Option<i16>,
+    pub confirm: Option<bool>,
 }
 
 impl Default for PayoutsUpdateInternal {
@@ -137,6 +141,7 @@ impl Default for PayoutsUpdateInternal {
             status: None,
             last_modified_at: common_utils::date_time::now(),
             attempt_count: None,
+            confirm: None,
         }
     }
 }
@@ -156,6 +161,7 @@ impl From<PayoutsUpdate> for PayoutsUpdateInternal {
                 metadata,
                 profile_id,
                 status,
+                confirm,
             } => Self {
                 amount: Some(amount),
                 destination_currency: Some(destination_currency),
@@ -168,6 +174,7 @@ impl From<PayoutsUpdate> for PayoutsUpdateInternal {
                 metadata,
                 profile_id,
                 status,
+                confirm,
                 ..Default::default()
             },
             PayoutsUpdate::PayoutMethodIdUpdate { payout_method_id } => Self {
@@ -207,6 +214,7 @@ impl PayoutsUpdate {
             status,
             last_modified_at,
             attempt_count,
+            confirm,
         } = self.into();
         Payouts {
             amount: amount.unwrap_or(source.amount),
@@ -223,6 +231,7 @@ impl PayoutsUpdate {
             status: status.unwrap_or(source.status),
             last_modified_at,
             attempt_count: attempt_count.unwrap_or(source.attempt_count),
+            confirm: confirm.or(source.confirm),
             ..source
         }
     }

crates/diesel_models/src/process_tracker.rs

@@ -209,6 +209,7 @@ pub enum ProcessTrackerRunner {
     DeleteTokenizeDataWorkflow,
     ApiKeyExpiryWorkflow,
     OutgoingWebhookRetryWorkflow,
+    AttachPayoutAccountWorkflow,
 }
 
 #[cfg(test)]

crates/diesel_models/src/schema.rs

@@ -999,6 +999,7 @@ diesel::table! {
         #[max_length = 64]
         profile_id -> Varchar,
         status -> PayoutStatus,
+        confirm -> Nullable<Bool>,
     }
 }
 

crates/router/src/bin/scheduler.rs

@@ -263,6 +263,23 @@ impl ProcessTrackerWorkflows<routes::AppState> for WorkflowRunner {
                 storage::ProcessTrackerRunner::OutgoingWebhookRetryWorkflow => Ok(Box::new(
                     workflows::outgoing_webhook_retry::OutgoingWebhookRetryWorkflow,
                 )),
+                storage::ProcessTrackerRunner::AttachPayoutAccountWorkflow => {
+                    #[cfg(feature = "payouts")]
+                    {
+                        Ok(Box::new(
+                            workflows::attach_payout_account_workflow::AttachPayoutAccountWorkflow,
+                        ))
+                    }
+                    #[cfg(not(feature = "payouts"))]
+                    {
+                        Err(
+                            error_stack::report!(ProcessTrackerError::UnexpectedFlow),
+                        )
+                        .attach_printable(
+                            "Cannot run Stripe external account workflow when payouts feature is disabled",
+                        )
+                    }
+                }
             }
         };