Move writes to blockChan in a select case to avoid blocking

m-Peter · m-Peter · commit 720f8c99eb87 · 2025-07-16T14:05:10.000+03:00
diff --git a/services/requester/keystore/key_store.go b/services/requester/keystore/key_store.go
@@ -116,9 +116,11 @@ func (k *KeyStore) NotifyBlock(blockHeader flowsdk.BlockHeader) {
 		k.logger.Warn().Msg(
 			"received `NotifyBlock` while the server is shutting down",
 		)
-		return
-	default:
-		k.blockChan <- blockHeader
+	case k.blockChan <- blockHeader:
+		k.logger.Info().Msgf(
+			"received `NotifyBlock` for block with ID: %s",
+			blockHeader.ID,
+		)
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -116,9 +116,11 @@ func (k *KeyStore) NotifyBlock(blockHeader flowsdk.BlockHeader) {`
`116`	`116`	`k.logger.Warn().Msg(`
`117`	`117`	"received `NotifyBlock` while the server is shutting down",
`118`	`118`	`)`
`119`		`- return`
`120`		`- default:`
`121`		`- k.blockChan <- blockHeader`
	`119`	`+ case k.blockChan <- blockHeader:`
	`120`	`+ k.logger.Info().Msgf(`
	`121`	+ "received `NotifyBlock` for block with ID: %s",
	`122`	`+ blockHeader.ID,`
	`123`	`+ )`
`122`	`124`	`}`
`123`	`125`	`}`
`124`	`126`