cashless2ecash

commit dc1ef32a87c72a0311934bbcf07ee55de84d7a1c
parent fd7a57115ed10b6c52a4bfb7316a3b290758039f
Author: Joel-Haeberli <haebu@rubigen.ch>
Date:   Mon, 15 Apr 2024 23:23:56 +0200

feat: retry mechanism

Diffstat:
M
c2ec/main.go
 | 
9
+++++----
M
c2ec/retrier.go
 | 
2
+-

2 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/c2ec/main.go b/c2ec/main.go
@@ -37,10 +37,11 @@ var PROVIDER_CLIENTS = map[string]ProviderClient{}
 //  1. load configuration or panic
 //  2. setup database or panic
 //  3. setup provider clients
-//  4. setup attestor
-//  5. setup routes for the bank-integration-api
-//  6. setup routes for the wire-gateway-api
-//  7. listen for incoming requests (as specified in config)
+//  4. setup retrier
+//  5. setup attestor
+//  6. setup routes for the bank-integration-api
+//  7. setup routes for the wire-gateway-api
+//  8. listen for incoming requests (as specified in config)
 func main() {
 
 	LogInfo("main", fmt.Sprintf("starting c2ec at %s", time.Now().Format(time.UnixDate)))
diff --git a/c2ec/retrier.go b/c2ec/retrier.go
@@ -26,7 +26,7 @@ func RunRetrier(ctx context.Context, errs chan error) {
 
 func retryCallback(ctx context.Context, notifications chan *Notification, errs chan error) {
 
-	listener, err := NewListener(PS_PAYMENT_NOTIFICATION_CHANNEL, notifications)
+	listener, err := NewListener(PS_RETRY_CHANNEL, notifications)
 	if err != nil {
 		LogError("retrier", err)
 		errs <- errors.New("retrier needs to be setup first")