feat(injector): add support for new crate - injector for external vault proxy

crates/common_utils/src/keymanager.rs

@@ -106,13 +106,13 @@ where
     let url = format!("{}/{endpoint}", &state.url);
 
     logger::info!(key_manager_request=?request_body);
-    let mut header = vec![];
-    header.push((
+    let mut header = vec![(
         HeaderName::from_str(CONTENT_TYPE)
             .change_context(errors::KeyManagerClientError::FailedtoConstructHeader)?,
         HeaderValue::from_str("application/json")
             .change_context(errors::KeyManagerClientError::FailedtoConstructHeader)?,
-    ));
+    )];
+
     #[cfg(feature = "km_forward_x_request_id")]
     if let Some(request_id) = state.request_id {
         header.push((
@@ -211,7 +211,7 @@ impl ConvertRaw for TransientBatchDecryptDataRequest {
     fn convert_raw(self) -> Result<Self::Output, errors::KeyManagerClientError> {
         let data = self
             .data
-            .iter()
+            .into_iter()
             .map(|(k, v)| {
                 let value = match String::from_utf8(v.peek().clone()) {
                     Ok(data) => data,
@@ -220,7 +220,7 @@ impl ConvertRaw for TransientBatchDecryptDataRequest {
                         format!("{DEFAULT_ENCRYPTION_VERSION}:{data}")
                     }
                 };
-                (k.to_owned(), StrongSecret::new(value))
+                (k, StrongSecret::new(value))
             })
             .collect();
         Ok(BatchDecryptDataRequest {

crates/diesel_models/src/payment_attempt.rs

@@ -1098,6 +1098,7 @@ impl PaymentAttemptUpdateInternal {
 
 #[cfg(feature = "v2")]
 impl PaymentAttemptUpdate {
+    // #[allow(clippy::todo)]
     pub fn apply_changeset(self, _source: PaymentAttempt) -> PaymentAttempt {
         todo!()
         // let PaymentAttemptUpdateInternal {
@@ -1325,6 +1326,7 @@ impl PaymentAttemptUpdate {
 
 #[cfg(feature = "v2")]
 impl From<PaymentAttemptUpdate> for PaymentAttemptUpdateInternal {
+    // #[allow(clippy::todo)]
     fn from(_payment_attempt_update: PaymentAttemptUpdate) -> Self {
         todo!()
         // match payment_attempt_update {

crates/hyperswitch_connectors/src/connectors/redsys.rs

@@ -921,4 +921,17 @@ impl ConnectorSpecifications for Redsys {
             connector_utils::generate_12_digit_number().to_string()
         }
     }
+
+    // #[cfg(feature = "v2")]
+    // fn generate_connector_request_reference_id(
+    //     &self,
+    //     payment_intent: &hyperswitch_domain_models::payments::PaymentIntent,
+    //     _payment_attempt: &hyperswitch_domain_models::payments::payment_attempt::PaymentAttempt,
+    // ) -> String {
+    //     payment_intent
+    //         .merchant_reference_id
+    //         .as_ref()
+    //         .map(|id| id.get_string_repr().to_owned())
+    //         .unwrap_or_else(|| connector_utils::generate_12_digit_number().to_string())
+    // }
 }

crates/hyperswitch_interfaces/src/api.rs

@@ -397,7 +397,7 @@ pub trait ConnectorSpecifications {
         false
     }
 
-    #[cfg(not(feature = "v2"))]
+    #[cfg(feature = "v1")]
     /// Generate connector request reference ID
     fn generate_connector_request_reference_id(
         &self,

crates/injector/Cargo.toml

@@ -0,0 +1,48 @@
+[package]
+name = "injector"
+description = "Token injection and payload processing for payment connectors"
+version = "0.1.0"
+edition.workspace = true
+rust-version.workspace = true
+license.workspace = true
+
+[features]
+default = [
+    "dep:hyperswitch_interfaces",
+    "dep:common_utils",
+    "dep:external_services",
+    "dep:masking",
+    "dep:router_env",
+    "dep:async-trait",
+    "dep:error-stack",
+    "dep:nom",
+    "dep:serde",
+    "dep:serde_json",
+    "dep:thiserror",
+    "dep:tokio",
+    "dep:url"
+]
+
+v1 = ["default"]
+v2 = ["default"] 
+serde = ["default"]
+tracing-actix-web = ["default"]
+
+[dependencies]
+hyperswitch_interfaces = { version = "0.1.0", path = "../hyperswitch_interfaces", optional = true }
+common_utils = { version = "0.1.0", path = "../common_utils", optional = true }
+external_services = { version = "0.1.0", path = "../external_services", optional = true }
+masking = { version = "0.1.0", path = "../masking", optional = true }
+router_env = { version = "0.1.0", path = "../router_env", optional = true }
+
+async-trait = { version = "0.1.88", optional = true }
+error-stack = { version = "0.4.1", optional = true }
+nom = { version = "7.1.3", optional = true }
+serde = { version = "1.0.219", features = ["derive"], optional = true }
+serde_json = { version = "1.0.140", optional = true }
+thiserror = { version = "1.0.69", optional = true }
+tokio = { version = "1.42.0", features = ["macros", "rt-multi-thread"], optional = true }
+url = { version = "2.5.4", features = ["serde"], optional = true }
+
+[lints]
+workspace = true