done generating mobx query stores in rpc queries

hoangdv2429 · Feb 22, 2023 · 5706f11 · 5706f11
1 parent 43994aa
commit 5706f11
Show file tree

Hide file tree

Showing 85 changed files with 7,839 additions and 227 deletions.
diff --git a/__fixtures__/output1/akash/audit/v1beta2/query.rpc.Query.ts b/__fixtures__/output1/akash/audit/v1beta2/query.rpc.Query.ts
@@ -5,6 +5,8 @@ import * as _m0 from "protobufjs/minimal";
 import { QueryClient, createProtobufRpcClient, ProtobufRpcClient } from "@cosmjs/stargate";
 import { ReactQueryParams } from "../../../react-query";
 import { useQuery } from "@tanstack/react-query";
+import { QueryStore, MobxResponse } from "../../../mobx";
+import { makeObservable, override } from "mobx";
 import { QueryAllProvidersAttributesRequest, QueryAllProvidersAttributesRequestSDKType, QueryProvidersResponse, QueryProvidersResponseSDKType, QueryProviderAttributesRequest, QueryProviderAttributesRequestSDKType, QueryProviderAuditorRequest, QueryProviderAuditorRequestSDKType, QueryAuditorAttributesRequest, QueryAuditorAttributesRequestSDKType } from "./query";
 
 /** Query defines the gRPC querier service */
@@ -205,4 +207,117 @@ export const createRpcQueryHooks = (rpc: ProtobufRpcClient | undefined) => {
      */
     useAuditorAttributes
   };
+};
+export const createRpcQueryStores = (rpc: ProtobufRpcClient | undefined) => {
+  const queryService = getQueryService(rpc);
+
+  class QueryAllProvidersAttributesStore extends QueryStore<QueryAllProvidersAttributesRequest, QueryProvidersResponse> {
+    constructor() {
+      super(queryService?.allProvidersAttributes);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    allProvidersAttributes(request?: QueryAllProvidersAttributesRequest): MobxResponse<QueryProvidersResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryProviderAttributesStore extends QueryStore<QueryProviderAttributesRequest, QueryProvidersResponse> {
+    constructor() {
+      super(queryService?.providerAttributes);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    providerAttributes(request: QueryProviderAttributesRequest): MobxResponse<QueryProvidersResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryProviderAuditorAttributesStore extends QueryStore<QueryProviderAuditorRequest, QueryProvidersResponse> {
+    constructor() {
+      super(queryService?.providerAuditorAttributes);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    providerAuditorAttributes(request: QueryProviderAuditorRequest): MobxResponse<QueryProvidersResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryAuditorAttributesStore extends QueryStore<QueryAuditorAttributesRequest, QueryProvidersResponse> {
+    constructor() {
+      super(queryService?.auditorAttributes);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    auditorAttributes(request: QueryAuditorAttributesRequest): MobxResponse<QueryProvidersResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  return {
+    /**
+     * AllProvidersAttributes queries all providers
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     */
+    QueryAllProvidersAttributesStore,
+
+    /**
+     * ProviderAttributes queries all provider signed attributes
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     */
+    QueryProviderAttributesStore,
+
+    /**
+     * ProviderAuditorAttributes queries provider signed attributes by specific auditor
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     */
+    QueryProviderAuditorAttributesStore,
+
+    /**
+     * AuditorAttributes queries all providers signed by this auditor
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     */
+    QueryAuditorAttributesStore
+  };
 };
diff --git a/__fixtures__/output1/akash/cert/v1beta2/query.rpc.Query.ts b/__fixtures__/output1/akash/cert/v1beta2/query.rpc.Query.ts
@@ -5,6 +5,8 @@ import * as _m0 from "protobufjs/minimal";
 import { QueryClient, createProtobufRpcClient, ProtobufRpcClient } from "@cosmjs/stargate";
 import { ReactQueryParams } from "../../../react-query";
 import { useQuery } from "@tanstack/react-query";
+import { QueryStore, MobxResponse } from "../../../mobx";
+import { makeObservable, override } from "mobx";
 import { QueryCertificatesRequest, QueryCertificatesRequestSDKType, QueryCertificatesResponse, QueryCertificatesResponseSDKType } from "./query";
 
 /** Query defines the gRPC querier service */
@@ -73,4 +75,32 @@ export const createRpcQueryHooks = (rpc: ProtobufRpcClient | undefined) => {
     /** Certificates queries certificates */
     useCertificates
   };
+};
+export const createRpcQueryStores = (rpc: ProtobufRpcClient | undefined) => {
+  const queryService = getQueryService(rpc);
+
+  class QueryCertificatesStore extends QueryStore<QueryCertificatesRequest, QueryCertificatesResponse> {
+    constructor() {
+      super(queryService?.certificates);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    certificates(request: QueryCertificatesRequest): MobxResponse<QueryCertificatesResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  return {
+    /** Certificates queries certificates */
+    QueryCertificatesStore
+  };
 };
diff --git a/__fixtures__/output1/akash/deployment/v1beta2/query.rpc.Query.ts b/__fixtures__/output1/akash/deployment/v1beta2/query.rpc.Query.ts
@@ -8,6 +8,8 @@ import * as _m0 from "protobufjs/minimal";
 import { QueryClient, createProtobufRpcClient, ProtobufRpcClient } from "@cosmjs/stargate";
 import { ReactQueryParams } from "../../../react-query";
 import { useQuery } from "@tanstack/react-query";
+import { QueryStore, MobxResponse } from "../../../mobx";
+import { makeObservable, override } from "mobx";
 import { QueryDeploymentsRequest, QueryDeploymentsRequestSDKType, QueryDeploymentsResponse, QueryDeploymentsResponseSDKType, QueryDeploymentRequest, QueryDeploymentRequestSDKType, QueryDeploymentResponse, QueryDeploymentResponseSDKType, QueryGroupRequest, QueryGroupRequestSDKType, QueryGroupResponse, QueryGroupResponseSDKType } from "./query";
 
 /** Query defines the gRPC querier service */
@@ -136,4 +138,78 @@ export const createRpcQueryHooks = (rpc: ProtobufRpcClient | undefined) => {
     /** Group queries group details */
     useGroup
   };
+};
+export const createRpcQueryStores = (rpc: ProtobufRpcClient | undefined) => {
+  const queryService = getQueryService(rpc);
+
+  class QueryDeploymentsStore extends QueryStore<QueryDeploymentsRequest, QueryDeploymentsResponse> {
+    constructor() {
+      super(queryService?.deployments);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    deployments(request: QueryDeploymentsRequest): MobxResponse<QueryDeploymentsResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryDeploymentStore extends QueryStore<QueryDeploymentRequest, QueryDeploymentResponse> {
+    constructor() {
+      super(queryService?.deployment);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    deployment(request: QueryDeploymentRequest): MobxResponse<QueryDeploymentResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryGroupStore extends QueryStore<QueryGroupRequest, QueryGroupResponse> {
+    constructor() {
+      super(queryService?.group);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    group(request: QueryGroupRequest): MobxResponse<QueryGroupResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  return {
+    /** Deployments queries deployments */
+    QueryDeploymentsStore,
+
+    /** Deployment queries deployment details */
+    QueryDeploymentStore,
+
+    /** Group queries group details */
+    QueryGroupStore
+  };
 };
diff --git a/__fixtures__/output1/akash/escrow/v1beta1/query.rpc.Query.ts b/__fixtures__/output1/akash/escrow/v1beta1/query.rpc.Query.ts
@@ -5,6 +5,8 @@ import * as _m0 from "protobufjs/minimal";
 import { QueryClient, createProtobufRpcClient, ProtobufRpcClient } from "@cosmjs/stargate";
 import { ReactQueryParams } from "../../../react-query";
 import { useQuery } from "@tanstack/react-query";
+import { QueryStore, MobxResponse } from "../../../mobx";
+import { makeObservable, override } from "mobx";
 import { QueryAccountsRequest, QueryAccountsRequestSDKType, QueryAccountsResponse, QueryAccountsResponseSDKType, QueryPaymentsRequest, QueryPaymentsRequestSDKType, QueryPaymentsResponse, QueryPaymentsResponseSDKType } from "./query";
 
 /** Query defines the gRPC querier service */
@@ -123,4 +125,63 @@ export const createRpcQueryHooks = (rpc: ProtobufRpcClient | undefined) => {
      */
     usePayments
   };
+};
+export const createRpcQueryStores = (rpc: ProtobufRpcClient | undefined) => {
+  const queryService = getQueryService(rpc);
+
+  class QueryAccountsStore extends QueryStore<QueryAccountsRequest, QueryAccountsResponse> {
+    constructor() {
+      super(queryService?.accounts);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    accounts(request: QueryAccountsRequest): MobxResponse<QueryAccountsResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  class QueryPaymentsStore extends QueryStore<QueryPaymentsRequest, QueryPaymentsResponse> {
+    constructor() {
+      super(queryService?.payments);
+      makeObservable(this, {
+        state: override,
+        request: override,
+        response: override,
+        isLoading: override,
+        isSuccess: override,
+        refetch: override,
+        getData: override
+      });
+    }
+
+    payments(request: QueryPaymentsRequest): MobxResponse<QueryPaymentsResponse> {
+      return this.getData(request);
+    }
+
+  }
+
+  return {
+    /**
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     * Accounts queries all accounts
+     */
+    QueryAccountsStore,
+
+    /**
+     * buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
+     * buf:lint:ignore RPC_RESPONSE_STANDARD_NAME
+     * Payments queries all payments
+     */
+    QueryPaymentsStore
+  };
 };