diff --git a/crates/router/src/services/kafka/dispute_event.rs b/crates/router/src/services/kafka/dispute_event.rs index 13301c30288..d8d06ce9a5a 100644 --- a/crates/router/src/services/kafka/dispute_event.rs +++ b/crates/router/src/services/kafka/dispute_event.rs @@ -29,9 +29,9 @@ pub struct KafkaDisputeEvent<'a> { pub connector_created_at: Option, #[serde(default, with = "time::serde::timestamp::nanoseconds::option")] pub connector_updated_at: Option, - #[serde(default, with = "time::serde::timestamp::nanoseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, - #[serde(default, with = "time::serde::timestamp::nanoseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, pub connector: &'a String, pub evidence: &'a Secret, diff --git a/crates/router/src/services/kafka/fraud_check_event.rs b/crates/router/src/services/kafka/fraud_check_event.rs index 4fd71174418..1948f27816a 100644 --- a/crates/router/src/services/kafka/fraud_check_event.rs +++ b/crates/router/src/services/kafka/fraud_check_event.rs @@ -11,7 +11,7 @@ pub struct KafkaFraudCheckEvent<'a> { pub payment_id: &'a common_utils::id_type::PaymentId, pub merchant_id: &'a common_utils::id_type::MerchantId, pub attempt_id: &'a String, - #[serde(default, with = "time::serde::timestamp::milliseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, pub frm_name: &'a String, pub frm_transaction_id: Option<&'a String>, @@ -22,7 +22,7 @@ pub struct KafkaFraudCheckEvent<'a> { pub frm_error: Option<&'a String>, pub payment_details: Option, pub metadata: Option, - #[serde(default, with = "time::serde::timestamp::milliseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, pub last_step: FraudCheckLastStep, pub payment_capture_method: Option, // In postFrm, we are updating capture method from automatic to manual. To store the merchant actual capture method, we are storing the actual capture method in payment_capture_method. It will be useful while approving the FRM decision. diff --git a/crates/router/src/services/kafka/payment_attempt_event.rs b/crates/router/src/services/kafka/payment_attempt_event.rs index a54ff3cc28a..e48c595c999 100644 --- a/crates/router/src/services/kafka/payment_attempt_event.rs +++ b/crates/router/src/services/kafka/payment_attempt_event.rs @@ -156,11 +156,11 @@ pub struct KafkaPaymentAttemptEvent<'a> { pub payment_method: storage_enums::PaymentMethod, pub connector_transaction_id: Option<&'a String>, pub authentication_type: storage_enums::AuthenticationType, - #[serde(with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, - #[serde(with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, - #[serde(default, with = "time::serde::timestamp::option")] + #[serde(default, with = "time::serde::timestamp::nanoseconds::option")] pub last_synced: Option, pub cancellation_reason: Option<&'a String>, pub amount_to_capture: Option, diff --git a/crates/router/src/services/kafka/payment_intent_event.rs b/crates/router/src/services/kafka/payment_intent_event.rs index 3e0733eeb7a..db6de3cce1e 100644 --- a/crates/router/src/services/kafka/payment_intent_event.rs +++ b/crates/router/src/services/kafka/payment_intent_event.rs @@ -74,11 +74,11 @@ pub struct KafkaPaymentIntentEvent<'a> { pub return_url: Option<&'a common_types::Url>, pub metadata: Option<&'a Secret>, pub statement_descriptor: Option<&'a common_types::StatementDescriptor>, - #[serde(with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, - #[serde(with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, - #[serde(default, with = "time::serde::timestamp::option")] + #[serde(default, with = "time::serde::timestamp::nanoseconds::option")] pub last_synced: Option, pub setup_future_usage: storage_enums::FutureUsage, pub off_session: bool, @@ -97,7 +97,7 @@ pub struct KafkaPaymentIntentEvent<'a> { pub surcharge_applicable: Option, pub request_incremental_authorization: RequestIncrementalAuthorization, pub authorization_count: Option, - #[serde(with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub session_expiry: OffsetDateTime, pub request_external_three_ds_authentication: common_enums::External3dsAuthenticationRequest, pub frm_metadata: Option>, diff --git a/crates/router/src/services/kafka/refund_event.rs b/crates/router/src/services/kafka/refund_event.rs index 18cc0445cc9..fed6ee52aff 100644 --- a/crates/router/src/services/kafka/refund_event.rs +++ b/crates/router/src/services/kafka/refund_event.rs @@ -31,9 +31,9 @@ pub struct KafkaRefundEvent<'a> { pub sent_to_gateway: &'a bool, pub refund_error_message: Option<&'a String>, pub refund_arn: Option<&'a String>, - #[serde(default, with = "time::serde::timestamp::nanoseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, - #[serde(default, with = "time::serde::timestamp::nanoseconds")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, pub description: Option<&'a String>, pub attempt_id: &'a String, @@ -95,9 +95,9 @@ pub struct KafkaRefundEvent<'a> { pub sent_to_gateway: &'a bool, pub refund_error_message: Option<&'a String>, pub refund_arn: Option<&'a String>, - #[serde(default, with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub created_at: OffsetDateTime, - #[serde(default, with = "time::serde::timestamp")] + #[serde(with = "time::serde::timestamp::nanoseconds")] pub modified_at: OffsetDateTime, pub description: Option<&'a String>, pub attempt_id: &'a id_type::GlobalAttemptId,