issue-19/entity-tx: base impl. (#34)

Solves #19

Makefile

@@ -21,7 +21,7 @@ fix-clj: cljfmt kibit
 fix-rs: rsfmt clippy
 
 proto:
-	protoc --clojure_out=grpc-client,grpc-server:src --proto_path=resources resources/transactions.proto resources/service.proto
+	protoc --clojure_out=grpc-client,grpc-server:src --proto_path=resources resources/common.proto resources/transactions.proto resources/entity.proto resources/service.proto
 
 all: proto fix
 

gxtdb-rs/tests/mock.rs

@@ -21,6 +21,13 @@ impl GrpcApi for ServerMock {
     ) -> Result<tonic::Response<proto_api::SubmitResponse>, tonic::Status> {
         todo!()
     }
+
+    async fn entity_tx(
+        &self,
+        _request: tonic::Request<proto_api::EntityTxRequest>,
+    ) -> Result<tonic::Response<proto_api::EntityTxResponse>, tonic::Status> {
+        todo!()
+    }
 }
 
 pub async fn client() -> gxtdb_rs::Client {

kreya/grpc/com/xtdb/protos/GrpcApi/EntityTx-request.json

@@ -0,0 +1,14 @@
+{
+  "idType": "Keyword",
+  "entityId": "id1",
+  "openSnapshot": false,
+  "txId": {
+    "none": {}
+  },
+  "validTime": {
+    "none": {}
+  },
+  "txTime": {
+    "none": {}
+  }
+}

kreya/grpc/com/xtdb/protos/GrpcApi/EntityTx.krop

@@ -0,0 +1,12 @@
+{
+  "details": {
+    "methodFqn": "com.xtdb.protos.GrpcApi.EntityTx"
+  },
+  "requests": [
+    {
+      "location": "EntityTx-request.json"
+    }
+  ],
+  "operationType": "unary",
+  "invokerName": "grpc"
+}

kreya/grpc/com/xtdb/protos/GrpcApi/SubmitTx-request.json

@@ -7,8 +7,5 @@
         "document": {"key": "value"}
       }
     }
-  ],
-  "txTime": {
-    "some": "2023-06-12T21:32:44.717-05:00"
-  }
+  ]
 }

resources/common.proto

@@ -2,8 +2,22 @@ syntax = "proto3";
 
 package com.xtdb.protos;
 
+enum IdType {
+  Uuid = 0;
+  Keyword = 1;
+  String = 2;
+  Int = 3;
+}
+
 message Empty {}
 
+message OptionInt64 {
+  oneof value {
+    Empty none = 1;
+    int64 some = 2;
+  }
+}
+
 message OptionString {
     oneof value {
       Empty none = 1;

resources/entity.proto

@@ -0,0 +1,21 @@
+syntax = "proto3";
+
+package com.xtdb.protos;
+import "common.proto";
+
+message EntityTxResponse {
+    string xt_id = 1;
+    string content_hash = 2;
+    string valid_time = 3;
+    string tx_time = 4;
+    int64 tx_id = 5;
+}
+
+message EntityTxRequest {
+    IdType id_type = 1;
+    string entity_id = 2;
+    bool open_snapshot = 3;
+    OptionInt64 tx_id = 4;
+    OptionDatetime valid_time = 5;
+    OptionDatetime tx_time = 6;
+}

resources/service.proto

@@ -3,6 +3,7 @@ syntax = "proto3";
 package com.xtdb.protos;
 
 import "transactions.proto";
+import "entity.proto";
 import "common.proto";
 
 
@@ -20,4 +21,6 @@ service GrpcApi {
   rpc Status(Empty) returns (StatusResponse);
   rpc SubmitTx(com.xtdb.protos.SubmitRequest)
       returns (com.xtdb.protos.SubmitResponse);
+  rpc EntityTx(com.xtdb.protos.EntityTxRequest)
+      returns (com.xtdb.protos.EntityTxResponse);
 }

resources/transactions.proto

@@ -13,15 +13,6 @@ message Transaction {
   }
 }
 
-enum IdType {
-  Uuid = 0;
-  Keyword = 1;
-  String = 2;
-  Int = 3;
-}
-
-
-
 message Put {
   IdType id_type = 1;
   string xt_id = 2;