Merge pull request #196 from securesecrets/js014_merge-develop

Js014 merge develop

Author: SissonJ

.changeset/brave-emus-share.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": patch
+---
+
+SecretJs Bump

.changeset/dirty-yaks-think.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": minor
+---
+
+adding decimals as a required arg to queryDerivativeShdStakingInfo

.changeset/large-bananas-speak.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": minor
+---
+
+upgrade secretjs which includes breaking changes for the pre-upgraded version of secret network

.changeset/rotten-paws-judge.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": patch
+---
+
+change from individual validator queries to batch data

.changeset/spicy-badgers-nail.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": patch
+---
+
+change secret endpoints to new api after upgrade

.changeset/swift-mirrors-cross.md

@@ -0,0 +1,5 @@
+---
+"@shadeprotocol/shadejs": patch
+---
+
+add batch query for shade staking

src/client/services/clientServices.ts

@@ -64,6 +64,45 @@ const sendSecretClientContractQuery$ = ({
     first(),
   );
 
+// This function queries the total supply of the a token
+const secretClientTokenSupplyQuery$ = (
+  client: SecretNetworkClient,
+  denom: string,
+) => createFetchClient(defer(
+  () => from(client.query.bank.supplyOf({
+    denom,
+  })),
+));
+
+// This function queries the individual validator data
+const secretClientValidatorQuery$ = (
+  client: SecretNetworkClient,
+  validatorAddress: string,
+) => createFetchClient(defer(
+  () => from(client.query.staking.validator({ validator_addr: validatorAddress })),
+));
+
+// This function queries a single page of multiple validators data
+const secretClientValidatorsQuery$ = ({
+  client,
+  offset,
+  limit,
+}:{
+  client: SecretNetworkClient,
+  offset?: number,
+  limit?: number,
+}) => createFetchClient(defer(
+  () => from(client.query.staking.validators({
+    pagination: {
+      offset: offset ? offset.toString() : undefined,
+      limit: limit ? limit.toString() : undefined,
+    },
+  })),
+));
+
 export {
   sendSecretClientContractQuery$,
+  secretClientTokenSupplyQuery$,
+  secretClientValidatorQuery$,
+  secretClientValidatorsQuery$,
 };

src/contracts/services/derivativeShd.test.ts

@@ -29,6 +29,7 @@ beforeAll(() => {
 test('it can parse the staking info', () => {
   expect(parseDerivativeShdStakingInfo(
     stakingInfoResponse as StakingInfoResponse,
+    8,
   )).toStrictEqual(stakingInfoResponseParsed);
 });
 
@@ -41,6 +42,7 @@ test('it can call the query staking info service', async () => {
     codeHash: 'CODE_HASH',
     lcdEndpoint: 'LCD_ENDPOINT',
     chainId: 'CHAIN_ID',
+    decimals: 8,
   };
 
   let output;

src/contracts/services/derivativeShd.ts

@@ -15,23 +15,21 @@ import {
 import { convertCoinFromUDenom } from '~/lib/utils';
 import { msgQueryShdDerivativeStakingInfo } from '~/contracts/definitions/derivativeShd';
 
-// Contract returns price as a rate of dSHD/SHD with 8 decimals
-const DERIVATE_PRICE_DECIMALS = 8;
-
 /**
 * Parses the staking info query into a cleaner data model
  * NOT FOR PRODUCTION USE, CONTRACT IS IN DEVELOPMENT ON TESTNET ONLY
 */
 const parseDerivativeShdStakingInfo = (
   response: StakingInfoResponse,
+  decimals: number,
 ): ParsedStakingInfoResponse => ({
   unbondingTime: response.staking_info.unbonding_time,
   bondedShd: response.staking_info.bonded_shd,
   rewards: response.staking_info.rewards,
   totalDerivativeTokenSupply: response.staking_info.total_derivative_token_supply,
   price: convertCoinFromUDenom(
     response.staking_info.price,
-    DERIVATE_PRICE_DECIMALS,
+    decimals,
   ).toNumber(),
   feeInfo: {
     stakingFee: response.staking_info.fee_info.staking.rate / (
@@ -54,19 +52,21 @@ const queryDerivativeShdStakingInfo$ = ({
   codeHash,
   lcdEndpoint,
   chainId,
+  decimals,
 }: {
   contractAddress: string,
   codeHash?: string,
   lcdEndpoint?: string,
   chainId?: string,
+  decimals: number,
 }) => getActiveQueryClient$(lcdEndpoint, chainId).pipe(
   switchMap(({ client }) => sendSecretClientContractQuery$({
     queryMsg: msgQueryShdDerivativeStakingInfo(),
     client,
     contractAddress,
     codeHash,
   })),
-  map((response) => parseDerivativeShdStakingInfo(response as StakingInfoResponse)),
+  map((response) => parseDerivativeShdStakingInfo(response as StakingInfoResponse, decimals)),
   first(),
 );
 
@@ -79,17 +79,20 @@ async function queryDerivativeShdStakingInfo({
   codeHash,
   lcdEndpoint,
   chainId,
+  decimals,
 }: {
   contractAddress: string,
   codeHash?: string,
   lcdEndpoint?: string,
   chainId?: string,
+  decimals: number,
 }) {
   return lastValueFrom(queryDerivativeShdStakingInfo$({
     contractAddress,
     codeHash,
     lcdEndpoint,
     chainId,
+    decimals,
   }));
 }
 

src/contracts/services/shadeStaking.test.ts

@@ -8,13 +8,18 @@ import { of } from 'rxjs';
 import stakingOpportunityResponse from '~/test/mocks/shadeStaking/stakingOpportunityResponse.json';
 import { stakingOpportunityResponseParsed } from '~/test/mocks/shadeStaking/response';
 import {
+  batchQueryShadeStakingOpportunity,
+  batchQueryShadeStakingOpportunity$,
   parseStakingOpportunity,
   queryShadeStakingOpportunity,
   queryShadeStakingOpportunity$,
 } from '~/contracts/services/shadeStaking';
 import { StakingInfoServiceResponse } from '~/types/contracts/shadeStaking/index';
+import { batchStakingInfoUnparsed } from '~/test/mocks/shadeStaking/batchStakingInfoUnparsed';
+import { batchStakingInfoParsed } from '~/test/mocks/shadeStaking/batchStakingInfoParsed';
 
 const sendSecretClientContractQuery$ = vi.hoisted(() => vi.fn());
+const batchQuery$ = vi.hoisted(() => vi.fn());
 
 beforeAll(() => {
   vi.mock('~/contracts/definitions/shadeStaking', () => ({
@@ -28,6 +33,10 @@ beforeAll(() => {
   vi.mock('~/client/services/clientServices', () => ({
     sendSecretClientContractQuery$,
   }));
+
+  vi.mock('~/contracts/services/batchQuery', () => ({
+    batchQuery$,
+  }));
 });
 
 test('it can parse the shade staking info', () => {
@@ -76,3 +85,60 @@ test('it can call the query shade staking info service', async () => {
 
   expect(output2).toStrictEqual(stakingOpportunityResponseParsed);
 });
+
+test('it can call the batch shade staking info query service', async () => {
+  const input = {
+    queryRouterContractAddress: 'CONTRACT_ADDRESS',
+    queryRouterCodeHash: 'CODE_HASH',
+    lcdEndpoint: 'LCD_ENDPOINT',
+    chainId: 'CHAIN_ID',
+    stakingContracts: [{
+      address: 'STAKING_ADDRESS',
+      codeHash: 'STAKING_CODE_HASH',
+    }],
+  };
+  // observables function
+  batchQuery$.mockReturnValueOnce(of(batchStakingInfoUnparsed));
+  let output;
+  batchQueryShadeStakingOpportunity$(input).subscribe({
+    next: (response) => {
+      output = response;
+    },
+  });
+
+  expect(batchQuery$).toHaveBeenCalledWith({
+    contractAddress: input.queryRouterContractAddress,
+    codeHash: input.queryRouterCodeHash,
+    lcdEndpoint: input.lcdEndpoint,
+    chainId: input.chainId,
+    queries: [{
+      id: input.stakingContracts[0].address,
+      contract: {
+        address: input.stakingContracts[0].address,
+        codeHash: input.stakingContracts[0].codeHash,
+      },
+      queryMsg: 'STAKING_INFO_MSG',
+    }],
+  });
+
+  expect(output).toStrictEqual(batchStakingInfoParsed);
+
+  // async/await function
+  batchQuery$.mockReturnValueOnce(of(batchStakingInfoUnparsed));
+  const response = await batchQueryShadeStakingOpportunity(input);
+  expect(batchQuery$).toHaveBeenCalledWith({
+    contractAddress: input.queryRouterContractAddress,
+    codeHash: input.queryRouterCodeHash,
+    lcdEndpoint: input.lcdEndpoint,
+    chainId: input.chainId,
+    queries: [{
+      id: input.stakingContracts[0].address,
+      contract: {
+        address: input.stakingContracts[0].address,
+        codeHash: input.stakingContracts[0].codeHash,
+      },
+      queryMsg: 'STAKING_INFO_MSG',
+    }],
+  });
+  expect(response).toStrictEqual(batchStakingInfoParsed);
+});