chore: replace yarn with npm

.github/workflows/test.yml

@@ -41,15 +41,13 @@ jobs:
         with:
           node-version: '16.14'
           registry-url: https://npm.pkg.github.com/aura-nw
-      - name: Install Yarn
-        run: npm install -g yarn
       - name: Cache node modules
         id: cache-npm
         uses: actions/cache@v3
         env:
           cache-name: cache-node-modules
         with:
-          path: ~/.npm
+          path: ./node_modules
           key: ${{ runner.os }}-build-${{ env.cache-name }}-${{ hashFiles('**/package-lock.json') }}
           restore-keys: |
             ${{ runner.os }}-build-${{ env.cache-name }}-

.husky/pre-push

@@ -6,4 +6,4 @@
 [ -n "$CI" ] && exit 0
 
 set -eux
-yarn test
+npm run test

Dockerfile

@@ -4,15 +4,15 @@ FROM node:16-alpine
 WORKDIR /app
 
 # Install dependencies
-COPY package.json package-lock.json yarn.lock ./
-RUN yarn install
+COPY package.json package-lock.json ./
+RUN npm install
 
 # Copy source
 COPY . .
 
 # Build and cleanup
 ENV NODE_ENV=production
-RUN yarn build
+RUN npm run build
 
 # Start server
-CMD ["yarn", "start"]
+CMD ["npm", "start"]

README.md

@@ -92,10 +92,10 @@ hasura metadata apply
 [Config list network](network.json) to config list network with LCD, RPC, database  
 [Config chain](config.json) to setup job crawl and select chain id to crawl
 
-## YARN scripts
+## Scripts
 
-- `yarn dev`: Start development mode (load all services locally with hot-reload & REPL)
-- `yarn build`: Build .dist folder to start production mode
-- `yarn start`: Start production mode (set `SERVICES` env variable to load certain services)
-- `yarn lint`: Run ESLint
-- `yarn test`: Run jest
+- `npm run dev`: Start development mode (load all services locally with hot-reload & REPL)
+- `npm run build`: Build .dist folder to start production mode
+- `npm run start`: Start production mode (set `SERVICES` env variable to load certain services)
+- `npm run lint`: Run ESLint
+- `npm run test`: Run jest

package.json

@@ -18,15 +18,15 @@
     "db:migrate:test:latest": "env DOTENV_CONFIG_PATH=./.env NODE_ENV=test ts-node --require dotenv/config ./node_modules/.bin/knex migrate:latest",
     "db:migrate:test:rollback": "env DOTENV_CONFIG_PATH=./.env NODE_ENV=test ts-node --require dotenv/config ./node_modules/.bin/knex migrate:rollback",
     "db:seed:make": "env DOTENV_CONFIG_PATH=./.env ts-node --require dotenv/config ./node_modules/.bin/knex seed:make",
-    "build": "yarn clean; tsc --project tsconfig.build.json",
+    "build": "npm run clean; tsc --project tsconfig.build.json",
     "up": "docker-compose up -d",
     "stop": "docker-compose stop",
     "prepare": "husky install",
     "jest": "NODE_OPTIONS='--loader ts-node/esm' jest",
-    "test": "docker compose up -d aurad && yarn jest --verbose --runInBand --forceExit && docker compose stop aurad && docker rm aurad_erascope",
-    "test-ci": "yarn jest --verbose --runInBand --forceExit",
-    "test-watch": "yarn jest --watch",
-    "test-coverage": "yarn jest --coverage",
+    "test": "docker compose up aurad -d && npm run jest -- --verbose --runInBand --forceExit && docker compose stop aurad && docker rm aurad_erascope",
+    "test-ci": "npm run jest -- --verbose --runInBand --forceExit",
+    "test-watch": "npm run jest --watch",
+    "test-coverage": "npm run jest --coverage",
     "lint": "echo 'Running lint for repository' && eslint ."
   },
   "nodemonConfig": {
@@ -43,7 +43,7 @@
     "ext": "ts, js"
   },
   "dependencies": {
-    "@aura-nw/aurajs": "^0.1.6",
+    "@aura-nw/aurajs": "0.1.7",
     "@bull-board/api": "^5.1.1",
     "@bull-board/express": "^5.1.1",
     "@cosmjs/cosmwasm-stargate": "^0.30.0",
@@ -121,6 +121,7 @@
     "husky": "^8.0.0",
     "jest": "^29.3.1",
     "jest-light-runner": "^0.4.1",
+    "jest-mock": "29.5.0",
     "moleculer-repl": "^0.7.3",
     "prettier": "^2.7.1",
     "ts-jest": "^29.0.3",

src/common/types/interfaces.ts

@@ -1,9 +1,9 @@
 import Long from 'long';
 
 export interface IAuraJSClientFactory {
-  auranw: any;
+  aura: any;
   cosmwasm: any;
   ibc: any;
 }
 
 export interface INetworkInfo {
@@ -85,7 +85,7 @@
 export interface IContextGraphQLQuery {
   operationName: string;
   query: string;
   variables: any;
 }
 
 export interface IContextUpdateCw20 {

src/common/utils/aurajs_client.ts

@@ -1,17 +1,17 @@
-import { auranw, cosmwasm, ibc } from '@aura-nw/aurajs';
+import { aura, cosmwasm, ibc } from '@aura-nw/aurajs';
 import { IAuraJSClientFactory } from '../types/interfaces';
 import network from '../../../network.json' assert { type: 'json' };
 import config from '../../../config.json' assert { type: 'json' };
 
 export default class AuraJsClient {
   public lcdClient: IAuraJSClientFactory = {
-    auranw: null,
+    aura: null,
     cosmwasm: null,
     ibc: null,
   };
 
   public rpcClient: IAuraJSClientFactory = {
-    auranw: null,
+    aura: null,
     cosmwasm: null,
     ibc: null,
   };
@@ -23,9 +23,9 @@ export async function getLcdClient() {
   const lcd =
     network.find((net: any) => net.chainId === config.chainId)?.LCD[0] || '';
 
-  if (!client.lcdClient.auranw) {
-    const auranwClient = auranw.ClientFactory;
-    client.lcdClient.auranw = await auranwClient.createLCDClient({
+  if (!client.lcdClient.aura) {
+    const auraClient = aura.ClientFactory;
+    client.lcdClient.aura = await auraClient.createLCDClient({
       restEndpoint: lcd,
     });
   }
@@ -48,9 +48,9 @@ export async function getRpcClient() {
   const rpc =
     network.find((net: any) => net.chainId === config.chainId)?.RPC[0] || '';
 
-  if (!client.rpcClient.auranw) {
-    const auranwClient = auranw.ClientFactory;
-    client.rpcClient.auranw = await auranwClient.createRPCQueryClient({
+  if (!client.rpcClient.aura) {
+    const auraClient = aura.ClientFactory;
+    client.rpcClient.aura = await auraClient.createRPCQueryClient({
       rpcEndpoint: rpc,
     });
   }

src/services/crawl-block/crawl_block.service.ts

@@ -56,7 +56,7 @@ export default class CrawlBlockService extends BullableService {
 
     // set version cosmos sdk to registry
     const nodeInfo: GetNodeInfoResponseSDKType =
-      await this._lcdClient.auranw.cosmos.base.tendermint.v1beta1.getNodeInfo();
+      await this._lcdClient.aura.cosmos.base.tendermint.v1beta1.getNodeInfo();
     const cosmosSdkVersion = nodeInfo.application_version?.cosmos_sdk_version;
     if (cosmosSdkVersion) {
       this._registry.setCosmosSdkVersionByString(cosmosSdkVersion);
@@ -81,7 +81,7 @@ export default class CrawlBlockService extends BullableService {
   async handleJobCrawlBlock() {
     // Get latest block in network
     const responseGetLatestBlock: GetLatestBlockResponseSDKType =
-      await this._lcdClient.auranw.cosmos.base.tendermint.v1beta1.getLatestBlock();
+      await this._lcdClient.aura.cosmos.base.tendermint.v1beta1.getLatestBlock();
     const latestBlockNetwork = parseInt(
       responseGetLatestBlock.block?.header?.height
         ? responseGetLatestBlock.block?.header?.height.toString()

src/services/crawl-proposal/crawl_proposal.service.ts

@@ -79,7 +79,7 @@ export default class CrawlProposalService extends BullableService {
             proposalIds
           );
           const nodeInfo: GetNodeInfoResponseSDKType =
-            await this._lcdClient.auranw.cosmos.base.tendermint.v1beta1.getNodeInfo();
+            await this._lcdClient.aura.cosmos.base.tendermint.v1beta1.getNodeInfo();
           const cosmosSdkVersion =
             nodeInfo.application_version?.cosmos_sdk_version ?? 'v0.45.99';
           await Promise.all(
@@ -88,15 +88,14 @@ export default class CrawlProposalService extends BullableService {
                 let proposal;
                 if (Utils.compareVersion(cosmosSdkVersion, 'v0.45.99') === -1) {
                   proposal =
-                    await this._lcdClient.auranw.cosmos.gov.v1beta1.proposal({
+                    await this._lcdClient.aura.cosmos.gov.v1beta1.proposal({
                       proposalId,
                     });
                 } else {
                   // use gov.v1 to call proposal
-                  proposal =
-                    await this._lcdClient.auranw.cosmos.gov.v1.proposal({
-                      proposalId,
-                    });
+                  proposal = await this._lcdClient.aura.cosmos.gov.v1.proposal({
+                    proposalId,
+                  });
                   proposal.proposal = {
                     ...proposal.proposal,
                     proposal_id: proposal.proposal.id,

src/services/crawl-proposal/crawl_tally_proposal.service.ts

@@ -88,7 +88,7 @@ export default class CrawlTallyProposalService extends BullableService {
       );
     });
 
-    const pool = await this._lcdClient.auranw.cosmos.staking.v1beta1.pool();
+    const pool = await this._lcdClient.aura.cosmos.staking.v1beta1.pool();
     const result: JsonRpcSuccessResponse[] = await Promise.all(batchQueries);
     const proposalTally: QueryTallyResultResponse[] = result.map(
       (res: JsonRpcSuccessResponse) =>

src/services/crawl-tx/aura.registry.ts

@@ -2,7 +2,7 @@
 import { Registry, TsProtoGeneratedType } from '@cosmjs/proto-signing';
 import { defaultRegistryTypes as defaultStargateTypes } from '@cosmjs/stargate';
 import { wasmTypes } from '@cosmjs/cosmwasm-stargate/build/modules';
-import { ibc, cosmos, auranw } from '@aura-nw/aurajs';
+import { ibc, cosmos, aura } from '@aura-nw/aurajs';
 import { toBase64, fromUtf8, fromBase64, toUtf8 } from '@cosmjs/encoding';
 import { LoggerInstance } from 'moleculer';
 import _ from 'lodash';
@@ -20,7 +20,7 @@ export default class AuraRegistry {
 
   public ibc: any;
 
-  public auranw: any;
+  public aura: any;
 
   public cosmosSdkVersion: SemVer = new SemVer('v0.45.17');
 
@@ -32,7 +32,7 @@ export default class AuraRegistry {
     this._logger = logger;
     this.cosmos = cosmos;
     this.ibc = ibc;
-    this.auranw = auranw;
+    this.aura = aura;
     this.setDefaultRegistry();
   }
 

src/services/crawl-tx/crawl_tx.service.ts

@@ -660,7 +660,7 @@ export default class CrawlTxService extends BullableService {
     const lcdClient = await getLcdClient();
     // set version cosmos sdk to registry
     const nodeInfo: GetNodeInfoResponseSDKType =
-      await lcdClient.auranw.cosmos.base.tendermint.v1beta1.getNodeInfo();
+      await lcdClient.aura.cosmos.base.tendermint.v1beta1.getNodeInfo();
     const cosmosSdkVersion = nodeInfo.application_version?.cosmos_sdk_version;
     if (cosmosSdkVersion) {
       this._registry.setCosmosSdkVersionByString(cosmosSdkVersion);

src/services/crawl-validator/crawl_delegators.service.ts

@@ -66,7 +66,7 @@ export default class CrawlDelegatorsService extends BullableService {
       countTotal: true,
     };
     const validatorDelegationInfo =
-      await this._lcdClient.auranw.cosmos.staking.v1beta1.validatorDelegations({
+      await this._lcdClient.aura.cosmos.staking.v1beta1.validatorDelegations({
         validatorAddr: _payload.address,
         pagination,
       });

src/services/crawl-validator/crawl_signing_info.service.ts

@@ -49,7 +49,7 @@ export default class CrawlSigningInfoService extends BullableService {
 
     if (foundValidators.length > 0) {
       const paramSlashing =
-        await this._lcdClient.auranw.cosmos.slashing.v1beta1.params();
+        await this._lcdClient.aura.cosmos.slashing.v1beta1.params();
 
       let resultCallApi;
       let done = false;
@@ -59,7 +59,7 @@ export default class CrawlSigningInfoService extends BullableService {
 
       while (!done) {
         resultCallApi =
-          await this._lcdClient.auranw.cosmos.slashing.v1beta1.signingInfos({
+          await this._lcdClient.aura.cosmos.slashing.v1beta1.signingInfos({
             pagination,
           });
 

src/services/crawl-validator/crawl_validator.service.ts

@@ -112,7 +112,7 @@ export default class CrawlValidatorService extends BullableService {
 
     while (!done) {
       resultCallApi =
-        await this._lcdClient.auranw.cosmos.staking.v1beta1.validators({
+        await this._lcdClient.aura.cosmos.staking.v1beta1.validators({
           pagination,
         });
 
@@ -196,7 +196,7 @@ export default class CrawlValidatorService extends BullableService {
   private async loadCustomInfo(validators: Validator[]): Promise<Validator[]> {
     const batchQueries: any[] = [];
 
-    const pool = await this._lcdClient.auranw.cosmos.staking.v1beta1.pool();
+    const pool = await this._lcdClient.aura.cosmos.staking.v1beta1.pool();
 
     validators.forEach((validator: Validator) => {
       const request: QueryDelegationRequest = {

src/services/statistics/dashboard_statistics.service.ts

@@ -109,10 +109,10 @@ export default class DashboardStatisticsService extends BullableService {
     ]);
 
     const [communityPool, inflation, distribution, supply] = await Promise.all([
-      this._lcdClient.auranw.cosmos.distribution.v1beta1.communityPool(),
-      this._lcdClient.auranw.cosmos.mint.v1beta1.inflation(),
-      this._lcdClient.auranw.cosmos.distribution.v1beta1.params(),
-      this._lcdClient.auranw.cosmos.bank.v1beta1.supplyOf({
+      this._lcdClient.aura.cosmos.distribution.v1beta1.communityPool(),
+      this._lcdClient.aura.cosmos.mint.v1beta1.inflation(),
+      this._lcdClient.aura.cosmos.distribution.v1beta1.params(),
+      this._lcdClient.aura.cosmos.bank.v1beta1.supplyOf({
         denom: config.networkDenom,
       }),
     ]);