tested tx implement

__fixtures__/misc/output-impl-interfaces-gen/types.ts

@@ -137,14 +137,14 @@ export interface TxRpc {
   ): Promise<DeliverTxResponse>;
 }
 
-export interface BroadcastTxRequest<T> {
+export interface BroadcastTxReq<T> {
   signerAddress: string;
-  message?: T;
+  message: T;
   fee: number | StdFee | "auto";
   memo: string;
 }
 
-export interface BroadcastTxResponse<T> {
+export interface BroadcastTxRes<T> {
   txResponse: DeliverTxResponse;
   response?: T;
 }

__fixtures__/v-next/outputinstantrpc/akash/audit/v1beta1/audit.rpc.msg.ts

@@ -1,21 +1,21 @@
 import { Attribute, AttributeSDKType } from "../../base/v1beta1/attribute";
-import { BroadcastTxRequest, BroadcastTxResponse, TxRpc } from "../../../types";
+import { BroadcastTxReq, BroadcastTxRes, TxRpc } from "../../../types";
 import { BinaryReader } from "../../../binary";
 import { MsgSignProviderAttributes, MsgSignProviderAttributesSDKType, MsgSignProviderAttributesResponse, MsgSignProviderAttributesResponseSDKType, MsgDeleteProviderAttributes, MsgDeleteProviderAttributesSDKType, MsgDeleteProviderAttributesResponse, MsgDeleteProviderAttributesResponseSDKType } from "./audit";
 /** Msg defines the provider Msg service */
 export interface Msg {
   /** SignProviderAttributes defines a method that signs provider attributes */
-  signProviderAttributes(request: BroadcastTxRequest<MsgSignProviderAttributes>): Promise<BroadcastTxResponse<MsgSignProviderAttributesResponse>>;
+  signProviderAttributes(request: BroadcastTxReq<MsgSignProviderAttributes>): Promise<BroadcastTxRes<MsgSignProviderAttributesResponse>>;
   /** DeleteProviderAttributes defines a method that deletes provider attributes */
-  deleteProviderAttributes(request: BroadcastTxRequest<MsgDeleteProviderAttributes>): Promise<BroadcastTxResponse<MsgDeleteProviderAttributesResponse>>;
+  deleteProviderAttributes(request: BroadcastTxReq<MsgDeleteProviderAttributes>): Promise<BroadcastTxRes<MsgDeleteProviderAttributesResponse>>;
 }
 export class MsgClientImpl implements Msg {
   private readonly rpc: TxRpc;
   constructor(rpc: TxRpc) {
     this.rpc = rpc;
   }
   /* SignProviderAttributes defines a method that signs provider attributes */
-  signProviderAttributes = async (request: BroadcastTxRequest<MsgSignProviderAttributes>): Promise<BroadcastTxResponse<MsgSignProviderAttributesResponse>> => {
+  signProviderAttributes = async (request: BroadcastTxReq<MsgSignProviderAttributes>): Promise<BroadcastTxRes<MsgSignProviderAttributesResponse>> => {
     const data = [{
       typeUrl: MsgSignProviderAttributes.typeUrl,
       value: request.message
@@ -27,7 +27,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* DeleteProviderAttributes defines a method that deletes provider attributes */
-  deleteProviderAttributes = async (request: BroadcastTxRequest<MsgDeleteProviderAttributes>): Promise<BroadcastTxResponse<MsgDeleteProviderAttributesResponse>> => {
+  deleteProviderAttributes = async (request: BroadcastTxReq<MsgDeleteProviderAttributes>): Promise<BroadcastTxRes<MsgDeleteProviderAttributesResponse>> => {
     const data = [{
       typeUrl: MsgDeleteProviderAttributes.typeUrl,
       value: request.message

__fixtures__/v-next/outputinstantrpc/akash/audit/v1beta2/audit.rpc.msg.ts

@@ -1,21 +1,21 @@
 import { Attribute, AttributeSDKType } from "../../base/v1beta2/attribute";
-import { BroadcastTxRequest, BroadcastTxResponse, TxRpc } from "../../../types";
+import { BroadcastTxReq, BroadcastTxRes, TxRpc } from "../../../types";
 import { BinaryReader } from "../../../binary";
 import { MsgSignProviderAttributes, MsgSignProviderAttributesSDKType, MsgSignProviderAttributesResponse, MsgSignProviderAttributesResponseSDKType, MsgDeleteProviderAttributes, MsgDeleteProviderAttributesSDKType, MsgDeleteProviderAttributesResponse, MsgDeleteProviderAttributesResponseSDKType } from "./audit";
 /** Msg defines the provider Msg service */
 export interface Msg {
   /** SignProviderAttributes defines a method that signs provider attributes */
-  signProviderAttributes(request: BroadcastTxRequest<MsgSignProviderAttributes>): Promise<BroadcastTxResponse<MsgSignProviderAttributesResponse>>;
+  signProviderAttributes(request: BroadcastTxReq<MsgSignProviderAttributes>): Promise<BroadcastTxRes<MsgSignProviderAttributesResponse>>;
   /** DeleteProviderAttributes defines a method that deletes provider attributes */
-  deleteProviderAttributes(request: BroadcastTxRequest<MsgDeleteProviderAttributes>): Promise<BroadcastTxResponse<MsgDeleteProviderAttributesResponse>>;
+  deleteProviderAttributes(request: BroadcastTxReq<MsgDeleteProviderAttributes>): Promise<BroadcastTxRes<MsgDeleteProviderAttributesResponse>>;
 }
 export class MsgClientImpl implements Msg {
   private readonly rpc: TxRpc;
   constructor(rpc: TxRpc) {
     this.rpc = rpc;
   }
   /* SignProviderAttributes defines a method that signs provider attributes */
-  signProviderAttributes = async (request: BroadcastTxRequest<MsgSignProviderAttributes>): Promise<BroadcastTxResponse<MsgSignProviderAttributesResponse>> => {
+  signProviderAttributes = async (request: BroadcastTxReq<MsgSignProviderAttributes>): Promise<BroadcastTxRes<MsgSignProviderAttributesResponse>> => {
     const data = [{
       typeUrl: MsgSignProviderAttributes.typeUrl,
       value: request.message
@@ -27,7 +27,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* DeleteProviderAttributes defines a method that deletes provider attributes */
-  deleteProviderAttributes = async (request: BroadcastTxRequest<MsgDeleteProviderAttributes>): Promise<BroadcastTxResponse<MsgDeleteProviderAttributesResponse>> => {
+  deleteProviderAttributes = async (request: BroadcastTxReq<MsgDeleteProviderAttributes>): Promise<BroadcastTxRes<MsgDeleteProviderAttributesResponse>> => {
     const data = [{
       typeUrl: MsgDeleteProviderAttributes.typeUrl,
       value: request.message

__fixtures__/v-next/outputinstantrpc/akash/audit/v1beta2/query.rpc.Query.ts

@@ -70,6 +70,6 @@ export class QueryClientImpl implements Query {
     return promise.then(data => QueryProvidersResponse.decode(new BinaryReader(data)));
   };
 }
-export const createClientImpl = (rpc: Rpc) => {
+export const createClientImpl = (rpc: TxRpc) => {
   return new QueryClientImpl(rpc);
 };

__fixtures__/v-next/outputinstantrpc/akash/cert/v1beta2/cert.rpc.msg.ts

@@ -1,20 +1,20 @@
-import { BroadcastTxRequest, BroadcastTxResponse, TxRpc } from "../../../types";
+import { BroadcastTxReq, BroadcastTxRes, TxRpc } from "../../../types";
 import { BinaryReader } from "../../../binary";
 import { MsgCreateCertificate, MsgCreateCertificateSDKType, MsgCreateCertificateResponse, MsgCreateCertificateResponseSDKType, MsgRevokeCertificate, MsgRevokeCertificateSDKType, MsgRevokeCertificateResponse, MsgRevokeCertificateResponseSDKType } from "./cert";
 /** Msg defines the provider Msg service */
 export interface Msg {
   /** CreateCertificate defines a method to create new certificate given proper inputs. */
-  createCertificate(request: BroadcastTxRequest<MsgCreateCertificate>): Promise<BroadcastTxResponse<MsgCreateCertificateResponse>>;
+  createCertificate(request: BroadcastTxReq<MsgCreateCertificate>): Promise<BroadcastTxRes<MsgCreateCertificateResponse>>;
   /** RevokeCertificate defines a method to revoke the certificate */
-  revokeCertificate(request: BroadcastTxRequest<MsgRevokeCertificate>): Promise<BroadcastTxResponse<MsgRevokeCertificateResponse>>;
+  revokeCertificate(request: BroadcastTxReq<MsgRevokeCertificate>): Promise<BroadcastTxRes<MsgRevokeCertificateResponse>>;
 }
 export class MsgClientImpl implements Msg {
   private readonly rpc: TxRpc;
   constructor(rpc: TxRpc) {
     this.rpc = rpc;
   }
   /* CreateCertificate defines a method to create new certificate given proper inputs. */
-  createCertificate = async (request: BroadcastTxRequest<MsgCreateCertificate>): Promise<BroadcastTxResponse<MsgCreateCertificateResponse>> => {
+  createCertificate = async (request: BroadcastTxReq<MsgCreateCertificate>): Promise<BroadcastTxRes<MsgCreateCertificateResponse>> => {
     const data = [{
       typeUrl: MsgCreateCertificate.typeUrl,
       value: request.message
@@ -26,7 +26,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* RevokeCertificate defines a method to revoke the certificate */
-  revokeCertificate = async (request: BroadcastTxRequest<MsgRevokeCertificate>): Promise<BroadcastTxResponse<MsgRevokeCertificateResponse>> => {
+  revokeCertificate = async (request: BroadcastTxReq<MsgRevokeCertificate>): Promise<BroadcastTxRes<MsgRevokeCertificateResponse>> => {
     const data = [{
       typeUrl: MsgRevokeCertificate.typeUrl,
       value: request.message

__fixtures__/v-next/outputinstantrpc/akash/cert/v1beta2/query.rpc.Query.ts

@@ -25,7 +25,7 @@ export class QueryClientImpl implements Query {
     return promise.then(data => QueryCertificatesResponse.decode(new BinaryReader(data)));
   };
 }
-export const createClientImpl = (rpc: Rpc) => {
+export const createClientImpl = (rpc: TxRpc) => {
   return new QueryClientImpl(rpc);
 };
 export interface UseCertificatesQuery<TData> extends ReactQueryParams<QueryCertificatesResponse, TData> {

__fixtures__/v-next/outputinstantrpc/akash/deployment/v1beta1/deployment.ts

@@ -4,7 +4,7 @@ import { GroupSpec, GroupSpecSDKType, GroupID, GroupIDSDKType } from "./group";
 import { Coin, CoinSDKType } from "../../../cosmos/base/v1beta1/coin";
 import { BinaryReader, BinaryWriter } from "../../../binary";
 import { isSet, bytesFromBase64, base64FromBytes, Exact } from "../../../helpers";
-import { BroadcastTxRequest, BroadcastTxResponse, TxRpc } from "../../../types";
+import { BroadcastTxReq, BroadcastTxRes, TxRpc } from "../../../types";
 export const protobufPackage = "akash.deployment.v1beta1";
 /** State is an enum which refers to state of deployment */
 export enum Deployment_State {
@@ -1350,27 +1350,27 @@ export const DeploymentFilters = {
 /** Msg defines the deployment Msg service. */
 export interface Msg {
   /** CreateDeployment defines a method to create new deployment given proper inputs. */
-  createDeployment(request: BroadcastTxRequest<MsgCreateDeployment>): Promise<BroadcastTxResponse<MsgCreateDeploymentResponse>>;
+  createDeployment(request: BroadcastTxReq<MsgCreateDeployment>): Promise<BroadcastTxRes<MsgCreateDeploymentResponse>>;
   /** DepositDeployment deposits more funds into the deployment account */
-  depositDeployment(request: BroadcastTxRequest<MsgDepositDeployment>): Promise<BroadcastTxResponse<MsgDepositDeploymentResponse>>;
+  depositDeployment(request: BroadcastTxReq<MsgDepositDeployment>): Promise<BroadcastTxRes<MsgDepositDeploymentResponse>>;
   /** UpdateDeployment defines a method to update a deployment given proper inputs. */
-  updateDeployment(request: BroadcastTxRequest<MsgUpdateDeployment>): Promise<BroadcastTxResponse<MsgUpdateDeploymentResponse>>;
+  updateDeployment(request: BroadcastTxReq<MsgUpdateDeployment>): Promise<BroadcastTxRes<MsgUpdateDeploymentResponse>>;
   /** CloseDeployment defines a method to close a deployment given proper inputs. */
-  closeDeployment(request: BroadcastTxRequest<MsgCloseDeployment>): Promise<BroadcastTxResponse<MsgCloseDeploymentResponse>>;
+  closeDeployment(request: BroadcastTxReq<MsgCloseDeployment>): Promise<BroadcastTxRes<MsgCloseDeploymentResponse>>;
   /** CloseGroup defines a method to close a group of a deployment given proper inputs. */
-  closeGroup(request: BroadcastTxRequest<MsgCloseGroup>): Promise<BroadcastTxResponse<MsgCloseGroupResponse>>;
+  closeGroup(request: BroadcastTxReq<MsgCloseGroup>): Promise<BroadcastTxRes<MsgCloseGroupResponse>>;
   /** PauseGroup defines a method to close a group of a deployment given proper inputs. */
-  pauseGroup(request: BroadcastTxRequest<MsgPauseGroup>): Promise<BroadcastTxResponse<MsgPauseGroupResponse>>;
+  pauseGroup(request: BroadcastTxReq<MsgPauseGroup>): Promise<BroadcastTxRes<MsgPauseGroupResponse>>;
   /** StartGroup defines a method to close a group of a deployment given proper inputs. */
-  startGroup(request: BroadcastTxRequest<MsgStartGroup>): Promise<BroadcastTxResponse<MsgStartGroupResponse>>;
+  startGroup(request: BroadcastTxReq<MsgStartGroup>): Promise<BroadcastTxRes<MsgStartGroupResponse>>;
 }
 export class MsgClientImpl implements Msg {
   private readonly rpc: TxRpc;
   constructor(rpc: TxRpc) {
     this.rpc = rpc;
   }
   /* CreateDeployment defines a method to create new deployment given proper inputs. */
-  createDeployment = async (request: BroadcastTxRequest<MsgCreateDeployment>): Promise<BroadcastTxResponse<MsgCreateDeploymentResponse>> => {
+  createDeployment = async (request: BroadcastTxReq<MsgCreateDeployment>): Promise<BroadcastTxRes<MsgCreateDeploymentResponse>> => {
     const data = [{
       typeUrl: MsgCreateDeployment.typeUrl,
       value: request.message
@@ -1382,7 +1382,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* DepositDeployment deposits more funds into the deployment account */
-  depositDeployment = async (request: BroadcastTxRequest<MsgDepositDeployment>): Promise<BroadcastTxResponse<MsgDepositDeploymentResponse>> => {
+  depositDeployment = async (request: BroadcastTxReq<MsgDepositDeployment>): Promise<BroadcastTxRes<MsgDepositDeploymentResponse>> => {
     const data = [{
       typeUrl: MsgDepositDeployment.typeUrl,
       value: request.message
@@ -1394,7 +1394,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* UpdateDeployment defines a method to update a deployment given proper inputs. */
-  updateDeployment = async (request: BroadcastTxRequest<MsgUpdateDeployment>): Promise<BroadcastTxResponse<MsgUpdateDeploymentResponse>> => {
+  updateDeployment = async (request: BroadcastTxReq<MsgUpdateDeployment>): Promise<BroadcastTxRes<MsgUpdateDeploymentResponse>> => {
     const data = [{
       typeUrl: MsgUpdateDeployment.typeUrl,
       value: request.message
@@ -1406,7 +1406,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* CloseDeployment defines a method to close a deployment given proper inputs. */
-  closeDeployment = async (request: BroadcastTxRequest<MsgCloseDeployment>): Promise<BroadcastTxResponse<MsgCloseDeploymentResponse>> => {
+  closeDeployment = async (request: BroadcastTxReq<MsgCloseDeployment>): Promise<BroadcastTxRes<MsgCloseDeploymentResponse>> => {
     const data = [{
       typeUrl: MsgCloseDeployment.typeUrl,
       value: request.message
@@ -1418,7 +1418,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* CloseGroup defines a method to close a group of a deployment given proper inputs. */
-  closeGroup = async (request: BroadcastTxRequest<MsgCloseGroup>): Promise<BroadcastTxResponse<MsgCloseGroupResponse>> => {
+  closeGroup = async (request: BroadcastTxReq<MsgCloseGroup>): Promise<BroadcastTxRes<MsgCloseGroupResponse>> => {
     const data = [{
       typeUrl: MsgCloseGroup.typeUrl,
       value: request.message
@@ -1430,7 +1430,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* PauseGroup defines a method to close a group of a deployment given proper inputs. */
-  pauseGroup = async (request: BroadcastTxRequest<MsgPauseGroup>): Promise<BroadcastTxResponse<MsgPauseGroupResponse>> => {
+  pauseGroup = async (request: BroadcastTxReq<MsgPauseGroup>): Promise<BroadcastTxRes<MsgPauseGroupResponse>> => {
     const data = [{
       typeUrl: MsgPauseGroup.typeUrl,
       value: request.message
@@ -1442,7 +1442,7 @@ export class MsgClientImpl implements Msg {
     }));
   };
   /* StartGroup defines a method to close a group of a deployment given proper inputs. */
-  startGroup = async (request: BroadcastTxRequest<MsgStartGroup>): Promise<BroadcastTxResponse<MsgStartGroupResponse>> => {
+  startGroup = async (request: BroadcastTxReq<MsgStartGroup>): Promise<BroadcastTxRes<MsgStartGroupResponse>> => {
     const data = [{
       typeUrl: MsgStartGroup.typeUrl,
       value: request.message

__fixtures__/v-next/outputinstantrpc/akash/deployment/v1beta1/query.ts

@@ -771,6 +771,6 @@ export class QueryClientImpl implements Query {
     return promise.then(data => QueryGroupResponse.decode(new BinaryReader(data)));
   };
 }
-export const createClientImpl = (rpc: Rpc) => {
+export const createClientImpl = (rpc: TxRpc) => {
   return new QueryClientImpl(rpc);
 };

__fixtures__/v-next/outputinstantrpc/akash/deployment/v1beta2/query.rpc.Query.ts

@@ -39,6 +39,6 @@ export class QueryClientImpl implements Query {
     return promise.then(data => QueryGroupResponse.decode(new BinaryReader(data)));
   };
 }
-export const createClientImpl = (rpc: Rpc) => {
+export const createClientImpl = (rpc: TxRpc) => {
   return new QueryClientImpl(rpc);
 };