Merge branch 'feat/upd-47' into feat/save-failed-result

src/helpers/cosmos.ts

@@ -28,6 +28,7 @@ import {
   PinnedCodesResponse,
   IcaHostParamsResponse,
   GlobalfeeParamsResponse,
+  InterchaintxsParamsResponse,
 } from './types';
 import { DEBUG_SUBMIT_TX, getContractBinary } from './env';
 const adminmodule = AdminProto.adminmodule.adminmodule;
@@ -75,7 +76,6 @@ cosmosclient.codec.register(
   '/cosmos.params.v1beta1.ParameterChangeProposal',
   cosmosclient.proto.cosmos.params.v1beta1.ParameterChangeProposal,
 );
-
 cosmosclient.codec.register(
   '/neutron.interchainqueries.MsgRemoveInterchainQueryRequest',
   neutron.interchainqueries.MsgRemoveInterchainQueryRequest,
@@ -104,6 +104,10 @@ cosmosclient.codec.register(
   '/pob.builder.v1.MsgAuctionBid',
   pob.builder.v1.MsgAuctionBid,
 );
+cosmosclient.codec.register(
+  '/neutron.interchaintxs.v1.MsgUpdateParams',
+  neutron.interchaintxs.v1.MsgUpdateParams,
+);
 
 export class CosmosWrapper {
   readonly sdk: cosmosclient.CosmosSDK;
@@ -396,6 +400,21 @@ export class CosmosWrapper {
     }
   }
 
+  async queryMaxTxsAllowed(): Promise<string> {
+    try {
+      const req = await axios.get<InterchaintxsParamsResponse>(
+        `${this.sdk.url}/neutron/interchaintxs/params`,
+        {},
+      );
+      return req.data.params.msg_submit_tx_max_messages;
+    } catch (e) {
+      if (e.response?.data?.message !== undefined) {
+        throw new Error(e.response?.data?.message);
+      }
+      throw e;
+    }
+  }
+
   async queryGlobalfeeParams(): Promise<GlobalfeeParamsResponse> {
     const req = await axios.get(
       `${this.sdk.url}/gaia/globalfee/v1beta1/params`,
@@ -676,8 +695,8 @@ export class WalletWrapper {
         }
       | string,
     fee = {
-      gas_limit: Long.fromString('200000'),
-      amount: [{ denom: this.chain.denom, amount: '1000' }],
+      gas_limit: Long.fromString('300000'),
+      amount: [{ denom: this.chain.denom, amount: '1500' }],
     },
     sequence: number = this.wallet.account.sequence,
     mode: cosmosclient.rest.tx.BroadcastTxMode = cosmosclient.rest.tx

src/helpers/dao.ts

@@ -30,6 +30,7 @@ import {
   SendProposalInfo,
   unpinCodesProposal,
   updateAdminProposal,
+  updateInterchaintxsParamsProposal,
   upgradeProposal,
 } from './proposal';
 import { ibc } from '../generated/ibc/proto';
@@ -1263,6 +1264,27 @@ export class DaoMember {
     );
   }
 
+  /**
+   * submitUpdateParamsInterchaintxsProposal creates proposal which changes params of interchaintxs module.
+   */
+
+  async submitUpdateParamsInterchaintxsProposal(
+    title: string,
+    description: string,
+    msgSubmitTxMaxMessages: number,
+    amount: string,
+  ): Promise<number> {
+    const message = updateInterchaintxsParamsProposal({
+      msg_submit_tx_max_messages: msgSubmitTxMaxMessages,
+    });
+    return await this.submitSingleChoiceProposal(
+      title,
+      description,
+      [message],
+      amount,
+    );
+  }
+
   /**
    * submitClientUpdateProposal creates proposal which updates client.
    */

src/helpers/proposal.ts

@@ -16,6 +16,9 @@ export type PinCodesInfo = {
   codes_ids: number[];
 };
 
+export type UpdateParamsInterchaintxsInfo = {
+  msg_submit_tx_max_messages: number;
+};
 export type UpdateAdmin = {
   sender: string;
   contract: string;
@@ -192,6 +195,26 @@ export const unpinCodesProposal = (info: PinCodesInfo): any => ({
   },
 });
 
+export const updateInterchaintxsParamsProposal = (
+  info: UpdateParamsInterchaintxsInfo,
+): any => ({
+  custom: {
+    submit_admin_proposal: {
+      admin_proposal: {
+        proposal_execute_message: {
+          message: JSON.stringify({
+            '@type': '/neutron.interchaintxs.v1.MsgUpdateParams',
+            authority: ADMIN_MODULE_ADDRESS,
+            params: {
+              msg_submit_tx_max_messages: info.msg_submit_tx_max_messages,
+            },
+          }),
+        },
+      },
+    },
+  },
+});
+
 export const updateAdminProposal = (info: UpdateAdmin): any => ({
   custom: {
     submit_admin_proposal: {

src/helpers/tokenfactory.ts

@@ -22,6 +22,10 @@ cosmosclient.codec.register(
   '/osmosis.tokenfactory.v1beta1.MsgChangeAdmin',
   osmosis.tokenfactory.v1beta1.MsgChangeAdmin,
 );
+cosmosclient.codec.register(
+  '/osmosis.tokenfactory.v1beta1.MsgSetBeforeSendHook',
+  osmosis.tokenfactory.v1beta1.MsgSetBeforeSendHook,
+);
 
 export const msgMintDenom = async (
   cmNeutron: WalletWrapper,
@@ -55,8 +59,8 @@ export const msgCreateDenom = async (
   });
   const res = await cmNeutron.execTx(
     {
-      gas_limit: Long.fromString('200000'),
-      amount: [{ denom: cmNeutron.chain.denom, amount: '1000' }],
+      gas_limit: Long.fromString('2000000'),
+      amount: [{ denom: cmNeutron.chain.denom, amount: '5000' }],
     },
     [msgCreateDenom],
     10,
@@ -77,11 +81,12 @@ export const msgBurn = async (
       denom: denom,
       amount: amountToBurn,
     },
+    burnFromAddress: creator,
   });
   const res = await cmNeutron.execTx(
     {
       gas_limit: Long.fromString('200000'),
-      amount: [{ denom: cmNeutron.chain.denom, amount: '1000' }],
+      amount: [{ denom: cmNeutron.chain.denom, amount: '5000' }],
     },
     [msgBurn],
     10,
@@ -100,16 +105,39 @@ export const msgChangeAdmin = async (
   const msgChangeAdmin = new osmosis.tokenfactory.v1beta1.MsgChangeAdmin({
     sender: creator,
     denom,
-    newAdmin,
+    new_admin: newAdmin,
   });
   const res = await cmNeutron.execTx(
     {
       gas_limit: Long.fromString('200000'),
-      amount: [{ denom: cmNeutron.chain.denom, amount: '1000' }],
+      amount: [{ denom: cmNeutron.chain.denom, amount: '5000' }],
     },
     [msgChangeAdmin],
     10,
   );
 
   return res.tx_response!;
 };
+
+export const msgSetBeforeSendHook = async (
+  cmNeutron: WalletWrapper,
+  creator: string,
+  denom: string,
+  contractAddr: string,
+): Promise<BroadcastTx200ResponseTxResponse> => {
+  const msgMint = new osmosis.tokenfactory.v1beta1.MsgSetBeforeSendHook({
+    sender: creator,
+    denom,
+    contract_addr: contractAddr,
+  });
+  const res = await cmNeutron.execTx(
+    {
+      gas_limit: Long.fromString('200000'),
+      amount: [{ denom: cmNeutron.chain.denom, amount: '1000' }],
+    },
+    [msgMint],
+    10,
+  );
+
+  return res.tx_response!;
+};

src/helpers/types.ts

@@ -80,26 +80,7 @@ export type AckFailuresResponse = {
 type Failure = {
   address: string;
   id: string;
-  ack: {
-    response: {
-      result: string | null; // base64 encoded bytes
-      error: string | null; // error text
-    };
-  };
-  ack_type: string;
-  packet: {
-    data: string;
-    destination_channel: string;
-    destination_port: string;
-    sequence: string;
-    source_channel: string;
-    source_port: string;
-    timeout_height: {
-      revision_height: string;
-      revision_number: string;
-    };
-    timeout_timestamp: string;
-  };
+  sudo_payload: string; // base64 encoded json bytes
 };
 
 export type ScheduleResponse = {
@@ -172,6 +153,7 @@ export const NeutronContract = {
   VESTING_INVESTORS: 'vesting_investors.wasm',
   INVESTORS_VESTING_VAULT: 'investors_vesting_vault.wasm',
   TOKENFACTORY: 'tokenfactory.wasm',
+  BEFORE_SEND_HOOK_TEST: 'before_send_hook_test.wasm',
 };
 
 export type MultiChoiceOption = {
@@ -284,6 +266,12 @@ export type IcaHostParamsResponse = {
   };
 };
 
+export type InterchaintxsParamsResponse = {
+  params: {
+    msg_submit_tx_max_messages: string;
+  };
+};
+
 export type GlobalfeeParamsResponse = {
   minimum_gas_prices: cosmos.base.v1beta1.ICoin[];
   bypass_min_fee_msg_types: string[];

src/testcases/parallel/governance.test.ts

@@ -389,6 +389,15 @@ describe('Neutron / Governance', () => {
       );
     });
 
+    test('create proposal #20, will pass', async () => {
+      await daoMember1.submitUpdateParamsInterchaintxsProposal(
+        'Proposal #20',
+        'Update interchaintxs params',
+        11,
+        '1000',
+      );
+    });
+
     test('create multi-choice proposal #2, will be rejected', async () => {
       await daoMember1.submitMultiChoiceParameterChangeProposal(
         [
@@ -1035,6 +1044,31 @@ describe('Neutron / Governance', () => {
     });
   });
 
+  describe('vote for proposal #20 with unbonded funds(no, yes, yes)', () => {
+    const proposalId = 20;
+    test('vote NO from wallet 1', async () => {
+      await daoMember1.voteNo(proposalId);
+    });
+    test('vote YES from wallet 2', async () => {
+      await daoMember2.voteYes(proposalId);
+    });
+    test('vote YES from wallet 3', async () => {
+      await daoMember3.voteYes(proposalId);
+    });
+  });
+
+  describe('try to execute proposal #20', () => {
+    const proposalId = 20;
+    test('check if proposal is passed', async () => {
+      await dao.checkPassedProposal(proposalId);
+    });
+    test('execute passed proposal', async () => {
+      await daoMember1.executeProposalWithAttempts(proposalId);
+      const paramAfter = await neutronChain.queryMaxTxsAllowed();
+      expect(paramAfter).toEqual('11');
+    });
+  });
+
   describe('check that only admin can create valid proposals', () => {
     test('submit admin proposal from non-admin addr, should fail', async () => {
       const res = await daoMember1.user.msgSendDirectProposal(