import { resolveSessionAgentId } from "../agents/agent-scope.js";

import { finalizeInboundContext } from "../auto-reply/reply/inbound-context.js";

import { dispatchReplyWithBufferedBlockDispatcher } from "../auto-reply/reply/provider-dispatcher.js";

import type { ChatType } from "../channels/chat-type.js";

import { getChannelPlugin, normalizeChannelId } from "../channels/plugins/index.js";

import { recordInboundSession } from "../channels/session.js";

import type { CliDeps } from "../cli/deps.types.js";

accountId?: string;

replyToId?: string;

threadId?: string;

chatType: ChatType;

};

function resolveRestartContinuationRoute(params: {

accountId?: string;

replyToId?: string;

threadId?: string;

chatType: ChatType;

}): RestartContinuationRoute | undefined {

if (!params.channel || !params.to) {

return undefined;

...(params.accountId ? { accountId: params.accountId } : {}),

...(params.replyToId ? { replyToId: params.replyToId } : {}),

...(params.threadId ? { threadId: params.threadId } : {}),

chatType: params.chatType,

};

}

Timestamp: Date.now(),

Provider: route.channel,

Surface: route.channel,

ChatType: "direct",

ChatType: route.chatType,

CommandAuthorized: true,

ReplyToId: route.replyToId,

OriginatingChannel: route.channel,

const sentinelContext = payload.deliveryContext;

let sessionDeliveryContext = deliveryContextFromSession(entry);

let chatType = entry?.origin?.chatType ?? "direct";

if (

!hasRoutableDeliveryContext(sessionDeliveryContext) &&

baseSessionKey &&

baseSessionKey !== sessionKey

) {

const { entry: baseEntry } = loadSessionEntry(baseSessionKey);

chatType = entry?.origin?.chatType ?? baseEntry?.origin?.chatType ?? "direct";

sessionDeliveryContext = mergeDeliveryContext(

sessionDeliveryContext,

deliveryContextFromSession(baseEntry),

accountId: origin?.accountId,

replyToId,

threadId: resolvedThreadId,

chatType,

}),

});

} catch (err) {