streaming is working

Signed-off-by: Matt Peterson <[email protected]>

Author: mattp-swirldslabs

consumer.sh

@@ -1,11 +1,29 @@
 #!/bin/bash
 
 echo "Starting consumer..."
-starting_block=$1
 
-payload="{\"id\": $starting_block}"
+# Set the gRPC server address and method
+GRPC_SERVER="localhost:8080"
+GRPC_METHOD="BlockStreamGrpc/StreamSource"
 
-grpcurl -vv -plaintext -proto ./protos/src/main/protobuf/blockstream.proto -d "$payload" localhost:8080 BlockStreamGrpc/StreamSource
+# Function to handle received messages and send replies
+handle_streaming() {
+  while read -r line; do
+    id=$(echo "$line" | jq -r '.id')
+    if [[ $id != "null" ]]; then
+      echo "{\"id\": $id}"
+    fi
+  done
+}
 
-echo "Finished"
+# Trap SIGINT to clean up
+trap "echo 'Received SIGINT, stopping...'; exit 0" SIGINT
 
+payload="{\"id\": 0}"
+
+#grpcurl -vv -plaintext -proto ./protos/src/main/protobuf/blockstream.proto -d "$payload" localhost:8080 BlockStreamGrpc/StreamSource
+
+# Initiate the bidirectional streaming connection
+grpcurl -vv -plaintext -proto ./protos/src/main/protobuf/blockstream.proto -d "$payload" $GRPC_SERVER $GRPC_METHOD
+#{} # Initial empty request if needed
+EOF | handle_streaming | grpcurl -plaintext -d @ $GRPC_SERVER $GRPC_METHOD --format json

server/src/main/java/com/hedera/block/server/observe/mediate/StreamMediatorImpl.java

@@ -54,7 +54,7 @@ public void onNext(BlockStreamServiceGrpcProto.Block block) {
         }
 
         // Persist the block
-        blockPersistenceHandler.persist(block);
+//        blockPersistenceHandler.persist(block);
     }
 
     @Override