import type { ClawdbotConfig, RuntimeEnv } from "../runtime-api.js";

import { listEnabledFeishuAccounts, resolveFeishuRuntimeAccount } from "./accounts.js";

import {

monitorSingleAccount,

resolveReactionSyntheticEvent,

type FeishuReactionCreatedEvent,

} from "./monitor.account.js";

import { fetchBotIdentityForMonitor } from "./monitor.startup.js";

import {

clearFeishuWebhookRateLimitStateForTest,

accountId?: string;

};

let monitorAccountRuntimePromise: Promise<typeof import("./monitor.account.js")> | undefined;

async function loadMonitorAccountRuntime() {

monitorAccountRuntimePromise ??= import("./monitor.account.js");

return await monitorAccountRuntimePromise;

}

export {

clearFeishuWebhookRateLimitStateForTest,

getFeishuWebhookRateLimitStateSizeForTest,

isWebhookRateLimitedForTest,

resolveReactionSyntheticEvent,

};

export type { FeishuReactionCreatedEvent };

export async function monitorFeishuProvider(opts: MonitorFeishuOpts = {}): Promise<void> {

const cfg = opts.config;

if (!account.enabled || !account.configured) {

throw new Error(`Feishu account "${opts.accountId}" not configured or disabled`);

}

const { monitorSingleAccount } = await loadMonitorAccountRuntime();

return monitorSingleAccount({

cfg,

account,

`feishu: starting ${accounts.length} account(s): ${accounts.map((a) => a.accountId).join(", ")}`,

);

const { monitorSingleAccount } = await loadMonitorAccountRuntime();

const monitorPromises: Promise<void>[] = [];

for (const account of accounts) {

if (opts.abortSignal?.aborted) {