cosmossdk cw20 quote token (#3671)

- **fix(typescript-sdk): quote token check**
- **feat(typescript-sdk): cosmos quote token prediction**
- **fix(typescript-sdk): fix incorrect dest chain id**

Author: cor

Cargo.lock

@@ -88,7 +88,7 @@ members = [
   "cosmwasm/ibc-union/light-clients/berachain",
   "cosmwasm/ibc-union/light-clients/cometbls",
   "cosmwasm/ibc-union/light-clients/ethereum",
-  "cosmwasm/ibc-union/light-clients/ethermint",
+  # "cosmwasm/ibc-union/light-clients/ethermint",
   "cosmwasm/ibc-union/light-clients/tendermint",
   "cosmwasm/ibc-union/light-clients/state-lens-ics23-mpt",
 

Cargo.toml

@@ -1,6 +1,6 @@
 {
   "name": "@unionlabs/client",
-  "version": "0.0.53",
+  "version": "0.0.54",
   "homepage": "https://union.build",
   "description": "Union Labs cross-chain transfers client",
   "type": "module",

typescript-sdk/package.json

@@ -0,0 +1,95 @@
+import { fromHex, http } from "viem"
+import { parseArgs } from "node:util"
+import { consola } from "scripts/logger"
+import { createUnionClient, hexToBytes } from "#mod.ts"
+import {
+  getChannelInfo,
+  getQuoteToken,
+  getRecommendedChannels
+} from "#query/offchain/ucs03-channels"
+import { DirectSecp256k1Wallet } from "@cosmjs/proto-signing"
+
+// hack to encode bigints to json
+declare global {
+  interface BigInt {
+    toJSON: () => string
+  }
+}
+
+if (!BigInt.prototype.toJSON) {
+  Object.defineProperty(BigInt.prototype, "toJSON", {
+    value: function () {
+      return this.toString()
+    },
+    writable: true,
+    configurable: true
+  })
+}
+// end hack
+
+const cliArgs = parseArgs({
+  args: process.argv.slice(2),
+  options: {
+    "private-key": { type: "string" },
+    "estimate-gas": { type: "boolean", default: false }
+  }
+})
+
+const PRIVATE_KEY = cliArgs.values["private-key"]
+const STARS_DENOM = "ubbn"
+const AMOUNT = 1n
+const RECEIVER = "0xE6831e169d77a861A0E71326AFA6d80bCC8Bc6aA"
+const SOURCE_CHAIN_ID = "bbn-test-5"
+const DESTINATION_CHAIN_ID = "union-testnet-9"
+
+const channels = await getRecommendedChannels()
+
+const channel = getChannelInfo(SOURCE_CHAIN_ID, DESTINATION_CHAIN_ID, channels)
+if (channel === null) {
+  consola.info("no channel found")
+  process.exit(1)
+}
+
+consola.info("channel", channel)
+
+const quoteToken = await getQuoteToken(SOURCE_CHAIN_ID, STARS_DENOM, channel)
+if (quoteToken.isErr()) {
+  consola.info("could not get quote token")
+  consola.error(quoteToken.error)
+  process.exit(1)
+}
+
+if (quoteToken.value.type === "NO_QUOTE_AVAILABLE") {
+  consola.error("No quote token available")
+  process.exit(1)
+}
+consola.info("quote token", quoteToken.value)
+
+if (!PRIVATE_KEY) {
+  consola.error("no private key provided")
+  process.exit(1)
+}
+
+const unionClient = createUnionClient({
+  chainId: SOURCE_CHAIN_ID,
+  account: await DirectSecp256k1Wallet.fromKey(Uint8Array.from(hexToBytes(PRIVATE_KEY)), "bbn"),
+  gasPrice: { amount: "0.025", denom: "ubbn" },
+  transport: http("https://rpc.bbn-test-5.babylon.chain.kitchen")
+})
+
+const transfer = await unionClient.transferAsset({
+  baseToken: STARS_DENOM,
+  baseAmount: AMOUNT,
+  quoteToken: quoteToken.value.quote_token,
+  quoteAmount: AMOUNT,
+  receiver: RECEIVER,
+  sourceChannelId: channel.source_channel_id,
+  ucs03address: fromHex(`0x${channel.source_port_id}`, "string")
+})
+
+if (transfer.isErr()) {
+  consola.error("transfer submission failed:", transfer.error)
+  process.exit(1)
+}
+
+consola.info("transfer tx hash", transfer.value)

typescript-sdk/playground/babylon-to-union.ts

@@ -44,6 +44,11 @@ if (quoteToken.isErr()) {
 
 consola.info("quote token", quoteToken.value)
 
+if (quoteToken.value.type === "NO_QUOTE_AVAILABLE") {
+  consola.error("No quote token available")
+  process.exit(1)
+}
+
 const transferArgs = {
   baseToken: BASE_TOKEN,
   baseAmount: AMOUNT,

typescript-sdk/playground/holesky-to-sepolia.ts

@@ -0,0 +1,34 @@
+import { CosmWasmClient } from "@cosmjs/cosmwasm-stargate"
+import { consola } from "scripts/logger"
+import { ResultAsync } from "neverthrow"
+import { toHex } from "viem"
+
+let publicClient = await ResultAsync.fromPromise(
+  CosmWasmClient.connect("https://rpc.bbn-test-5.babylon.chain.kitchen"),
+  error => {
+    return new Error("failed to create public cosmos client", { cause: error })
+  }
+)
+
+if (publicClient.isErr()) {
+  consola.error(publicClient.error)
+  process.exit(1)
+}
+
+let client = publicClient.value
+
+// TODO: don't haredcode this either.
+let quoteToken = await ResultAsync.fromPromise(
+  client.queryContractSmart("bbn1mvvl3jvyn8dh9whfzkdzgedk56cjge7stsfwdjrcsvczns5waqzs6023q4", {
+    predict_wrapped_denom: { path: "0", channel: 6, token: toHex("ubbn") }
+  }),
+  error => {
+    return new Error("failed to query predict wrapped denom", { cause: error })
+  }
+)
+
+consola.info(quoteToken)
+
+if (quoteToken.isOk()) {
+  consola.info(toHex(quoteToken.value))
+}

typescript-sdk/playground/quote-token-test.ts

@@ -59,6 +59,11 @@ if (quoteToken.isErr()) {
   process.exit(1)
 }
 
+if (quoteToken.value.type === "NO_QUOTE_AVAILABLE") {
+  consola.error("No quote token available")
+  process.exit(1)
+}
+
 consola.info("quote token", quoteToken.value)
 
 if (!PRIVATE_KEY) {
@@ -84,8 +89,7 @@ const transfer = await stargazeClient.transferAsset({
 })
 
 if (transfer.isErr()) {
-  consola.info("transfer submission failed")
-  consola.error(transfer.error)
+  consola.error("transfer submission failed:", transfer.error)
   process.exit(1)
 }
 

typescript-sdk/playground/stargaze-to-holesky.ts

@@ -0,0 +1,95 @@
+import { fromHex, http } from "viem"
+import { parseArgs } from "node:util"
+import { consola } from "scripts/logger"
+import { createUnionClient, hexToBytes } from "#mod.ts"
+import {
+  getChannelInfo,
+  getQuoteToken,
+  getRecommendedChannels
+} from "#query/offchain/ucs03-channels"
+import { DirectSecp256k1Wallet } from "@cosmjs/proto-signing"
+
+// hack to encode bigints to json
+declare global {
+  interface BigInt {
+    toJSON: () => string
+  }
+}
+
+if (!BigInt.prototype.toJSON) {
+  Object.defineProperty(BigInt.prototype, "toJSON", {
+    value: function () {
+      return this.toString()
+    },
+    writable: true,
+    configurable: true
+  })
+}
+// end hack
+
+const cliArgs = parseArgs({
+  args: process.argv.slice(2),
+  options: {
+    "private-key": { type: "string" },
+    "estimate-gas": { type: "boolean", default: false }
+  }
+})
+
+const PRIVATE_KEY = cliArgs.values["private-key"]
+const STARS_DENOM = "muno"
+const AMOUNT = 1n
+const RECEIVER = "0xE6831e169d77a861A0E71326AFA6d80bCC8Bc6aA"
+const SOURCE_CHAIN_ID = "union-testnet-9"
+const DESTINATION_CHAIN_ID = "bbn-test-5"
+
+const channels = await getRecommendedChannels()
+
+const channel = getChannelInfo(SOURCE_CHAIN_ID, DESTINATION_CHAIN_ID, channels)
+if (channel === null) {
+  consola.info("no channel found")
+  process.exit(1)
+}
+
+consola.info("channel", channel)
+
+const quoteToken = await getQuoteToken(SOURCE_CHAIN_ID, STARS_DENOM, channel)
+if (quoteToken.isErr()) {
+  consola.info("could not get quote token")
+  consola.error(quoteToken.error)
+  process.exit(1)
+}
+
+if (quoteToken.value.type === "NO_QUOTE_AVAILABLE") {
+  consola.error("No quote token available")
+  process.exit(1)
+}
+consola.info("quote token", quoteToken.value)
+
+if (!PRIVATE_KEY) {
+  consola.error("no private key provided")
+  process.exit(1)
+}
+
+const unionClient = createUnionClient({
+  chainId: SOURCE_CHAIN_ID,
+  account: await DirectSecp256k1Wallet.fromKey(Uint8Array.from(hexToBytes(PRIVATE_KEY)), "union"),
+  gasPrice: { amount: "0.025", denom: "muno" },
+  transport: http("https://rpc.testnet-9.union.build")
+})
+
+const transfer = await unionClient.transferAsset({
+  baseToken: STARS_DENOM,
+  baseAmount: AMOUNT,
+  quoteToken: quoteToken.value.quote_token,
+  quoteAmount: AMOUNT,
+  receiver: RECEIVER,
+  sourceChannelId: channel.source_channel_id,
+  ucs03address: fromHex(`0x${channel.source_port_id}`, "string")
+})
+
+if (transfer.isErr()) {
+  consola.error("transfer submission failed:", transfer.error)
+  process.exit(1)
+}
+
+consola.info("transfer tx hash", transfer.value)

typescript-sdk/playground/union-to-babylon.ts

@@ -1,6 +1,5 @@
 import {
   cosmwasmTransfer,
-  ibcTransferSimulate,
   cosmwasmTransferSimulate,
   cosmosSameChainTransferSimulate
 } from "./transfer.ts"
@@ -16,15 +15,21 @@ import type {
 } from "../types.ts"
 
 export const cosmosChainId = [
-  "mocha-4",
   "elgafar-1",
   "osmo-test-5",
-  "union-testnet-8",
   "union-testnet-9",
   "stride-internal-1",
   "bbn-test-5"
 ] as const
 
+export const cosmosRpcs: Record<CosmosChainId, string> = {
+  "elgafar-1": "https://rpc.elgafar-1.stargaze.chain.kitchen",
+  "osmo-test-5": "https://rpc.osmo-test-5.osmosis.chain.kitchen",
+  "union-testnet-9": "https://rpc.union-testnet-9.union.chain.kitchen",
+  "stride-internal-1": "https://rpc.stride-internal-1.stride.chain.kitchen",
+  "bbn-test-5": "https://rpc.bbn-test-5.babylon.chain.kitchen"
+}
+
 export type CosmosChainId = `${(typeof cosmosChainId)[number]}`
 
 export interface CosmosClientParameters {
@@ -222,32 +227,6 @@ export const createCosmosClient = (parameters: CosmosClientParameters) =>
           ]
         })
       }
-
-      if (destinationChainId === "union-testnet-8") {
-        if (!sourceChannel) return err(new Error("Source channel not found"))
-        const [account_] = await account.getAccounts()
-        if (!account) return err(new Error("No account found"))
-
-        const stamp = timestamp()
-
-        return await ibcTransferSimulate({
-          gasPrice,
-          account,
-          rpcUrl,
-          messageTransfers: [
-            {
-              sourceChannel: sourceChannel.toString(),
-              sourcePort: "transfer",
-              sender: account_?.address,
-              token: { denom: denomAddress, amount: amount.toString() },
-              timeoutHeight: { revisionHeight: 888_888_888n, revisionNumber: 8n },
-              receiver: receiver.startsWith("0x") ? receiver.slice(2) : receiver,
-              memo: memo ?? `${stamp} Sending ${amount} ${denomAddress} to ${receiver}`
-            }
-          ]
-        })
-      }
-
       return err(new Error("Unsupported network"))
     }
   }))