"use strict";Object.defineProperty(exports, "__esModule", { value: true });exports.i = markdownToWhatsApp;exports.n = sendPollWhatsApp;exports.r = sendReactionWhatsApp;exports.t = sendMessageWhatsApp;var _accountsBFBjizxh = require("./accounts-BFBjizxh.js");
var _configDiiPndBn = require("./config-DiiPndBn.js");
var _loggerU3s76KST = require("./logger-U3s76KST.js");
var _pollsVFmJRKGR = require("./polls-VFmJRKGR.js");
var _irKp5uANes = require("./ir-Kp5uANes.js");
var _tablesDkBUhlLj = require("./tables-DkBUhlLj.js");
var _secureRandom_kmh2emF = require("./secure-random-_kmh2emF.js");
var _activeListenerCMb_0BEz = require("./active-listener-CMb_0BEz.js");
//#region src/markdown/whatsapp.ts
/**
* Convert standard Markdown formatting to WhatsApp-compatible markup.
*
* WhatsApp uses its own formatting syntax:
*   bold:          *text*
*   italic:        _text_
*   strikethrough: ~text~
*   monospace:     ```text```
*
* Standard Markdown uses:
*   bold:          **text** or __text__
*   italic:        *text* or _text_
*   strikethrough: ~~text~~
*   code:          `text` (inline) or ```text``` (block)
*
* The conversion preserves fenced code blocks and inline code,
* then converts bold and strikethrough markers.
*/
/** Placeholder tokens used during conversion to protect code spans. */
const FENCE_PLACEHOLDER = "\0FENCE";
const INLINE_CODE_PLACEHOLDER = "\0CODE";
/**
* Convert standard Markdown bold/italic/strikethrough to WhatsApp formatting.
*
* Order of operations matters:
* 1. Protect fenced code blocks (```...```) — already WhatsApp-compatible
* 2. Protect inline code (`...`) — leave as-is
* 3. Convert **bold** → *bold* and __bold__ → *bold*
* 4. Convert ~~strike~~ → ~strike~
* 5. Restore protected spans
*
* Italic *text* and _text_ are left alone since WhatsApp uses _text_ for italic
* and single * is already WhatsApp bold — no conversion needed for single markers.
*/
function markdownToWhatsApp(text) {
  if (!text) return text;
  const fences = [];
  let result = text.replace(/```[\s\S]*?```/g, (match) => {
    fences.push(match);
    return `${FENCE_PLACEHOLDER}${fences.length - 1}`;
  });
  const inlineCodes = [];
  result = result.replace(/`[^`\n]+`/g, (match) => {
    inlineCodes.push(match);
    return `${INLINE_CODE_PLACEHOLDER}${inlineCodes.length - 1}`;
  });
  result = result.replace(/\*\*(.+?)\*\*/g, "*$1*");
  result = result.replace(/__(.+?)__/g, "*$1*");
  result = result.replace(/~~(.+?)~~/g, "~$1~");
  result = result.replace(new RegExp(`${(0, _loggerU3s76KST.v)(INLINE_CODE_PLACEHOLDER)}(\\d+)`, "g"), (_, idx) => inlineCodes[Number(idx)] ?? "");
  result = result.replace(new RegExp(`${(0, _loggerU3s76KST.v)(FENCE_PLACEHOLDER)}(\\d+)`, "g"), (_, idx) => fences[Number(idx)] ?? "");
  return result;
}
//#endregion
//#region src/web/outbound.ts
const outboundLog = (0, _loggerU3s76KST.a)("gateway/channels/whatsapp").child("outbound");
async function sendMessageWhatsApp(to, body, options) {
  let text = body;
  const correlationId = (0, _secureRandom_kmh2emF.n)();
  const startedAt = Date.now();
  const { listener: active, accountId: resolvedAccountId } = (0, _activeListenerCMb_0BEz.n)(options.accountId);
  const cfg = options.cfg ?? (0, _configDiiPndBn.i)();
  const account = (0, _accountsBFBjizxh.i)({
    cfg,
    accountId: resolvedAccountId ?? options.accountId
  });
  const tableMode = (0, _irKp5uANes.i)({
    cfg,
    channel: "whatsapp",
    accountId: resolvedAccountId ?? options.accountId
  });
  text = (0, _tablesDkBUhlLj.t)(text ?? "", tableMode);
  text = markdownToWhatsApp(text);
  const redactedTo = (0, _activeListenerCMb_0BEz.i)(to);
  const logger = (0, _loggerU3s76KST.K)({
    module: "web-outbound",
    correlationId,
    to: redactedTo
  });
  try {
    const jid = (0, _loggerU3s76KST.N)(to);
    const redactedJid = (0, _activeListenerCMb_0BEz.i)(jid);
    let mediaBuffer;
    let mediaType;
    let documentFileName;
    if (options.mediaUrl) {
      const media = await (0, _irKp5uANes.v)(options.mediaUrl, {
        maxBytes: (0, _accountsBFBjizxh.o)(account),
        localRoots: options.mediaLocalRoots
      });
      const caption = text || void 0;
      mediaBuffer = media.buffer;
      mediaType = media.contentType;
      if (media.kind === "audio") mediaType = media.contentType === "audio/ogg" ? "audio/ogg; codecs=opus" : media.contentType ?? "application/octet-stream";else
      if (media.kind === "video") text = caption ?? "";else
      if (media.kind === "image") text = caption ?? "";else
      {
        text = caption ?? "";
        documentFileName = media.fileName;
      }
    }
    outboundLog.info(`Sending message -> ${redactedJid}${options.mediaUrl ? " (media)" : ""}`);
    logger.info({
      jid: redactedJid,
      hasMedia: Boolean(options.mediaUrl)
    }, "sending message");
    await active.sendComposingTo(to);
    const accountId = Boolean(options.accountId?.trim()) ? resolvedAccountId : void 0;
    const sendOptions = options.gifPlayback || accountId || documentFileName ? {
      ...(options.gifPlayback ? { gifPlayback: true } : {}),
      ...(documentFileName ? { fileName: documentFileName } : {}),
      accountId
    } : void 0;
    const messageId = (sendOptions ? await active.sendMessage(to, text, mediaBuffer, mediaType, sendOptions) : await active.sendMessage(to, text, mediaBuffer, mediaType))?.messageId ?? "unknown";
    const durationMs = Date.now() - startedAt;
    outboundLog.info(`Sent message ${messageId} -> ${redactedJid}${options.mediaUrl ? " (media)" : ""} (${durationMs}ms)`);
    logger.info({
      jid: redactedJid,
      messageId
    }, "sent message");
    return {
      messageId,
      toJid: jid
    };
  } catch (err) {
    logger.error({
      err: String(err),
      to: redactedTo,
      hasMedia: Boolean(options.mediaUrl)
    }, "failed to send via web session");
    throw err;
  }
}
async function sendReactionWhatsApp(chatJid, messageId, emoji, options) {
  const correlationId = (0, _secureRandom_kmh2emF.n)();
  const { listener: active } = (0, _activeListenerCMb_0BEz.n)(options.accountId);
  const redactedChatJid = (0, _activeListenerCMb_0BEz.i)(chatJid);
  const logger = (0, _loggerU3s76KST.K)({
    module: "web-outbound",
    correlationId,
    chatJid: redactedChatJid,
    messageId
  });
  try {
    const redactedJid = (0, _activeListenerCMb_0BEz.i)((0, _loggerU3s76KST.N)(chatJid));
    outboundLog.info(`Sending reaction "${emoji}" -> message ${messageId}`);
    logger.info({
      chatJid: redactedJid,
      messageId,
      emoji
    }, "sending reaction");
    await active.sendReaction(chatJid, messageId, emoji, options.fromMe ?? false, options.participant);
    outboundLog.info(`Sent reaction "${emoji}" -> message ${messageId}`);
    logger.info({
      chatJid: redactedJid,
      messageId,
      emoji
    }, "sent reaction");
  } catch (err) {
    logger.error({
      err: String(err),
      chatJid: redactedChatJid,
      messageId,
      emoji
    }, "failed to send reaction via web session");
    throw err;
  }
}
async function sendPollWhatsApp(to, poll, options) {
  const correlationId = (0, _secureRandom_kmh2emF.n)();
  const startedAt = Date.now();
  const { listener: active } = (0, _activeListenerCMb_0BEz.n)(options.accountId);
  const redactedTo = (0, _activeListenerCMb_0BEz.i)(to);
  const logger = (0, _loggerU3s76KST.K)({
    module: "web-outbound",
    correlationId,
    to: redactedTo
  });
  try {
    const jid = (0, _loggerU3s76KST.N)(to);
    const redactedJid = (0, _activeListenerCMb_0BEz.i)(jid);
    const normalized = (0, _pollsVFmJRKGR.n)(poll, { maxOptions: 12 });
    outboundLog.info(`Sending poll -> ${redactedJid}`);
    logger.info({
      jid: redactedJid,
      optionCount: normalized.options.length,
      maxSelections: normalized.maxSelections
    }, "sending poll");
    const messageId = (await active.sendPoll(to, normalized))?.messageId ?? "unknown";
    const durationMs = Date.now() - startedAt;
    outboundLog.info(`Sent poll ${messageId} -> ${redactedJid} (${durationMs}ms)`);
    logger.info({
      jid: redactedJid,
      messageId
    }, "sent poll");
    return {
      messageId,
      toJid: jid
    };
  } catch (err) {
    logger.error({
      err: String(err),
      to: redactedTo
    }, "failed to send poll via web session");
    throw err;
  }
}
//#endregion /* v9-f9c551b27067e90e */