import type { FetchMediaOptions, FetchMediaResult, SecretInputRef } from "./types.js";

// ============ Re-exports (port interfaces) ============

export type { HistoryPort, HistoryEntryLike } from "./history.port.js";

export type {

MentionGatePort,

MentionFacts,

MentionPolicy,

MentionGateDecision,

ImplicitMentionKind,

} from "./mention-gate.port.js";

export type { AudioConvertPort, OutboundAudioPort } from "./audio.port.js";

export type { CommandsPort, ApproveRuntimeGetter } from "./commands.port.js";

// ============ EngineAdapters (aggregated port injection) ============

/**

*/

/** Implicit mention kind aligned with SDK's `InboundImplicitMentionKind`. */

export type ImplicitMentionKind =

| "reply_to_bot"

| "quoted_bot"

| "bot_thread_participant"

| "native";

type ImplicitMentionKind = "reply_to_bot" | "quoted_bot" | "bot_thread_participant" | "native";

/** Facts about the current message's mention state. */

export interface MentionFacts {

};

}

export type ApprovalDecision = "allow-once" | "allow-always" | "deny";

type ApprovalDecision = "allow-once" | "allow-always" | "deny";

export interface ApprovalTarget {

interface ApprovalTarget {

type: ChatScope;

id: string;

}

export interface ParsedApprovalAction {

interface ParsedApprovalAction {

approvalId: string;

decision: ApprovalDecision;

}

* under `~/.openclaw/media/qqbot/downloads/` without appId subdivision.

* The clear-storage command therefore cleans the entire downloads root.

*/

export function resolveQqbotDownloadsDir(): string {

function resolveQqbotDownloadsDir(): string {

return getQQBotMediaPath("downloads");

}

initSlashCommandDeps(port);

}

export type {

SlashCommandContext,

SlashCommandResult,

SlashCommandFileResult,

QQBotFrameworkCommand,

QueueSnapshot,

} from "./slash-commands.js";

/**

* Return all commands that require authorization, for registration with the

* framework via api.registerCommand() in registerFull().

export type SlashCommandResult = string | SlashCommandFileResult | null;

/** Slash command result that sends text first and then a local file. */

export interface SlashCommandFileResult {

interface SlashCommandFileResult {

text: string;

/** Local file path to send. */

filePath: string;

}

/** Slash command definition. */

export interface SlashCommand {

interface SlashCommand {

/** Command name without the leading slash. */

name: string;

/** Short description. */

// ============ Dispatch result ============

export type DispatchResult =

type DispatchResult =

| { action: "ready"; data: unknown; sessionId: string }

| { action: "resumed"; data: unknown }

| { action: "message"; msg: QueuedMessage }

// ============ Connection context ============

export interface GatewayConnectionContext {

interface GatewayConnectionContext {

account: GatewayAccount;

abortSignal: AbortSignal;

cfg: unknown;

* representative turn, the merge information lands here instead of

* being scattered across `_` -prefixed fields on {@link QueuedMessage}.

*/

export interface QueuedMergeInfo {

interface QueuedMergeInfo {

/** Number of original messages folded in. Always >= 2. */

count: number;

/** Original messages in insertion order — `messages.at(-1)` is "current". */

return (msg.merge?.count ?? 0) > 1;

}

export interface MessageQueueContext {

interface MessageQueueContext {

accountId: string;

log?: {

info: (msg: string, meta?: Record<string, unknown>) => void;

}

/** Snapshot of the queue state for diagnostics. */

export interface QueueSnapshot {

interface QueueSnapshot {

totalPending: number;

activeUsers: number;

maxConcurrentUsers: number;

senderPending: number;

}

export interface MessageQueue {

interface MessageQueue {

enqueue: (msg: QueuedMessage) => void;

startProcessor: (handleMessageFn: (msg: QueuedMessage) => Promise<void>) => void;

getSnapshot: (senderPeerId: string) => QueueSnapshot;

// ============ Dependencies ============

export interface OutboundDispatchDeps {

interface OutboundDispatchDeps {

runtime: GatewayPluginRuntime;

cfg: unknown;

account: GatewayAccount;