First cut at additional serde tests (#75)

* First cut at additional serde tests

* Add JSON test

* Add protobuf ref test

* Add format params

* Checkpoint

* Add coverage to gitignore

* Remove coverage

* Minor fix

* Minor fix

* Avro ref test

* Add json ref test

* Add nested tests

Author: rayokota

.gitignore

@@ -15,3 +15,4 @@ deps/*
 
 .idea
 .vscode
+coverage

jest.config.js

@@ -3,4 +3,3 @@ module.exports = {
       '^.+\\.tsx?$': 'ts-jest',
     },
   };
-  

proto/test/schemaregistry/serde/cycle.proto

@@ -0,0 +1,9 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+message LinkedList {
+  int32 value = 1;
+  LinkedList next = 10;
+}

proto/test/schemaregistry/serde/dep.proto

@@ -0,0 +1,11 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+import "test/schemaregistry/serde/test.proto";
+
+message DependencyMessage {
+    bool is_active = 1;
+    TestMessage test_messsage = 2;
+}

proto/test/schemaregistry/serde/example.proto

@@ -0,0 +1,22 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+import "confluent/meta.proto";
+
+message Author {
+  string name = 1 [
+    (confluent.field_meta).tags = "PII"
+  ];
+  int32 id = 2;
+  bytes picture = 3 [
+    (confluent.field_meta).tags = "PII"
+  ];
+  repeated string works = 4;
+}
+
+message Pizza {
+  string size = 1;
+  repeated string toppings = 2;
+}

proto/test/schemaregistry/serde/nested.proto

@@ -0,0 +1,59 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+import "google/protobuf/timestamp.proto";
+
+message UserId {
+    oneof user_id {
+        string kafka_user_id = 1;
+        int32 other_user_id = 2;
+        MessageId another_id = 3;
+    }
+}
+
+message MessageId {
+    string id = 1;
+}
+
+enum Status {
+    ACTIVE = 0;
+    INACTIVE = 1;
+}
+
+message ComplexType {
+    oneof some_val {
+        string one_id = 1;
+        int32 other_id = 2;
+    }
+    bool is_active = 3;
+}
+
+/*
+ * Complex message using nested protos and repeated fields
+ */
+message NestedMessage {
+    UserId user_id = 1;
+    bool is_active = 2;
+    repeated string experiments_active = 3;
+    google.protobuf.Timestamp updated_at = 4;
+    Status status = 5;
+    ComplexType complex_type = 6;
+    map<string, string> map_type = 7;
+    InnerMessage inner = 8;
+
+    message InnerMessage {
+        string id = 1 [json_name="id"];
+        repeated int32 ids = 2 [packed=true];
+    }
+
+    enum InnerEnum {
+        option allow_alias = true;
+        ZERO = 0;
+        ALSO_ZERO = 0;
+    }
+
+    reserved 14, 15, 9 to 11;
+    reserved "foo", "bar";
+}

proto/test/schemaregistry/serde/newerwidget.proto

@@ -0,0 +1,10 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+message NewerWidget {
+    string name = 1;
+    int32 length = 2;
+    int32 version = 3;
+}

proto/test/schemaregistry/serde/newwidget.proto

@@ -0,0 +1,10 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+message NewWidget {
+    string name = 1;
+    int32 height = 2;
+    int32 version = 3;
+}

proto/test/schemaregistry/serde/test.proto

@@ -0,0 +1,24 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+import "google/protobuf/descriptor.proto";
+
+message TestMessage {
+    string test_string = 1;
+    bool test_bool = 2;
+    bytes test_bytes = 3;
+    double test_double = 4;
+    float test_float = 5;
+    fixed32 test_fixed32 = 6;
+    fixed64 test_fixed64 = 7;
+    int32 test_int32 = 8;
+    int64 test_int64 = 9;
+    sfixed32 test_sfixed32 = 10;
+    sfixed64 test_sfixed64 = 11;
+    sint32 test_sint32 = 12;
+    sint64 test_sint64 = 13;
+    uint32 test_uint32 = 14;
+    uint64 test_uint64 = 15;
+}

proto/test/schemaregistry/serde/widget.proto

@@ -0,0 +1,10 @@
+syntax = "proto3";
+
+package test;
+option go_package="../test";
+
+message Widget {
+    string name = 1;
+    int32 size = 2;
+    int32 version = 3;
+}