vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-04-05 22:32:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(contracts): lazy-load outbound contract plugin helpers

Browse Source
This commit is contained in:
Vincent Koc
2026-04-03 23:40:15 +09:00
parent cd38eba316
commit 8ffeadd8f9
1 changed files with 35 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
test/helpers/channels/outbound-payload-contract.ts
View File

@@ -15,15 +15,37 @@ import type { ChannelOutboundAdapter } from "../../../src/channels/plugins/types
import { loadBundledPluginTestApiSync } from "../../../src/test-utils/bundled-plugin-public-surface.js";
type ParseZalouserOutboundTarget = (raw: string) => { threadId: string; isGroup: boolean };
const { discordOutbound } = loadBundledPluginTestApiSync<{
discordOutbound: ChannelOutboundAdapter;
}>("discord");
const { whatsappOutbound } = loadBundledPluginTestApiSync<{
whatsappOutbound: ChannelOutboundAdapter;
}>("whatsapp");
const { parseZalouserOutboundTarget } = loadBundledPluginTestApiSync<{
parseZalouserOutboundTarget: ParseZalouserOutboundTarget;
}>("zalouser");
let discordOutboundCache: ChannelOutboundAdapter | undefined;
let whatsappOutboundCache: ChannelOutboundAdapter | undefined;
let parseZalouserOutboundTargetCache: ParseZalouserOutboundTarget | undefined;
function getDiscordOutbound(): ChannelOutboundAdapter {
if (!discordOutboundCache) {
({ discordOutbound: discordOutboundCache } = loadBundledPluginTestApiSync<{
discordOutbound: ChannelOutboundAdapter;
}>("discord"));
}
return discordOutboundCache;
}
function getWhatsAppOutbound(): ChannelOutboundAdapter {
if (!whatsappOutboundCache) {
({ whatsappOutbound: whatsappOutboundCache } = loadBundledPluginTestApiSync<{
whatsappOutbound: ChannelOutboundAdapter;
}>("whatsapp"));
}
return whatsappOutboundCache;
}
function getParseZalouserOutboundTarget(): ParseZalouserOutboundTarget {
if (!parseZalouserOutboundTargetCache) {
({ parseZalouserOutboundTarget: parseZalouserOutboundTargetCache } =
loadBundledPluginTestApiSync<{
parseZalouserOutboundTarget: ParseZalouserOutboundTarget;
}>("zalouser"));
}
return parseZalouserOutboundTargetCache;
}
type PayloadHarnessParams = {
payload: ReplyPayload;
@@ -54,7 +76,7 @@ function createDiscordHarness(params: PayloadHarnessParams) {
},
};
return {
run: async () => await discordOutbound.sendPayload!(ctx),
run: async () => await getDiscordOutbound().sendPayload!(ctx),
sendMock: sendDiscord,
to: ctx.to,
};
@@ -73,7 +95,7 @@ function createWhatsAppHarness(params: PayloadHarnessParams) {
},
};
return {
run: async () => await whatsappOutbound.sendPayload!(ctx),
run: async () => await getWhatsAppOutbound().sendPayload!(ctx),
sendMock: sendWhatsApp,
to: ctx.to,
};
@@ -155,7 +177,7 @@ function createZalouserHarness(params: PayloadHarnessParams) {
await sendZalouserPayloadWithChunkedTextAndMedia({
ctx,
sendText: async (nextCtx) => {
const target = parseZalouserOutboundTarget(nextCtx.to);
const target = getParseZalouserOutboundTarget()(nextCtx.to);
return buildChannelSendResult(
"zalouser",
await sendZalouser(target.threadId, nextCtx.text, {
@@ -168,7 +190,7 @@ function createZalouserHarness(params: PayloadHarnessParams) {
);
},
sendMedia: async (nextCtx) => {
const target = parseZalouserOutboundTarget(nextCtx.to);
const target = getParseZalouserOutboundTarget()(nextCtx.to);
return buildChannelSendResult(
"zalouser",
await sendZalouser(target.threadId, nextCtx.text, {