Skip to content

Scoped import objects for RPC and LCD objects #156

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 20 commits into from
Jul 29, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
36 changes: 36 additions & 0 deletions __fixtures__/output1/akash/audit/v1beta1/audit.rpc.msg.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
import { Attribute } from "../../base/v1beta1/attribute";
import { Rpc } from "@osmonauts/helpers";
import * as _m0 from "protobufjs/minimal";
import { MsgSignProviderAttributes, MsgSignProviderAttributesResponse, MsgDeleteProviderAttributes, MsgDeleteProviderAttributesResponse } from "./audit";

/** Msg defines the RPC service */
export interface Msg {
signProviderAttributes(request: MsgSignProviderAttributes): Promise<MsgSignProviderAttributesResponse>;
/*SignProviderAttributes defines a method that signs provider attributes*/

deleteProviderAttributes(request: MsgDeleteProviderAttributes): Promise<MsgDeleteProviderAttributesResponse>;
/*DeleteProviderAttributes defines a method that deletes provider attributes*/

}
export class MsgClientImpl implements Msg {
private readonly rpc: Rpc;

constructor(rpc: Rpc) {
this.rpc = rpc;
this.signProviderAttributes = this.signProviderAttributes.bind(this);
this.deleteProviderAttributes = this.deleteProviderAttributes.bind(this);
}

signProviderAttributes(request: MsgSignProviderAttributes): Promise<MsgSignProviderAttributesResponse> {
const data = MsgSignProviderAttributes.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta1.Msg", "SignProviderAttributes", data);
return promise.then(data => MsgSignProviderAttributesResponse.decode(new _m0.Reader(data)));
}

deleteProviderAttributes(request: MsgDeleteProviderAttributes): Promise<MsgDeleteProviderAttributesResponse> {
const data = MsgDeleteProviderAttributes.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta1.Msg", "DeleteProviderAttributes", data);
return promise.then(data => MsgDeleteProviderAttributesResponse.decode(new _m0.Reader(data)));
}

}
36 changes: 36 additions & 0 deletions __fixtures__/output1/akash/audit/v1beta2/audit.rpc.msg.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,36 @@
import { Attribute } from "../../base/v1beta2/attribute";
import { Rpc } from "@osmonauts/helpers";
import * as _m0 from "protobufjs/minimal";
import { MsgSignProviderAttributes, MsgSignProviderAttributesResponse, MsgDeleteProviderAttributes, MsgDeleteProviderAttributesResponse } from "./audit";

/** Msg defines the RPC service */
export interface Msg {
signProviderAttributes(request: MsgSignProviderAttributes): Promise<MsgSignProviderAttributesResponse>;
/*SignProviderAttributes defines a method that signs provider attributes*/

deleteProviderAttributes(request: MsgDeleteProviderAttributes): Promise<MsgDeleteProviderAttributesResponse>;
/*DeleteProviderAttributes defines a method that deletes provider attributes*/

}
export class MsgClientImpl implements Msg {
private readonly rpc: Rpc;

constructor(rpc: Rpc) {
this.rpc = rpc;
this.signProviderAttributes = this.signProviderAttributes.bind(this);
this.deleteProviderAttributes = this.deleteProviderAttributes.bind(this);
}

signProviderAttributes(request: MsgSignProviderAttributes): Promise<MsgSignProviderAttributesResponse> {
const data = MsgSignProviderAttributes.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Msg", "SignProviderAttributes", data);
return promise.then(data => MsgSignProviderAttributesResponse.decode(new _m0.Reader(data)));
}

deleteProviderAttributes(request: MsgDeleteProviderAttributes): Promise<MsgDeleteProviderAttributesResponse> {
const data = MsgDeleteProviderAttributes.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Msg", "DeleteProviderAttributes", data);
return promise.then(data => MsgDeleteProviderAttributesResponse.decode(new _m0.Reader(data)));
}

}
65 changes: 65 additions & 0 deletions __fixtures__/output1/akash/audit/v1beta2/query.rpc.query.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,65 @@
import { PageRequest, PageResponse } from "../../../cosmos/base/query/v1beta1/pagination";
import { Provider } from "./audit";
import { Rpc } from "@osmonauts/helpers";
import * as _m0 from "protobufjs/minimal";
import { QueryAllProvidersAttributesRequest, QueryProvidersResponse, QueryProviderAttributesRequest, QueryProviderAuditorRequest, QueryAuditorAttributesRequest } from "./query";

/** Query defines the RPC service */
export interface Query {
allProvidersAttributes(request: QueryAllProvidersAttributesRequest): Promise<QueryProvidersResponse>;
/*AllProvidersAttributes queries all providers
buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
buf:lint:ignore RPC_RESPONSE_STANDARD_NAME*/

providerAttributes(request: QueryProviderAttributesRequest): Promise<QueryProvidersResponse>;
/*ProviderAttributes queries all provider signed attributes
buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
buf:lint:ignore RPC_RESPONSE_STANDARD_NAME*/

providerAuditorAttributes(request: QueryProviderAuditorRequest): Promise<QueryProvidersResponse>;
/*ProviderAuditorAttributes queries provider signed attributes by specific auditor
buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
buf:lint:ignore RPC_RESPONSE_STANDARD_NAME*/

auditorAttributes(request: QueryAuditorAttributesRequest): Promise<QueryProvidersResponse>;
/*AuditorAttributes queries all providers signed by this auditor
buf:lint:ignore RPC_REQUEST_RESPONSE_UNIQUE
buf:lint:ignore RPC_RESPONSE_STANDARD_NAME*/

}
export class QueryClientImpl implements Query {
private readonly rpc: Rpc;

constructor(rpc: Rpc) {
this.rpc = rpc;
this.allProvidersAttributes = this.allProvidersAttributes.bind(this);
this.providerAttributes = this.providerAttributes.bind(this);
this.providerAuditorAttributes = this.providerAuditorAttributes.bind(this);
this.auditorAttributes = this.auditorAttributes.bind(this);
}

allProvidersAttributes(request: QueryAllProvidersAttributesRequest): Promise<QueryProvidersResponse> {
const data = QueryAllProvidersAttributesRequest.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Query", "AllProvidersAttributes", data);
return promise.then(data => QueryProvidersResponse.decode(new _m0.Reader(data)));
}

providerAttributes(request: QueryProviderAttributesRequest): Promise<QueryProvidersResponse> {
const data = QueryProviderAttributesRequest.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Query", "ProviderAttributes", data);
return promise.then(data => QueryProvidersResponse.decode(new _m0.Reader(data)));
}

providerAuditorAttributes(request: QueryProviderAuditorRequest): Promise<QueryProvidersResponse> {
const data = QueryProviderAuditorRequest.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Query", "ProviderAuditorAttributes", data);
return promise.then(data => QueryProvidersResponse.decode(new _m0.Reader(data)));
}

auditorAttributes(request: QueryAuditorAttributesRequest): Promise<QueryProvidersResponse> {
const data = QueryAuditorAttributesRequest.encode(request).finish();
const promise = this.rpc.request("akash.audit.v1beta2.Query", "AuditorAttributes", data);
return promise.then(data => QueryProvidersResponse.decode(new _m0.Reader(data)));
}

}
61 changes: 50 additions & 11 deletions __fixtures__/output1/akash/bundle.ts
Original file line number Diff line number Diff line change
Expand Up @@ -75,18 +75,40 @@ import * as _339 from "./escrow/v1beta1/query.lcd";
import * as _340 from "./escrow/v1beta2/query.lcd";
import * as _341 from "./market/v1beta2/query.lcd";
import * as _342 from "./provider/v1beta2/query.lcd";
import * as _343 from "./audit/v1beta2/query.rpc.query";
import * as _344 from "./cert/v1beta2/query.rpc.query";
import * as _345 from "./deployment/v1beta1/query.rpc.query";
import * as _346 from "./deployment/v1beta2/query.rpc.query";
import * as _347 from "./escrow/v1beta1/query.rpc.query";
import * as _348 from "./escrow/v1beta2/query.rpc.query";
import * as _349 from "./market/v1beta2/query.rpc.query";
import * as _350 from "./provider/v1beta2/query.rpc.query";
import * as _351 from "./audit/v1beta1/audit.rpc.msg";
import * as _352 from "./audit/v1beta2/audit.rpc.msg";
import * as _353 from "./cert/v1beta2/cert.rpc.msg";
import * as _354 from "./deployment/v1beta1/deployment.rpc.msg";
import * as _355 from "./deployment/v1beta2/service.rpc.msg";
import * as _356 from "./market/v1beta2/service.rpc.msg";
import * as _357 from "./provider/v1beta1/provider.rpc.msg";
import * as _358 from "./provider/v1beta2/provider.rpc.msg";
import * as _530 from "./lcd";
import * as _531 from "./rpc.query";
import * as _532 from "./rpc.msg";
export namespace akash {
export namespace audit {
export const v1beta1 = { ..._0,
..._319,
..._327
..._327,
..._351
};
export const v1beta2 = { ..._1,
..._2,
..._3,
..._320,
..._328,
..._335
..._335,
..._343,
..._352
};
}
export namespace base {
Expand All @@ -108,7 +130,9 @@ export namespace akash {
..._15,
..._321,
..._329,
..._336
..._336,
..._344,
..._353
};
}
export namespace deployment {
Expand All @@ -120,7 +144,9 @@ export namespace akash {
..._21,
..._322,
..._330,
..._337
..._337,
..._345,
..._354
};
export const v1beta2 = { ..._22,
..._23,
Expand All @@ -136,19 +162,23 @@ export namespace akash {
..._33,
..._323,
..._331,
..._338
..._338,
..._346,
..._355
};
}
export namespace escrow {
export const v1beta1 = { ..._34,
..._35,
..._36,
..._339
..._339,
..._347
};
export const v1beta2 = { ..._37,
..._38,
..._39,
..._340
..._340,
..._348
};
}
export namespace inflation {
Expand All @@ -166,20 +196,29 @@ export namespace akash {
..._48,
..._324,
..._332,
..._341
..._341,
..._349,
..._356
};
}
export namespace provider {
export const v1beta1 = { ..._49,
..._325,
..._333
..._333,
..._357
};
export const v1beta2 = { ..._50,
..._51,
..._52,
..._326,
..._334,
..._342
..._342,
..._350,
..._358
};
}
}
}
export const ClientFactory = { ..._530,
..._531,
..._532
};
35 changes: 35 additions & 0 deletions __fixtures__/output1/akash/cert/v1beta2/cert.rpc.msg.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,35 @@
import { Rpc } from "@osmonauts/helpers";
import * as _m0 from "protobufjs/minimal";
import { MsgCreateCertificate, MsgCreateCertificateResponse, MsgRevokeCertificate, MsgRevokeCertificateResponse } from "./cert";

/** Msg defines the RPC service */
export interface Msg {
createCertificate(request: MsgCreateCertificate): Promise<MsgCreateCertificateResponse>;
/*CreateCertificate defines a method to create new certificate given proper inputs.*/

revokeCertificate(request: MsgRevokeCertificate): Promise<MsgRevokeCertificateResponse>;
/*RevokeCertificate defines a method to revoke the certificate*/

}
export class MsgClientImpl implements Msg {
private readonly rpc: Rpc;

constructor(rpc: Rpc) {
this.rpc = rpc;
this.createCertificate = this.createCertificate.bind(this);
this.revokeCertificate = this.revokeCertificate.bind(this);
}

createCertificate(request: MsgCreateCertificate): Promise<MsgCreateCertificateResponse> {
const data = MsgCreateCertificate.encode(request).finish();
const promise = this.rpc.request("akash.cert.v1beta2.Msg", "CreateCertificate", data);
return promise.then(data => MsgCreateCertificateResponse.decode(new _m0.Reader(data)));
}

revokeCertificate(request: MsgRevokeCertificate): Promise<MsgRevokeCertificateResponse> {
const data = MsgRevokeCertificate.encode(request).finish();
const promise = this.rpc.request("akash.cert.v1beta2.Msg", "RevokeCertificate", data);
return promise.then(data => MsgRevokeCertificateResponse.decode(new _m0.Reader(data)));
}

}
27 changes: 27 additions & 0 deletions __fixtures__/output1/akash/cert/v1beta2/query.rpc.query.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,27 @@
import { CertificateFilter, Certificate } from "./cert";
import { PageRequest, PageResponse } from "../../../cosmos/base/query/v1beta1/pagination";
import { Rpc } from "@osmonauts/helpers";
import * as _m0 from "protobufjs/minimal";
import { QueryCertificatesRequest, QueryCertificatesResponse } from "./query";

/** Query defines the RPC service */
export interface Query {
certificates(request: QueryCertificatesRequest): Promise<QueryCertificatesResponse>;
/*Certificates queries certificates*/

}
export class QueryClientImpl implements Query {
private readonly rpc: Rpc;

constructor(rpc: Rpc) {
this.rpc = rpc;
this.certificates = this.certificates.bind(this);
}

certificates(request: QueryCertificatesRequest): Promise<QueryCertificatesResponse> {
const data = QueryCertificatesRequest.encode(request).finish();
const promise = this.rpc.request("akash.cert.v1beta2.Query", "Certificates", data);
return promise.then(data => QueryCertificatesResponse.decode(new _m0.Reader(data)));
}

}
Loading