-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Piercetrey figure/sc 253074/update to blockapi #54
Piercetrey figure/sc 253074/update to blockapi #54
Conversation
piercetrey-figure
commented
Aug 16, 2023
•
edited
Loading
edited
- Using blockapi for the event listening instead of the event stream
- Updated to Java 17
This pull request has been linked to Shortcut Story #253074: Update object store gateway to use blockapi. |
server/src/main/kotlin/tech/figure/objectstore/gateway/components/BlockStreamConsumer.kt
Show resolved
Hide resolved
).collect { block -> | ||
val lastProcessedHeight = blockHeightRepository.getLastProcessedBlockHeight() | ||
|
||
block.blockResult.block.transactionsList.flatMap { it.eventsList } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
took me a while to figure out that block.blockResult.transactions.transactions.transactionsList was an empty red herring 🤦
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yea, there's a branch out there to nix that out that's about 8 months old.
going to adjust this to be pluggable between event stream and blockapi since this is public and might need to be more flexible |
server/src/main/kotlin/tech/figure/objectstore/gateway/components/BlockStreamConsumer.kt
Outdated
Show resolved
Hide resolved
server/src/main/kotlin/tech/figure/objectstore/gateway/components/BlockStreamConsumer.kt
Show resolved
Hide resolved
server/src/main/kotlin/tech/figure/objectstore/gateway/components/BlockStreamConsumer.kt
Show resolved
Hide resolved
server/src/main/kotlin/tech/figure/objectstore/gateway/configuration/BlockStreamConfig.kt
Show resolved
Hide resolved
2bf2761