multiclient setup3 removing legacy

common/proto/tables_data.proto

@@ -136,6 +136,9 @@ message PostTableDataResponse {
 
   // Rows whose stored script values changed through dependency propagation.
   repeated RecomputedRow recomputed_rows = 4;
+
+  // Revision committed for the inserted row.
+  int64 row_revision = 5;
 }
 
 // One row in a bulk insert request.
@@ -190,6 +193,9 @@ message PutTableDataRequest {
   //
   // Passing an empty map results in a no-op success response.
   map<string, google.protobuf.Value> data = 4;
+
+  // Required. Revision returned when this row was loaded or last saved.
+  int64 expected_revision = 5;
 }
 
 // Update response.
@@ -205,6 +211,9 @@ message PutTableDataResponse {
 
   // Rows whose stored script values changed through dependency propagation.
   repeated RecomputedRow recomputed_rows = 4;
+
+  // Revision committed for the updated row.
+  int64 row_revision = 5;
 }
 
 message RecomputedRow {
@@ -223,6 +232,9 @@ message DeleteTableDataRequest {
 
   // Required. Row id to soft-delete.
   int64 record_id = 3;
+
+  // Required. Revision returned when this row was loaded or last saved.
+  int64 expected_revision = 4;
 }
 
 // Soft-delete response.

common/src/grpc_error.rs

@@ -1,6 +1,4 @@
 pub const ERROR_REASON_METADATA_KEY: &str = "komp-ac-error-reason";
-pub const EXPECTED_ROW_REVISION_METADATA_KEY: &str = "komp-ac-expected-row-revision";
-pub const ROW_REVISION_METADATA_KEY: &str = "komp-ac-row-revision";
 pub const COMPUTED_VALUE_MISMATCH_REASON: &str = "computed-value-mismatch";
 pub const ROW_STALE_REASON: &str = "row-stale";
 pub const ROW_ID_CONFLICT_REASON: &str = "row-id-conflict";

common/src/proto/komp_ac.tables_data.rs

@@ -61,6 +61,9 @@ pub struct PostTableDataResponse {
     /// Rows whose stored script values changed through dependency propagation.
     #[prost(message, repeated, tag = "4")]
     pub recomputed_rows: ::prost::alloc::vec::Vec<RecomputedRow>,
+    /// Revision committed for the inserted row.
+    #[prost(int64, tag = "5")]
+    pub row_revision: i64,
 }
 /// One row in a bulk insert request.
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -126,6 +129,9 @@ pub struct PutTableDataRequest {
         ::prost::alloc::string::String,
         ::prost_types::Value,
     >,
+    /// Required. Revision returned when this row was loaded or last saved.
+    #[prost(int64, tag = "5")]
+    pub expected_revision: i64,
 }
 /// Update response.
 #[derive(Clone, PartialEq, ::prost::Message)]
@@ -142,6 +148,9 @@ pub struct PutTableDataResponse {
     /// Rows whose stored script values changed through dependency propagation.
     #[prost(message, repeated, tag = "4")]
     pub recomputed_rows: ::prost::alloc::vec::Vec<RecomputedRow>,
+    /// Revision committed for the updated row.
+    #[prost(int64, tag = "5")]
+    pub row_revision: i64,
 }
 #[derive(Clone, PartialEq, Eq, Hash, ::prost::Message)]
 pub struct RecomputedRow {
@@ -164,6 +173,9 @@ pub struct DeleteTableDataRequest {
     /// Required. Row id to soft-delete.
     #[prost(int64, tag = "3")]
     pub record_id: i64,
+    /// Required. Revision returned when this row was loaded or last saved.
+    #[prost(int64, tag = "4")]
+    pub expected_revision: i64,
 }
 /// Soft-delete response.
 #[derive(Clone, PartialEq, ::prost::Message)]