Collapsing 3 commits together.

Signed-off-by: a-saksena <[email protected]>

Author: a-saksena

.gitignore

@@ -47,5 +47,7 @@ gradle-app.setting
 # JDT-specific (Eclipse Java Development Tools)
 .classpath
 
+.idea
+.DS_Store
 # .env files
 server/docker/.env

protos/src/main/protobuf/blockstream.proto

@@ -46,6 +46,8 @@ service BlockStreamGrpc {
      * message with the id of each block received.
      */
     rpc StreamSource(stream BlockResponse) returns (stream Block) {}
+
+    rpc GetBlock(Block) returns (Block) {}
 }
 
 /**

server/src/main/java/com/hedera/block/server/BlockStreamService.java

@@ -27,6 +27,8 @@
 
 import java.time.Clock;
 
+import static io.helidon.webserver.grpc.ResponseHelper.complete;
+
 import static com.hedera.block.server.Constants.*;
 
 /**
@@ -87,6 +89,7 @@ public String serviceName() {
     public void update(final Routing routing) {
         routing.bidi(CLIENT_STREAMING_METHOD_NAME, this::streamSink);
         routing.bidi(SERVER_STREAMING_METHOD_NAME, this::streamSource);
+        routing.unary("GetBlock", this::getBlock);
     }
 
     /**
@@ -129,6 +132,13 @@ private StreamObserver<BlockStreamServiceGrpcProto.BlockResponse> streamSource(f
 
         return streamObserver;
     }
+
+    private void getBlock(BlockStreamServiceGrpcProto.BlockRequest request, StreamObserver<BlockStreamServiceGrpcProto.Block> responseObserver) {
+        String message = "GET BLOCK RESPONSE! ";
+        LOGGER.log(System.Logger.Level.INFO, "GetBlock request received");
+        BlockStreamServiceGrpcProto.Block response = BlockStreamServiceGrpcProto.Block.newBuilder().setValue(message).build();
+        complete(responseObserver, response);
+    }
 }
 
 

server/src/main/java/com/hedera/block/server/Server.java

@@ -26,7 +26,6 @@
 import io.helidon.config.Config;
 import io.helidon.webserver.WebServer;
 import io.helidon.webserver.grpc.GrpcRouting;
-import io.helidon.webserver.http.HttpRouting;
 
 import java.io.IOException;
 import java.util.stream.Stream;
@@ -79,13 +78,18 @@ public static void main(final String[] args) {
                             .bidi(BlockStreamServiceGrpcProto.getDescriptor(),
                                     SERVICE_NAME,
                                     SERVER_STREAMING_METHOD_NAME,
-                                    serverBidiStreamingMethod))
+                                    serverBidiStreamingMethod)
+                            .unary(BlockStreamServiceGrpcProto.getDescriptor(),
+                            "BlockStreamGrpc",
+                            "GetBlock",
+                            Server::grpcGetBlock))
                     .build()
                     .start();
-
         } catch (IOException e) {
             LOGGER.log(System.Logger.Level.ERROR, "An exception was thrown starting the server", e);
             throw new RuntimeException(e);
         }
     }
+
+    static void grpcGetBlock(BlockStreamServiceGrpcProto.BlockRequest request, StreamObserver<BlockStreamServiceGrpcProto.Block> responseObserver) {}
 }