using @oraichain/cw-simulate

.gitignore

@@ -26,4 +26,5 @@ typings/
 .env
 
 .npmrc
-build
+build
+*oraidex-sync-data*

.vscode/settings.json

@@ -0,0 +1,7 @@
+{
+    "prettier.singleQuote": false,
+    "prettier.trailingComma": "none",
+    "prettier.jsxSingleQuote": false,
+    "prettier.printWidth": 120,
+    "typescript.tsdk": "node_modules/typescript/lib"
+}

jest.config.js

@@ -0,0 +1,5 @@
+/** @type {import('ts-jest').JestConfigWithTsJest} */
+module.exports = {
+    preset: 'ts-jest',
+    testEnvironment: 'node',
+};

package.json

@@ -4,9 +4,12 @@
   "license": "MIT",
   "scripts": {
     "postinstall": "patch-package",
+    "test": "jest",
     "docs": "typedoc --entryPointStrategy expand --name 'Oraidex SDK' --readme none --tsconfig packages/contracts-sdk/tsconfig.json packages/contracts-sdk/src",
     "build": "tsc -p",
-    "deploy": "yarn publish --access public --patch"
+    "deploy": "yarn publish --access public --patch",
+    "start:server": "yarn build packages/oraidex-sync/ && npx ts-node packages/oraidex-server/src/index.ts"
+
   },
   "workspaces": [
     "packages/*"
@@ -15,17 +18,20 @@
     "node": ">=16 <=18"
   },
   "dependencies": {
-    "@cosmjs/amino": "^0.29.5",
-    "@cosmjs/cosmwasm-stargate": "^0.29.5",
-    "@cosmjs/crypto": "^0.29.5",
-    "@cosmjs/proto-signing": "^0.29.5",
-    "@cosmjs/stargate": "^0.29.5"
+    "@cosmjs/amino": "^0.31.0",
+    "@cosmjs/cosmwasm-stargate": "^0.31.0",
+    "@cosmjs/crypto": "^0.31.0",
+    "@cosmjs/proto-signing": "^0.31.0",
+    "@cosmjs/stargate": "^0.31.0"
   },
   "devDependencies": {
     "@oraichain/cw-simulate": "^2.8.33",
+    "@types/jest": "^29.5.2",
     "@types/node": "^18.15.8",
+    "jest": "^29.5.0",
     "lerna": "^5.6.1",
     "patch-package": "^7.0.0",
+    "ts-jest": "^29.1.1",
     "ts-node": "^10.9.1",
     "typedoc": "^0.24.7",
     "typescript": "^4.8.3"

packages/contracts-sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@oraichain/oraidex-contracts-sdk",
-  "version": "1.0.17",
+  "version": "1.0.19",
   "main": "build/index.js",
   "files": [
     "build/"

packages/contracts-sdk/src/OraiswapFactory.client.ts

@@ -6,7 +6,7 @@
 
 import { CosmWasmClient, SigningCosmWasmClient, ExecuteResult } from "@cosmjs/cosmwasm-stargate";
 import { Coin, StdFee } from "@cosmjs/amino";
-import {Addr, AssetInfo, PairInfo} from "./types";
+import {Addr, AssetInfo, Binary, PairInfo} from "./types";
 import {InstantiateMsg, ExecuteMsg, QueryMsg, MigrateMsg, ConfigResponse, PairsResponse} from "./OraiswapFactory.types";
 export interface OraiswapFactoryReadOnlyInterface {
   contractAddress: string;
@@ -91,6 +91,15 @@ export interface OraiswapFactoryInterface extends OraiswapFactoryReadOnlyInterfa
   }: {
     pairInfo: PairInfo;
   }, $fee?: number | StdFee | "auto", $memo?: string, $funds?: Coin[]) => Promise<ExecuteResult>;
+  migrateContract: ({
+    contractAddr,
+    msg,
+    newCodeId
+  }: {
+    contractAddr: string;
+    msg: Binary;
+    newCodeId: number;
+  }, $fee?: number | StdFee | "auto", $memo?: string, $funds?: Coin[]) => Promise<ExecuteResult>;
 }
 export class OraiswapFactoryClient extends OraiswapFactoryQueryClient implements OraiswapFactoryInterface {
   client: SigningCosmWasmClient;
@@ -105,6 +114,7 @@ export class OraiswapFactoryClient extends OraiswapFactoryQueryClient implements
     this.updateConfig = this.updateConfig.bind(this);
     this.createPair = this.createPair.bind(this);
     this.addPair = this.addPair.bind(this);
+    this.migrateContract = this.migrateContract.bind(this);
   }
 
   updateConfig = async ({
@@ -149,4 +159,21 @@ export class OraiswapFactoryClient extends OraiswapFactoryQueryClient implements
       }
     }, $fee, $memo, $funds);
   };
+  migrateContract = async ({
+    contractAddr,
+    msg,
+    newCodeId
+  }: {
+    contractAddr: string;
+    msg: Binary;
+    newCodeId: number;
+  }, $fee: number | StdFee | "auto" = "auto", $memo?: string, $funds?: Coin[]): Promise<ExecuteResult> => {
+    return await this.client.execute(this.sender, this.contractAddress, {
+      migrate_contract: {
+        contract_addr: contractAddr,
+        msg,
+        new_code_id: newCodeId
+      }
+    }, $fee, $memo, $funds);
+  };
 }

packages/contracts-sdk/src/OraiswapFactory.types.ts

@@ -1,4 +1,4 @@
-import {Addr, AssetInfo, PairInfo} from "./types";
+import {Addr, AssetInfo, Binary, PairInfo} from "./types";
 export interface InstantiateMsg {
   commission_rate?: string | null;
   oracle_addr: Addr;
@@ -20,6 +20,12 @@ export type ExecuteMsg = {
   add_pair: {
     pair_info: PairInfo;
   };
+} | {
+  migrate_contract: {
+    contract_addr: string;
+    msg: Binary;
+    new_code_id: number;
+  };
 };
 export type QueryMsg = {
   config: {};

packages/contracts-sdk/src/OraiswapOracle.client.ts

@@ -54,7 +54,9 @@ export class OraiswapOracleQueryClient implements OraiswapOracleReadOnlyInterfac
 
   taxRate = async (): Promise<TaxRateResponse> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      tax_rate: {}
+      treasury: {
+        tax_rate: {}
+      }
     });
   };
   taxCap = async ({
@@ -63,8 +65,10 @@ export class OraiswapOracleQueryClient implements OraiswapOracleReadOnlyInterfac
     denom: string;
   }): Promise<TaxCapResponse> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      tax_cap: {
-        denom
+      treasury: {
+        tax_cap: {
+          denom
+        }
       }
     });
   };
@@ -76,9 +80,11 @@ export class OraiswapOracleQueryClient implements OraiswapOracleReadOnlyInterfac
     quoteDenom: string;
   }): Promise<ExchangeRateResponse> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      exchange_rate: {
-        base_denom: baseDenom,
-        quote_denom: quoteDenom
+      exchange: {
+        exchange_rate: {
+          base_denom: baseDenom,
+          quote_denom: quoteDenom
+        }
       }
     });
   };
@@ -90,15 +96,19 @@ export class OraiswapOracleQueryClient implements OraiswapOracleReadOnlyInterfac
     quoteDenoms: string[];
   }): Promise<ExchangeRatesResponse> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      exchange_rates: {
-        base_denom: baseDenom,
-        quote_denoms: quoteDenoms
+      exchange: {
+        exchange_rates: {
+          base_denom: baseDenom,
+          quote_denoms: quoteDenoms
+        }
       }
     });
   };
   contractInfo = async (): Promise<ContractInfoResponse> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      contract_info: {}
+      contract: {
+        contract_info: {}
+      }
     });
   };
   rewardPool = async ({
@@ -107,8 +117,10 @@ export class OraiswapOracleQueryClient implements OraiswapOracleReadOnlyInterfac
     denom: string;
   }): Promise<Coin> => {
     return this.client.queryContractSmart(this.contractAddress, {
-      reward_pool: {
-        denom
+      contract: {
+        reward_pool: {
+          denom
+        }
       }
     });
   };

packages/contracts-sdk/src/types.ts

@@ -31,11 +31,11 @@ export interface PairInfo {
   liquidity_token: Addr;
   oracle_addr: Addr;
 }
-export type OrderDirection = "buy" | "sell";
 export interface Asset {
   amount: Uint128;
   info: AssetInfo;
 }
+export type OrderDirection = "buy" | "sell";
 export type OrderFilter = ("tick" | "none") | {
   bidder: string;
 } | {

packages/oraidex-server/.env.example

@@ -0,0 +1,11 @@
+PORT=2024
+RPC_URL=https://rpc.orai,io
+FACTORY_CONTACT_ADDRESS_V1="orai1hemdkz4xx9kukgrunxu3yw0nvpyxf34v82d2c8"
+FACTORY_CONTACT_ADDRESS_V2="orai167r4ut7avvgpp3rlzksz6vw5spmykluzagvmj3ht845fjschwugqjsqhst"
+ROUTER_CONTRACT_ADDRESS="orai1j0r67r9k8t34pnhy00x3ftuxuwg0r6r4p8p6rrc8az0ednzr8y9s3sj2sf"
+MULTICALL_CONTRACT_ADDRESS="orai1q7x644gmf7h8u8y6y8t9z9nnwl8djkmspypr6mxavsk9ual7dj0sxpmgwd"
+LIMIT=1000
+MAX_THREAD_LEVEL=3
+DUCKDB_PROD_FILENAME="oraidex-sync-data"
+DUCKDB_FILENAME="oraidex-sync-data-staging"
+INITIAL_SYNC_HEIGHT=12388825

packages/oraidex-server/package.json

@@ -0,0 +1,26 @@
+{
+  "name": "@oraichain/oraidex-server",
+  "version": "1.0.0",
+  "main": "build/index.js",
+  "license": "MIT",
+  "files": [
+    "build/"
+  ],
+  "scripts": {
+    "start": "npx ts-node src/index.ts"
+  },
+  "dependencies": {
+    "@cosmjs/cosmwasm-stargate": "^0.31.0",
+    "@cosmjs/stargate": "^0.31.0",
+    "@oraichain/common-contracts-sdk": "1.0.13",
+    "@cosmjs/tendermint-rpc": "^0.31.0",
+    "@oraichain/cosmos-rpc-sync": "^1.0.5",
+    "@oraichain/oraidex-sync": "1.0.0",
+    "cors": "^2.8.5",
+    "express": "^4.18.2"
+  },
+  "devDependencies": {
+    "@types/cors": "^2.8.13",
+    "@types/express": "^4.17.17"
+  }
+}

packages/oraidex-server/src/helper.ts

@@ -0,0 +1,9 @@
+export function parseSymbolsToTickerId(symbols: [string, string]) {
+  return `${symbols[0]}_${symbols[1]}`;
+}
+
+export function getDate24hBeforeNow(time: Date) {
+  const twentyFourHoursInMilliseconds = 24 * 60 * 60 * 1000; // 24 hours in milliseconds
+  const date24hBeforeNow = new Date(time.getTime() - twentyFourHoursInMilliseconds);
+  return date24hBeforeNow;
+}