still-to-improve fix to prevent congestion of the ws output queue

Lukas1Komarek · May 2, 2023 · cf1d074 · cf1d074
1 parent be9eadb
commit cf1d074
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/internal/trapri/trapri.go b/internal/trapri/trapri.go
@@ -45,8 +45,14 @@ func TokenTransactionFormatter(gb *gloomberg.Gloomberg, queueTokenTransactions c
 	for ttx := range queueTokenTransactions {
 		go formatTokenTransaction(gb, ttx, terminalPrinterQueue)
 
-		// send to ws
-		queueWsOutTokenTransactions <- ttx
+		// send to ws if webserver enabled & the queue is not congested
+		if viper.GetBool("web.enabled") {
+			if len(queueWsOutTokenTransactions) < cap(queueWsOutTokenTransactions)-10 {
+				queueWsOutTokenTransactions <- ttx
+			} else {
+				gbl.Log.Warnf("🧱 ws out queue is congested")
+			}
+		}
 	}
 }