working server with grpc + http

Author: Patrick Koss

server/api/server.openapi.yaml

@@ -112,7 +112,7 @@ paths:
                   in: path
                   required: true
                   schema:
-                    $ref: '#/components/schemas/GoogleProtobufAny'
+                    $ref: '#/components/schemas/GoogleProtobufValue'
             responses:
                 "200":
                     description: OK
@@ -163,14 +163,6 @@ components:
             properties:
                 keyValue:
                     $ref: '#/components/schemas/KeyValue'
-        GoogleProtobufAny:
-            type: object
-            properties:
-                '@type':
-                    type: string
-                    description: The type of the serialized message.
-            additionalProperties: true
-            description: Contains an arbitrary serialized message along with a @type that describes the type of the serialized message.
         GoogleProtobufValue:
             description: Represents a dynamically typed value which can be either null, a number, a string, a boolean, a recursive struct value, or a list of values.
         KeyValue:
@@ -180,9 +172,9 @@ components:
             type: object
             properties:
                 key:
-                    $ref: '#/components/schemas/GoogleProtobufAny'
+                    $ref: '#/components/schemas/GoogleProtobufValue'
                 value:
-                    $ref: '#/components/schemas/GoogleProtobufAny'
+                    $ref: '#/components/schemas/GoogleProtobufValue'
         UpdateResponse:
             required:
                 - keyValue

server/envoy.yaml

@@ -22,7 +22,7 @@ static_resources:
                       routes:
                         # NOTE: by default, matching happens based on the gRPC route, and not on the incoming request path.
                         # Reference: https://envoyproxy.io/docs/envoy/latest/configuration/http/http_filters/grpc_json_transcoder_filter#route-configs-for-transcoded-requests
-                        - match: {prefix: "/server-envoy.KeyValueService"}
+                        - match: {prefix: "/server.KeyValueService"}
                           route: {cluster: grpc, timeout: 60s}
                 http_filters:
                   - name: envoy.filters.http.grpc_json_transcoder

server/proto/server-envoy.pb

@@ -60,13 +60,13 @@ option (gnostic.openapi.v3.document) = {
 };
 
 message KeyValue {
-  google.protobuf.Any key = 1 [
+  google.protobuf.Value key = 1 [
     (google.api.field_behavior) = REQUIRED,
     (validate.rules).any = {
       required: true,
     }
   ];
-  google.protobuf.Any value = 2 [
+  google.protobuf.Value value = 2 [
     (google.api.field_behavior) = REQUIRED,
     (validate.rules).any = {
       required: true,
@@ -87,7 +87,7 @@ message CreateRequest {
 }
 
 message DeleteRequest {
-  google.protobuf.Any key = 1 [
+  google.protobuf.Value key = 1 [
     (google.api.field_behavior) = REQUIRED
   ];
 }

server/proto/server.pb.go

@@ -25,8 +25,18 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     println!("RESPONSE={:?}", response);
 
     let key_value = response.into_inner().key_value.unwrap();
-    println!("KEY={:?}", String::from_utf8_lossy(&key_value.key.unwrap().value));
-    println!("VALUE={:?}", String::from_utf8_lossy(&key_value.value.unwrap().value));
+
+    let key = match key_value.key.unwrap().kind {
+        Some(Kind::StringValue(s)) => s,
+        _ => String::from(""),
+    };
+    println!("VALUE={:?}", &key);
+
+    let value = match key_value.value.unwrap().kind {
+        Some(Kind::StringValue(s)) => s,
+        _ => String::from(""),
+    };
+    println!("VALUE={:?}", &value);
 
     Ok(())
 }

server/proto/server.proto

@@ -2,8 +2,9 @@ use tonic::{Request, Response, Status, transport::Server};
 
 use key_value_store::{DeleteRequest, DeleteResponse, GetRequest, GetResponse, KeyValue, CreateRequest, CreateResponse, UpdateRequest, UpdateResponse};
 use key_value_store::key_value_service_server::{KeyValueService, KeyValueServiceServer};
-use prost_types::Any;
+use prost_types::Value;
 use std::string::String;
+use prost_types::value::Kind;
 
 pub mod key_value_store {
     tonic::include_proto!("server");
@@ -16,28 +17,42 @@ pub struct KeyValueStoreImpl {}
 impl KeyValueService for KeyValueStoreImpl {
     async fn get(&self, request: Request<GetRequest>) -> Result<Response<GetResponse>, Status> {
         println!("Got a request: {:?}", request);
-        let key = Any {
-            type_url: "type_url".to_string(),
-            value: String::from("key").into_bytes(),
+        let key = Value {
+            kind: Some(Kind::StringValue("key".to_string())),
         };
 
-        let value = Any {
-            type_url: "type_url".to_string(),
-            value: String::from("value").into_bytes(),
+        let value = Value {
+            kind: Some(Kind::StringValue("value".to_string())),
         };
 
         let reply = GetResponse {
             key_value: Option::from(KeyValue {
-                key: Some(key),
-                value: Some(value),
+                key: key.into(),
+                value: value.into(),
             })
         };
 
         Ok(Response::new(reply))
     }
 
     async fn create(&self, _request: Request<CreateRequest>) -> Result<Response<CreateResponse>, Status> {
-        todo!()
+        println!("Got a request: {:?}", _request);
+        let key = Value {
+            kind: Some(Kind::StringValue("key".to_string())),
+        };
+
+        let value = Value {
+            kind: Some(Kind::StringValue("value".to_string())),
+        };
+
+        let reply = CreateResponse {
+            key_value: Option::from(KeyValue {
+                key: key.into(),
+                value: value.into(),
+            })
+        };
+
+        Ok(Response::new(reply))
     }
 
     async fn update(&self, _request: Request<UpdateRequest>) -> Result<Response<UpdateResponse>, Status> {