hashgraph / hedera-block-node

New Block Node services
Apache License 2.0
23 stars 3 forks source link

feat: WIP Implement consumer handler in the Simulator #360

Open georgi-l95 opened 3 days ago

georgi-l95 commented 3 days ago

Description: TBD

Related issue(s):

Fixes #121

Notes for reviewer:

Checklist

codecov[bot] commented 21 hours ago

Codecov Report

Attention: Patch coverage is 64.77273% with 31 lines in your changes missing coverage. Please review.

Project coverage is 92.68%. Comparing base (ad18213) to head (a8b4589).

Files with missing lines Patch % Lines
...ulator/grpc/impl/ConsumerStreamGrpcClientImpl.java 0.00% 30 Missing :warning:
...edera/block/simulator/BlockStreamSimulatorApp.java 90.00% 0 Missing and 1 partial :warning:
Additional details and impacted files ```diff @@ Coverage Diff @@ ## main #360 +/- ## ============================================ - Coverage 94.62% 92.68% -1.95% - Complexity 316 327 +11 ============================================ Files 69 71 +2 Lines 1228 1298 +70 Branches 84 85 +1 ============================================ + Hits 1162 1203 +41 - Misses 55 84 +29 Partials 11 11 ``` | [Files with missing lines](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?dropdown=coverage&src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph) | Coverage Δ | | |---|---|---| | [...dera/block/simulator/grpc/GrpcInjectionModule.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fgrpc%2FGrpcInjectionModule.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvZ3JwYy9HcnBjSW5qZWN0aW9uTW9kdWxlLmphdmE=) | `0.00% <ø> (ø)` | | | [...ck/simulator/grpc/impl/ConsumerStreamObserver.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fgrpc%2Fimpl%2FConsumerStreamObserver.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvZ3JwYy9pbXBsL0NvbnN1bWVyU3RyZWFtT2JzZXJ2ZXIuamF2YQ==) | `100.00% <100.00%> (ø)` | | | [...mulator/grpc/impl/PublishStreamGrpcClientImpl.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fgrpc%2Fimpl%2FPublishStreamGrpcClientImpl.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvZ3JwYy9pbXBsL1B1Ymxpc2hTdHJlYW1HcnBjQ2xpZW50SW1wbC5qYXZh) | `96.07% <100.00%> (ø)` | | | [...ock/simulator/grpc/impl/PublishStreamObserver.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fgrpc%2Fimpl%2FPublishStreamObserver.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvZ3JwYy9pbXBsL1B1Ymxpc2hTdHJlYW1PYnNlcnZlci5qYXZh) | `100.00% <100.00%> (ø)` | | | [.../block/simulator/metrics/SimulatorMetricTypes.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fmetrics%2FSimulatorMetricTypes.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvbWV0cmljcy9TaW11bGF0b3JNZXRyaWNUeXBlcy5qYXZh) | `100.00% <100.00%> (ø)` | | | [...dera/block/simulator/mode/CombinedModeHandler.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fmode%2FCombinedModeHandler.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvbW9kZS9Db21iaW5lZE1vZGVIYW5kbGVyLmphdmE=) | `100.00% <100.00%> (ø)` | | | [...dera/block/simulator/mode/ConsumerModeHandler.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fmode%2FConsumerModeHandler.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvbW9kZS9Db25zdW1lck1vZGVIYW5kbGVyLmphdmE=) | `100.00% <100.00%> (ø)` | | | [...era/block/simulator/mode/PublisherModeHandler.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fmode%2FPublisherModeHandler.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvbW9kZS9QdWJsaXNoZXJNb2RlSGFuZGxlci5qYXZh) | `100.00% <100.00%> (ø)` | | | [...edera/block/simulator/BlockStreamSimulatorApp.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2FBlockStreamSimulatorApp.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvQmxvY2tTdHJlYW1TaW11bGF0b3JBcHAuamF2YQ==) | `96.96% <90.00%> (+3.21%)` | :arrow_up: | | [...ulator/grpc/impl/ConsumerStreamGrpcClientImpl.java](https://app.codecov.io/gh/hashgraph/hedera-block-node/pull/360?src=pr&el=tree&filepath=simulator%2Fsrc%2Fmain%2Fjava%2Fcom%2Fhedera%2Fblock%2Fsimulator%2Fgrpc%2Fimpl%2FConsumerStreamGrpcClientImpl.java&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=hashgraph#diff-c2ltdWxhdG9yL3NyYy9tYWluL2phdmEvY29tL2hlZGVyYS9ibG9jay9zaW11bGF0b3IvZ3JwYy9pbXBsL0NvbnN1bWVyU3RyZWFtR3JwY0NsaWVudEltcGwuamF2YQ==) | `0.00% <0.00%> (ø)` | |

🚨 Try these New Features: