github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-19 07:17:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(imessage): fix monitor test harness usage

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-14 21:02:17 +01:00
parent 2a1ed0ed41
commit 7db6eade05
1 changed files with 21 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
src/imessage/monitor.skips-group-messages-without-mention-by-default.test.ts
View File

@@ -3,6 +3,7 @@ import {
flush, flush,
getCloseResolve, getCloseResolve,
getConfigMock, getConfigMock,
getReadAllowFromStoreMock,
getNotificationHandler, getNotificationHandler,
getReplyMock, getReplyMock,
getSendMock, getSendMock,
@@ -40,7 +41,7 @@ describe("monitorIMessageProvider", () => {
const run = monitorIMessageProvider(); const run = monitorIMessageProvider();
await waitForSubscribe(); await waitForSubscribe();
notificationHandler?.({ getNotificationHandler()?.({
method: "message", method: "message",
params: { params: {
message: { message: {
@@ -52,7 +53,7 @@ describe("monitorIMessageProvider", () => {
}); });
await flush(); await flush();
closeResolve?.(); getCloseResolve()?.();
await run; await run;
expect(replyMock).not.toHaveBeenCalled(); expect(replyMock).not.toHaveBeenCalled();
@@ -396,7 +397,8 @@ describe("monitorIMessageProvider", () => {
}); });
it("does not allow group sender from pairing store when groupPolicy is allowlist", async () => { it("does not allow group sender from pairing store when groupPolicy is allowlist", async () => {
config = { const config = getConfig();
setConfigMock({
...config, ...config,
channels: { channels: {
...config.channels, ...config.channels,
@@ -408,12 +410,12 @@ describe("monitorIMessageProvider", () => {
groupAllowFrom: [], groupAllowFrom: [],
}, },
}, },
}; });
readAllowFromStoreMock.mockResolvedValue(["+15550003333"]); getReadAllowFromStoreMock().mockResolvedValue(["+15550003333"]);
const run = monitorIMessageProvider(); const run = monitorIMessageProvider();
await waitForSubscribe(); await waitForSubscribe();
notificationHandler?.({ getNotificationHandler()?.({
method: "message", method: "message",
params: { params: {
message: { message: {
@@ -428,7 +430,7 @@ describe("monitorIMessageProvider", () => {
}); });
await flush(); await flush();
closeResolve?.(); getCloseResolve()?.();
await run; await run;
expect(replyMock).not.toHaveBeenCalled(); expect(replyMock).not.toHaveBeenCalled();
@@ -436,7 +438,8 @@ describe("monitorIMessageProvider", () => {
}); });
it("does not allow sender from pairing store when groupAllowFrom is restricted to a different chat_id", async () => { it("does not allow sender from pairing store when groupAllowFrom is restricted to a different chat_id", async () => {
config = { const config = getConfig();
setConfigMock({
...config, ...config,
channels: { channels: {
...config.channels, ...config.channels,
@@ -448,12 +451,12 @@ describe("monitorIMessageProvider", () => {
groupAllowFrom: ["chat_id:101"], groupAllowFrom: ["chat_id:101"],
}, },
}, },
}; });
readAllowFromStoreMock.mockResolvedValue(["+15550003333"]); getReadAllowFromStoreMock().mockResolvedValue(["+15550003333"]);
const run = monitorIMessageProvider(); const run = monitorIMessageProvider();
await waitForSubscribe(); await waitForSubscribe();
notificationHandler?.({ getNotificationHandler()?.({
method: "message", method: "message",
params: { params: {
message: { message: {
@@ -468,7 +471,7 @@ describe("monitorIMessageProvider", () => {
}); });
await flush(); await flush();
closeResolve?.(); getCloseResolve()?.();
await run; await run;
expect(replyMock).not.toHaveBeenCalled(); expect(replyMock).not.toHaveBeenCalled();
@@ -476,7 +479,8 @@ describe("monitorIMessageProvider", () => {
}); });
it("does not authorize control command via pairing-store sender in non-allowlisted chat", async () => { it("does not authorize control command via pairing-store sender in non-allowlisted chat", async () => {
config = { const config = getConfig();
setConfigMock({
...config, ...config,
channels: { channels: {
...config.channels, ...config.channels,
@@ -488,12 +492,12 @@ describe("monitorIMessageProvider", () => {
groupAllowFrom: ["chat_id:101"], groupAllowFrom: ["chat_id:101"],
}, },
}, },
}; });
readAllowFromStoreMock.mockResolvedValue(["+15550003333"]); getReadAllowFromStoreMock().mockResolvedValue(["+15550003333"]);
const run = monitorIMessageProvider(); const run = monitorIMessageProvider();
await waitForSubscribe(); await waitForSubscribe();
notificationHandler?.({ getNotificationHandler()?.({
method: "message", method: "message",
params: { params: {
message: { message: {
@@ -508,7 +512,7 @@ describe("monitorIMessageProvider", () => {
}); });
await flush(); await flush();
closeResolve?.(); getCloseResolve()?.();
await run; await run;
expect(replyMock).not.toHaveBeenCalled(); expect(replyMock).not.toHaveBeenCalled();