File size: 3,184 Bytes
fc93158 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 | import { logVerbose } from "../../../globals.js";
import type { SlackFile, SlackMessageEvent } from "../../types.js";
import {
MAX_SLACK_MEDIA_FILES,
resolveSlackAttachmentContent,
resolveSlackMedia,
type SlackMediaResult,
type SlackThreadStarter,
} from "../media.js";
export type SlackResolvedMessageContent = {
rawBody: string;
effectiveDirectMedia: SlackMediaResult[] | null;
};
function filterInheritedParentFiles(params: {
files: SlackFile[] | undefined;
isThreadReply: boolean;
threadStarter: SlackThreadStarter | null;
}): SlackFile[] | undefined {
const { files, isThreadReply, threadStarter } = params;
if (!isThreadReply || !files?.length) {
return files;
}
if (!threadStarter?.files?.length) {
return files;
}
const starterFileIds = new Set(threadStarter.files.map((file) => file.id));
const filtered = files.filter((file) => !file.id || !starterFileIds.has(file.id));
if (filtered.length < files.length) {
logVerbose(
`slack: filtered ${files.length - filtered.length} inherited parent file(s) from thread reply`,
);
}
return filtered.length > 0 ? filtered : undefined;
}
export async function resolveSlackMessageContent(params: {
message: SlackMessageEvent;
isThreadReply: boolean;
threadStarter: SlackThreadStarter | null;
isBotMessage: boolean;
botToken: string;
mediaMaxBytes: number;
}): Promise<SlackResolvedMessageContent | null> {
const ownFiles = filterInheritedParentFiles({
files: params.message.files,
isThreadReply: params.isThreadReply,
threadStarter: params.threadStarter,
});
const media = await resolveSlackMedia({
files: ownFiles,
token: params.botToken,
maxBytes: params.mediaMaxBytes,
});
const attachmentContent = await resolveSlackAttachmentContent({
attachments: params.message.attachments,
token: params.botToken,
maxBytes: params.mediaMaxBytes,
});
const mergedMedia = [...(media ?? []), ...(attachmentContent?.media ?? [])];
const effectiveDirectMedia = mergedMedia.length > 0 ? mergedMedia : null;
const mediaPlaceholder = effectiveDirectMedia
? effectiveDirectMedia.map((item) => item.placeholder).join(" ")
: undefined;
const fallbackFiles = ownFiles ?? [];
const fileOnlyFallback =
!mediaPlaceholder && fallbackFiles.length > 0
? fallbackFiles
.slice(0, MAX_SLACK_MEDIA_FILES)
.map((file) => file.name?.trim() || "file")
.join(", ")
: undefined;
const fileOnlyPlaceholder = fileOnlyFallback ? `[Slack file: ${fileOnlyFallback}]` : undefined;
const botAttachmentText =
params.isBotMessage && !attachmentContent?.text
? (params.message.attachments ?? [])
.map((attachment) => attachment.text?.trim() || attachment.fallback?.trim())
.filter(Boolean)
.join("\n")
: undefined;
const rawBody =
[
(params.message.text ?? "").trim(),
attachmentContent?.text,
botAttachmentText,
mediaPlaceholder,
fileOnlyPlaceholder,
]
.filter(Boolean)
.join("\n") || "";
if (!rawBody) {
return null;
}
return {
rawBody,
effectiveDirectMedia,
};
}
|