web: announce available presence when relay starts

This commit is contained in:
Peter Steinberger
2025-11-25 06:42:39 +01:00
parent 0adc0ed7a6
commit dc31efb7aa
2 changed files with 11 additions and 4 deletions

View File

@@ -153,6 +153,7 @@ describe("provider-web", () => {
const listener = await monitorWebInbox({ verbose: false, onMessage });
const sock = getLastSocket();
expect(sock.sendPresenceUpdate).toHaveBeenCalledWith("available");
const upsert = {
type: "notify",
messages: [
@@ -174,10 +175,8 @@ describe("provider-web", () => {
expect(sock.readMessages).toHaveBeenCalledWith([
{ remoteJid: "999@s.whatsapp.net", id: "abc", participant: undefined, fromMe: false },
]);
expect(sock.sendPresenceUpdate).toHaveBeenCalledWith(
"composing",
"999@s.whatsapp.net",
);
expect(sock.sendPresenceUpdate).toHaveBeenCalledWith("available");
expect(sock.sendPresenceUpdate).toHaveBeenCalledWith("composing", "999@s.whatsapp.net");
expect(sock.sendMessage).toHaveBeenCalledWith("999@s.whatsapp.net", {
text: "pong",
});
@@ -218,6 +217,7 @@ describe("provider-web", () => {
fromMe: false,
},
]);
expect(sock.sendPresenceUpdate).toHaveBeenCalledWith("available");
await listener.close();
});

View File

@@ -243,6 +243,13 @@ export async function monitorWebInbox(options: {
}) {
const sock = await createWaSocket(false, options.verbose);
await waitForWaConnection(sock);
try {
// Advertise that the relay is online right after connecting.
await sock.sendPresenceUpdate("available");
if (isVerbose()) logVerbose("Sent global 'available' presence on connect");
} catch (err) {
logVerbose(`Failed to send 'available' presence on connect: ${String(err)}`);
}
const selfJid = sock.user?.id;
const selfE164 = selfJid ? jidToE164(selfJid) : null;
const seen = new Set<string>();