@@ -7,7 +7,7 @@ use common_utils::{
7
7
request:: RequestContent ,
8
8
} ;
9
9
use diesel_models:: enums;
10
- use error_stack:: ResultExt ;
10
+ use error_stack:: { report , ResultExt } ;
11
11
use masking:: PeekInterface ;
12
12
use transformers as airwallex;
13
13
@@ -223,12 +223,11 @@ impl ConnectorIntegration<api::AccessTokenAuth, types::AccessTokenRequestData, t
223
223
event_builder. map ( |i| i. set_response_body ( & response) ) ;
224
224
router_env:: logger:: info!( connector_response=?response) ;
225
225
226
- types:: ResponseRouterData {
226
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
227
227
response,
228
228
data : data. clone ( ) ,
229
229
http_code : res. status_code ,
230
- }
231
- . try_into ( )
230
+ } )
232
231
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
233
232
}
234
233
@@ -313,12 +312,11 @@ impl
313
312
event_builder. map ( |i| i. set_response_body ( & response) ) ;
314
313
router_env:: logger:: info!( connector_response=?response) ;
315
314
316
- types:: ResponseRouterData {
315
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
317
316
response,
318
317
data : data. clone ( ) ,
319
318
http_code : res. status_code ,
320
- }
321
- . try_into ( )
319
+ } )
322
320
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
323
321
}
324
322
@@ -444,12 +442,11 @@ impl ConnectorIntegration<api::Authorize, types::PaymentsAuthorizeData, types::P
444
442
. change_context ( errors:: ConnectorError :: ResponseDeserializationFailed ) ?;
445
443
event_builder. map ( |i| i. set_response_body ( & response) ) ;
446
444
router_env:: logger:: info!( connector_response=?response) ;
447
- types:: ResponseRouterData {
445
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
448
446
response,
449
447
data : data. clone ( ) ,
450
448
http_code : res. status_code ,
451
- }
452
- . try_into ( )
449
+ } )
453
450
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
454
451
}
455
452
@@ -526,7 +523,7 @@ impl ConnectorIntegration<api::PSync, types::PaymentsSyncData, types::PaymentsRe
526
523
event_builder. map ( |i| i. set_response_body ( & response) ) ;
527
524
router_env:: logger:: info!( connector_response=?response) ;
528
525
529
- types:: PaymentsSyncRouterData :: try_from ( types:: ResponseRouterData {
526
+ types:: RouterData :: try_from ( types:: ResponseRouterData {
530
527
response,
531
528
data : data. clone ( ) ,
532
529
http_code : res. status_code ,
@@ -706,12 +703,11 @@ impl ConnectorIntegration<api::Capture, types::PaymentsCaptureData, types::Payme
706
703
. change_context ( errors:: ConnectorError :: ResponseDeserializationFailed ) ?;
707
704
event_builder. map ( |i| i. set_response_body ( & response) ) ;
708
705
router_env:: logger:: info!( connector_response=?response) ;
709
- types:: ResponseRouterData {
706
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
710
707
response,
711
708
data : data. clone ( ) ,
712
709
http_code : res. status_code ,
713
- }
714
- . try_into ( )
710
+ } )
715
711
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
716
712
}
717
713
@@ -783,12 +779,11 @@ impl ConnectorIntegration<api::Void, types::PaymentsCancelData, types::PaymentsR
783
779
. change_context ( errors:: ConnectorError :: ResponseDeserializationFailed ) ?;
784
780
event_builder. map ( |i| i. set_response_body ( & response) ) ;
785
781
router_env:: logger:: info!( connector_response=?response) ;
786
- types:: ResponseRouterData {
782
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
787
783
response,
788
784
data : data. clone ( ) ,
789
785
http_code : res. status_code ,
790
- }
791
- . try_into ( )
786
+ } )
792
787
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
793
788
}
794
789
@@ -897,12 +892,11 @@ impl ConnectorIntegration<api::Execute, types::RefundsData, types::RefundsRespon
897
892
. change_context ( errors:: ConnectorError :: RequestEncodingFailed ) ?;
898
893
event_builder. map ( |i| i. set_response_body ( & response) ) ;
899
894
router_env:: logger:: info!( connector_response=?response) ;
900
- types:: ResponseRouterData {
895
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
901
896
response,
902
897
data : data. clone ( ) ,
903
898
http_code : res. status_code ,
904
- }
905
- . try_into ( )
899
+ } )
906
900
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
907
901
}
908
902
@@ -971,12 +965,11 @@ impl ConnectorIntegration<api::RSync, types::RefundsData, types::RefundsResponse
971
965
. change_context ( errors:: ConnectorError :: ResponseDeserializationFailed ) ?;
972
966
event_builder. map ( |i| i. set_response_body ( & response) ) ;
973
967
router_env:: logger:: info!( connector_response=?response) ;
974
- types:: ResponseRouterData {
968
+ types:: RouterData :: try_from ( types :: ResponseRouterData {
975
969
response,
976
970
data : data. clone ( ) ,
977
971
http_code : res. status_code ,
978
- }
979
- . try_into ( )
972
+ } )
980
973
. change_context ( errors:: ConnectorError :: ResponseHandlingFailed )
981
974
}
982
975
@@ -1076,7 +1069,7 @@ impl api::IncomingWebhook for Airwallex {
1076
1069
) ,
1077
1070
) )
1078
1071
} else {
1079
- Err ( errors:: ConnectorError :: WebhookEventTypeNotFound )
1072
+ Err ( report ! ( errors:: ConnectorError :: WebhookEventTypeNotFound ) )
1080
1073
}
1081
1074
}
1082
1075
0 commit comments