File tree Expand file tree Collapse file tree 1 file changed +2
-10
lines changed Expand file tree Collapse file tree 1 file changed +2
-10
lines changed Original file line number Diff line number Diff line change 1
1
use std:: collections:: HashMap ;
2
2
use std:: sync:: Arc ;
3
- use std:: time:: { Duration , SystemTime , UNIX_EPOCH } ; // Added SystemTime, UNIX_EPOCH
3
+ use std:: time:: { Duration , SystemTime , UNIX_EPOCH } ;
4
4
5
5
use hex;
6
6
use hmac:: { Hmac , Mac } ;
@@ -165,7 +165,7 @@ impl DurableExecution for WebhookJobPayload {
165
165
let signature_bytes = mac. finalize ( ) . into_bytes ( ) ;
166
166
let signature_hex = hex:: encode ( signature_bytes) ;
167
167
168
- // Standard header names (you can customize these if needed, but be consistent)
168
+ // Standard header names
169
169
let signature_header_name = "X-Signature-SHA256" ;
170
170
let timestamp_header_name = "X-Request-Timestamp" ;
171
171
@@ -351,7 +351,6 @@ impl DurableExecution for WebhookJobPayload {
351
351
}
352
352
}
353
353
354
- // on_success, on_nack, on_fail, on_timeout methods remain the same
355
354
async fn on_success (
356
355
& self ,
357
356
job : & Job < Self > ,
@@ -399,11 +398,4 @@ impl DurableExecution for WebhookJobPayload {
399
398
"Webhook FAILED permanently (on_fail hook)."
400
399
) ;
401
400
}
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
- }
409
401
}
You can’t perform that action at this time.
0 commit comments