mirrors/bitcoin-s
1
0
Fork 0
mirror of https://github.com/bitcoin-s/bitcoin-s.git synced 2024-11-20 10:13:26 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix empty.tail exception occurring on chain block filter / filter headers callbacks (#5021)

Browse Source 
* Fix empty.tail exception occurring on chain block filter / filter headers callbacks

* scalafmt
This commit is contained in:
Chris Stewart 2023-03-23 06:38:42 -05:00 committed by GitHub
parent e3e1c7f949
commit 6b03133a34
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/server/src/main/scala/org/bitcoins/server/util/WebsocketUtil.scala
View File

@ -112,7 +112,9 @@ object WebsocketUtil extends Logging {
val emitBlockProccessedWhileIBDOnGoing =
chainAppConfig.ibdBlockProcessedEvents
isIBDF.flatMap { isIBD =>
if (isIBD && !emitBlockProccessedWhileIBDOnGoing) {
if (
isIBD && !emitBlockProccessedWhileIBDOnGoing && filterHeaders.nonEmpty
) {
val notifications =
CompactFilterHeaderProcessedNotification(filterHeaders.last)
sendHeadersToWs(Vector(notifications), queue)
@ -130,7 +132,9 @@ object WebsocketUtil extends Logging {
val emitBlockProccessedWhileIBDOnGoing =
chainAppConfig.ibdBlockProcessedEvents
isIBDF.flatMap { isIBD =>
if (isIBD && !emitBlockProccessedWhileIBDOnGoing) {
if (
isIBD && !emitBlockProccessedWhileIBDOnGoing && filters.nonEmpty
) {
val notifications = CompactFilterProcessedNotification(filters.last)
sendHeadersToWs(Vector(notifications), queue)
} else {