Add @walletconnect/staking-cli package and CLI SDK improvements

packages/cli-sdk/src/cli.ts

@@ -1,4 +1,5 @@
 import { WalletConnectCLI } from "./client.js";
+import { resolveProjectId, setConfigValue, getConfigValue } from "./config.js";
 
 const METADATA = {
   name: "walletconnect",
@@ -11,23 +12,28 @@ function usage(): void {
   console.log(`Usage: walletconnect <command> [options]
 
 Commands:
-  connect          Connect to a wallet via QR code
-  whoami           Show current session info
-  sign <message>   Sign a message with the connected wallet
-  disconnect       Disconnect the current session
+  connect              Connect to a wallet via QR code
+  whoami               Show current session info
+  sign <message>       Sign a message with the connected wallet
+  disconnect           Disconnect the current session
+  config set <k> <v>   Set a config value (e.g. project-id)
+  config get <k>       Get a config value
 
 Options:
   --browser        Use browser UI instead of terminal QR code
   --help           Show this help message
 
+Config keys:
+  project-id       WalletConnect Cloud project ID
+
 Environment:
-  WALLETCONNECT_PROJECT_ID   Required for connect and sign commands`);
+  WALLETCONNECT_PROJECT_ID   Overrides config project-id when set`);
 }
 
 function getProjectId(): string {
-  const id = process.env.WALLETCONNECT_PROJECT_ID;
+  const id = resolveProjectId();
   if (!id) {
-    console.error("Error: WALLETCONNECT_PROJECT_ID environment variable is required.");
+    console.error("Error: No project ID found. Set via: walletconnect config set project-id <id>");
     process.exit(1);
   }
   return id;
@@ -102,12 +108,9 @@ async function cmdSign(message: string, browser: boolean): Promise<void> {
       console.log();
     }
 
-    const walletName = result.session.peer.metadata.name;
     const { chain, address } = parseAccount(result.accounts[0]);
     const hexMessage = "0x" + Buffer.from(message, "utf8").toString("hex");
 
-    console.log(`Requesting signature from ${walletName}...\n`);
-
     const signature = await sdk.request<string>({
       chainId: chain,
       request: {
@@ -163,6 +166,32 @@ async function main(): Promise<void> {
     case "disconnect":
       await cmdDisconnect();
       break;
+    case "config": {
+      const action = filtered[1];
+      const key = filtered[2];
+      if (action === "set") {
+        const value = filtered[3];
+        if (key === "project-id" && value) {
+          setConfigValue("projectId", value);
+          console.log(`Saved project-id to ~/.walletconnect-cli/config.json`);
+        } else {
+          console.error("Usage: walletconnect config set project-id <value>");
+          process.exit(1);
+        }
+      } else if (action === "get") {
+        if (key === "project-id") {
+          const value = getConfigValue("projectId");
+          console.log(value || "(not set)");
+        } else {
+          console.error("Usage: walletconnect config get project-id");
+          process.exit(1);
+        }
+      } else {
+        console.error("Usage: walletconnect config <set|get> <key> [value]");
+        process.exit(1);
+      }
+      break;
+    }
     case "--help":
     case "-h":
     case undefined:
@@ -175,7 +204,10 @@ async function main(): Promise<void> {
   }
 }
 
-main().catch((err) => {
-  console.error(err instanceof Error ? err.message : err);
-  process.exit(1);
-});
+main().then(
+  () => process.exit(0),
+  (err) => {
+    console.error(err instanceof Error ? err.message : err);
+    process.exit(1);
+  },
+);

packages/cli-sdk/src/client.ts

@@ -1,4 +1,5 @@
 import { EventEmitter } from "events";
+import { execSync } from "child_process";
 import { homedir } from "os";
 import { join } from "path";
 import { KeyValueStorage } from "@walletconnect/keyvaluestorage";
@@ -113,6 +114,8 @@
       throw new Error("No active session. Call connect() first.");
     }
 
+    this.logRequestDetails(options);
+
     try {
       return await client.request<T>({
         topic,
@@ -142,14 +145,23 @@
 
     try {
       const client = await this.ensureClient();
-      await client.disconnect({
-        topic: this.currentSession.topic,
-        reason: { code: 6000, message: "User disconnected" },
-      });
+      // Absorb relay WebSocket errors during disconnect so they don't
+      // surface as unhandled 'error' events that crash the process.
+      const swallow = () => {};
+      client.core.relayer.on("error", swallow);
+      try {
+        await client.disconnect({
+          topic: this.currentSession.topic,
+          reason: { code: 6000, message: "User disconnected" },
+        });
+      } finally {
+        client.core.relayer.off("error", swallow);
+      }
     } catch {
       // Ignore disconnect errors — session may have already expired
     }
 
+    // Always clean up local state even if relay notification failed
     this.currentSession = null;
     this.emit("disconnect");
   }
@@ -175,6 +187,13 @@
       this.browserUI = null;
     }
     this.removeAllListeners();
+    if (this.signClient) {
+      try {
+        await this.signClient.core.relayer.transportClose();
+      } catch {
+        // ignore cleanup errors
+      }
+    }
     this.signClient = null;
     this.currentSession = null;
   }
@@ -201,6 +220,32 @@
 
   // ---------- Private -------------------------------------------------- //
 
+  private logRequestDetails(options: RequestOptions): void {
+    const walletName = this.currentSession?.peer.metadata.name;
+    if (walletName) {
+      console.log(`\nRequesting approval on ${walletName}...`);
+    }
+
+    if (options.request.method === "eth_sendTransaction") {
+      const params = options.request.params as Array<{ data?: string }>;
+      const data = params[0]?.data;
+      if (data && data !== "0x") {
+        try {
+          const decoded = execSync(`cast 4d ${data}`, {
+            encoding: "utf-8",
+            timeout: 5000,
+            stdio: ["pipe", "pipe", "pipe"],
+          }).trim();
+          if (decoded) {
+            console.log(`\n  Decoded calldata:\n${decoded.split("\n").map((l) => `    ${l}`).join("\n")}\n`);
+          }
+        } catch {
+          // cast not available or decode failed — skip silently
+        }
+      }
+    }
+  }
+
   private async ensureClient(): Promise<InstanceType<typeof SignClient>> {
     if (this.signClient) return this.signClient;