feat(qa): wire crabline whatsapp transport

RomneyDa · RomneyDa · commit c3390e60f5f9 · 2026-06-29T10:58:01.000-07:00
diff --git a/extensions/qa-lab/package.json b/extensions/qa-lab/package.json
@@ -16,7 +16,7 @@
     "@openclaw/plugin-sdk": "workspace:*",
     "@openclaw/slack": "workspace:*",
     "@openclaw/whatsapp": "workspace:*",
-    "@openclaw/crabline": "0.1.3",
+    "@openclaw/crabline": "0.1.4",
     "openclaw": "2026.5.28"
   },
   "peerDependencies": {
diff --git a/extensions/qa-lab/src/crabline-transport.test.ts b/extensions/qa-lab/src/crabline-transport.test.ts
@@ -8,7 +8,7 @@ import { describe, expect, it } from "vitest";
 import { createQaBusState } from "./bus-state.js";
 import { createQaCrablineTransportAdapter } from "./crabline-transport.js";
 
-function createSelection(channel: "slack" | "telegram" = "telegram") {
+function createSelection(channel: "slack" | "telegram" | "whatsapp" = "telegram") {
   return {
     capabilityMatrixPath: "crabline-fake-provider-capabilities.json",
     channel,
@@ -160,6 +160,91 @@ describe("crabline transport", () => {
     });
   });
 
+  it("configures OpenClaw's WhatsApp plugin against a Crabline Baileys WebSocket server", async () => {
+    await withTempDir("qa-crabline-transport-", async (outputDir) => {
+      const transport = await createQaCrablineTransportAdapter({
+        outputDir,
+        selection: createSelection("whatsapp"),
+        state: createQaBusState(),
+      });
+
+      try {
+        expect(transport.id).toBe("crabline");
+        expect(transport.requiredPluginIds).toEqual(["whatsapp"]);
+        expect(transport.createGatewayConfig({ baseUrl: "http://127.0.0.1:1" })).toMatchObject({
+          channels: {
+            whatsapp: {
+              allowFrom: ["*"],
+              dmPolicy: "open",
+              enabled: true,
+              groupAllowFrom: ["*"],
+              groupPolicy: "open",
+            },
+          },
+        });
+        expect(transport.buildAgentDelivery({ target: "15551234567@s.whatsapp.net" })).toEqual({
+          channel: "whatsapp",
+          to: "15551234567@s.whatsapp.net",
+          replyChannel: "whatsapp",
+          replyTo: "15551234567@s.whatsapp.net",
+        });
+        const env = transport.createRuntimeEnvPatch?.() ?? {};
+        expect(env).toMatchObject({
+          CRABLINE_WHATSAPP_ADMIN_TOKEN: expect.any(String),
+          CRABLINE_WHATSAPP_RECORDER_PATH: expect.stringMatching(/whatsapp-fake-provider\.jsonl$/u),
+          CRABLINE_WHATSAPP_SELF_JID: "15550000000@s.whatsapp.net",
+          OPENCLAW_WHATSAPP_WEB_SOCKET_URL: expect.stringMatching(
+            /^ws:\/\/127\.0\.0\.1:\d+\/crabline\/whatsapp\/ws\/chat\?access_token=/u,
+          ),
+        });
+        expect(env.CRABLINE_WHATSAPP_ACCESS_TOKEN).toBeUndefined();
+        expect(env.CRABLINE_WHATSAPP_API_ROOT).toBeUndefined();
+
+        const manifest = JSON.parse(
+          await fs.readFile(path.join(outputDir, OPENCLAW_CRABLINE_MANIFEST_PATH), "utf8"),
+        ) as {
+          provider?: string;
+        };
+        expect(manifest.provider).toBe("whatsapp");
+      } finally {
+        await transport.cleanup?.();
+      }
+    });
+  });
+
+  it("injects WhatsApp inbound messages through Crabline into normalized state", async () => {
+    await withTempDir("qa-crabline-transport-", async (outputDir) => {
+      const transport = await createQaCrablineTransportAdapter({
+        outputDir,
+        selection: createSelection("whatsapp"),
+        state: createQaBusState(),
+      });
+
+      try {
+        const message = await transport.state.addInboundMessage({
+          conversation: {
+            id: "15551234567@s.whatsapp.net",
+            kind: "direct",
+          },
+          senderId: "15557654321@s.whatsapp.net",
+          senderName: "Alice",
+          text: "WhatsApp baseline marker check.",
+        });
+        expect(message).toMatchObject({
+          conversation: {
+            id: "15551234567@s.whatsapp.net",
+            kind: "direct",
+          },
+          direction: "inbound",
+          senderId: "15557654321@s.whatsapp.net",
+          text: "WhatsApp baseline marker check.",
+        });
+      } finally {
+        await transport.cleanup?.();
+      }
+    });
+  });
+
   it("injects inbound messages through Crabline and mirrors Telegram sends into normalized state", async () => {
     await withTempDir("qa-crabline-transport-", async (outputDir) => {
       const transport = await createQaCrablineTransportAdapter({
diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/pnpm-workspace.yaml b/pnpm-workspace.yaml
@@ -7,7 +7,7 @@ packages:
 minimumReleaseAge: 2880
 
 minimumReleaseAgeExclude:
-  - "@openclaw/crabline@0.1.3"
+  - "@openclaw/crabline@0.1.4"
   - "@openclaw/fs-safe@0.3.0"
   - "@openclaw/proxyline@0.3.3"
   - "acpx"

-Original file line number
+Diff line change
 minimumReleaseAge: 2880
 minimumReleaseAgeExclude:
 -  - "@openclaw/[email protected].3"
 +  - "@openclaw/[email protected].4"
   - "@openclaw/[email protected]"
   - "@openclaw/[email protected]"
   - "acpx"