File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change 11use std:: collections:: HashMap ;
22use std:: sync:: Arc ;
3- use std:: time:: { Duration , SystemTime , UNIX_EPOCH } ; // Added SystemTime, UNIX_EPOCH
3+ use std:: time:: { Duration , SystemTime , UNIX_EPOCH } ;
44
55use hex;
66use hmac:: { Hmac , Mac } ;
@@ -165,7 +165,7 @@ impl DurableExecution for WebhookJobPayload {
165165 let signature_bytes = mac. finalize ( ) . into_bytes ( ) ;
166166 let signature_hex = hex:: encode ( signature_bytes) ;
167167
168- // Standard header names (you can customize these if needed, but be consistent)
168+ // Standard header names
169169 let signature_header_name = "X-Signature-SHA256" ;
170170 let timestamp_header_name = "X-Request-Timestamp" ;
171171
@@ -351,7 +351,6 @@ impl DurableExecution for WebhookJobPayload {
351351 }
352352 }
353353
354- // on_success, on_nack, on_fail, on_timeout methods remain the same
355354 async fn on_success (
356355 & self ,
357356 job : & Job < Self > ,
@@ -399,11 +398,4 @@ impl DurableExecution for WebhookJobPayload {
399398 "Webhook FAILED permanently (on_fail hook)."
400399 ) ;
401400 }
402-
403- async fn on_timeout ( & self , _tx : & mut TransactionContext < ' _ > ) {
404- tracing:: warn!(
405- url = %self . url, // Assuming job_id is not directly available here
406- "Webhook job lease timed out (on_timeout hook)."
407- ) ;
408- }
409401}
You can’t perform that action at this time.
0 commit comments