import { readdir, readFile, stat, unlink } from "node:fs/promises";

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

import { join } from "node:path";

import {

asDateTimestampMs,

resolveExpiresAtMsFromDurationMs,

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

import { loadOutboundMediaFromUrl } from "openclaw/plugin-sdk/outbound-media";

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

import { resolvePreferredOpenClawTmpDir } from "openclaw/plugin-sdk/temp-path";

}

async function cleanupExpiredHostedZaloMedia(nowMs = Date.now()): Promise<void> {

const now = asDateTimestampMs(nowMs);

if (now === undefined) {

return;

}

let fileNames: string[];

try {

fileNames = await readdir(ZALO_OUTBOUND_MEDIA_DIR);

try {

const metadataRaw = await readFile(resolveHostedZaloMediaMetadataPath(id), "utf8");

const metadata = JSON.parse(metadataRaw) as HostedZaloMediaMetadata;

if (metadata.expiresAt <= nowMs) {

const expiresAt = asDateTimestampMs(metadata.expiresAt);

if (expiresAt === undefined || expiresAt <= now) {

await deleteHostedZaloMediaEntry(id);

}

} catch {

await ensureHostedZaloMediaDir();

await cleanupExpiredHostedZaloMedia();

const now = asDateTimestampMs(Date.now());

const expiresAt =

now === undefined

? undefined

: resolveExpiresAtMsFromDurationMs(ZALO_OUTBOUND_MEDIA_TTL_MS, { nowMs: now });

if (expiresAt === undefined) {

throw new Error("Zalo outbound media expiry could not be resolved");

}

const media = await loadOutboundMediaFromUrl(params.mediaUrl, {

maxBytes: params.maxBytes,

...(params.proxyUrl ? { proxyUrl: params.proxyUrl } : {}),

routePath,

token,

contentType: media.contentType,

expiresAt: Date.now() + ZALO_OUTBOUND_MEDIA_TTL_MS,

expiresAt,

} satisfies HostedZaloMediaMetadata);

} catch (error) {

await deleteHostedZaloMediaEntry(id);

return true;

}

if (entry.metadata.expiresAt <= Date.now()) {

const now = asDateTimestampMs(Date.now());

const expiresAt = asDateTimestampMs(entry.metadata.expiresAt);

if (now === undefined || expiresAt === undefined || expiresAt <= now) {

await deleteHostedZaloMediaEntry(id);

res.statusCode = 410;

res.end("Expired");