feat: @demex-sdk/polynetwork

.gitignore

@@ -5,3 +5,5 @@ yarn-error.log
 *.tsbuildinfo
 dist
 dist-*
+
+.env

package.json

@@ -16,6 +16,7 @@
   },
   "packageManager": "yarn@1.22.19",
   "dependencies": {
-    "@changesets/cli": "^2.27.9"
+    "@changesets/cli": "^2.27.9",
+    "turbo": "2.3.0"
   }
 }

packages/core/package.json

@@ -13,11 +13,19 @@
   "module": "./dist-es/index.js",
   "types": "./dist-types/index.d.ts",
   "dependencies": {
-    "@demex-sdk/codecs": "0.0.3",
+    "@cityofzion/neon-core-next": "npm:@cityofzion/neon-core@^5.0.0",
     "@cosmjs/stargate": "^0.32.4",
     "@cosmjs/tendermint-rpc": "^0.32.4",
+    "@demex-sdk/codecs": "0.0.3",
     "@improbable-eng/grpc-web": "^0.15.0",
     "@improbable-eng/grpc-web-node-http-transport": "^0.15.0",
+    "base58check": "^2.0.0",
+    "bignumber.js": "^9.1.2",
+    "bip32": "^2.0.6",
+    "bip39": "^3.0.4",
+    "ethers": "^6.13.4",
+    "secp256k1": "^4.0.2",
+    "secp256r1": "^0.0.3",
     "tslib": "^2.6.2"
   },
   "exports": {
@@ -39,6 +47,9 @@
     "dist-*/**"
   ],
   "devDependencies": {
+    "@types/crypto-js": "4.2.0",
+    "@types/secp256k1": "^4.0.2",
+    "@types/wif": "^2.0.2",
     "concurrently": "7.0.0",
     "eslint": "^9.13.0"
   }

packages/core/src/env/address.ts

@@ -0,0 +1 @@
+export type Bech32AddrType = "main" | "validator" | "consensus";

packages/core/src/env/chain.ts

@@ -0,0 +1,33 @@
+import { Carbon } from "@demex-sdk/codecs";
+
+export interface PolyNetworkBridge extends Carbon.Coin.Bridge {
+  isEvmChain: boolean;
+};
+
+export interface IbcBridge extends Carbon.Coin.Bridge {
+  chain_id_name: string;
+  channels: {
+    src_channel: string;
+    dst_channel: string;
+    port_id: string; // for cosmwasm bridges
+  }
+};
+
+export interface AxelarBridge extends Carbon.Coin.Bridge {
+  chain_id_name: string;
+  bridgeAddress: string;
+};
+
+export interface BridgeMap {
+  polynetwork: PolyNetworkBridge[]
+  ibc: IbcBridge[]
+  axelar: AxelarBridge[]
+};
+
+export type BlockchainV2 = ReturnType<TokenClient['getAllBlockchainNames']>[number] | "Native" | "Carbon" | "Tradehub" | "Ibc" | "Polynetwork";
+
+export const BRIDGE_IDS = {
+  polynetwork: 1,
+  ibc: 2,
+  axelar: 3,
+};

packages/core/src/env/crypto.ts

@@ -0,0 +1,5 @@
+export const BIP44_PURPOSE = 44;
+export const NEO_COIN_TYPE = 0x00000378;
+export const ETH_COIN_TYPE = 0x0000003c;
+
+export const SWTH_COIN_TYPE = 118;

packages/core/src/env/index.ts

@@ -0,0 +1,4 @@
+export * from "./address";
+export * from "./chain";
+export * from "./crypto";
+export * from "./network";

packages/core/src/env/network.ts

@@ -0,0 +1,63 @@
+export enum Network {
+  MainNet = "mainnet",
+  TestNet = "testnet",
+  DevNet = "devnet",
+  Local = "local",
+}
+
+export interface NetworkConfig {
+  network: Network
+  chainId: string
+
+  tmRpcUrl: string
+  restUrl: string
+  grpcUrl: string
+
+  bech32Prefix: string;
+};
+
+export interface NetworkConfigProvider {
+  getConfig(): NetworkConfig;
+};
+
+export const defaultNetworkConfig: Record<Network, NetworkConfig> = {
+  [Network.MainNet]: {
+    network: Network.MainNet,
+    chainId: "carbon-1",
+
+    tmRpcUrl: "https://tm-api.carbon.network",
+    restUrl: "https://api.carbon.network",
+    grpcUrl: "grpc.carbon.network",
+
+    bech32Prefix: "swth",
+  },
+  [Network.TestNet]: {
+    network: Network.TestNet,
+    chainId: "carbon-1",
+
+    tmRpcUrl: "https://test-tm-api.carbon.network",
+    restUrl: "https://test-api.carbon.network",
+    grpcUrl: "test-grpc.carbon.network",
+
+    bech32Prefix: "tswth",
+  },
+  [Network.DevNet]: {
+    network: Network.DevNet,
+    chainId: "carbon-1",
+
+    tmRpcUrl: "https://dev-tm-api.carbon.network",
+    restUrl: "https://dev-api.carbon.network",
+    grpcUrl: "dev-grpc.carbon.network",
+
+    bech32Prefix: "swth",
+  },
+  [Network.Local]: {
+    network: Network.Local,
+    chainId: "carbon-1",
+    tmRpcUrl: "http://localhost:26657",
+    restUrl: "http://localhost:1317",
+    grpcUrl: "localhost:9090",
+
+    bech32Prefix: "tswth",
+  },
+};

packages/core/src/helpers/index.ts

@@ -0,0 +1 @@
+export * from "./token";

packages/core/src/helpers/token.ts

@@ -0,0 +1,118 @@
+import { Carbon } from "@demex-sdk/codecs";
+import Long from "long";
+import { DemexQueryClient, Network, NetworkConfigProvider, OptionalNetworkMap } from "@demex-sdk/core";
+import { AxelarBridge, BlockchainV2, BRIDGE_IDS, BridgeMap, IbcBridge, ibcTokenRegex, regexLPDenom, regexCdpDenom } from "../../env";
+import { SimpleMap } from "../../util";
+
+export const TokenBlacklist: OptionalNetworkMap<string[]> = {
+  [Network.MainNet]: [
+    "brkl.1.2.337f55", // wrong token address
+    "zusdt.1.18.1cbca1", // duplicated token
+  ],
+};
+
+// This class is just created as a stand-in class for polynetwork bridge helpers (i.e. packages/polynetwork/src/clients/...), this is not final
+// Pls make any changes if required
+export class TokenClient {
+  public readonly tokens: SimpleMap<Carbon.Coin.Token> = {};
+  public readonly bridges: BridgeMap = { polynetwork: [], ibc: [], axelar: [] };
+
+  private constructor(public readonly query: DemexQueryClient, public readonly configProvider: NetworkConfigProvider) { }
+
+  public static instance(query: DemexQueryClient, configProvider: NetworkConfigProvider) {
+    return new TokenClient(query, configProvider);
+  }
+
+  public async getAllTokens(): Promise<Carbon.Coin.Token[]> {
+    const result = await this.query.coin.TokenAll({
+      pagination: {
+        limit: new Long(10000),
+        offset: Long.UZERO,
+        key: new Uint8Array(),
+        countTotal: false,
+        reverse: false,
+      },
+    });
+
+    const networkConfig = this.configProvider.getConfig();
+    const tokenBlacklist = TokenBlacklist[networkConfig.network] ?? [];
+    return result.tokens.filter((token) => !tokenBlacklist.includes(token.denom));
+  };
+
+  public getBlockchainV2(denom: string | undefined): BlockchainV2 | undefined {
+    if (!denom) return undefined
+    const token = this.tokens[denom]
+    if (this.isNativeToken(denom) || this.isNativeStablecoin(denom) || TokenClient.isPoolToken(denom) || TokenClient.isCdpToken(denom) || this.isGroupedToken(denom)) {
+      // native denoms "swth" and "usc" should be native.
+      // pool and cdp tokens are on the Native blockchain, hence 0
+      return 'Native'
+    }
+
+    if (this.isBridgedToken(denom)) {
+      // brdg tokens will all be chain_id 0 which will also be deprecated in future
+      // hence for brdg tokens cannot use chain_id to differentiate between blockchains
+      const bridgeList = this.bridges.axelar
+      const chainName = bridgeList.find((bridge) => bridge.bridgeAddress === token.bridgeAddress)?.chainName
+      return chainName
+    }
+    const bridge = this.getBridgeFromToken(token)
+    return bridge?.chainName;
+  };
+
+  public getBridgesFromBridgeId(bridgeId: number): Carbon.Coin.Bridge[] | IbcBridge[] | AxelarBridge[] {
+    switch (bridgeId) {
+      case BRIDGE_IDS.polynetwork:
+        return this.bridges.polynetwork
+      case BRIDGE_IDS.ibc:
+        return this.bridges.ibc
+      case BRIDGE_IDS.axelar:
+        return this.bridges.axelar
+      default:
+        return this.bridges.polynetwork
+    }
+  };
+
+  public getBridgeFromToken(token: Carbon.Coin.Token | null): Carbon.Coin.Bridge | IbcBridge | undefined {
+    if (!token || !token.bridgeId) return undefined
+    const bridgeList = this.getBridgesFromBridgeId(token.bridgeId.toNumber())
+    return bridgeList.find(bridge => token.chainId.equals(bridge.chainId))
+  };
+
+  public isNativeToken(denom: string): boolean {
+    return denom === "swth";
+  };
+
+  public isNativeStablecoin(denom: string): boolean {
+    return denom === "usc";
+  };
+
+  public static isPoolToken(denom: string): boolean {
+    return this.isPoolTokenNew(denom) || this.isPoolTokenLegacy(denom);
+  };
+
+  public static isPoolTokenNew(denom: string): boolean {
+    return denom.match(regexLPDenom) !== null;
+  };
+
+  public static isPoolTokenLegacy(denom: string): boolean {
+    return denom.match(/^([a-z\d.-]+)-(\d+)-([a-z\d.-]+)-(\d+)-lp\d+$/i) !== null;
+  };
+
+  public static isCdpToken(denom: string): boolean {
+    return denom.match(regexCdpDenom) !== null;
+  };
+
+  public static isIBCDenom(denom: string): boolean {
+    return denom.match(ibcTokenRegex) !== null;
+  };
+
+  public isBridgedToken(denom: string): boolean {
+    const bridgedTokenRegex = new RegExp(/^brdg\//)
+    return bridgedTokenRegex.test(denom)
+  };
+
+  public isGroupedToken(denom: string): boolean {
+    const groupedTokenRegex = new RegExp(/^cgt\/\d+$/)
+    return groupedTokenRegex.test(denom)
+  };
+};

packages/core/src/index.ts

@@ -1,2 +1,4 @@
-export * from "./client";
+export * from "./env";
+export * from "./helpers";
 export * from "./query";
+export * from "./util";

packages/core/src/query/client.ts

@@ -4,7 +4,7 @@ import { AdlQueryClient, AllianceQueryClient, AuthQueryClient, AuthzQueryClient,
 import { BlockchainClient } from "./chain";
 import { GrpcQueryClient } from "./grpc";
 
-export interface CarbonQueryClientOpts {
+export interface DemexQueryClientOpts {
   tmClient: Tendermint37Client;
   grpcClient?: GrpcQueryClient;
 }
@@ -80,12 +80,12 @@ const extendQueryClient = (tmClient: Tendermint37Client, rpcClient: Rpc) => Quer
   },
 }))
 
-type CarbonQueryClient = ReturnType<typeof extendQueryClient>;
-namespace CarbonQueryClient {
-  export const instance = (opts: CarbonQueryClientOpts) => {
+type DemexQueryClient = ReturnType<typeof extendQueryClient>;
+namespace DemexQueryClient {
+  export const instance = (opts: DemexQueryClientOpts) => {
     const rpcClient = opts.grpcClient ?? createProtobufRpcClient(new QueryClient(opts.tmClient));
     return extendQueryClient(opts.tmClient, rpcClient);
   }
 }
 
-export { CarbonQueryClient };
+export { DemexQueryClient };