Skip to content

Commit

Permalink
Merge remote-tracking branch 'origin/main' into affan/update-revshare
Browse files Browse the repository at this point in the history
  • Loading branch information
affanv14 committed Sep 24, 2024
2 parents 53b26b2 + cc59dd2 commit e98790b
Show file tree
Hide file tree
Showing 25 changed files with 3,062 additions and 355 deletions.
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
import { setPaginationParams } from "../../helpers";
import { LCDClient } from "@osmonauts/lcd";
import { QueryParamsRequest, QueryParamsResponseSDKType, QueryVaultRequest, QueryVaultResponseSDKType, QueryAllVaultsRequest, QueryAllVaultsResponseSDKType, QueryMegavaultTotalSharesRequest, QueryMegavaultTotalSharesResponseSDKType, QueryMegavaultOwnerSharesRequest, QueryMegavaultOwnerSharesResponseSDKType, QueryVaultParamsRequest, QueryVaultParamsResponseSDKType } from "./query";
import { QueryParamsRequest, QueryParamsResponseSDKType, QueryVaultRequest, QueryVaultResponseSDKType, QueryAllVaultsRequest, QueryAllVaultsResponseSDKType, QueryMegavaultTotalSharesRequest, QueryMegavaultTotalSharesResponseSDKType, QueryMegavaultOwnerSharesRequest, QueryMegavaultOwnerSharesResponseSDKType, QueryMegavaultAllOwnerSharesRequest, QueryMegavaultAllOwnerSharesResponseSDKType, QueryVaultParamsRequest, QueryVaultParamsResponseSDKType, QueryMegavaultWithdrawalInfoRequest, QueryMegavaultWithdrawalInfoResponseSDKType } from "./query";
export class LCDQueryClient {
req: LCDClient;

Expand All @@ -15,7 +15,9 @@ export class LCDQueryClient {
this.allVaults = this.allVaults.bind(this);
this.megavaultTotalShares = this.megavaultTotalShares.bind(this);
this.megavaultOwnerShares = this.megavaultOwnerShares.bind(this);
this.megavaultAllOwnerShares = this.megavaultAllOwnerShares.bind(this);
this.vaultParams = this.vaultParams.bind(this);
this.megavaultWithdrawalInfo = this.megavaultWithdrawalInfo.bind(this);
}
/* Queries the Params. */

Expand Down Expand Up @@ -58,9 +60,16 @@ export class LCDQueryClient {
/* Queries owner shares of megavault. */


async megavaultOwnerShares(params: QueryMegavaultOwnerSharesRequest = {
async megavaultOwnerShares(params: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponseSDKType> {
const endpoint = `dydxprotocol/vault/megavault/owner_shares/${params.address}`;
return await this.req.get<QueryMegavaultOwnerSharesResponseSDKType>(endpoint);
}
/* Queries all owner shares of megavault. */


async megavaultAllOwnerShares(params: QueryMegavaultAllOwnerSharesRequest = {
pagination: undefined
}): Promise<QueryMegavaultOwnerSharesResponseSDKType> {
}): Promise<QueryMegavaultAllOwnerSharesResponseSDKType> {
const options: any = {
params: {}
};
Expand All @@ -69,8 +78,8 @@ export class LCDQueryClient {
setPaginationParams(options, params.pagination);
}

const endpoint = `dydxprotocol/vault/megavault/owner_shares`;
return await this.req.get<QueryMegavaultOwnerSharesResponseSDKType>(endpoint, options);
const endpoint = `dydxprotocol/vault/megavault/all_owner_shares`;
return await this.req.get<QueryMegavaultAllOwnerSharesResponseSDKType>(endpoint, options);
}
/* Queries vault params of a vault. */

Expand All @@ -79,5 +88,20 @@ export class LCDQueryClient {
const endpoint = `dydxprotocol/vault/params/${params.type}/${params.number}`;
return await this.req.get<QueryVaultParamsResponseSDKType>(endpoint);
}
/* Queries withdrawal info for megavault. */


async megavaultWithdrawalInfo(params: QueryMegavaultWithdrawalInfoRequest): Promise<QueryMegavaultWithdrawalInfoResponseSDKType> {
const options: any = {
params: {}
};

if (typeof params?.sharesToWithdraw !== "undefined") {
options.params.shares_to_withdraw = params.sharesToWithdraw;
}

const endpoint = `dydxprotocol/vault/megavault/withdrawal_info`;
return await this.req.get<QueryMegavaultWithdrawalInfoResponseSDKType>(endpoint, options);
}

}
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
import { Rpc } from "../../helpers";
import * as _m0 from "protobufjs/minimal";
import { QueryClient, createProtobufRpcClient } from "@cosmjs/stargate";
import { QueryParamsRequest, QueryParamsResponse, QueryVaultRequest, QueryVaultResponse, QueryAllVaultsRequest, QueryAllVaultsResponse, QueryMegavaultTotalSharesRequest, QueryMegavaultTotalSharesResponse, QueryMegavaultOwnerSharesRequest, QueryMegavaultOwnerSharesResponse, QueryVaultParamsRequest, QueryVaultParamsResponse } from "./query";
import { QueryParamsRequest, QueryParamsResponse, QueryVaultRequest, QueryVaultResponse, QueryAllVaultsRequest, QueryAllVaultsResponse, QueryMegavaultTotalSharesRequest, QueryMegavaultTotalSharesResponse, QueryMegavaultOwnerSharesRequest, QueryMegavaultOwnerSharesResponse, QueryMegavaultAllOwnerSharesRequest, QueryMegavaultAllOwnerSharesResponse, QueryVaultParamsRequest, QueryVaultParamsResponse, QueryMegavaultWithdrawalInfoRequest, QueryMegavaultWithdrawalInfoResponse } from "./query";
/** Query defines the gRPC querier service. */

export interface Query {
Expand All @@ -18,10 +18,16 @@ export interface Query {
megavaultTotalShares(request?: QueryMegavaultTotalSharesRequest): Promise<QueryMegavaultTotalSharesResponse>;
/** Queries owner shares of megavault. */

megavaultOwnerShares(request?: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponse>;
megavaultOwnerShares(request: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponse>;
/** Queries all owner shares of megavault. */

megavaultAllOwnerShares(request?: QueryMegavaultAllOwnerSharesRequest): Promise<QueryMegavaultAllOwnerSharesResponse>;
/** Queries vault params of a vault. */

vaultParams(request: QueryVaultParamsRequest): Promise<QueryVaultParamsResponse>;
/** Queries withdrawal info for megavault. */

megavaultWithdrawalInfo(request: QueryMegavaultWithdrawalInfoRequest): Promise<QueryMegavaultWithdrawalInfoResponse>;
}
export class QueryClientImpl implements Query {
private readonly rpc: Rpc;
Expand All @@ -33,7 +39,9 @@ export class QueryClientImpl implements Query {
this.allVaults = this.allVaults.bind(this);
this.megavaultTotalShares = this.megavaultTotalShares.bind(this);
this.megavaultOwnerShares = this.megavaultOwnerShares.bind(this);
this.megavaultAllOwnerShares = this.megavaultAllOwnerShares.bind(this);
this.vaultParams = this.vaultParams.bind(this);
this.megavaultWithdrawalInfo = this.megavaultWithdrawalInfo.bind(this);
}

params(request: QueryParamsRequest = {}): Promise<QueryParamsResponse> {
Expand Down Expand Up @@ -62,20 +70,32 @@ export class QueryClientImpl implements Query {
return promise.then(data => QueryMegavaultTotalSharesResponse.decode(new _m0.Reader(data)));
}

megavaultOwnerShares(request: QueryMegavaultOwnerSharesRequest = {
pagination: undefined
}): Promise<QueryMegavaultOwnerSharesResponse> {
megavaultOwnerShares(request: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponse> {
const data = QueryMegavaultOwnerSharesRequest.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Query", "MegavaultOwnerShares", data);
return promise.then(data => QueryMegavaultOwnerSharesResponse.decode(new _m0.Reader(data)));
}

megavaultAllOwnerShares(request: QueryMegavaultAllOwnerSharesRequest = {
pagination: undefined
}): Promise<QueryMegavaultAllOwnerSharesResponse> {
const data = QueryMegavaultAllOwnerSharesRequest.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Query", "MegavaultAllOwnerShares", data);
return promise.then(data => QueryMegavaultAllOwnerSharesResponse.decode(new _m0.Reader(data)));
}

vaultParams(request: QueryVaultParamsRequest): Promise<QueryVaultParamsResponse> {
const data = QueryVaultParamsRequest.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Query", "VaultParams", data);
return promise.then(data => QueryVaultParamsResponse.decode(new _m0.Reader(data)));
}

megavaultWithdrawalInfo(request: QueryMegavaultWithdrawalInfoRequest): Promise<QueryMegavaultWithdrawalInfoResponse> {
const data = QueryMegavaultWithdrawalInfoRequest.encode(request).finish();
const promise = this.rpc.request("dydxprotocol.vault.Query", "MegavaultWithdrawalInfo", data);
return promise.then(data => QueryMegavaultWithdrawalInfoResponse.decode(new _m0.Reader(data)));
}

}
export const createRpcQueryExtension = (base: QueryClient) => {
const rpc = createProtobufRpcClient(base);
Expand All @@ -97,12 +117,20 @@ export const createRpcQueryExtension = (base: QueryClient) => {
return queryService.megavaultTotalShares(request);
},

megavaultOwnerShares(request?: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponse> {
megavaultOwnerShares(request: QueryMegavaultOwnerSharesRequest): Promise<QueryMegavaultOwnerSharesResponse> {
return queryService.megavaultOwnerShares(request);
},

megavaultAllOwnerShares(request?: QueryMegavaultAllOwnerSharesRequest): Promise<QueryMegavaultAllOwnerSharesResponse> {
return queryService.megavaultAllOwnerShares(request);
},

vaultParams(request: QueryVaultParamsRequest): Promise<QueryVaultParamsResponse> {
return queryService.vaultParams(request);
},

megavaultWithdrawalInfo(request: QueryMegavaultWithdrawalInfoRequest): Promise<QueryMegavaultWithdrawalInfoResponse> {
return queryService.megavaultWithdrawalInfo(request);
}

};
Expand Down
Loading

0 comments on commit e98790b

Please sign in to comment.