feat(payment_request): add field amount to OrderDetails and make order_details a Vec in payments_create request (#964)

crates/api_models/src/payments.rs

@@ -1424,12 +1424,14 @@ pub struct OrderDetails {
     /// The quantity of the product to be purchased
     #[schema(example = 1)]
     pub quantity: u16,
+    /// the amount per quantity of product
+    pub amount: i64,
 }
 
 #[derive(Default, Debug, Eq, PartialEq, serde::Deserialize, serde::Serialize, Clone, ToSchema)]
 pub struct Metadata {
     /// Information about the product and quantity for specific connectors. (e.g. Klarna)
-    pub order_details: Option<OrderDetails>,
+    pub order_details: Option<Vec<OrderDetails>>,
     /// Any other metadata that is to be provided
     #[schema(value_type = Object, example = r#"{ "city": "NY", "unit": "245" }"#)]
     #[serde(flatten)]

crates/router/src/connector/adyen/transformers.rs

@@ -883,18 +883,31 @@ fn get_address_info(address: Option<&api_models::payments::Address>) -> Option<A
 }
 
 fn get_line_items(item: &types::PaymentsAuthorizeRouterData) -> Vec<LineItem> {
-    let order_details = item.request.order_details.as_ref();
+    let order_details = item.request.order_details.clone();
+    match order_details {
+        Some(od) => od
+            .iter()
+            .map(|data| LineItem {
+                amount_including_tax: Some(item.request.amount),
+                amount_excluding_tax: Some(item.request.amount),
+                description: Some(data.product_name.clone()),
+                id: Some(String::from("Items #1")),
+                tax_amount: None,
+                quantity: Some(data.quantity),
+            })
+            .collect(),
+        None => {
             let line_item = LineItem {
                 amount_including_tax: Some(item.request.amount),
                 amount_excluding_tax: Some(item.request.amount),
-        description: order_details.map(|details| details.product_name.clone()),
-        // We support only one product details in payment request as of now, therefore hard coded the id.
-        // If we begin to support multiple product details in future then this logic should be made to create ID dynamically
+                description: None,
                 id: Some(String::from("Items #1")),
                 tax_amount: None,
-        quantity: Some(order_details.map_or(1, |details| details.quantity)),
+                quantity: Some(1),
             };
             vec![line_item]
+        }
+    }
 }
 
 fn get_telephone_number(item: &types::PaymentsAuthorizeRouterData) -> Option<Secret<String>> {

crates/router/src/connector/klarna/transformers.rs

@@ -48,12 +48,15 @@ impl TryFrom<&types::PaymentsSessionRouterData> for KlarnaSessionRequest {
                 purchase_currency: request.currency,
                 order_amount: request.amount,
                 locale: "en-US".to_string(),
-                order_lines: vec![OrderLines {
-                    name: order_details.product_name,
-                    quantity: order_details.quantity,
-                    unit_price: request.amount,
-                    total_amount: request.amount,
-                }],
+                order_lines: order_details
+                    .iter()
+                    .map(|data| OrderLines {
+                        name: data.product_name.clone(),
+                        quantity: data.quantity,
+                        unit_price: data.amount,
+                        total_amount: i64::from(data.quantity) * (data.amount),
+                    })
+                    .collect(),
             }),
             None => Err(report!(errors::ConnectorError::MissingRequiredField {
                 field_name: "product_name",
@@ -93,12 +96,15 @@ impl TryFrom<&types::PaymentsAuthorizeRouterData> for KlarnaPaymentsRequest {
                 purchase_country: "US".to_string(),
                 purchase_currency: request.currency,
                 order_amount: request.amount,
-                order_lines: vec![OrderLines {
-                    name: order_details.product_name,
-                    quantity: order_details.quantity,
-                    unit_price: request.amount,
-                    total_amount: request.amount,
-                }],
+                order_lines: order_details
+                    .iter()
+                    .map(|data| OrderLines {
+                        name: data.product_name.clone(),
+                        quantity: data.quantity,
+                        unit_price: data.amount,
+                        total_amount: i64::from(data.quantity) * (data.amount),
+                    })
+                    .collect(),
             }),
             None => Err(report!(errors::ConnectorError::MissingRequiredField {
                 field_name: "product_name"

crates/router/src/connector/utils.rs

@@ -163,7 +163,7 @@ pub trait PaymentsAuthorizeRequestData {
     fn is_auto_capture(&self) -> Result<bool, Error>;
     fn get_email(&self) -> Result<Email, Error>;
     fn get_browser_info(&self) -> Result<types::BrowserInformation, Error>;
-    fn get_order_details(&self) -> Result<OrderDetails, Error>;
+    fn get_order_details(&self) -> Result<Vec<OrderDetails>, Error>;
     fn get_card(&self) -> Result<api::Card, Error>;
     fn get_return_url(&self) -> Result<String, Error>;
     fn connector_mandate_id(&self) -> Option<String>;
@@ -189,7 +189,7 @@ impl PaymentsAuthorizeRequestData for types::PaymentsAuthorizeData {
             .clone()
             .ok_or_else(missing_field_err("browser_info"))
     }
-    fn get_order_details(&self) -> Result<OrderDetails, Error> {
+    fn get_order_details(&self) -> Result<Vec<OrderDetails>, Error> {
         self.order_details
             .clone()
             .ok_or_else(missing_field_err("order_details"))

crates/router/src/connector/zen/transformers.rs

@@ -204,12 +204,15 @@ impl TryFrom<&types::PaymentsAuthorizeRouterData> for ZenPaymentsRequest {
                 ip,
             },
             custom_ipn_url: item.request.get_webhook_url()?,
-            items: vec![ZenItemObject {
-                name: order_details.product_name,
-                price: order_amount.clone(),
-                quantity: 1,
-                line_amount_total: order_amount,
-            }],
+            items: order_details
+                .iter()
+                .map(|data| ZenItemObject {
+                    name: data.product_name.clone(),
+                    quantity: data.quantity,
+                    price: data.amount.to_string(),
+                    line_amount_total: order_amount.clone(),
+                })
+                .collect(),
         })
     }
 }

crates/router/src/core/payments/helpers.rs

@@ -1429,6 +1429,7 @@ mod tests {
             active_attempt_id: "nopes".to_string(),
             business_country: storage_enums::CountryAlpha2::AG,
             business_label: "no".to_string(),
+            meta_data: None,
         };
         let req_cs = Some("1".to_string());
         let merchant_fulfillment_time = Some(900);
@@ -1468,6 +1469,7 @@ mod tests {
             active_attempt_id: "nopes".to_string(),
             business_country: storage_enums::CountryAlpha2::AG,
             business_label: "no".to_string(),
+            meta_data: None,
         };
         let req_cs = Some("1".to_string());
         let merchant_fulfillment_time = Some(10);
@@ -1507,6 +1509,7 @@ mod tests {
             active_attempt_id: "nopes".to_string(),
             business_country: storage_enums::CountryAlpha2::AG,
             business_label: "no".to_string(),
+            meta_data: None,
         };
         let req_cs = Some("1".to_string());
         let merchant_fulfillment_time = Some(10);

crates/router/src/core/payments/operations/payment_session.rs

@@ -196,16 +196,20 @@ impl<F: Clone> UpdateTracker<F, PaymentData<F>, api::PaymentsSessionRequest> for
         F: 'b + Send,
     {
         let metadata = payment_data.payment_intent.metadata.clone();
-        payment_data.payment_intent = match metadata {
-            Some(metadata) => db
+        let meta_data = payment_data.payment_intent.meta_data.clone();
+        payment_data.payment_intent = match (metadata, meta_data) {
+            (Some(metadata), Some(meta_data)) => db
                 .update_payment_intent(
                     payment_data.payment_intent,
-                    storage::PaymentIntentUpdate::MetadataUpdate { metadata },
+                    storage::PaymentIntentUpdate::MetadataUpdate {
+                        metadata,
+                        meta_data,
+                    },
                     storage_scheme,
                 )
                 .await
                 .to_not_found_response(errors::ApiErrorResponse::PaymentNotFound)?,
-            None => payment_data.payment_intent,
+            _ => payment_data.payment_intent,
         };
 
         Ok((Box::new(self), payment_data))

crates/router/src/core/payments/transformers.rs

@@ -513,14 +513,14 @@ impl<F: Clone> TryFrom<PaymentAdditionalData<'_, F>> for types::PaymentsAuthoriz
 
         let parsed_metadata: Option<api_models::payments::Metadata> = payment_data
             .payment_intent
-            .metadata
+            .meta_data
             .map(|metadata_value| {
                 metadata_value
-                    .parse_value("metadata")
+                    .parse_value("meta_data")
                     .change_context(errors::ApiErrorResponse::InvalidDataValue {
-                        field_name: "metadata",
+                        field_name: "meta_data",
                     })
-                    .attach_printable("unable to parse metadata")
+                    .attach_printable("unable to parse meta_data")
             })
             .transpose()
             .unwrap_or_default();
@@ -683,14 +683,14 @@ impl<F: Clone> TryFrom<PaymentAdditionalData<'_, F>> for types::PaymentsSessionD
         let payment_data = additional_data.payment_data;
         let parsed_metadata: Option<api_models::payments::Metadata> = payment_data
             .payment_intent
-            .metadata
+            .meta_data
             .map(|metadata_value| {
                 metadata_value
-                    .parse_value("metadata")
+                    .parse_value("meta_data")
                     .change_context(errors::ApiErrorResponse::InvalidDataValue {
-                        field_name: "metadata",
+                        field_name: "meta_data",
                     })
-                    .attach_printable("unable to parse metadata")
+                    .attach_printable("unable to parse meta_data")
             })
             .transpose()
             .unwrap_or_default();

crates/router/src/db/payment_intent.rs

@@ -95,6 +95,7 @@ mod storage {
                         business_country: new.business_country,
                         business_label: new.business_label.clone(),
                         active_attempt_id: new.active_attempt_id.to_owned(),
+                        meta_data: new.meta_data.clone(),
                     };
 
                     match self
@@ -353,6 +354,7 @@ impl PaymentIntentInterface for MockDb {
             business_country: new.business_country,
             business_label: new.business_label,
             active_attempt_id: new.active_attempt_id.to_owned(),
+            meta_data: new.meta_data,
         };
         payment_intents.push(payment_intent.clone());
         Ok(payment_intent)

crates/router/src/types.rs

@@ -215,7 +215,7 @@ pub struct PaymentsAuthorizeData {
     pub off_session: Option<bool>,
     pub setup_mandate_details: Option<payments::MandateData>,
     pub browser_info: Option<BrowserInformation>,
-    pub order_details: Option<api_models::payments::OrderDetails>,
+    pub order_details: Option<Vec<api_models::payments::OrderDetails>>,
     pub session_token: Option<String>,
     pub enrolled_for_3ds: bool,
     pub related_transaction_id: Option<String>,
@@ -297,7 +297,7 @@ pub struct PaymentsSessionData {
     pub amount: i64,
     pub currency: storage_enums::Currency,
     pub country: Option<api::enums::CountryAlpha2>,
-    pub order_details: Option<api_models::payments::OrderDetails>,
+    pub order_details: Option<Vec<api_models::payments::OrderDetails>>,
 }
 
 #[derive(Debug, Clone)]

crates/router/tests/connectors/zen.rs

@@ -306,10 +306,11 @@ async fn should_fail_payment_for_incorrect_card_number() {
                     card_number: CardNumber::from_str("1234567891011").unwrap(),
                     ..utils::CCardType::default().0
                 }),
-                order_details: Some(OrderDetails {
+                order_details: Some(vec![OrderDetails {
                     product_name: "test".to_string(),
                     quantity: 1,
-                }),
+                    amount: 1000,
+                }]),
                 email: Some(Email::from_str("test@gmail.com").unwrap()),
                 webhook_url: Some("https://1635-116-74-253-164.ngrok-free.app".to_string()),
                 ..utils::PaymentAuthorizeType::default().0
@@ -340,10 +341,11 @@ async fn should_fail_payment_for_incorrect_cvc() {
                     card_cvc: Secret::new("12345".to_string()),
                     ..utils::CCardType::default().0
                 }),
-                order_details: Some(OrderDetails {
+                order_details: Some(vec![OrderDetails {
                     product_name: "test".to_string(),
                     quantity: 1,
-                }),
+                    amount: 1000,
+                }]),
                 email: Some(Email::from_str("test@gmail.com").unwrap()),
                 webhook_url: Some("https://1635-116-74-253-164.ngrok-free.app".to_string()),
                 ..utils::PaymentAuthorizeType::default().0
@@ -374,10 +376,11 @@ async fn should_fail_payment_for_invalid_exp_month() {
                     card_exp_month: Secret::new("20".to_string()),
                     ..utils::CCardType::default().0
                 }),
-                order_details: Some(OrderDetails {
+                order_details: Some(vec![OrderDetails {
                     product_name: "test".to_string(),
                     quantity: 1,
-                }),
+                    amount: 1000,
+                }]),
                 email: Some(Email::from_str("test@gmail.com").unwrap()),
                 webhook_url: Some("https://1635-116-74-253-164.ngrok-free.app".to_string()),
                 ..utils::PaymentAuthorizeType::default().0
@@ -408,10 +411,11 @@ async fn should_fail_payment_for_incorrect_expiry_year() {
                     card_exp_year: Secret::new("2000".to_string()),
                     ..utils::CCardType::default().0
                 }),
-                order_details: Some(OrderDetails {
+                order_details: Some(vec![OrderDetails {
                     product_name: "test".to_string(),
                     quantity: 1,
-                }),
+                    amount: 1000,
+                }]),
                 email: Some(Email::from_str("test@gmail.com").unwrap()),
                 webhook_url: Some("https://1635-116-74-253-164.ngrok-free.app".to_string()),
                 ..utils::PaymentAuthorizeType::default().0

crates/storage_models/src/payment_intent.rs

@@ -36,6 +36,7 @@ pub struct PaymentIntent {
     pub active_attempt_id: String,
     pub business_country: storage_enums::CountryAlpha2,
     pub business_label: String,
+    pub meta_data: Option<pii::SecretSerdeValue>,
 }
 
 #[derive(
@@ -78,6 +79,7 @@ pub struct PaymentIntentNew {
     pub active_attempt_id: String,
     pub business_country: storage_enums::CountryAlpha2,
     pub business_label: String,
+    pub meta_data: Option<pii::SecretSerdeValue>,
 }
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
@@ -89,6 +91,7 @@ pub enum PaymentIntentUpdate {
     },
     MetadataUpdate {
         metadata: pii::SecretSerdeValue,
+        meta_data: pii::SecretSerdeValue,
     },
     ReturnUrlUpdate {
         return_url: Option<String>,
@@ -142,6 +145,7 @@ pub struct PaymentIntentUpdateInternal {
     pub active_attempt_id: Option<String>,
     pub business_country: Option<storage_enums::CountryAlpha2>,
     pub business_label: Option<String>,
+    pub meta_data: Option<pii::SecretSerdeValue>,
 }
 
 impl PaymentIntentUpdate {
@@ -169,6 +173,7 @@ impl PaymentIntentUpdate {
                 .shipping_address_id
                 .or(source.shipping_address_id),
             modified_at: common_utils::date_time::now(),
+            meta_data: internal_update.meta_data.or(source.meta_data),
             ..source
         }
     }
@@ -203,8 +208,12 @@ impl From<PaymentIntentUpdate> for PaymentIntentUpdateInternal {
                 business_label,
                 ..Default::default()
             },
-            PaymentIntentUpdate::MetadataUpdate { metadata } => Self {
+            PaymentIntentUpdate::MetadataUpdate {
+                metadata,
+                meta_data,
+            } => Self {
                 metadata: Some(metadata),
+                meta_data: Some(meta_data),
                 modified_at: Some(common_utils::date_time::now()),
                 ..Default::default()
             },

crates/storage_models/src/schema.rs

@@ -353,6 +353,7 @@ diesel::table! {
         active_attempt_id -> Varchar,
         business_country -> CountryAlpha2,
         business_label -> Varchar,
+        meta_data -> Nullable<Jsonb>,
     }
 }
 

migrations/2023-05-12-103127_payment_intent.sql/down.sql

@@ -0,0 +1 @@
+ALTER TABLE payment_intent DROP COLUMN meta_data;

migrations/2023-05-12-103127_payment_intent.sql/up.sql

@@ -0,0 +1,7 @@
+ALTER TABLE payment_intent ADD COLUMN meta_data jsonb;
+    
+UPDATE payment_intent SET meta_data = metadata;
+
+UPDATE payment_intent SET meta_data = jsonb_set(meta_data, '{order_details}', to_jsonb(ARRAY(select metadata -> 'order_details')), true);
+
+