feat: XCM native transfer tool call (#58)

+ Add XCM native token transfer Relay <-> Parachain
+ Fix bug transfer tool call

Author: CocDap

.github/workflows/ci.yaml

@@ -17,6 +17,8 @@ jobs:
         run: |
           echo COREPACK_INTEGRITY_KEYS="$(curl https://registry.npmjs.org/-/npm/v1/keys | jq -c '{npm: .keys}')" >> $GITHUB_ENV
       - run: corepack enable
+      - name: Install pnpm
+        run: corepack prepare pnpm@10.6.5 --activate
       - uses: actions/setup-node@v4
         with:
           node-version: 22

examples/telegram-bot/src/TelegramBot.ts

@@ -56,10 +56,14 @@ export class TelegramBot {
       const checkBalance = this.agent.getNativeBalanceTool();
       // Transfer native tokens to a recipient address on a specific chain.
       const transferNative = this.agent.transferNativeTool();
+      // Transfer native tokens to a recipient address on a specific chain via xcm.
+      // xcm_transfer_native_asset
+      const xcmTransferNativeAsset = this.agent.xcmTransferNativeTool();
 
       setupHandlers(this.bot, this.llm, {
         checkBalance: checkBalance,
         transferNative: transferNative,
+        xcmTransferNativeAsset: xcmTransferNativeAsset,
       });
 
       console.log("Bot initialization complete");

examples/telegram-bot/src/handlers.ts

@@ -9,16 +9,46 @@ const SYSTEM_PROMPT = `I am a Telegram bot powered by PolkadotAgentKit. I can as
 - Checking proxies (e.g., "check proxies on westend" or "check proxies")
 - Transfer tokens through XCM (e.g., "transfer 1 WND to 5CSox4ZSN4SGLKUG9NYPtfVK9sByXLtxP4hmoF4UgkM4jgDJ from west to westend_asset_hub ")
 
+IMPORTANT: When users mention chain names, I must convert them to the correct parameter values using this mapping:
+
+| User Input | Real Param (USE THIS IN TOOL CALLS) |
+|------------|-------------------------------------|
+| Westend | west |
+| Westend Asset Hub | west_asset_hub |
+| Polkadot | polkadot |
+| Kusama | kusama |
+
+CHAIN NAME CONVERSION RULES:
+- Always use the "Real Param" values when calling tools
+- "Westend" → "west"
+- "Westend Asset Hub" → "west_asset_hub"  
+- "Polkadot" → "polkadot"
+- "Kusama" → "kusama"
+
+For XCM transfers, when the user says:
+"transfer X WND to [address] from [source_chain_user_input] to [dest_chain_user_input]"
+
+I must:
+1. Convert source chain user input to real param (e.g., "Westend" → "west")
+2. Convert destination chain user input to real param (e.g., "Westend Asset Hub" → "west_asset_hub")
+3. Use these converted values in the tool call parameters
+
+Example:
+User: "transfer 0.1 WND to 5D7jcv6aYbhbYGVY8k65oemM6FVNoyBfoVkuJ5cbFvbefftr from Westend to Westend Asset Hub"
+Tool call should use: sourceChain: "west", destChain: "west_asset_hub"
+
 When transferring tokens, please provide:
 1. The amount of tokens to transfer (e.g., 1)
 2. The address to receive the tokens (e.g., 5CSox4ZSN4SGLKUG9NYPtfVK9sByXLtxP4hmoF4UgkM4jgDJ)
-3. The name of the destination chain (e.g., westend, westend_asset_hub)
-
+3. The name of the destination chain (convert to real param)
 
-Suggested syntax: "transfer [amount] token to [chain name] to [address]"
+When transferring tokens through XCM, please provide:
+1. The amount of tokens to transfer (e.g., 1)
+2. The address to receive the tokens (e.g., 5CSox4ZSN4SGLKUG9NYPtfVK9sByXLtxP4hmoF4UgkM4jgDJ)
+3. The name of the source chain (convert to real param)
+4. The name of the destination chain (convert to real param)
 
-When checking proxies, you can specify the chain (e.g., "check proxies on westend") or 
-not specify a chain (the first chain will be used by default)
+When checking proxies, you can specify the chain (convert to real param) or not specify a chain (the first chain will be used by default)
 
 Please provide instructions, and I will assist you!`;
 
@@ -34,6 +64,7 @@ export function setupHandlers(
         '- Transferring native tokens  (e.g., "transfer 1 token to westend_asset_hub to 5CSox4ZSN4SGLKUG9NYPtfVK9sByXLtxP4hmoF4UgkM4jgDJ")\n' +
         '- Checking balance (e.g., "check balance on west/polkadot/kusama")\n' +
         '- Checking proxies (e.g., "check proxies on westend" or "check proxies")\n' +
+        '- Transfer tokens through XCM (e.g., "transfer 1 WND to 5CSox4ZSN4SGLKUG9NYPtfVK9sByXLtxP4hmoF4UgkM4jgDJ from west to west_asset_hub ")\n' +
         "Try asking something!",
     );
   });
@@ -60,6 +91,7 @@ export function setupHandlers(
               return;
             }
             const response = JSON.parse(toolMessage.content || "{}");
+            console.log("response", response);
             if (response.error) {
               await ctx.reply(`Error: ${response.message}`);
             } else {

packages/common/src/api/api.ts

@@ -16,8 +16,10 @@ import {
 import { type ClientOptions, getClient } from "../clients/client"
 
 export type LightClients = ClientOptions["lightClients"]
+
 type ApiBase<Id extends ChainId> = Id extends KnownChainId
-  ? TypedApi<Descriptors<Id>>
+  ? // @ts-ignore
+    TypedApi<Descriptors<Id>>
   : TypedApi<ChainDefinition>
 
 export type Api<Id extends ChainId> = ApiBase<Id> & {
@@ -50,6 +52,7 @@ export const getApiInner = async <Id extends ChainId>(
   const client = await getClient(chainId, chains, { lightClients })
   if (!client) throw new Error(`Could not create client for chain ${chainId}`)
 
+  // @ts-ignore
   const api = client.getTypedApi(descriptors ?? polkadot) as Api<Id>
 
   api.chainId = chainId as Id

packages/common/src/chains/supported-chains.ts

@@ -12,10 +12,10 @@ export const polkadotChain = createChain({
   id: "polkadot",
   name: "Polkadot",
   specName: "polkadot",
-  wsUrls: ["wss://polkadot-rpc.dwellir.com"],
+  wsUrls: ["wss://polkadot-rpc.n.dwellir.com"],
   relay: "polkadot",
   type: "relay",
-  chainId: null,
+  chainId: 0,
   blockExplorerUrl: "https://polkadot.subscan.io",
   prefix: 0,
   decimals: 10,
@@ -43,7 +43,7 @@ export const westendChain = createChain({
   wsUrls: ["wss://westend-rpc.polkadot.io"],
   relay: "west",
   type: "relay",
-  chainId: null,
+  chainId: 0,
   blockExplorerUrl: "https://westend.subscan.io",
   xcmExtrinsic: "limited_teleport_assets",
   prefix: 42, // default

packages/common/src/index.ts

@@ -3,4 +3,3 @@ export * from "./chains"
 export * from "./clients"
 export * from "./types"
 export * from "./utils"
-export * from "./utils"

packages/common/src/types/account.ts

@@ -1,72 +1,18 @@
-import { ed25519 } from "@noble/curves/ed25519"
-import type { PolkadotSigner } from "polkadot-api/signer"
-import { getPolkadotSigner } from "polkadot-api/signer"
-export type Hex = Uint8Array | string
-
-import * as ss58 from "@subsquid/ss58"
-
-export function buildAccountSigner(): PolkadotSigner {
-  const seed = getPrivateKey(process.env.PRIVATE_KEY) as string
-  const signer = getPolkadotSigner(ed25519.getPublicKey(seed), "Ed25519", input =>
-    ed25519.sign(input, seed)
-  )
-  return signer
-}
-
-export function buildAccountDelegateProxySigner(): PolkadotSigner {
-  const seed = getPrivateKey(process.env.DELEGATE_PRIVATE_KEY) as string
-  const signer = getPolkadotSigner(ed25519.getPublicKey(seed), "Ed25519", input =>
-    ed25519.sign(input, seed)
-  )
-  return signer
-}
-
-export function getPrivateKey(account?: string) {
-  return account || process.env.PRIVATE_KEY
-}
-
-export function publicKeyOf(seed?: string) {
-  let privateKey: Hex | undefined = seed || getPrivateKey()
-  if (!privateKey) {
-    privateKey = ed25519.utils.randomPrivateKey()
-  }
-  return ed25519.getPublicKey(privateKey)
-}
-
-/**
- * Check if a value is a hex string
- * @param value - the value to check
- **/
-export function isHex(value: unknown): value is string {
-  return typeof value === "string" && value.length % 2 === 0 && /^0x[\da-f]*$/i.test(value)
-}
-
-/**
- * Decode an ss58 address from the value
- * @param address - the address to decode
- **/
-export function addressOf(address: Uint8Array): string {
-  const value = address
-  if (!value) {
-    return ""
-  }
-  return ss58.codec("polkadot").encode(value)
-}
-
-export function addressOfSubstrate(address: Uint8Array): string {
-  const value = address
-  if (!value) {
-    return ""
-  }
-  return ss58.codec("substrate").encode(value)
-}
-
 export interface BalanceInfo {
   balance: bigint
   decimals: number
   symbol: string
 }
 
-// export function toMultiAddress(address: string): MultiAddress {
-//   return MultiAddress.Id(address);
-// }
+export interface AccountData {
+  nonce: number
+  consumers: number
+  providers: number
+  sufficients: number
+  data: {
+    free: bigint
+    reserved: bigint
+    frozen: bigint
+    flags: bigint
+  }
+}

packages/core/package.json

@@ -35,9 +35,15 @@
     "test:watch": "vitest"
   },
   "dependencies": {
+    "@paraspell/sdk": "^10.5.2",
     "@polkadot-agent-kit/common": "workspace:*",
+    "@polkadot/util-crypto": "^13.5.1",
     "@subsquid/ss58": "^2.0.2",
-    "polkadot-api": "^1.9.13"
+    "polkadot-api": "^1.9.13",
+    "rxjs": "^7.8.2",
+    "@substrate/asset-transfer-api": "^0.7.2",
+    "@polkadot/api": "^16.2.2",
+    "@polkadot/keyring": "^13.5.1"
   },
   "devDependencies": {
     "@babel/plugin-syntax-import-attributes": "^7.26.0",

packages/core/src/index.ts

@@ -1,4 +1,6 @@
 // Polkadot Core exports
 export * from "./api"
 export * from "./pallets/assets"
+export * from "./pallets/xcm"
+export * from "./types"
 export * from "./utils"

packages/core/src/pallets/assets/getNativeBalance.ts

@@ -1,4 +1,4 @@
-import type { Api, BalanceInfo, KnownChainId } from "@polkadot-agent-kit/common"
+import type { AccountData, Api, BalanceInfo, KnownChainId } from "@polkadot-agent-kit/common"
 import { getAllSupportedChains, getChainById } from "@polkadot-agent-kit/common"
 
 /**
@@ -11,7 +11,7 @@ export const getNativeBalance = async (
   api: Api<KnownChainId>,
   address: string
 ): Promise<BalanceInfo> => {
-  const balance = await api.query.System.Account.getValue(address)
+  const balance = (await api.query.System.Account.getValue(address)) as AccountData
   const chain = getChainById(api.chainId, getAllSupportedChains())
 
   return {