-
Notifications
You must be signed in to change notification settings - Fork 192
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #257 from InjectiveLabs/dev
chore: patch release
- Loading branch information
Showing
54 changed files
with
971 additions
and
381 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
33 changes: 33 additions & 0 deletions
33
packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcCampaignApi.spec.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,33 @@ | ||
| import { getNetworkEndpoints, Network } from '@injectivelabs/networks' | ||
| import { IndexerCampaignTransformer } from '../transformers' | ||
| import { IndexerGrpcCampaignApi } from './IndexerGrpcCampaignApi' | ||
|
|
||
| const CAMPAIGN_ID = 'spot-grid-inj-usdt-test' | ||
| const MARKET_ID = | ||
| '0xa508cb32923323679f29a032c70342c147c17d0145625922b0ef22e955c844c0' | ||
| const endpoints = getNetworkEndpoints(Network.MainnetSentry) | ||
| const indexerGrpcCampaignApi = new IndexerGrpcCampaignApi(endpoints.indexer) | ||
|
|
||
| describe('IndexerGrpcCampaignApi', () => { | ||
| test('fetchCampaign', async () => { | ||
| try { | ||
| const response = await indexerGrpcCampaignApi.fetchCampaign({ | ||
| marketId: MARKET_ID, | ||
| campaignId: CAMPAIGN_ID, | ||
| }) | ||
|
|
||
| expect(response).toBeDefined() | ||
| expect(response).toEqual( | ||
| expect.objectContaining< | ||
| ReturnType< | ||
| typeof IndexerCampaignTransformer.CampaignResponseToCampaign | ||
| > | ||
| >(response), | ||
| ) | ||
| } catch (e) { | ||
| console.error( | ||
| 'IndexerGrpcCampaignApi.fetchCampaign => ' + (e as any).message, | ||
| ) | ||
| } | ||
| }) | ||
| }) |
82 changes: 82 additions & 0 deletions
82
packages/sdk-ts/src/client/indexer/grpc/IndexerGrpcCampaignApi.ts
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,82 @@ | ||
| import { | ||
| UnspecifiedErrorCode, | ||
| GrpcUnaryRequestException, | ||
| } from '@injectivelabs/exceptions' | ||
| import { InjectiveMetaRpc } from '@injectivelabs/indexer-proto-ts' | ||
| import { InjectiveCampaignRpc } from '@injectivelabs/indexer-proto-ts' | ||
| import BaseGrpcConsumer from '../../BaseGrpcConsumer' | ||
| import { IndexerCampaignTransformer } from '../transformers' | ||
| import { IndexerModule } from '../types' | ||
|
|
||
| /** | ||
| * @category Indexer Grpc API | ||
| */ | ||
| export class IndexerGrpcCampaignApi extends BaseGrpcConsumer { | ||
| protected module: string = IndexerModule.Campaign | ||
|
|
||
| protected client: InjectiveCampaignRpc.InjectiveCampaignRPCClientImpl | ||
|
|
||
| constructor(endpoint: string) { | ||
| super(endpoint) | ||
|
|
||
| this.client = new InjectiveCampaignRpc.InjectiveCampaignRPCClientImpl( | ||
| this.getGrpcWebImpl(endpoint), | ||
| ) | ||
| } | ||
|
|
||
| async fetchCampaign({ | ||
| skip, | ||
| limit, | ||
| marketId, | ||
| campaignId, | ||
| accountAddress, | ||
| }: { | ||
| skip?: string | ||
| limit?: number | ||
| marketId?: string | ||
| campaignId: string | ||
| accountAddress?: string | ||
| }) { | ||
| const request = InjectiveCampaignRpc.RankingRequest.create() | ||
|
|
||
| request.campaignId = campaignId | ||
|
|
||
| if (skip) { | ||
| request.skip = skip | ||
| } | ||
|
|
||
| if (limit) { | ||
| request.limit = limit | ||
| } | ||
|
|
||
| if (marketId) { | ||
| request.marketId = marketId | ||
| } | ||
|
|
||
| if (accountAddress) { | ||
| request.accountAddress = accountAddress | ||
| } | ||
|
|
||
| try { | ||
| const response = await this.retry<InjectiveCampaignRpc.RankingResponse>( | ||
| () => this.client.Ranking(request), | ||
| ) | ||
|
|
||
| return IndexerCampaignTransformer.CampaignResponseToCampaign(response) | ||
| } catch (e: unknown) { | ||
| if (e instanceof InjectiveMetaRpc.GrpcWebError) { | ||
| throw new GrpcUnaryRequestException(new Error(e.toString()), { | ||
| code: e.code, | ||
| context: 'FetchCampaign', | ||
| contextModule: this.module, | ||
| }) | ||
| } | ||
|
|
||
| throw new GrpcUnaryRequestException(e as Error, { | ||
| code: UnspecifiedErrorCode, | ||
| context: 'FetchCampaign', | ||
| contextModule: this.module, | ||
| }) | ||
| } | ||
| } | ||
| } |
Oops, something went wrong.