feat:add-tx-recovery

.changeset/mighty-birds-thank.md

@@ -0,0 +1,13 @@
+---
+"@axelarjs/transaction-recovery": minor
+"@axelarjs/api": minor
+"@axelarjs/cosmos": patch
+"@axelarjs/core": patch
+"@axelarjs/maestro": patch
+---
+
+- Added `manualRelayToDestChain` function in the `@axelarjs/transaction-recovery` module for enhanced transaction recovery capabilities.
+- Added `searchBatchedCommands` query for the Axelarscan client in the `@axelarjs/api` module.
+- Added Axelar Recovery client to facilitate server-side signing of Axelar transactions in the `@axelarjs/api` module.
+- Added `AXELAR_LCD_URLS` to `@axelarjs/core` module.
+- Added `connectToFirstAvailable` function to allow passing multiple rpc urls and connect to first available node in the `@axelarjs/cosmos` module.

apps/maestro/src/lib/contracts/IERC20MintableBurnable.hooks.ts

@@ -2,8 +2,8 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
 
 import {
-  createUseSimulateContract,
   createUseWriteContract,
+  createUseSimulateContract,
 } from "wagmi/codegen";
 
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

apps/maestro/src/lib/contracts/InterchainToken.hooks.ts

@@ -3,9 +3,9 @@
 
 import {
   createUseReadContract,
+  createUseWriteContract,
   createUseSimulateContract,
   createUseWatchContractEvent,
-  createUseWriteContract,
 } from "wagmi/codegen";
 
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
@@ -518,14 +518,14 @@ export const useReadInterchainTokenNameHash =
  * Wraps __{@link useReadContract}__ with `abi` set to __{@link interchainTokenAbi}__ and `functionName` set to `"nonces"`
  */
 export const useReadInterchainTokenNonces = /*#__PURE__*/ createUseReadContract(
-  { abi: interchainTokenAbi, functionName: "nonces" }
+  { abi: interchainTokenAbi, functionName: "nonces" },
 );
 
 /**
  * Wraps __{@link useReadContract}__ with `abi` set to __{@link interchainTokenAbi}__ and `functionName` set to `"symbol"`
  */
 export const useReadInterchainTokenSymbol = /*#__PURE__*/ createUseReadContract(
-  { abi: interchainTokenAbi, functionName: "symbol" }
+  { abi: interchainTokenAbi, functionName: "symbol" },
 );
 
 /**
@@ -566,7 +566,7 @@ export const useWriteInterchainTokenApprove =
  * Wraps __{@link useWriteContract}__ with `abi` set to __{@link interchainTokenAbi}__ and `functionName` set to `"burn"`
  */
 export const useWriteInterchainTokenBurn = /*#__PURE__*/ createUseWriteContract(
-  { abi: interchainTokenAbi, functionName: "burn" }
+  { abi: interchainTokenAbi, functionName: "burn" },
 );
 
 /**
@@ -591,7 +591,7 @@ export const useWriteInterchainTokenIncreaseAllowance =
  * Wraps __{@link useWriteContract}__ with `abi` set to __{@link interchainTokenAbi}__ and `functionName` set to `"init"`
  */
 export const useWriteInterchainTokenInit = /*#__PURE__*/ createUseWriteContract(
-  { abi: interchainTokenAbi, functionName: "init" }
+  { abi: interchainTokenAbi, functionName: "init" },
 );
 
 /**
@@ -616,7 +616,7 @@ export const useWriteInterchainTokenInterchainTransferFrom =
  * Wraps __{@link useWriteContract}__ with `abi` set to __{@link interchainTokenAbi}__ and `functionName` set to `"mint"`
  */
 export const useWriteInterchainTokenMint = /*#__PURE__*/ createUseWriteContract(
-  { abi: interchainTokenAbi, functionName: "mint" }
+  { abi: interchainTokenAbi, functionName: "mint" },
 );
 
 /**

apps/maestro/src/lib/contracts/InterchainTokenFactory.hooks.ts

@@ -3,9 +3,9 @@
 
 import {
   createUseReadContract,
+  createUseWriteContract,
   createUseSimulateContract,
   createUseWatchContractEvent,
-  createUseWriteContract,
 } from "wagmi/codegen";
 
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

apps/maestro/src/lib/contracts/InterchainTokenService.hooks.ts

@@ -3,9 +3,9 @@
 
 import {
   createUseReadContract,
+  createUseWriteContract,
   createUseSimulateContract,
   createUseWatchContractEvent,
-  createUseWriteContract,
 } from "wagmi/codegen";
 
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////

apps/maestro/src/lib/contracts/TokenManager.hooks.ts

@@ -3,9 +3,9 @@
 
 import {
   createUseReadContract,
+  createUseWriteContract,
   createUseSimulateContract,
   createUseWatchContractEvent,
-  createUseWriteContract,
 } from "wagmi/codegen";
 
 //////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
@@ -418,7 +418,7 @@ export const useReadTokenManagerFlowInAmount =
  * Wraps __{@link useReadContract}__ with `abi` set to __{@link tokenManagerAbi}__ and `functionName` set to `"flowLimit"`
  */
 export const useReadTokenManagerFlowLimit = /*#__PURE__*/ createUseReadContract(
-  { abi: tokenManagerAbi, functionName: "flowLimit" }
+  { abi: tokenManagerAbi, functionName: "flowLimit" },
 );
 
 /**

packages/api/.gitignore

@@ -7,8 +7,9 @@
 /axelar-config
 /deposit-address
 /deposit-service
+/axelar-recovery
 /docs
 
 *.d.ts
 *.js
-.turbo/
+.turbo/

packages/api/package.json

@@ -82,7 +82,8 @@
   "license": "LicenseRef-LICENSE",
   "devDependencies": {
     "@axelarjs/config": "workspace:*",
-    "@types/node": "^20.11.30",
+    "@cosmjs/stargate": "^0.31.3",
+    "@types/node": "^20.11.28",
     "dotenv": "^16.4.5",
     "fast-check": "^3.17.0",
     "gh-pages": "^6.1.1",
@@ -102,6 +103,7 @@
   },
   "dependencies": {
     "@axelarjs/core": "workspace:*",
+    "@axelarjs/cosmos": "workspace:*",
     "@axelarjs/utils": "workspace:*",
     "isomorphic-unfetch": "^4.0.2",
     "rambda": "^9.1.1",

packages/api/src/axelar-recovery/client.ts

@@ -0,0 +1,26 @@
+import { AXELAR_RECOVERY_API_URLS, type Environment } from "@axelarjs/core";
+import {
+  HttpClient,
+  type HttpClientOptions,
+} from "@axelarjs/utils/http-client";
+
+import { createAxelarConfigClient } from "../axelar-config";
+import { AxelarRecoveryApiClient } from "./isomorphic";
+
+export const createAxelarRecoveryApiClient = (
+  env: Environment,
+  options?: HttpClientOptions
+) =>
+  AxelarRecoveryApiClient.init(
+    {
+      instance: HttpClient.extend({
+        ...(options ?? {
+          prefixUrl: AXELAR_RECOVERY_API_URLS[env],
+        }),
+      }),
+    },
+    {
+      axelarConfigClient: createAxelarConfigClient(env),
+    },
+    env
+  );

packages/api/src/axelar-recovery/index.ts

@@ -0,0 +1,3 @@
+export * from "./types";
+export * from "./isomorphic";
+export * from "./client";

packages/api/src/axelar-recovery/isomorphic.ts

@@ -0,0 +1,100 @@
+import { AXELAR_RPC_URLS, Environment } from "@axelarjs/core";
+import { createAxelarBroadcastClient } from "@axelarjs/cosmos";
+import type { Body as HttpBody } from "@axelarjs/utils/http-client";
+
+import type { DeliverTxResponse } from "@cosmjs/stargate";
+
+import { AxelarConfigClient } from "../axelar-config";
+import {
+  RestService,
+  type ClientMeta,
+  type RestServiceOptions,
+} from "../lib/rest-service";
+import type { ChainModule } from "./types";
+
+export type AxelarRecoveryQueryDependencies = {
+  axelarConfigClient: AxelarConfigClient;
+};
+
+export class AxelarRecoveryApiClient extends RestService {
+  protected env: Environment;
+  protected rpcUrl: string;
+  protected deps: AxelarRecoveryQueryDependencies;
+
+  public constructor(
+    options: RestServiceOptions,
+    deps: AxelarRecoveryQueryDependencies,
+    env: Environment,
+    meta?: ClientMeta
+  ) {
+    super(options, meta);
+    this.deps = deps;
+    this.rpcUrl = AXELAR_RPC_URLS[env];
+    this.env = env;
+  }
+
+  static init(
+    options: RestServiceOptions,
+    deps: AxelarRecoveryQueryDependencies,
+    env: Environment
+  ) {
+    return new AxelarRecoveryApiClient(options, deps, env, {
+      name: "AxelarRecoveryQueryAPI",
+      version: "0.0.1",
+    });
+  }
+
+  private async generateTxBytesAndBroadcast<B extends HttpBody>(
+    endpoint: string,
+    body: B
+  ) {
+    const { data: txBytes } = await this.client
+      .post(endpoint, body)
+      .json<{ data: Uint8Array }>();
+
+    const broadcaster = await createAxelarBroadcastClient(this.rpcUrl);
+
+    return broadcaster.broadcastTx(txBytes);
+  }
+
+  async confirm(
+    txHash: `0x${string}`,
+    module: ChainModule,
+    chain: string
+  ): Promise<DeliverTxResponse> {
+    return this.generateTxBytesAndBroadcast("/confirm_gateway_tx", {
+      txHash,
+      module,
+      chain,
+    });
+  }
+
+  async createPendingTransfers(module: ChainModule, chain: string) {
+    return this.generateTxBytesAndBroadcast("/create_pending_transfers", {
+      module,
+      chain,
+    });
+  }
+
+  async executePendingTransfers(module: ChainModule, chain: string) {
+    return this.generateTxBytesAndBroadcast("/execute_pending_transfers", {
+      module,
+      chain,
+    });
+  }
+
+  async routeMessage(payload: string, id: string) {
+    return this.generateTxBytesAndBroadcast("/route_message", {
+      payload,
+      id,
+    });
+  }
+
+  async signCommands(chain: string, module: ChainModule) {
+    return this.generateTxBytesAndBroadcast("/sign_commands", {
+      chain,
+      module,
+    });
+  }
+
+}

packages/api/src/axelar-recovery/types.ts

@@ -0,0 +1 @@
+export type ChainModule = "axelarnet" | "evm";

packages/api/src/axelarscan/isomorphic.ts

@@ -9,6 +9,7 @@ import type {
   LinkEvent,
   LinkRequestRawResponse,
   LinkRequestResponse,
+  SearchBatchesResponse,
 } from "./types";
 
 export type AxelarApiParams<T extends Record<string, unknown>> = T & {
@@ -66,6 +67,22 @@ export class AxelarscanClient extends RestService {
     return await this.client.get(path).json<LinkRequestRawResponse>();
   }
 
+  async searchBatchedCommands(params: {
+    commandId?: string | undefined;
+    sourceTransactionHash?: string | undefined;
+  }) {
+    const json = {
+      commandId: params.commandId,
+      sourceTransactionHash: params.sourceTransactionHash,
+    };
+
+    const result = await this.client
+      .post("token/searchBatches", { json })
+      .json<SearchBatchesResponse>();
+
+    return result;
+  }
+
   async getRecentLinkTransactions(params: {
     size: number;
   }): Promise<LinkRequestResponse[]> {

packages/api/src/axelarscan/types.ts

@@ -187,3 +187,30 @@ export type LinkRequestResponse = {
   tokenAddress?: string | undefined;
   timestamp?: number;
 };
+
+export type BaseChainConfigsResponse = {
+  evm: EVMChainConfig[];
+  cosmos: CosmosChainConfig[];
+};
+
+export type SearchBatchesData = {
+  data: string;
+  command_ids: string[];
+  batch_id: string;
+  id: string;
+  status: string;
+  execute_data: string;
+  chain: string;
+  commands: SearchBatchesCommands[];
+};
+
+export type SearchBatchesCommands = {
+  executed: boolean;
+  id: string;
+  transactionHash: string;
+  type: string;
+};
+
+export type SearchBatchesResponse = {
+  data: SearchBatchesData[];
+};

packages/api/src/deposit-address/client.spec.ts

@@ -53,8 +53,8 @@ describe("deposit address client (node)", () => {
       const api = createDepositAddressApiClient(ENVIRONMENTS.testnet);
       const dummyAccount = privateKeyToAccount(generatePrivateKey());
       const otcRes: OTC = await retryGetOtc(api, dummyAccount.address);
-      const fromChain = "osmosis-7";
-      const toChain = "ethereum-2";
+      const fromChain = "ojo";
+      const toChain = "ethereum-sepolia";
       const asset = "uaxl";
 
       const signature = await dummyAccount.signMessage({
@@ -88,7 +88,7 @@ describe("deposit address client (node)", () => {
       // retry if get http error 429 (too many requests)
       const otcRes = await retryGetOtc(api, dummyAccount.address);
       const fromChain = "Fantom";
-      const toChain = "ethereum-2";
+      const toChain = "ethereum-sepolia";
       const asset = "uaxl";
 
       const signature = await dummyAccount.signMessage({