romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge 0267171e29 into 09be5d45d5

Browse Source
This commit is contained in:
Manoj Naik 2026-01-30 07:50:52 -08:00 committed by GitHub
commit 49c909266e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 24 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/infra/outbound/outbound-session.ts
View File

@ -2,7 +2,11 @@ import type { MsgContext } from "../../auto-reply/templating.js";
import { getChannelPlugin } from "../../channels/plugins/index.js"; import { getChannelPlugin } from "../../channels/plugins/index.js";
import type { ChannelId } from "../../channels/plugins/types.js"; import type { ChannelId } from "../../channels/plugins/types.js";
import type { OpenClawConfig } from "../../config/config.js"; import type { OpenClawConfig } from "../../config/config.js";
import { recordSessionMetaFromInbound, resolveStorePath } from "../../config/sessions.js"; import {
recordSessionMetaFromInbound,
resolveStorePath,
updateLastRoute,
} from "../../config/sessions.js";
import { parseDiscordTarget } from "../../discord/targets.js"; import { parseDiscordTarget } from "../../discord/targets.js";
import { parseIMessageTarget, normalizeIMessageHandle } from "../../imessage/targets.js"; import { parseIMessageTarget, normalizeIMessageHandle } from "../../imessage/targets.js";
import { import {
@ -10,7 +14,7 @@ import {
type RoutePeer, type RoutePeer,
type RoutePeerKind, type RoutePeerKind,
} from "../../routing/resolve-route.js"; } from "../../routing/resolve-route.js";
import { resolveThreadSessionKeys } from "../../routing/session-key.js"; import { buildAgentMainSessionKey, resolveThreadSessionKeys } from "../../routing/session-key.js";
import { resolveSlackAccount } from "../../slack/accounts.js"; import { resolveSlackAccount } from "../../slack/accounts.js";
import { createSlackWebClient } from "../../slack/client.js"; import { createSlackWebClient } from "../../slack/client.js";
import { normalizeAllowListLower } from "../../slack/monitor/allow-list.js"; import { normalizeAllowListLower } from "../../slack/monitor/allow-list.js";
@ -833,6 +837,24 @@ export async function ensureOutboundSessionEntry(params: {
const storePath = resolveStorePath(params.cfg.session?.store, { const storePath = resolveStorePath(params.cfg.session?.store, {
agentId: params.agentId, agentId: params.agentId,
}); });
const mainSessionKey = buildAgentMainSessionKey({ agentId: params.agentId });
if (params.route.baseSessionKey === mainSessionKey) {
try {
await updateLastRoute({
storePath,
sessionKey: params.route.sessionKey,
deliveryContext: {
channel: params.channel,
to: params.route.to,
accountId: params.accountId ?? undefined,
threadId: params.route.threadId,
},
});
} catch {
// Do not block outbound sends on session store writes.
}
return;
}
const ctx: MsgContext = { const ctx: MsgContext = {
From: params.route.from, From: params.route.from,
To: params.route.to, To: params.route.to,