feat: slinky #ntrn-250

package.json

@@ -8,6 +8,7 @@
     "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:simple": "jest -b src/testcases/parallel/simple",
+    "test:slinky": "jest -b src/testcases/parallel/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",
@@ -45,7 +46,7 @@
     "@cosmos-client/core": "^0.47.4",
     "@cosmos-client/cosmwasm": "^0.40.3",
     "@cosmos-client/ibc": "^1.2.1",
-    "@neutron-org/neutronjsplus": "0.4.0-rc10",
+    "@neutron-org/neutronjsplus": "0.4.0-rc11",
     "@types/lodash": "^4.14.182",
     "@types/long": "^5.0.0",
     "axios": "^0.27.2",

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 --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/testcases/parallel/slinky.test.ts

@@ -0,0 +1,140 @@
+import '@neutron-org/neutronjsplus';
+import {
+  WalletWrapper,
+  CosmosWrapper,
+  NEUTRON_DENOM,
+} from '@neutron-org/neutronjsplus/dist/cosmos';
+import { TestStateLocalCosmosTestNet } from '@neutron-org/neutronjsplus';
+import { getWithAttempts } from '@neutron-org/neutronjsplus/dist/wait';
+import {
+  Dao,
+  DaoMember,
+  getDaoContracts,
+} from '@neutron-org/neutronjsplus/dist/dao';
+
+const config = require('../../config.json');
+
+describe('Neutron / Slinky', () => {
+  let testState: TestStateLocalCosmosTestNet;
+  let neutronChain: CosmosWrapper;
+  let neutronAccount: WalletWrapper;
+  let daoMember1: DaoMember;
+  let dao: Dao;
+
+  let proposalId: number;
+
+  beforeAll(async () => {
+    testState = new TestStateLocalCosmosTestNet(config);
+    await testState.init();
+    neutronChain = new CosmosWrapper(
+      testState.sdk1,
+      testState.blockWaiter1,
+      NEUTRON_DENOM,
+    );
+    neutronAccount = new WalletWrapper(
+      neutronChain,
+      testState.wallets.qaNeutron.genQaWal1,
+    );
+    const daoCoreAddress = (await neutronChain.getChainAdmins())[0];
+    const daoContracts = await getDaoContracts(neutronChain, daoCoreAddress);
+    dao = new Dao(neutronChain, daoContracts);
+    daoMember1 = new DaoMember(neutronAccount, dao);
+  });
+
+  describe('prepare: bond funds', () => {
+    test('bond form wallet 1', async () => {
+      await daoMember1.bondFunds('10000');
+      await getWithAttempts(
+        neutronChain.blockWaiter,
+        async () =>
+          await dao.queryVotingPower(daoMember1.user.wallet.address.toString()),
+        async (response) => response.power == 10000,
+        20,
+      );
+    });
+  });
+
+  describe('submit proposal', () => {
+    test('create proposal', async () => {
+      proposalId = await daoMember1.submitUpdateMarketMap(
+        'Proposal for update marketmap',
+        'Add new marketmap with currency pair',
+        [
+          {
+            ticker: {
+              currency_pair: {
+                Base: 'ETH',
+                Quote: 'USDT',
+              },
+              decimals: 8,
+              min_provider_count: 1,
+              enabled: true,
+              metadata_JSON: '{}',
+            },
+            providers: {
+              providers: [
+                {
+                  name: 'kucoin_ws',
+                  off_chain_ticker: 'eth-usdt',
+                },
+              ],
+            },
+            paths: {
+              paths: [
+                {
+                  operations: [
+                    {
+                      provider: 'kucoin_ws',
+                      currency_pair: {
+                        Base: 'ETH',
+                        Quote: 'USDT',
+                      },
+                      invert: false,
+                    },
+                  ],
+                },
+              ],
+            },
+          },
+        ],
+      );
+    });
+
+    describe('vote for proposal', () => {
+      test('vote YES', async () => {
+        await daoMember1.voteYes(proposalId);
+      });
+    });
+
+    describe('execute proposal', () => {
+      test('check if proposal is passed', async () => {
+        await neutronChain.blockWaiter.waitBlocks(5);
+        await dao.checkPassedProposal(proposalId);
+      });
+      test('execute passed proposal', async () => {
+        await daoMember1.executeProposalWithAttempts(proposalId);
+      });
+    });
+  });
+
+  describe('module fetches prices', () => {
+    test('currency pairs not empty', async () => {
+      // wait to make sure we updated the price in oracle module
+      await neutronChain.blockWaiter.waitBlocks(5);
+      // check
+      const res = await neutronChain.queryOracleAllCurrencyPairs();
+      expect(res.currency_pairs[0].Base).toBe('ETH');
+      expect(res.currency_pairs[0].Quote).toBe('USDT');
+    });
+
+    test('prices not empty', async () => {
+      const res = await neutronChain.queryOraclePrices(['ETH/USDT']);
+      expect(+res.prices[0].price.price).toBeGreaterThan(0);
+    });
+
+    test('eth price present', async () => {
+      const res = await neutronChain.queryOraclePrice('ETH', 'USDT');
+      expect(+res.price.price).toBeGreaterThan(0);
+    });
+  });
+});

yarn.lock

@@ -1573,10 +1573,10 @@
   resolved "https://registry.yarnpkg.com/@ledgerhq/logs/-/logs-5.50.0.tgz#29c6419e8379d496ab6d0426eadf3c4d100cd186"
   integrity sha512-swKHYCOZUGyVt4ge0u8a7AwNcA//h4nx5wIi0sruGye1IJ5Cva0GyK9L2/WdX+kWVTKp92ZiEo1df31lrWGPgA==
 
-"@neutron-org/neutronjsplus@0.4.0-rc10":
-  version "0.4.0-rc10"
-  resolved "https://registry.yarnpkg.com/@neutron-org/neutronjsplus/-/neutronjsplus-0.4.0-rc10.tgz#3fa2d4d41f856a7f983f395e990c6d74af3699cf"
-  integrity sha512-cecCtsxmIKdLbEJg879MrpLscCt77F+tK9/zfr+61UDRAZ+hXyyfRo5q0BDUI5mxE+oP3ijmuaDMJn6nQkWPaQ==
+"@neutron-org/neutronjsplus@0.4.0-rc11":
+  version "0.4.0-rc11"
+  resolved "https://registry.yarnpkg.com/@neutron-org/neutronjsplus/-/neutronjsplus-0.4.0-rc11.tgz#8e7a5278b2020f626b40adf50989d5759ac66551"
+  integrity sha512-47QCOIETwyPRYC2ekHYTpVo6zYyYUDv7jyJI/2Pu+r/kKoEfx3UDmPLjTIw+g3vCjbptw7MjBHKmCUPMYTNtQA==
   dependencies:
     "@bufbuild/protobuf" "^1.4.2"
     "@cosmos-client/core" "^0.47.4"