feat(2720): add validations on input types

src/core/blueprint/from_config.rs

@@ -71,11 +71,12 @@ pub fn to_json_schema_for_field(field: &Field, config: &Config) -> JsonSchema {
     to_json_schema(field, config)
 }
 pub fn to_json_schema_for_args(args: &BTreeMap<String, Arg>, config: &Config) -> JsonSchema {
-    let mut schema_fields = BTreeMap::new();
-    for (name, arg) in args.iter() {
-        schema_fields.insert(name.clone(), to_json_schema(arg, config));
+    if let Some(arg) = args.values().next() {
+        // gRPC can only support one input message, so we check for only one argument
+        // compatibility
+        return to_json_schema(arg, config);
     }
-    JsonSchema::Obj(schema_fields)
+    JsonSchema::Empty
 }
 fn to_json_schema<T>(field: &T, config: &Config) -> JsonSchema
 where

src/core/blueprint/operators/grpc.rs

@@ -70,17 +70,18 @@ fn validate_schema(
 ) -> Valid<(), String> {
     let input_type = &operation.input_type;
     let output_type = &operation.output_type;
-
     Valid::from(JsonSchema::try_from(input_type))
         .zip(Valid::from(JsonSchema::try_from(output_type)))
-        .and_then(|(_input_schema, sub_type)| {
-            // TODO: add validation for input schema - should compare result grpc.body to
-            // schema
+        .and_then(|(sub_args, sub_type)| {
             let super_type = field_schema.field;
+            let super_args = field_schema.args;
+
             // TODO: all of the fields in protobuf are optional actually
             // and if we want to mark some fields as required in GraphQL
             // JsonSchema won't match and the validation will fail
-            sub_type.is_a(&super_type, name)
+            sub_type
+                .is_a(&super_type, name)
+                .and(super_args.is_a(&sub_args, name))
         })
 }