} from "openclaw/plugin-sdk/context-visibility-runtime";

import { hasFinalInboundReplyDispatch } from "openclaw/plugin-sdk/inbound-reply-dispatch";

import type { GetReplyOptions } from "openclaw/plugin-sdk/reply-runtime";

import { resolvePinnedMainDmOwnerFromAllowlist } from "openclaw/plugin-sdk/security-runtime";

import {

loadSessionStore,

resolveSessionStoreEntry,

import { resolveMatrixStoredSessionMeta } from "../session-store-metadata.js";

import { resolveMatrixMonitorAccessState } from "./access-state.js";

import { resolveMatrixAckReactionConfig } from "./ack-config.js";

import { resolveMatrixAllowListMatch } from "./allowlist.js";

import { normalizeMatrixUserId, resolveMatrixAllowListMatch } from "./allowlist.js";

import {

resolveMatrixMonitorLiveUserAllowlist,

type MatrixResolvedAllowlistEntry,

onReplyStart: typingCallbacks.onReplyStart,

onIdle: typingCallbacks.onIdle,

});

const pinnedMainDmOwner = isDirectMessage

? resolvePinnedMainDmOwnerFromAllowlist({

dmScope: cfg.session?.dmScope,

allowFrom: liveDmAllowFrom,

normalizeEntry: normalizeMatrixUserId,

})

: null;

const turnResult = await core.channel.turn.run({

channel: "matrix",

channel: "matrix",

to: `room:${roomId}`,

accountId: _route.accountId,

mainDmOwnerPin: pinnedMainDmOwner

? {

ownerRecipient: pinnedMainDmOwner,

senderRecipient: normalizeMatrixUserId(senderId),

onSkip: ({

ownerRecipient,

senderRecipient,

}: {

ownerRecipient: string;

senderRecipient: string;

}) => {

logVerboseMessage(

`matrix: skip main-session last route for ${senderRecipient} (pinned owner ${ownerRecipient})`,

);

},

}

: undefined,

}

: undefined,

onRecordError: (err) => {