vultr/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-06-06 14:12:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

refactor: share MSTeams outbound send resolvers

Browse Source
This commit is contained in:
Vincent Koc
2026-05-30 05:46:38 +02:00
parent 723b5085d9
commit 03415bb696
1 changed files with 51 additions and 56 deletions
Download Patch File Download Diff File Expand all files Collapse all files

107
extensions/msteams/src/outbound.ts
View File

@@ -1,4 +1,7 @@
import { resolveOutboundSendDep } from "openclaw/plugin-sdk/channel-outbound";
import {
resolveOutboundSendDep,
type OutboundSendDeps,
} from "openclaw/plugin-sdk/channel-outbound";
import {
attachChannelToResult,
createAttachedChannelResultAdapter,
@@ -25,6 +28,48 @@ function asObjectRecord(value: unknown): Record<string, unknown> | undefined {
const MSTEAMS_TEXT_CHUNK_LIMIT = 4000;
type MSTeamsSendConfig = Parameters<typeof sendMessageMSTeams>[0]["cfg"];
type MSTeamsSendResult = { messageId: string; conversationId: string };
type MSTeamsMediaSendOptions = {
mediaUrl?: string;
mediaLocalRoots?: readonly string[];
mediaReadFile?: (filePath: string) => Promise<Buffer>;
};
type MSTeamsTextSendFn = (to: string, text: string) => Promise<MSTeamsSendResult>;
type MSTeamsMediaSendFn = (
to: string,
text: string,
opts?: MSTeamsMediaSendOptions,
) => Promise<MSTeamsSendResult>;
function resolveMSTeamsTextSend(params: {
cfg: MSTeamsSendConfig;
deps?: OutboundSendDeps;
}): MSTeamsTextSendFn {
return (
resolveOutboundSendDep<MSTeamsTextSendFn>(params.deps, "msteams") ??
((to, text) => sendMessageMSTeams({ cfg: params.cfg, to, text }))
);
}
function resolveMSTeamsMediaSend(params: {
cfg: MSTeamsSendConfig;
deps?: OutboundSendDeps;
}): MSTeamsMediaSendFn {
return (
resolveOutboundSendDep<MSTeamsMediaSendFn>(params.deps, "msteams") ??
((to, text, opts) =>
sendMessageMSTeams({
cfg: params.cfg,
to,
text,
mediaUrl: opts?.mediaUrl,
mediaLocalRoots: opts?.mediaLocalRoots,
mediaReadFile: opts?.mediaReadFile,
}))
);
}
export const msteamsOutbound: ChannelOutboundAdapter = {
deliveryMode: "direct",
chunker: chunkTextForOutbound,
@@ -91,26 +136,7 @@ export const msteamsOutbound: ChannelOutboundAdapter = {
}),
);
if (mediaUrls.length > 0) {
type SendFn = (
to: string,
text: string,
opts?: {
mediaUrl?: string;
mediaLocalRoots?: readonly string[];
mediaReadFile?: (filePath: string) => Promise<Buffer>;
},
) => Promise<{ messageId: string; conversationId: string }>;
const send =
resolveOutboundSendDep<SendFn>(deps, "msteams") ??
((to, text, opts) =>
sendMessageMSTeams({
cfg,
to,
text,
mediaUrl: opts?.mediaUrl,
mediaLocalRoots: opts?.mediaLocalRoots,
mediaReadFile: opts?.mediaReadFile,
}));
const send = resolveMSTeamsMediaSend({ cfg, deps });
const result = await sendPayloadMediaSequence({
text,
mediaUrls,
@@ -122,18 +148,12 @@ export const msteamsOutbound: ChannelOutboundAdapter = {
}
}
if (text.trim()) {
type SendFn = (
to: string,
text: string,
) => Promise<{ messageId: string; conversationId: string }>;
const send =
resolveOutboundSendDep<SendFn>(deps, "msteams") ??
((to, text) => sendMessageMSTeams({ cfg, to, text }));
const send = resolveMSTeamsTextSend({ cfg, deps });
const chunks = resolveTextChunksWithFallback(
text,
chunkTextForOutbound(text, MSTEAMS_TEXT_CHUNK_LIMIT),
);
let result: Awaited<ReturnType<SendFn>>;
let result: Awaited<ReturnType<MSTeamsTextSendFn>>;
for (const chunk of chunks) {
result = await send(to, chunk);
}
@@ -144,36 +164,11 @@ export const msteamsOutbound: ChannelOutboundAdapter = {
...createAttachedChannelResultAdapter({
channel: "msteams",
sendText: async ({ cfg, to, text, deps }) => {
type SendFn = (
to: string,
text: string,
) => Promise<{ messageId: string; conversationId: string }>;
const send =
resolveOutboundSendDep<SendFn>(deps, "msteams") ??
((to, text) => sendMessageMSTeams({ cfg, to, text }));
const send = resolveMSTeamsTextSend({ cfg, deps });
return await send(to, text);
},
sendMedia: async ({ cfg, to, text, mediaUrl, mediaLocalRoots, mediaReadFile, deps }) => {
type SendFn = (
to: string,
text: string,
opts?: {
mediaUrl?: string;
mediaLocalRoots?: readonly string[];
mediaReadFile?: (filePath: string) => Promise<Buffer>;
},
) => Promise<{ messageId: string; conversationId: string }>;
const send =
resolveOutboundSendDep<SendFn>(deps, "msteams") ??
((to, text, opts) =>
sendMessageMSTeams({
cfg,
to,
text,
mediaUrl: opts?.mediaUrl,
mediaLocalRoots: opts?.mediaLocalRoots,
mediaReadFile: opts?.mediaReadFile,
}));
const send = resolveMSTeamsMediaSend({ cfg, deps });
return await send(to, text, { mediaUrl, mediaLocalRoots, mediaReadFile });
},
sendPoll: async ({ cfg, to, poll }) => {