});

}

export function createMessageReactionPayloadForTest(dataOverrides: Record<string, unknown> = {}) {

function createMessageReactionPayloadForTest(dataOverrides: Record<string, unknown> = {}) {

return {

type: "message-reaction",

data: {

return req;

}

export function createMockRequestForTest(params: WebhookRequestParams = {}): IncomingMessage {

function createMockRequestForTest(params: WebhookRequestParams = {}): IncomingMessage {

return createMockRequest(

params.method ?? "POST",

params.url ?? "/bluebubbles-webhook",

return { req, destroyMock };

}

export function createMockResponse(): ServerResponse & { body: string; statusCode: number } {

function createMockResponse(): ServerResponse & { body: string; statusCode: number } {

const res = {

statusCode: 200,

body: "",

return res;

}

export async function flushAsync() {

async function flushAsync() {

for (let i = 0; i < 2; i += 1) {

await new Promise<void>((resolve) => setImmediate(resolve));

}

return registration;

}

export function registerWebhookTargetForTest(params: {

function registerWebhookTargetForTest(params: {

core: PluginRuntime;

account?: ResolvedBlueBubblesAccount;

config?: OpenClawConfig;

});

}

export function registerWebhookTargetsForTest(params: {

function registerWebhookTargetsForTest(params: {

core: PluginRuntime;

accounts: Array<{

account: ResolvedBlueBubblesAccount;