Protocol Buffers definition and registry synchronization with Cosmos

src/cosmos/index.ts

@@ -12,50 +12,32 @@ import {
 import { Hex, hexToBytes } from "viem";
 
 import {
+  MsgCreatePendingClaim,
+  MsgCreatePendingClaimResponse,
   MsgCreateRequestForFunds,
   MsgCreateRequestForFundsResponse,
-  MsgCreateSolverData,
-  MsgCreateSolverDataResponse,
-  MsgDoubleCheckTx,
-  MsgRefundReq,
-  MsgRefundReqResponse,
-  MsgUpdateSolverData,
 } from "../proto/definition";
 import { Bytes } from "../types";
 
 export const Registry = new CosmosRegistry(defaultRegistryTypes);
 
 {
   Registry.register(
-    "/xarchain.chainabstraction.MsgCreateSolverData",
-    MsgCreateSolverData,
-  );
-  Registry.register(
-    "/xarchain.chainabstraction.MsgCreateSolverDataResponse",
-    MsgCreateSolverDataResponse,
-  );
-  Registry.register(
-    "/xarchain.chainabstraction.MsgUpdateSolverData",
-    MsgUpdateSolverData,
-  );
-  Registry.register(
-    "/xarchain.chainabstraction.MsgUpdateSolverDataResponse",
-    MsgCreateSolverDataResponse,
-  );
-  Registry.register(
-    "/xarchain.chainabstraction.MsgCreateRequestForFunds",
+    "/xarchain.chainabstraction.v1.MsgCreateRequestForFunds",
     MsgCreateRequestForFunds,
   );
   Registry.register(
-    "/xarchain.chainabstraction.MsgCreateRequestForFundsResponse",
+    "/xarchain.chainabstraction.v1.MsgCreateRequestForFundsResponse",
     MsgCreateRequestForFundsResponse,
   );
-  Registry.register("/xarchain.chainabstraction.MsgRefundReq", MsgRefundReq);
   Registry.register(
-    "/xarchain.chainabstraction.MsgRefundReqResponse",
-    MsgRefundReqResponse,
+    "/xarchain.chainabstraction.v1.MsgCreatePendingClaim",
+    MsgCreatePendingClaim,
+  );
+  Registry.register(
+    "/xarchain.chainabstraction.v1.MsgCreatePendingClaimResponse",
+    MsgCreatePendingClaimResponse,
   );
-  Registry.register("/xarchain.chainabstraction.MsgDoubleCheckTx", MsgDoubleCheckTx);
 }
 
 export function createCosmosWallet(

src/index.ts

@@ -5,7 +5,7 @@ export {
   Query,
   GrpcWebError,
   GrpcWebImpl,
-} from "./proto/grpc";
+} from "./proto/cosmos";
 export { createGrpcWebImpl } from "./proto/client";
 export * from "./data";
 export * from "./vaultcontracts";

src/proto/client.ts

@@ -1,4 +1,4 @@
-import { GrpcWebImpl } from "./grpc";
+import { GrpcWebImpl } from "./cosmos";
 
 export const createGrpcWebImpl = async (url: string) => {
   const options: ConstructorParameters<typeof GrpcWebImpl>[1] = {};

src/proto/cosmos.proto

@@ -0,0 +1,49 @@
+syntax = "proto3";
+import "definition.proto";
+package xarchain.chainabstraction.v1;
+
+service Query {
+  // ListRequestForFunds Queries a list of RequestForFunds items.
+  rpc GetRequestForFunds(QueryGetRequestForFundsRequest) returns (QueryGetRequestForFundsResponse) {
+  }
+
+  // ListRequestForFunds defines the ListRequestForFunds RPC.
+  rpc ListRequestForFunds(QueryAllRequestForFundsRequest) returns (QueryAllRequestForFundsResponse) {
+  }
+
+  // ListPendingClaims Queries a list of PendingClaims items.
+  rpc GetPendingClaims(QueryGetPendingClaimsRequest) returns (QueryGetPendingClaimsResponse) {
+  }
+
+  // ListPendingClaims defines the ListPendingClaims RPC.
+  rpc ListPendingClaims(QueryAllPendingClaimsRequest) returns (QueryAllPendingClaimsResponse) {
+  }
+
+  // ListPendingSettlements Queries a list of PendingSettlements items.
+  rpc GetPendingSettlements(QueryGetPendingSettlementsRequest) returns (QueryGetPendingSettlementsResponse) {
+  }
+
+  // ListPendingSettlements defines the ListPendingSettlements RPC.
+  rpc ListPendingSettlements(QueryAllPendingSettlementsRequest) returns (QueryAllPendingSettlementsResponse) {
+  }
+
+  // Queries a ProtocolFees by index.
+  rpc GetProtocolFees(QueryGetProtocolFeesRequest) returns (QueryGetProtocolFeesResponse) {
+  }
+
+  // ListSolverData Queries a list of SolverData items.
+  rpc GetSolverData(QueryGetSolverDataRequest) returns (QueryGetSolverDataResponse) {
+  }
+
+  // ListSolverData defines the ListSolverData RPC.
+  rpc ListSolverData(QueryAllSolverDataRequest) returns (QueryAllSolverDataResponse) {
+  }
+
+  // ListSettlement Queries a list of Settlement items.
+  rpc GetSettlement(QueryGetSettlementRequest) returns (QueryGetSettlementResponse) {
+  }
+
+  // ListSettlement defines the ListSettlement RPC.
+  rpc ListSettlement(QueryAllSettlementRequest) returns (QueryAllSettlementResponse) {
+  }
+}