shutter-service: update latest trigger time at last

faheelsattar · faheelsattar · commit 9b7324136e1f · 2024-12-13T20:24:37.000+05:00
diff --git a/rolling-shutter/keyperimpl/shutterservice/newblock.go b/rolling-shutter/keyperimpl/shutterservice/newblock.go
@@ -55,8 +55,6 @@ func (kpr *Keyper) maybeTriggerDecryption(ctx context.Context, block *syncevent.
 		return errors.Wrap(err, "failed to query non decrypted identity registered events from db")
 	}
 
-	kpr.latestTriggeredTime = &block.Header.Time
-
 	obsDB := obskeyper.New(kpr.dbpool)
 	eventsToDecrypt := make([]servicedatabase.IdentityRegisteredEvent, 0)
 	for _, event := range nonTriggeredEvents {
@@ -65,7 +63,12 @@ func (kpr *Keyper) maybeTriggerDecryption(ctx context.Context, block *syncevent.
 		}
 	}
 
-	return kpr.triggerDecryption(ctx, eventsToDecrypt, block)
+	err = kpr.triggerDecryption(ctx, eventsToDecrypt, block)
+	if err != nil {
+		return err
+	}
+	kpr.latestTriggeredTime = &block.Header.Time
+	return nil
 }
 
 func (kpr *Keyper) shouldTriggerDecryption(

Original file line number	Diff line number	Diff line change
`@@ -55,8 +55,6 @@ func (kpr Keyper) maybeTriggerDecryption(ctx context.Context, block syncevent.`
`55`	`55`	`return errors.Wrap(err, "failed to query non decrypted identity registered events from db")`
`56`	`56`	`}`
`57`	`57`
`58`		`- kpr.latestTriggeredTime = &block.Header.Time`
`59`		`-`
`60`	`58`	`obsDB := obskeyper.New(kpr.dbpool)`
`61`	`59`	`eventsToDecrypt := make([]servicedatabase.IdentityRegisteredEvent, 0)`
`62`	`60`	`for _, event := range nonTriggeredEvents {`
`@@ -65,7 +63,12 @@ func (kpr Keyper) maybeTriggerDecryption(ctx context.Context, block syncevent.`
`65`	`63`	`}`
`66`	`64`	`}`
`67`	`65`
`68`		`- return kpr.triggerDecryption(ctx, eventsToDecrypt, block)`
	`66`	`+ err = kpr.triggerDecryption(ctx, eventsToDecrypt, block)`
	`67`	`+ if err != nil {`
	`68`	`+ return err`
	`69`	`+ }`
	`70`	`+ kpr.latestTriggeredTime = &block.Header.Time`
	`71`	`+ return nil`
`69`	`72`	`}`
`70`	`73`
`71`	`74`	`func (kpr *Keyper) shouldTriggerDecryption(`