Hanzo_dev
b11d57465e
- transcriptor: restaurar await toFile() — sin él Whisper recibía una Promise en vez del archivo y devolvía 400 - transcriptor: detectar MIME type real (m4a para Instagram, mp3 TikTok) - analizar: normalizar duración (TikTok→ms, Instagram→s float) a entero antes de guardar en Supabase y pasar a GPT-4o - analizar/server: reemplazar .catch() en insert de error por try/catch — el builder de Supabase no expone .catch() directamente; el TypeError escapaba al outer catch y causaba FUNCTION_INVOCATION_FAILED en Vercel - validador: fallback de último recurso en enums cuando GPT-4o devuelve valor inválido (ej. "ninguno" para desarrollo_tipo) Probado end-to-end: Instagram Reel → OK en 27s Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
64 lines
2.5 KiB
JavaScript
64 lines
2.5 KiB
JavaScript
// ============================================================
|
|
// TRANSCRIPTOR — OpenAI Whisper
|
|
// Descarga el audio desde la URL y lo transcribe
|
|
// Incluye reintentos automáticos para URLs de CDN inestables
|
|
// ============================================================
|
|
import OpenAI, { toFile } from 'openai'
|
|
|
|
const openai = new OpenAI({ apiKey: process.env.OPENAI_API_KEY })
|
|
|
|
/**
|
|
* Descarga una URL con reintentos (para CDNs que expiran o fallan transitoriamente)
|
|
* @param {string} url
|
|
* @param {number} intentos Máximo de intentos (default: 3)
|
|
* @returns {Response}
|
|
*/
|
|
async function fetchConReintentos(url, intentos = 3) {
|
|
let ultimoError
|
|
for (let i = 1; i <= intentos; i++) {
|
|
try {
|
|
const res = await fetch(url)
|
|
if (res.ok) return res
|
|
ultimoError = new Error(`HTTP ${res.status} al descargar audio (intento ${i}/${intentos})`)
|
|
} catch (err) {
|
|
ultimoError = err
|
|
}
|
|
if (i < intentos) await new Promise(r => setTimeout(r, 1200 * i)) // backoff: 1.2s, 2.4s
|
|
}
|
|
throw ultimoError
|
|
}
|
|
|
|
/**
|
|
* @param {string} audioUrl URL directa del MP3 (de Social Download API)
|
|
* @param {string} idioma Código de idioma: 'es', 'en', 'pt', etc.
|
|
* @returns {string} Transcripción completa del audio
|
|
*/
|
|
export async function transcribir(audioUrl, idioma = 'es') {
|
|
const audioResponse = await fetchConReintentos(audioUrl)
|
|
|
|
// En Vercel Serverless (Node < 20), Web API `File` no está disponible por defecto,
|
|
// y `arrayBuffer` consume mucha RAM. `toFile` soluciona ambos.
|
|
// Detectar extensión real del audio (TikTok→mp3, Instagram→m4a, etc.)
|
|
const ext = audioUrl.split('?')[0].split('.').pop()?.toLowerCase() || 'mp3'
|
|
const mimeMap = { mp3: 'audio/mpeg', m4a: 'audio/mp4', mp4: 'audio/mp4', webm: 'audio/webm', ogg: 'audio/ogg', wav: 'audio/wav' }
|
|
const mimeType = mimeMap[ext] || 'audio/mpeg'
|
|
// toFile es async en el SDK de OpenAI — await es necesario aunque el IDE lo marque como hint
|
|
const audioFile = await toFile(audioResponse, `audio.${ext}`, { type: mimeType })
|
|
|
|
const transcripcion = await openai.audio.transcriptions.create({
|
|
file: audioFile,
|
|
model: 'whisper-1',
|
|
language: idioma === 'otro' ? undefined : idioma, // auto-detect si es 'otro'
|
|
response_format: 'text',
|
|
})
|
|
|
|
if (!transcripcion || transcripcion.trim().length < 10) {
|
|
throw new Error(
|
|
'Whisper no detectó voz suficiente en el audio. ' +
|
|
'Verifica que el video tenga narración clara (no solo música o texto en pantalla).'
|
|
)
|
|
}
|
|
|
|
return transcripcion.trim()
|
|
}
|