// Covers outbound delivery core: hooks, queue cleanup, durable capability

// checks, adapter sends, transcript mirroring, and payload outcomes.

import path from "node:path";

import { afterEach, beforeAll, beforeEach, describe, expect, it, vi } from "vitest";

import { chunkText } from "../../auto-reply/chunk.js";

// Outbound delivery core runs plugin hooks, queue durability, channel adapter

// sends, commit hooks, diagnostics, transcript mirroring, and payload outcomes.

import { resolveChunkMode, resolveTextChunkLimit } from "../../auto-reply/chunk.js";

import { runReplyPayloadSendingHook } from "../../auto-reply/reply/reply-payload-sending-hook.js";

import type { ReplyPayload } from "../../auto-reply/types.js";

| undefined;

async function loadTranscriptRuntime() {

// Transcript writes are optional side effects; keep this lazy for import-only

// delivery policy checks and tests.

transcriptRuntimePromise ??= import("../../config/sessions/transcript.runtime.js");

return await transcriptRuntimePromise;

}

// Delivery commit hooks attach post-commit side effects to result objects

// without widening the public outbound result shape.

import { createSubsystemLogger } from "../../logging/subsystem.js";

import { formatErrorMessage } from "../errors.js";

import type { OutboundDeliveryResult } from "./deliver-types.js";

// Delivery queue recovery drains pending outbound sends with backoff, crash

// replay protection, unknown-send reconciliation, and failed-entry pruning.

import {

resolveDateTimestampMs,

resolveExpiresAtMsFromDurationMs,

entry.recoveryState === "send_attempt_started" ||

entry.recoveryState === "unknown_after_send"

) {

// A crash after platform send start cannot be blindly replayed; adapters

// must reconcile whether the platform already committed the message.

const reconciliation = await reconcileUnknownQueuedDelivery({

entry,

cfg: opts.cfg,

// Delivery queue storage persists replayable outbound send intents and tracks

// platform-send recovery state in the shared SQLite queue.

import type { ReplyDispatchKind } from "../../auto-reply/reply/reply-dispatcher.types.js";

import type { ReplyPayload } from "../../auto-reply/types.js";

import type { RenderedMessageBatchPlanItem } from "../../channels/message/types.js";

// Covers delivery retry policy: permanent-error classification, backoff timing,

// and first-replay eligibility after crashes.

import { describe, expect, it } from "vitest";

import {

computeBackoffMs,

// Covers reconnect-triggered queue drain selection, active claims, backoff

// bypass, and concurrent drain suppression.

import { beforeEach, describe, expect, it, vi } from "vitest";

import type { OpenClawConfig } from "../../config/config.js";

import { openOpenClawStateDatabase } from "../../state/openclaw-state-db.js";

// Covers startup delivery recovery, backoff, permanent failures, unknown-send

// reconciliation, commit hooks, and retry budget deferral.

import { MAX_DATE_TIMESTAMP_MS } from "@openclaw/normalization-core/number-coercion";

import { beforeEach, describe, expect, it, vi } from "vitest";

import { openOpenClawStateDatabase } from "../../state/openclaw-state-db.js";

// Verifies SQLite-backed outbound queue storage, metadata, failure updates,

// recovery-state markers, and failed-entry moves.

import path from "node:path";

import { describe, expect, it } from "vitest";

import { openOpenClawStateDatabase } from "../../state/openclaw-state-db.js";

// Test helpers provide isolated delivery-queue state directories and logger

// stubs for queue/recovery tests.

import fs from "node:fs";

import path from "node:path";

import { afterAll, beforeAll, beforeEach, vi } from "vitest";