🍱 add proto assets

Author: sanshengshui

groza-dao/pom.xml

@@ -18,14 +18,15 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
     <parent>
         <artifactId>groza</artifactId>
         <groupId>iot.technology</groupId>
         <version>1.0-SNAPSHOT</version>
     </parent>
-    <modelVersion>4.0.0</modelVersion>
 
     <artifactId>groza-dao</artifactId>
+    <name>Groza :: Server :: Dao</name>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

groza-transport-api/pom.xml

@@ -10,6 +10,7 @@
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>groza-transport-api</artifactId>
+    <name>Groza :: Server :: Transport :: Api</name>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>

groza-transport-api/src/main/proto/queue.proto

@@ -0,0 +1,42 @@
+syntax = "proto3";
+
+package transport;
+
+option java_package = "iot.technology.server.gen.transport";
+option java_outer_classname = "TransportProtos";
+
+enum KeyValueType {
+    BOOLEAN_V = 0;
+    LONG_V = 1;
+    DOUBLE_V = 2;
+    STRING_V = 3;
+    JSON_V = 4;
+}
+
+message  KeyValueProto {
+    string key = 1;
+    KeyValueType type = 2;
+    bool bool_v = 3;
+    int64 long_v = 4;
+    double double_v = 5;
+    string string_v = 6;
+    string json_v = 7;
+}
+
+message TsKvProto {
+    int64 ts = 1;
+    KeyValueProto kv = 2;
+}
+
+message TsKvListProto {
+    int64 ts = 1;
+    repeated KeyValueProto kv = 2;
+}
+
+message PostTelemetryMsg {
+    repeated TsKvListProto tsKvList = 1;
+}
+
+message PostAttributeMsg {
+    repeated KeyValueProto kv = 1;
+}

groza-transport-api/src/main/proto/transport.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+package transportapi;
+
+option java_package = "iot.technology.server.gen.transport";
+option java_outer_classname = "TransportApiProtos";
+
+import "queue.proto";
+
+message TelemetryMsg {
+  string deviceName = 1;
+  transport.PostTelemetryMsg msg = 2;
+}

pom.xml

@@ -59,7 +59,7 @@
         <commons-lang3.version>3.4</commons-lang3.version>
         <gson.version>2.6.2</gson.version>
         <protobuf.version>3.11.4</protobuf.version>
-        <grpc.version>1.22.1</grpc.version>
+        <grpc.version>1.42.1</grpc.version>
         <mysql.version>8.0.16</mysql.version>
         <postgresql.driver.version>9.4.1211</postgresql.driver.version>
         <cassandra.version>3.5.0</cassandra.version>
@@ -441,7 +441,7 @@
                     -->
                     <protocArtifact>com.google.protobuf:protoc:${protobuf.version}:exe:${os.detected.classifier}</protocArtifact>
                     <pluginId>grpc-java</pluginId>
-                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:1.0.0:exe:${os.detected.classifier}</pluginArtifact>
+                    <pluginArtifact>io.grpc:protoc-gen-grpc-java:${grpc.version}:exe:${os.detected.classifier}</pluginArtifact>
                 </configuration>
                 <executions>
                     <execution>