mirror of
https://github.com/openclaw/openclaw.git
synced 2026-05-06 17:01:37 +00:00
fix(hooks): add isGroup and groupId to message:sent context
Adds group context fields to MessageSentHookContext so hooks can correlate sent events with received events for the same conversation. Previously, message:received included isGroup/groupId but message:sent did not, forcing hooks to use mismatched identifiers (e.g. groupId vs numeric chat ID) when tracking conversations. Fields are derived from MsgContext in dispatch-from-config and threaded through route-reply and deliver via the mirror parameter. Addresses feedback from matskevich (production user, 550+ events) reported on PR #6797.
This commit is contained in:
committed by
Peter Steinberger
parent
7ad6a04058
commit
b5102ba4f9
@@ -106,6 +106,9 @@ export async function dispatchReplyFromConfig(params: {
|
||||
const sessionKey = ctx.SessionKey;
|
||||
const startTime = diagnosticsEnabled ? Date.now() : 0;
|
||||
const canTrackSession = diagnosticsEnabled && Boolean(sessionKey);
|
||||
const isGroup = Boolean(ctx.GroupSubject || ctx.GroupChannel);
|
||||
const groupId =
|
||||
ctx.From?.includes(":group:") || ctx.From?.includes(":channel:") ? ctx.From : undefined;
|
||||
|
||||
const recordProcessed = (
|
||||
outcome: "completed" | "skipped" | "error",
|
||||
@@ -291,6 +294,8 @@ export async function dispatchReplyFromConfig(params: {
|
||||
cfg,
|
||||
abortSignal,
|
||||
mirror,
|
||||
isGroup,
|
||||
groupId,
|
||||
});
|
||||
if (!result.ok) {
|
||||
logVerbose(`dispatch-from-config: route-reply failed: ${result.error ?? "unknown error"}`);
|
||||
@@ -316,6 +321,8 @@ export async function dispatchReplyFromConfig(params: {
|
||||
accountId: ctx.AccountId,
|
||||
threadId: ctx.MessageThreadId,
|
||||
cfg,
|
||||
isGroup,
|
||||
groupId,
|
||||
});
|
||||
queuedFinal = result.ok;
|
||||
if (result.ok) {
|
||||
@@ -499,6 +506,8 @@ export async function dispatchReplyFromConfig(params: {
|
||||
accountId: ctx.AccountId,
|
||||
threadId: ctx.MessageThreadId,
|
||||
cfg,
|
||||
isGroup,
|
||||
groupId,
|
||||
});
|
||||
if (!result.ok) {
|
||||
logVerbose(
|
||||
@@ -549,6 +558,8 @@ export async function dispatchReplyFromConfig(params: {
|
||||
accountId: ctx.AccountId,
|
||||
threadId: ctx.MessageThreadId,
|
||||
cfg,
|
||||
isGroup,
|
||||
groupId,
|
||||
});
|
||||
queuedFinal = result.ok || queuedFinal;
|
||||
if (result.ok) {
|
||||
|
||||
@@ -37,6 +37,10 @@ export type RouteReplyParams = {
|
||||
abortSignal?: AbortSignal;
|
||||
/** Mirror reply into session transcript (default: true when sessionKey is set). */
|
||||
mirror?: boolean;
|
||||
/** Whether this message is being sent in a group/channel context */
|
||||
isGroup?: boolean;
|
||||
/** Group or channel identifier for correlation with received events */
|
||||
groupId?: string;
|
||||
};
|
||||
|
||||
export type RouteReplyResult = {
|
||||
@@ -145,6 +149,8 @@ export async function routeReply(params: RouteReplyParams): Promise<RouteReplyRe
|
||||
agentId: resolvedAgentId,
|
||||
text,
|
||||
mediaUrls,
|
||||
...(params.isGroup != null ? { isGroup: params.isGroup } : {}),
|
||||
...(params.groupId ? { groupId: params.groupId } : {}),
|
||||
}
|
||||
: undefined,
|
||||
});
|
||||
|
||||
Reference in New Issue
Block a user