build(aggregator): add u256 values protobufs support

Signed-off-by: Joseph Livesey <[email protected]>

Author: suchapalaver

tap_aggregator/build.rs

@@ -9,8 +9,11 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     tonic_build::configure().compile_protos(
         &[
             "proto/uint128.proto",
+            "proto/uint256.proto",
             "proto/tap_aggregator.proto",
+            "proto/tap_aggregator_u256.proto",
             "proto/v2.proto",
+            "proto/v2_u256.proto",
         ],
         &["proto"],
     )?;

tap_aggregator/proto/tap_aggregator_u256.proto

@@ -0,0 +1,43 @@
+// Copyright 2023-, Semiotic AI, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+syntax = "proto3";
+package tap_aggregator.v1_u256;
+
+import "uint256.proto";
+
+message Receipt {
+  bytes allocation_id = 1;
+  uint64 timestamp_ns = 2;
+  uint64 nonce = 3;
+  grpc.uint256.Uint256 value = 4;
+}
+
+message SignedReceipt {
+  Receipt message = 1;
+  bytes signature = 2;
+}
+
+message ReceiptAggregateVoucher {
+  bytes allocation_id = 1;
+  uint64 timestamp_ns = 2;
+  grpc.uint256.Uint256 value_aggregate = 3;
+}
+
+message SignedRav {
+  ReceiptAggregateVoucher message = 1;
+  bytes signature = 2;
+}
+
+message RavRequest {
+  repeated SignedReceipt receipts = 1;
+  optional SignedRav previous_rav = 2;
+}
+
+message RavResponse {
+  SignedRav rav = 1;
+}
+
+service TapAggregator {
+  rpc AggregateReceipts(RavRequest) returns (RavResponse);
+}

tap_aggregator/proto/uint256.proto

@@ -0,0 +1,16 @@
+// Copyright 2023-, Semiotic AI, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+syntax = "proto3";
+package grpc.uint256;
+
+message Uint256 {
+  // Bits 192-255 of a 256 bit number.
+  uint64 word3 = 1;
+  // Bits 128-191 of a 256 bit number.
+  uint64 word2 = 2;
+  // Bits 64-127 of a 256 bit number.
+  uint64 word1 = 3;
+  // Bits 0-63 of a 256 bit number.
+  uint64 word0 = 4;
+}

tap_aggregator/proto/v2_u256.proto

@@ -0,0 +1,50 @@
+// Copyright 2023-, Semiotic AI, Inc.
+// SPDX-License-Identifier: Apache-2.0
+
+syntax = "proto3";
+package tap_aggregator.v2_u256;
+
+import "uint256.proto";
+
+message Receipt {
+  bytes allocation_id = 1;
+  uint64 timestamp_ns = 2;
+  uint64 nonce = 3;
+  grpc.uint256.Uint256 value = 4;
+  bytes payer = 5;
+  bytes data_service = 6;
+  bytes service_provider = 7;
+}
+
+message SignedReceipt {
+  Receipt message = 1;
+  bytes signature = 2;
+}
+
+message ReceiptAggregateVoucher {
+  bytes allocation_id = 1;
+  uint64 timestamp_ns = 2;
+  grpc.uint256.Uint256 value_aggregate = 3;
+  bytes payer = 4;
+  bytes data_service = 5;
+  bytes service_provider = 6;
+  bytes metadata = 7;
+}
+
+message SignedRav {
+  ReceiptAggregateVoucher message = 1;
+  bytes signature = 2;
+}
+
+message RavRequest {
+  repeated SignedReceipt receipts = 1;
+  optional SignedRav previous_rav = 2;
+}
+
+message RavResponse {
+  SignedRav rav = 1;
+}
+
+service TapAggregator {
+  rpc AggregateReceipts(RavRequest) returns (RavResponse);
+}