dips grpc update

Author: mangas

Cargo.lock

@@ -77,6 +77,7 @@ rstest = "0.23.0"
 wiremock = "0.6.1"
 typed-builder = "0.20.0"
 tonic = { version = "0.12.3", features = ["tls-roots", "gzip"] }
-tonic-build = { version = "0.12.3", features = ["prost"] }
-prost = "0.13.3"
+prost = "0.13.4"
 prost-types = "0.13.3"
+dipper-rpc = { git = "https://github.com/edgeandnode/dipper/", rev = "c8700e2", default-features = false }
+tonic-build = "0.12.3"

Cargo.toml

@@ -5,8 +5,17 @@ fn main() {
     println!("cargo:rerun-if-changed=proto");
     tonic_build::configure()
         .out_dir("src/proto")
-        .include_file("mod.rs")
+        .include_file("indexer.rs")
+        .build_client(false)
         .protoc_arg("--experimental_allow_proto3_optional")
-        .compile_protos(&["proto/dips.proto"], &["proto"])
-        .expect("Failed to compile dips proto(s)");
+        .compile_protos(&["proto/indexer.proto"], &["proto/"])
+        .expect("Failed to compile DIPs indexer RPC proto(s)");
+
+    tonic_build::configure()
+        .out_dir("src/proto")
+        .include_file("gateway.rs")
+        .build_server(false)
+        .protoc_arg("--experimental_allow_proto3_optional")
+        .compile_protos(&["proto/gateway.proto"], &["proto"])
+        .expect("Failed to compile DIPs gateway RPC proto(s)");
 }

crates/dips/build.rs

@@ -0,0 +1,66 @@
+syntax = "proto3";
+
+package graphprotocol.gateway.dips;
+
+service DipsService {
+  /**
+   * Cancel an _indexing agreement_.
+   *
+   * This method allows the indexer to notify the DIPs gateway that the agreement
+   * should be canceled.
+   */
+  rpc CancelAgreement(CancelAgreementRequest) returns (CancelAgreementResponse);
+
+  /**
+   * Report the progress of an _indexing agreement_.
+   *
+   * This method allows the indexer to report the work completed to the DIPs gateway
+   * and receive payment for the indexing work done.
+   */
+  rpc ReportProgress(ReportProgressRequest) returns (ReportProgressResponse);
+}
+
+
+/**
+ * A request to cancel an _indexing agreement_.
+ *
+ * See the `DipsService.CancelAgreement` method.
+ */
+message CancelAgreementRequest {
+  bytes agreement_id = 1;  /// The ID of the agreement to cancel.
+  reserved 2 to 20;        /// Reserved for future use.
+
+  bytes signature = 99; /// The signature of the message.
+}
+
+/**
+ * A response to a request to cancel an _indexing agreement_.
+ *
+ * See the `DipsService.CancelAgreement` method.
+ */
+message CancelAgreementResponse {
+  // Empty message
+}
+
+
+/**
+ * A request to report the progress of an _indexing agreement_.
+  *
+  * See the `DipsService.ReportProgress` method.
+ */
+message ReportProgressRequest {
+  bytes agreement_id = 1;  /// The ID of the agreement to report progress for.
+  // TODO(LNSD): Add fields to the message
+
+  bytes signature = 99; /// The signature of the message.
+}
+
+/**
+ * A response to a request to report the progress of an _indexing agreement_.
+ *
+ * See the `DipsService.ReportProgress` method.
+ */
+message ReportProgressResponse {
+  // TODO(LNSD): Add fields to the message
+}
+

crates/dips/proto/dips.proto

@@ -0,0 +1,104 @@
+syntax = "proto3";
+
+package graphprotocol.indexer.dips;
+
+service DipsService {
+  /**
+   * Propose a new _indexing agreement_ to an _indexer_.
+   *
+   * The _indexer_ can `ACCEPT` or `REJECT` the agreement.
+   */
+  rpc SubmitAgreementProposal(SubmitAgreementProposalRequest) returns (SubmitAgreementProposalResponse);
+
+  /**
+   * Request to cancel an existing _indexing agreement_.
+   */
+  rpc CancelAgreement(CancelAgreementRequest) returns (CancelAgreementResponse);
+}
+
+/**
+ * A request to propose a new _indexing agreement_ to an _indexer_.
+ *
+ * See the `DipsService.SubmitAgreementProposal` method.
+ */
+message SubmitAgreementProposalRequest {
+  bytes agreementId = 1; /// The ID of the agreement to register.
+  reserved 2 to 19;      /// Reserved for future use.
+
+  Voucher voucher = 20;    /// The voucher of the agreement.
+
+  bytes signature = 99; /// The signature of the message.
+}
+
+/**
+ * A voucher of an _indexing agreement_.
+ */
+message Voucher {
+  bytes payer = 1;     /// The agreement payer.
+  bytes recipient = 2; /// The voucher recipient address.
+  bytes service = 3;   /// Service address that will initiate the payment collection.
+  reserved 4 to 9;     /// Reserved for future use.
+
+  uint32 durationEpochs = 10; /// The duration of the agreement in epochs.
+  reserved 11 to 19;          /// Reserved for future use.
+
+  bytes maxInitialAmount = 20;         /// The maximum amount, in _wei GRT_, that can be collected for the initial subgraph sync.
+  bytes minOngoingAmountPerEpoch = 21; /// The maximum amount, in _wei GRT_, that can be collected per epoch (after the initial sync).
+  reserved 22 to 29;                   /// Reserved for future use.
+
+  uint32 maxEpochsPerCollection = 30; /// The maximum number of epochs that can be collected at once.
+  uint32 minEpochsPerCollection = 31; /// The minimum number of epochs that can be collected at once.
+  reserved 32 to 39;                  /// Reserved for future use.
+
+  VoucherMetadata metadata = 50; /// The voucher metadata.
+}
+
+
+/**
+ * The indexing agreement voucher metadata.
+ */
+message VoucherMetadata {
+  bytes deploymentId = 1; /// The Subgraph deployment ID to index.
+  reserved 2 to 19;       /// Reserved for future use.
+
+  bytes pricePerBlock = 20;          /// The amount to pay per indexed block in _wei GRT per block_.
+  bytes pricePerEntityPerEpoch = 21; /// The amount to pay per indexed and stored entity in _wei GRT per entity per epoch_.
+}
+
+/**
+ * A response to a request to propose a new _indexing agreement_ to an _indexer_.
+ *
+ * See the `DipsService.SubmitAgreementProposal` method.
+ */
+message SubmitAgreementProposalResponse {
+  ProposalResponse response = 1; /// The response to the agreement proposal.
+}
+
+/**
+ * The response to an _indexing agreement_ proposal.
+ */
+enum ProposalResponse {
+  ACCEPT = 0; /// The agreement proposal was accepted.
+  REJECT = 1; /// The agreement proposal was rejected.
+}
+
+/**
+ * A request to cancel an existing _indexing agreement_.
+ *
+ * See the `DipsService.CancelAgreement` method.
+ */
+message CancelAgreementRequest {
+  bytes agreementId = 1; /// The ID of the agreement to cancel.
+  reserved 2 to 20;      /// Reserved for future use.
+
+  bytes signature = 99; /// The signature of the message.
+}
+
+/**
+ * A response to a request to cancel an existing _indexing agreement_.
+ *
+ * See the `DipsService.CancelAgreement` method.
+ */
+message CancelAgreementResponse {
+  // Empty message
+}

crates/dips/proto/gateway.proto

@@ -0,0 +1,8 @@
+// This file is @generated by prost-build.
+pub mod graphprotocol {
+    pub mod gateway {
+        pub mod dips {
+            include!("graphprotocol.gateway.dips.rs");
+        }
+    }
+}