import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/text-runtime";

import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/string-coerce-runtime";

import type { NormalizedWebhookMessage } from "./monitor-normalize.js";

import type { BlueBubblesCoreRuntime, WebhookTarget } from "./monitor-shared.js";

import type { OpenClawConfig } from "./runtime-api.js";

normalizeLowercaseStringOrEmpty,

normalizeOptionalLowercaseString,

normalizeOptionalString,

} from "openclaw/plugin-sdk/text-runtime";

} from "openclaw/plugin-sdk/string-coerce-runtime";

import {

downloadBlueBubblesAttachment,

fetchBlueBubblesMessageAttachments,

import type { IncomingMessage, ServerResponse } from "node:http";

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

import { formatErrorMessage } from "openclaw/plugin-sdk/error-runtime";

import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/text-runtime";

import { normalizeLowercaseStringOrEmpty } from "openclaw/plugin-sdk/string-coerce-runtime";

import { resolveBlueBubblesEffectiveAllowPrivateNetwork } from "./accounts.js";

import { runBlueBubblesCatchup } from "./catchup.js";

import { createBlueBubblesDebounceRegistry } from "./monitor-debounce.js";

import {

asRecord,

// same processMessage path webhooks use, and #66230's inbound dedupe

// drops any GUID that was already handled, so this is safe even if a

// live webhook raced the startup replay. See #66721.

runBlueBubblesCatchup(target).catch((err) => {

runtime.error?.(

`[${account.accountId}] BlueBubbles catchup: unexpected failure: ${String(err)}`,

);

});

import("./catchup.js")

.then(({ runBlueBubblesCatchup }) => runBlueBubblesCatchup(target))

.catch((err) => {

runtime.error?.(

`[${account.accountId}] BlueBubbles catchup: unexpected failure: ${String(err)}`,

);

});

});

}