惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

腾
腾讯CDC
N
Netflix TechBlog - Medium
aimingoo的专栏
aimingoo的专栏
P
Proofpoint News Feed
F
Fortinet All Blogs
大猫的无限游戏
大猫的无限游戏
I
InfoQ
V
V2EX
Cyber Security Advisories - MS-ISAC
Cyber Security Advisories - MS-ISAC
有赞技术团队
有赞技术团队
G
Google Developers Blog
L
LangChain Blog
博
博客园_首页
M
MIT News - Artificial intelligence
H
Hackread – Cybersecurity News, Data Breaches, AI and More
月光博客
月光博客
IT之家
IT之家
量
量子位
宝玉的分享
宝玉的分享
S
SegmentFault 最新的问题
Stack Overflow Blog
Stack Overflow Blog
V
Visual Studio Blog
奇客Solidot–传递最新科技情报
奇客Solidot–传递最新科技情报
雷峰网
雷峰网

Recent Commits to openclaw:main

test: merge chat side-result checks · openclaw/openclaw@ddd2c2a test: merge cron history checks · openclaw/openclaw@f7eb746 test: merge responsive navigation shell checks · openclaw/openclaw@c2e4b47 docs(changelog): add codex oauth fixes · openclaw/openclaw@628e6cd test: merge navigation routing cases · openclaw/openclaw@5d8cecb Tests: mock channel registry bundled fallback · openclaw/openclaw@2b08233 Secrets: avoid broad web search discovery for single plugin config · openclaw/openclaw@a464f59 test: merge config view browser checks · openclaw/openclaw@20cf511 fix(status): align oauth health with runtime · openclaw/openclaw@eed7116 feat: add macOS screen snapshots for monitor preview (#67954) thanks … · openclaw/openclaw@f377db1 fix: report shared auth scopes in hello-ok (#67810) thanks @BunsDev · openclaw/openclaw@0b6c39b Auto-reply: avoid eager bundled route fallback · openclaw/openclaw@3ea1bf4 Tests: narrow session binding contract setup · openclaw/openclaw@54e4e16 fix(macOS): enable undo/redo in webchat composer text input (#34962) · openclaw/openclaw@00951dc Tests: speed up channel setup promotion · openclaw/openclaw@82b529a Docs: refresh agent instructions · openclaw/openclaw@5775fe2 fix(auth): serialize OAuth refresh across agents to fix #26322 (#67876) · openclaw/openclaw@8e79080 test: allow ollama public surface boundary test · openclaw/openclaw@7d4f1a6 Docs: add test performance guardrails · openclaw/openclaw@89706d3 Tests: restore context-engine usage proof · openclaw/openclaw@e4c4f95 Tests: slim context engine runtime coverage · openclaw/openclaw@74c198f ci: retry failed custom checkouts · openclaw/openclaw@0ee5baf test: trim duplicate provider auth onboarding cases · openclaw/openclaw@1ffc02e matrix: fix sessions_spawn --thread subagent session spawning (#67643) · openclaw/openclaw@1ce2596 test: reduce auth choice fixture churn · openclaw/openclaw@857b9cd test: mock health status config boundaries · openclaw/openclaw@9d5ab4a test: mock onboard config io boundary · openclaw/openclaw@299694d test: mock legacy state plugin boundaries · openclaw/openclaw@2713089 test: mock channel install boundaries · openclaw/openclaw@b945248 test: mock doctor preview channel boundaries · openclaw/openclaw@b1a3ad4
test: slim slack media imports · openclaw/openclaw@04a54cf
steipete · 2026-04-24 · via Recent Commits to openclaw:main

@@ -1,16 +1,21 @@

1-

import type { WebClient as SlackWebClient } from "@slack/web-api";

2-

import { pruneMapToMaxSize } from "openclaw/plugin-sdk/collection-runtime";

3-

import { formatErrorMessage } from "openclaw/plugin-sdk/error-runtime";

41

import { normalizeHostname } from "openclaw/plugin-sdk/host-runtime";

52

import { resolveRequestUrl } from "openclaw/plugin-sdk/request-url";

63

import type { SlackAttachment, SlackFile } from "../types.js";

4+

export { MAX_SLACK_MEDIA_FILES, type SlackMediaResult } from "./media-types.js";

5+

import { MAX_SLACK_MEDIA_FILES, type SlackMediaResult } from "./media-types.js";

76

import {

87

type FetchLike,

98

fetchRemoteMedia,

109

fetchWithRuntimeDispatcher,

11-

logVerbose,

1210

saveMediaBuffer,

1311

} from "./media.runtime.js";

12+

export {

13+

resetSlackThreadStarterCacheForTest,

14+

resolveSlackThreadHistory,

15+

resolveSlackThreadStarter,

16+

type SlackThreadMessage,

17+

type SlackThreadStarter,

18+

} from "./thread.js";

14191520

function normalizeLowercaseStringOrEmpty(value: unknown): string {

1621

return typeof value === "string" ? value.trim().toLowerCase() : "";

@@ -165,13 +170,6 @@ function looksLikeHtmlBuffer(buffer: Buffer): boolean {

165170

return head.startsWith("<!doctype html") || head.startsWith("<html");

166171

}

167172168-

export type SlackMediaResult = {

169-

path: string;

170-

contentType?: string;

171-

placeholder: string;

172-

};

173-174-

export const MAX_SLACK_MEDIA_FILES = 8;

175173

const MAX_SLACK_MEDIA_CONCURRENCY = 3;

176174

const MAX_SLACK_FORWARDED_ATTACHMENTS = 8;

177175

@@ -373,186 +371,3 @@ export async function resolveSlackAttachmentContent(params: {

373371

}

374372

return { text: combinedText, media: allMedia };

375373

}

376-377-

export type SlackThreadStarter = {

378-

text: string;

379-

userId?: string;

380-

botId?: string;

381-

ts?: string;

382-

files?: SlackFile[];

383-

};

384-385-

type SlackThreadStarterCacheEntry = {

386-

value: SlackThreadStarter;

387-

cachedAt: number;

388-

};

389-390-

const THREAD_STARTER_CACHE = new Map<string, SlackThreadStarterCacheEntry>();

391-

const THREAD_STARTER_CACHE_TTL_MS = 6 * 60 * 60_000;

392-

const THREAD_STARTER_CACHE_MAX = 2000;

393-394-

function evictThreadStarterCache(): void {

395-

const now = Date.now();

396-

for (const [cacheKey, entry] of THREAD_STARTER_CACHE.entries()) {

397-

if (now - entry.cachedAt > THREAD_STARTER_CACHE_TTL_MS) {

398-

THREAD_STARTER_CACHE.delete(cacheKey);

399-

}

400-

}

401-

pruneMapToMaxSize(THREAD_STARTER_CACHE, THREAD_STARTER_CACHE_MAX);

402-

}

403-404-

function formatSlackFilePlaceholder(files: SlackFile[] | undefined): string {

405-

return `[attached: ${files?.map((file) => file.name ?? "file").join(", ") ?? "file"}]`;

406-

}

407-408-

export async function resolveSlackThreadStarter(params: {

409-

channelId: string;

410-

threadTs: string;

411-

client: SlackWebClient;

412-

}): Promise<SlackThreadStarter | null> {

413-

evictThreadStarterCache();

414-

const cacheKey = `${params.channelId}:${params.threadTs}`;

415-

const cached = THREAD_STARTER_CACHE.get(cacheKey);

416-

if (cached && Date.now() - cached.cachedAt <= THREAD_STARTER_CACHE_TTL_MS) {

417-

return cached.value;

418-

}

419-

if (cached) {

420-

THREAD_STARTER_CACHE.delete(cacheKey);

421-

}

422-

try {

423-

const response = (await params.client.conversations.replies({

424-

channel: params.channelId,

425-

ts: params.threadTs,

426-

limit: 1,

427-

inclusive: true,

428-

})) as {

429-

messages?: Array<{

430-

text?: string;

431-

user?: string;

432-

bot_id?: string;

433-

ts?: string;

434-

files?: SlackFile[];

435-

}>;

436-

};

437-

const message = response?.messages?.[0];

438-

const text = (message?.text ?? "").trim();

439-

const files = message?.files?.length ? message.files : undefined;

440-

if (!message || (!text && !files)) {

441-

return null;

442-

}

443-

const starter: SlackThreadStarter = {

444-

text: text || formatSlackFilePlaceholder(files),

445-

userId: message.user,

446-

botId: message.bot_id,

447-

ts: message.ts,

448-

files,

449-

};

450-

if (THREAD_STARTER_CACHE.has(cacheKey)) {

451-

THREAD_STARTER_CACHE.delete(cacheKey);

452-

}

453-

THREAD_STARTER_CACHE.set(cacheKey, {

454-

value: starter,

455-

cachedAt: Date.now(),

456-

});

457-

evictThreadStarterCache();

458-

return starter;

459-

} catch (err) {

460-

logVerbose(

461-

`slack thread starter fetch failed channel=${params.channelId} ts=${params.threadTs}: ${formatErrorMessage(err)}`,

462-

);

463-

return null;

464-

}

465-

}

466-467-

export function resetSlackThreadStarterCacheForTest(): void {

468-

THREAD_STARTER_CACHE.clear();

469-

}

470-471-

export type SlackThreadMessage = {

472-

text: string;

473-

userId?: string;

474-

ts?: string;

475-

botId?: string;

476-

files?: SlackFile[];

477-

};

478-479-

type SlackRepliesPageMessage = {

480-

text?: string;

481-

user?: string;

482-

bot_id?: string;

483-

ts?: string;

484-

files?: SlackFile[];

485-

};

486-487-

type SlackRepliesPage = {

488-

messages?: SlackRepliesPageMessage[];

489-

response_metadata?: { next_cursor?: string };

490-

};

491-492-

/**

493-

* Fetches the most recent messages in a Slack thread (excluding the current message).

494-

* Used to populate thread context when a new thread session starts.

495-

*

496-

* Uses cursor pagination and keeps only the latest N retained messages so long threads

497-

* still produce up-to-date context without unbounded memory growth.

498-

*/

499-

export async function resolveSlackThreadHistory(params: {

500-

channelId: string;

501-

threadTs: string;

502-

client: SlackWebClient;

503-

currentMessageTs?: string;

504-

limit?: number;

505-

}): Promise<SlackThreadMessage[]> {

506-

const maxMessages = params.limit ?? 20;

507-

if (!Number.isFinite(maxMessages) || maxMessages <= 0) {

508-

return [];

509-

}

510-511-

// Slack recommends no more than 200 per page.

512-

const fetchLimit = 200;

513-

const retained: SlackRepliesPageMessage[] = [];

514-

let cursor: string | undefined;

515-516-

try {

517-

do {

518-

const response = (await params.client.conversations.replies({

519-

channel: params.channelId,

520-

ts: params.threadTs,

521-

limit: fetchLimit,

522-

inclusive: true,

523-

...(cursor ? { cursor } : {}),

524-

})) as SlackRepliesPage;

525-526-

for (const msg of response.messages ?? []) {

527-

// Keep messages with text OR file attachments

528-

if (!msg.text?.trim() && !msg.files?.length) {

529-

continue;

530-

}

531-

if (params.currentMessageTs && msg.ts === params.currentMessageTs) {

532-

continue;

533-

}

534-

retained.push(msg);

535-

if (retained.length > maxMessages) {

536-

retained.shift();

537-

}

538-

}

539-540-

const next = response.response_metadata?.next_cursor;

541-

cursor = typeof next === "string" && next.trim().length > 0 ? next.trim() : undefined;

542-

} while (cursor);

543-544-

return retained.map((msg) => ({

545-

// For file-only messages, create a placeholder showing attached filenames

546-

text: msg.text?.trim() ? msg.text : formatSlackFilePlaceholder(msg.files),

547-

userId: msg.user,

548-

botId: msg.bot_id,

549-

ts: msg.ts,

550-

files: msg.files,

551-

}));

552-

} catch (err) {

553-

logVerbose(

554-

`slack thread history fetch failed channel=${params.channelId} ts=${params.threadTs}: ${formatErrorMessage(err)}`,

555-

);

556-

return [];

557-

}

558-

}

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。