Transcripción de audio en tickets

# Codificar el audio en base64 y enviarlo
AUDIO_BASE64=$(base64 -i grabacion.webm)
 
curl -X POST 'https://os.utilia.ai/api/external/v1/tickets/ai-transcribe' \
  -H 'Content-Type: application/json' \
  -H 'X-Api-Key: utl_tu_clave_de_api' \
  -H 'x-request-id: req-transcribe-001' \
  -d "{
    \"audioBase64\": \"${AUDIO_BASE64}\",
    \"audioFilename\": \"grabacion.webm\"
  }"

AUDIO_BASE64=$(base64 -i reunion-larga.mp3)
 
curl -X POST 'https://os.utilia.ai/api/external/v1/tickets/ai-transcribe-async' \
  -H 'Content-Type: application/json' \
  -H 'X-Api-Key: utl_tu_clave_de_api' \
  -H 'x-request-id: req-transcribe-async-001' \
  -d "{
    \"audioBase64\": \"${AUDIO_BASE64}\",
    \"audioFilename\": \"reunion-larga.mp3\"
  }"

curl -N -X GET 'https://os.utilia.ai/api/external/v1/tickets/ai-transcribe/job_tr_abc123/stream' \
  -H 'X-Api-Key: utl_tu_clave_de_api' \
  -H 'Accept: text/event-stream' \
  -H 'x-request-id: req-transcribe-stream-001'
 
# Salida real (sin líneas `event:`, el tipo va dentro del JSON):
# data: {"event":"progress","progress":30}
#
# data: {"event":"progress","progress":80}
#
# data: {"event":"completed","result":{"transcription":"Hola, quiero reportar un problema..."}}

curl -X GET 'https://os.utilia.ai/api/external/v1/tickets/ai-transcribe/job_tr_abc123' \
  -H 'X-Api-Key: utl_tu_clave_de_api' \
  -H 'x-request-id: req-transcribe-poll-001'
 
# Respuesta cuando está en progreso:
# {
#   "status": "processing",
#   "progress": 45
# }
 
# Respuesta cuando ha completado:
# {
#   "status": "completed",
#   "transcription": "Hola, quiero reportar un problema con la exportación de informes..."
# }

const API_BASE = 'https://os.utilia.ai/api/external/v1/tickets';
const headers = {
  'Content-Type': 'application/json',
  'X-Api-Key': 'utl_tu_clave_de_api',
};
 
// 1. Obtener el audio (ejemplo: desde un input file)
const fileInput = document.querySelector('input[type="file"]');
const audioFile = fileInput.files[0];
const arrayBuffer = await audioFile.arrayBuffer();
const base64 = btoa(
  new Uint8Array(arrayBuffer).reduce(
    (data, byte) => data + String.fromCharCode(byte),
    ''
  )
);
 
// 2. Decidir síncrono o asíncrono según el tamaño
const MAX_SYNC_SIZE = 10 * 1024 * 1024; // 10 MB
 
if (audioFile.size <= MAX_SYNC_SIZE) {
  // Transcripción síncrona
  const response = await fetch(`${API_BASE}/ai-transcribe`, {
    method: 'POST',
    headers,
    body: JSON.stringify({
      audioBase64: base64,
      audioFilename: audioFile.name,
    }),
  });
  const { transcription } = await response.json();
  console.log('Transcripción (síncrona):', transcription);
} else {
  // Transcripción asíncrona con streaming (fetch + ReadableStream)
  const enqueue = await fetch(`${API_BASE}/ai-transcribe-async`, {
    method: 'POST',
    headers,
    body: JSON.stringify({
      audioBase64: base64,
      audioFilename: audioFile.name,
    }),
  });
  const { jobId } = await enqueue.json();
 
  // Importante: el SSE emite TODOS los eventos como `message`. Lee el
  // campo `event` del JSON; no uses addEventListener('completed', ...).
  const stream = await fetch(`${API_BASE}/ai-transcribe/${jobId}/stream`, {
    method: 'GET',
    headers: {
      'X-Api-Key': 'utl_tu_clave_de_api',
      Accept: 'text/event-stream',
    },
  });
 
  const reader = stream.body.getReader();
  const decoder = new TextDecoder();
  let buffer = '';
  outer: while (true) {
    const { value, done } = await reader.read();
    if (done) break;
    buffer += decoder.decode(value, { stream: true });
    let sep = buffer.indexOf('\n\n');
    while (sep !== -1) {
      const bloque = buffer.slice(0, sep);
      buffer = buffer.slice(sep + 2);
      sep = buffer.indexOf('\n\n');
      const dataLines = bloque
        .split('\n')
        .filter((l) => l.startsWith('data:'))
        .map((l) => l.slice(5).trimStart());
      if (dataLines.length === 0) continue;
      const data = JSON.parse(dataLines.join('\n'));
      if (data.event === 'completed') {
        console.log('Transcripción (asíncrona):', data.result.transcription);
        reader.cancel();
        break outer;
      }
      if (data.event === 'failed') {
        console.error('Error:', data.error);
        reader.cancel();
        break outer;
      }
    }
  }
}