let5see/clawdbot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(web): improve WhatsApp Web listener errors (#612, thanks @YuriNachos)

Browse Source
This commit is contained in:
Peter Steinberger
2026-01-09 22:40:41 +00:00
parent a9f8719cd2
commit a18743eabc
3 changed files with 26 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/web/outbound.test.ts
View File

@@ -51,6 +51,19 @@ describe("web outbound", () => {
);
});
it("throws a helpful error when no active listener exists", async () => {
setActiveWebListener(null);
await expect(
sendMessageWhatsApp("+1555", "hi", { verbose: false, accountId: "work" }),
).rejects.toThrow(/No active WhatsApp Web listener/);
await expect(
sendMessageWhatsApp("+1555", "hi", { verbose: false, accountId: "work" }),
).rejects.toThrow(/providers login/);
await expect(
sendMessageWhatsApp("+1555", "hi", { verbose: false, accountId: "work" }),
).rejects.toThrow(/account: work/);
});
it("maps audio to PTT with opus mime when ogg", async () => {
const buf = Buffer.from("audio");
loadWebMediaMock.mockResolvedValueOnce({

30
src/web/outbound.ts
View File

@@ -13,6 +13,15 @@ const outboundLog = createSubsystemLogger("gateway/providers/whatsapp").child(
"outbound",
);
function requireActiveListener(accountId?: string | null) {
const active = getActiveWebListener(accountId);
if (active) return active;
const id = (accountId ?? "").trim() || "default";
throw new Error(
`No active WhatsApp Web listener (account: ${id}). Start the gateway, then link WhatsApp with: clawdbot providers login --provider whatsapp --account ${id}.`,
);
}
export async function sendMessageWhatsApp(
to: string,
body: string,
@@ -26,12 +35,7 @@ export async function sendMessageWhatsApp(
let text = body;
const correlationId = randomUUID();
const startedAt = Date.now();
const active = getActiveWebListener(options.accountId);
if (!active) {
throw new Error(
"No active gateway listener. Start the gateway before sending messages.",
);
}
const active = requireActiveListener(options.accountId);
const logger = getChildLogger({
module: "web-outbound",
correlationId,
@@ -108,12 +112,7 @@ export async function sendReactionWhatsApp(
},
): Promise<void> {
const correlationId = randomUUID();
const active = getActiveWebListener(options.accountId);
if (!active) {
throw new Error(
"No active gateway listener. Start the gateway before sending reactions.",
);
}
const active = requireActiveListener(options.accountId);
const logger = getChildLogger({
module: "web-outbound",
correlationId,
@@ -149,12 +148,7 @@ export async function sendPollWhatsApp(
): Promise<{ messageId: string; toJid: string }> {
const correlationId = randomUUID();
const startedAt = Date.now();
const active = getActiveWebListener(options.accountId);
if (!active) {
throw new Error(
"No active gateway listener. Start the gateway before sending polls.",
);
}
const active = requireActiveListener(options.accountId);
const logger = getChildLogger({
module: "web-outbound",
correlationId,