- Memory/search: scan the JS-side fallback vector path (used when the sqlite-vec index is unavailable or has a mismatched dimension) in bounded rowid batches and yield to the event loop between batches so large chunk tables can no longer pin the Node.js main thread for multi-second windows. Also keeps the SQL prepared statement rooted in a local so node:sqlite cannot finalize it mid-scan under heap pressure. Fixes #81172. Thanks @dev23xyz-oss.

- Memory Wiki: preserve fs-safe diagnostics when bridge source page writes fail for non-symlink filesystem safety reasons, so directory collisions are reported with the underlying error code. (#83776) Thanks @TurboTheTurtle.

- Telegram: keep forum topics from blocking sibling topic traffic by routing inbound serialization, media/text buffers, and account API queues on topic-aware lanes. (#83829)

- Telegram: keep queued forum-topic follow-up messages from inheriting superseded source abort signals, so later same-topic user turns can still run and reply after an active turn is replaced. (#83827) Thanks @VACInc.

- CLI/update: bypass npm freshness filters consistently during managed package and plugin installs so freshly published release plugins remain installable. Thanks @jalehman.

- CLI/update: guide root-owned npm install EACCES recovery by stopping the managed Gateway before manual package replacement, then reinstalling and restarting the service. Fixes #83747. (#83757) Thanks @brokemac79.

- Agents/subagents: keep collect-mode announce queues batching unresolved-origin items with compatible same-route messages and resume collection after a true cross-channel drain when a later compatible batch remains. Fixes #83577.

expect(call.abortSignal).toBe(abortController.signal);

});

it("does not inherit source abort signals for queued user followups", async () => {

const sourceAbortController = new AbortController();

sourceAbortController.abort();

runEmbeddedPiAgentMock.mockResolvedValueOnce({

payloads: [],

meta: {},

});

const runner = createFollowupRunner({

opts: { abortSignal: sourceAbortController.signal },

typing: createMockTypingController(),

typingMode: "instant",

defaultModel: "openai/gpt-5.4",

});

await runner(

createQueuedRun({

currentInboundEventKind: "user_request",

run: {

provider: "openai",

model: "gpt-5.4",

sourceReplyDeliveryMode: "message_tool_only",

},

}),

);

const call = requireLastMockCallArg(runEmbeddedPiAgentMock, "run embedded pi agent");

expect(call.abortSignal).toBeUndefined();

});

it("keeps queued delivery correlations active during followup agent runs", async () => {

const events: string[] = [];

runEmbeddedPiAgentMock.mockImplementationOnce(async () => {

sessionId: run.sessionId,

sessionKey: replySessionKey ?? "",

resetTriggered: false,

upstreamAbortSignal: queued.abortSignal ?? opts?.abortSignal,

upstreamAbortSignal: queued.abortSignal,

});

const runId = crypto.randomUUID();

const shouldSurfaceToControlUi = isInternalMessageChannel(

agentAccountId: run.agentAccountId,

senderIsOwner: run.senderIsOwner,

disableTools: opts?.disableTools,

abortSignal: queued.abortSignal ?? opts?.abortSignal,

abortSignal: queued.abortSignal,

},

transformResult: (rawResult) =>

isRoomEventCliRun && rawResult.meta.agentMeta

bashElevated: run.bashElevated,

timeoutMs: run.timeoutMs,

runId,

abortSignal: queued.abortSignal ?? opts?.abortSignal,

abortSignal: queued.abortSignal,

images: queuedImages,

imageOrder: queuedImageOrder,

allowTransientCooldownProbe: runOptions?.allowTransientCooldownProbe,

it("queues active room events as followups instead of steering fake prompts", async () => {

const queueSettings = await import("./queue/settings-runtime.js");

const piRuntime = await import("../../agents/pi-embedded.runtime.js");

const abortController = new AbortController();

vi.mocked(queueSettings.resolveQueueSettings).mockReturnValueOnce({

mode: "steer",

debounceMs: 500,

await runPreparedReply(

baseParams({

opts: { abortSignal: abortController.signal },

ctx: {

Body: "ambient",

RawBody: "ambient",

expect(call.resolvedQueue.mode).toBe("steer");

expect(call.followupRun.prompt).toBe("[OpenClaw room event]");

expect(call.followupRun.currentInboundEventKind).toBe("room_event");

expect(call.followupRun.abortSignal).toBe(abortController.signal);

expect(call.followupRun.currentInboundContext?.text).toContain("Current event:");

});

it("detaches queued user requests from superseded source abort signals", async () => {

const queueSettings = await import("./queue/settings-runtime.js");

const piRuntime = await import("../../agents/pi-embedded.runtime.js");

const abortController = new AbortController();

vi.mocked(queueSettings.resolveQueueSettings).mockReturnValueOnce({

mode: "collect",

debounceMs: 500,

cap: 20,

dropPolicy: "summarize",

});

vi.mocked(piRuntime.resolveActiveEmbeddedRunSessionId)

.mockReturnValueOnce("active-session")

.mockReturnValueOnce("active-session");

vi.mocked(piRuntime.isEmbeddedPiRunActive).mockReturnValueOnce(true);

vi.mocked(piRuntime.isEmbeddedPiRunStreaming).mockReturnValueOnce(true);

vi.mocked(buildInboundUserContextPrefix).mockReturnValueOnce("user request context");

await runPreparedReply(

baseParams({

opts: { abortSignal: abortController.signal },

ctx: {

Body: "@bot keep this",

RawBody: "@bot keep this",

CommandBody: "@bot keep this",

Provider: "telegram",

Surface: "telegram",

ChatType: "group",

},

sessionCtx: {

Body: "@bot keep this",

BodyStripped: "@bot keep this",

Provider: "telegram",

Surface: "telegram",

ChatType: "group",

InboundEventKind: "user_request",

MessageSid: "994",

SenderName: "Alice",

},

}),

);

const call = requireLastRunReplyAgentCall();

expect(call.shouldFollowup).toBe(true);

expect(call.isActive).toBe(true);

expect(call.followupRun.currentInboundEventKind).toBe("user_request");

expect(call.followupRun.abortSignal).toBeUndefined();

});

it("queues active room events instead of interrupting active user requests", async () => {

const queueSettings = await import("./queue/settings-runtime.js");

const piRuntime = await import("../../agents/pi-embedded.runtime.js");

imageOrder: opts?.imageOrder,

}),

);

const queuedFollowupAbortSignal =

inboundEventKind === "room_event" ? opts?.abortSignal : undefined;

const followupRun = {

prompt: queuedBody,

transcriptPrompt: transcriptCommandBody,

currentInboundEventKind: inboundEventKind,

currentInboundContext,

abortSignal: opts?.abortSignal,

...(queuedFollowupAbortSignal ? { abortSignal: queuedFollowupAbortSignal } : {}),

deliveryCorrelations: opts?.queuedDeliveryCorrelations,

queuedLifecycle: opts?.queuedFollowupLifecycle,

messageId: sessionCtx.MessageSidFull ?? sessionCtx.MessageSid,