feat: slinky #ntrn-250

package.json

@@ -6,8 +6,9 @@
   "scripts": {
     "test": "yarn test:parallel && yarn test:run_in_band",
     "test:parallel": "jest -b src/testcases/parallel",
-    "test:run_in_band": "yarn test:tge:auction && yarn test:tge:credits && yarn test:interchaintx && yarn test:interchain_kv_query && yarn test:interchain_tx_query_plain && yarn test:tokenomics && yarn test:reserve && yarn test:ibc_hooks && yarn test:float && yarn test:parameters && yarn test:dex_stargate && yarn test:globalfee && yarn test:dex_bindings && yarn test:pob",
+    "test:run_in_band": "yarn test:tge:auction && yarn test:tge:credits && yarn test:interchaintx && yarn test:interchain_kv_query && yarn test:interchain_tx_query_plain && yarn test:tokenomics && yarn test:reserve && yarn test:ibc_hooks && yarn test:float && yarn test:parameters && yarn test:dex_stargate && yarn test:globalfee && yarn test:dex_bindings && yarn test:pob && yarn test:slinky",
     "test:simple": "jest -b src/testcases/parallel/simple",
+    "test:slinky": "jest -b src/testcases/run_in_band/slinky",
     "test:stargate_queries": "jest -b src/testcases/parallel/stargate_queries",
     "test:interchaintx": "jest -b src/testcases/run_in_band/interchaintx",
     "test:interchain_kv_query": "jest -b src/testcases/run_in_band/interchain_kv_query",

setup/.tool-versions

@@ -0,0 +1 @@
+nodejs 16.20.0

setup/Makefile

@@ -13,7 +13,10 @@ build-hermes:
 build-relayer:
 		cd $(APP_DIR)/neutron-query-relayer/ && make build-docker
 
-build-all: build-gaia build-neutron build-hermes build-relayer
+build-slinky:
+		@docker buildx build --load --build-context app=$(APP_DIR)/slinky -t skip-mev/slinky-e2e-oracle -f dockerbuilds/Dockerfile.slinky .
+
+build-all: build-gaia build-neutron build-hermes build-relayer build-slinky
 
 start-cosmopark:
 		@$(COMPOSE) up -d

setup/docker-compose.yml

@@ -12,6 +12,7 @@ services:
       - 8090:9090
     environment:
       - RUN_BACKGROUND=0
+      - ORACLE_ADDRESS=oracle:8080
     networks:
       - neutron-testing
 
@@ -78,6 +79,21 @@ services:
     networks:
       - neutron-testing
 
+  oracle:
+    image: skip-mev/slinky-e2e-oracle
+    entrypoint: [
+      "slinky",
+      "--oracle-config-path",
+      "/oracle/oracle.json",
+      "--market-config-path",
+      "/oracle/market.json",
+      ]
+    ports:
+      - "8080:8080" # main oracle port
+      - "8002:8002" # oracle metrics port
+    networks:
+      - neutron-testing
+
 volumes:
   data:
     name: neutron-testing-data

setup/dockerbuilds/Dockerfile.slinky

@@ -0,0 +1,21 @@
+FROM golang:1.22-bullseye AS builder
+
+WORKDIR /src/slinky
+COPY --from=app go.mod .
+
+RUN go mod download
+
+COPY --from=app . .
+
+RUN make build
+
+FROM ubuntu:rolling
+EXPOSE 8080
+EXPOSE 8002
+
+COPY --from=builder /src/slinky/build/* /usr/local/bin/
+COPY --from=builder /src/slinky/config/local/* /oracle/
+RUN apt-get update && apt-get install ca-certificates -y
+
+WORKDIR /usr/local/bin/
+ENTRYPOINT ["slinky", "--oracle-config-path", "/oracle/oracle.json", "--market-config-path", "/oracle/market.json"]

src/helpers/gaia.ts

@@ -3,11 +3,19 @@ import {
   MsgDelegate,
   MsgUndelegate,
 } from '@neutron-org/neutronjsplus/dist/proto/cosmos_sdk/cosmos/staking/v1beta1/tx_pb';
+import {
+  MsgSubmitProposal,
+  MsgVote,
+} from '@neutron-org/neutronjsplus/dist/proto/cosmos_sdk/cosmos/gov/v1beta1/tx_pb';
 import {
   packAnyMsg,
   WalletWrapper,
 } from '@neutron-org/neutronjsplus/dist/cosmos';
 import Long from 'long';
+import {
+  TextProposal,
+  VoteOption,
+} from '@neutron-org/neutronjsplus/dist/proto/cosmos_sdk/cosmos/gov/v1beta1/gov_pb';
 
 export const msgDelegate = async (
   wallet: WalletWrapper,
@@ -48,5 +56,56 @@ export const msgUndelegate = async (
     },
     [packAnyMsg('/cosmos.staking.v1beta1.MsgUndelegate', msgUndelegate)],
   );
+
+  return res?.tx_response;
+};
+
+export const msgSubmitProposal = async (
+  wallet: WalletWrapper,
+  proposer: string,
+  amount = '0',
+): Promise<BroadcastTx200ResponseTxResponse> => {
+  const msgSubmitProposal = new MsgSubmitProposal({
+    proposer,
+    content: {
+      typeUrl: '/cosmos.gov.v1beta1.TextProposal',
+      value: new TextProposal({
+        title: 'mock',
+        description: 'mock',
+      }).toBinary(),
+    },
+    initialDeposit: [{ denom: wallet.chain.denom, amount: '10000000' }],
+  });
+  const res = await wallet.execTx(
+    {
+      gas_limit: Long.fromString('500000'),
+      amount: [{ denom: wallet.chain.denom, amount: amount }],
+    },
+    [packAnyMsg('/cosmos.gov.v1beta1.MsgSubmitProposal', msgSubmitProposal)],
+  );
+
+  return res?.tx_response;
+};
+
+export const msgVote = async (
+  wallet: WalletWrapper,
+  voter: string,
+  proposalId: number,
+  amount = '0',
+): Promise<BroadcastTx200ResponseTxResponse> => {
+  const msgVote = new MsgVote({
+    voter,
+    proposalId: BigInt(proposalId),
+    option: VoteOption.YES,
+  });
+
+  const res = await wallet.execTx(
+    {
+      gas_limit: Long.fromString('500000'),
+      amount: [{ denom: wallet.chain.denom, amount: amount }],
+    },
+    [packAnyMsg('/cosmos.gov.v1beta1.MsgVote', msgVote)],
+  );
+
   return res?.tx_response;
 };

src/testcases/parallel/overrule.test.ts

@@ -16,7 +16,7 @@ import {
 
 const config = require('../../config.json');
 
-describe('Neutron / Subdao', () => {
+describe('Neutron / Subdao Overrule', () => {
   let testState: TestStateLocalCosmosTestNet;
   let neutronChain: CosmosWrapper;
   let neutronAccount1: WalletWrapper;

src/testcases/parallel/subdao.test.ts

@@ -18,10 +18,16 @@ import {
   TimelockConfig,
   TimelockProposalListResponse,
 } from '@neutron-org/neutronjsplus/dist/dao';
-import { Wallet } from '@neutron-org/neutronjsplus/dist/types';
+import {
+  SingleChoiceProposal,
+  Wallet,
+} from '@neutron-org/neutronjsplus/dist/types';
 import { BroadcastTx200ResponseTxResponse } from '@cosmos-client/core/cjs/openapi/api';
 import cosmosclient from '@cosmos-client/core';
-import { waitSeconds } from '@neutron-org/neutronjsplus/dist/wait';
+import {
+  getWithAttempts,
+  waitSeconds,
+} from '@neutron-org/neutronjsplus/dist/wait';
 import {
   paramChangeProposal,
   sendProposal,
@@ -480,6 +486,86 @@ describe('Neutron / Subdao', () => {
     });
   });
 
+  describe('Timelock3: Closed overruled proposal should not prevent execution', () => {
+    let proposalId: number;
+    beforeAll(async () => {
+      proposalId = await subdaoMember1.submitUpdateSubDaoConfigProposal(
+        {
+          name: 'dao name after timelock3',
+        },
+        'single2',
+      );
+
+      // move proposal to the timelocked state where it can be overruled
+      const timelockedProp = await subdaoMember1.supportAndExecuteProposal(
+        proposalId,
+        'single2',
+      );
+
+      expect(timelockedProp.id).toEqual(proposalId);
+      expect(timelockedProp.status).toEqual('timelocked');
+      expect(timelockedProp.msgs).toHaveLength(1);
+    });
+
+    test('close rejected overrule proposal', async () => {
+      const overruleProposalId = await mainDao.getOverruleProposalId(
+        subDao.contracts.proposals.single2.pre_propose.timelock!.address,
+        proposalId,
+      );
+
+      // wait 20 seconds
+      await waitSeconds(20);
+
+      const propOverruledTest =
+        await mainDao.chain.queryContract<SingleChoiceProposal>(
+          mainDaoMember.dao.contracts.proposals.overrule?.address,
+          {
+            proposal: {
+              proposal_id: overruleProposalId,
+            },
+          },
+        );
+      expect(propOverruledTest.proposal.status).toEqual('rejected');
+
+      await subdaoMember1.user.executeContract(
+        mainDaoMember.dao.contracts.proposals.overrule.address,
+        JSON.stringify({
+          close: { proposal_id: overruleProposalId },
+        }),
+      );
+
+      const propOverruledTest2 = await getWithAttempts(
+        neutronChain.blockWaiter,
+        async () =>
+          await mainDao.chain.queryContractWithWait<SingleChoiceProposal>(
+            mainDaoMember.dao.contracts.proposals.overrule?.address,
+            {
+              proposal: {
+                proposal_id: overruleProposalId,
+              },
+            },
+          ),
+        async (p) => p.proposal.status === 'closed',
+        5,
+      );
+
+      expect(propOverruledTest2.proposal.status).toEqual('closed');
+    });
+
+    test('execute timelocked: success', async () => {
+      await waitSeconds(20);
+      await subdaoMember1.executeTimelockedProposal(proposalId, 'single2');
+
+      const timelockedProp = await subDao.getTimelockedProposal(
+        proposalId,
+        'single2',
+      );
+      expect(timelockedProp.id).toEqual(proposalId);
+      expect(timelockedProp.status).toEqual('executed');
+      expect(timelockedProp.msgs).toHaveLength(1);
+    });
+  });
+
   describe('Non-timelock typed duration pause proposal: Succeed creation', () => {
     let proposalId: number;
 

src/testcases/run_in_band/dex_bindings.test.ts

@@ -548,7 +548,7 @@ describe('Neutron / dex module bindings', () => {
         );
       console.log(resp);
       expect(Number(resp.deposits[0].total_shares)).toBeGreaterThan(0);
-      expect(Number(resp.deposits[0].pool!.id)).toEqual(0);
+      expect(Number(resp.deposits[0].pool.id)).toEqual(0);
 
       const respNoPoolData =
         await neutronAccount.chain.queryContract<AllUserDepositsResponse>(

src/testcases/run_in_band/dex_stargate.test.ts

@@ -467,7 +467,7 @@ describe('Neutron / dex module (stargate contract)', () => {
         );
       console.log(resp);
       expect(Number(resp.deposits[0].total_shares)).toBeGreaterThan(0);
-      expect(Number(resp.deposits[0].pool!.id)).toEqual(0);
+      expect(Number(resp.deposits[0].pool.id)).toEqual(0);
 
       const respNoPoolData =
         await neutronAccount.chain.queryContract<AllUserDepositsResponse>(