Merge pull request #98 from iotaledger/fix/enqueued-requests-loss

Fix loss of enqueued requests
iotaledger · Oct 23, 2023 · fb93426 · fb93426
2 parents 935b512 + b1caad0
commit fb93426
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/components/app/app.go b/components/app/app.go
@@ -13,7 +13,7 @@ var (
 	Name = "inx-faucet"
 
 	// Version of the app.
-	Version = "2.0.0-alpha.3"
+	Version = "2.0.0-alpha.4"
 )
 
 func App() *app.App {

diff --git a/pkg/faucet/faucet.go b/pkg/faucet/faucet.go
@@ -785,6 +785,8 @@ func (f *Faucet) collectRequestsAndSendFaucetBlock(ctx context.Context) error {
 			}
 			f.logSoftError(err)
 		}
+		// readd the all collected requests back to the queue
+		f.readdRequestsWithoutLocking(batchedRequests)
 
 		return nil
 	}
@@ -797,6 +799,7 @@ func (f *Faucet) collectRequestsAndSendFaucetBlock(ctx context.Context) error {
 			// => stop the faucet
 			return err
 		}
+		// readd the non-processed requests back to the queue
 		f.readdRequestsWithoutLocking(processableRequests)
 		f.logSoftError(err)
 	}