81 lines
2.3 KiB
JavaScript
81 lines
2.3 KiB
JavaScript
// utils/decryptMediaContent.js (ES modules)
|
|
import fs from 'fs';
|
|
import path from 'path';
|
|
import axios from 'axios';
|
|
import mime from 'mime-types';
|
|
import { decryptMedia } from '@open-wa/wa-automate';
|
|
import { log } from '../logger.js';
|
|
|
|
// 🔒 quita caracteres que rompen rutas
|
|
const safe = s => (s || '').replace(/[\\/:*?"<>|]/g, '_');
|
|
|
|
export async function decryptMediaContent(
|
|
mediaInfo,
|
|
outputDir = 'media/dec',
|
|
rawDir = 'media/raw',
|
|
filename = null
|
|
) {
|
|
const { clientUrl, t, filehash, msgId, type } = mediaInfo;
|
|
let { mimetype } = mediaInfo;
|
|
|
|
if (!clientUrl) {
|
|
log('error', '❌ Sin clientUrl, no se puede bajar');
|
|
return null;
|
|
}
|
|
|
|
// deducir mimetype si falta
|
|
if (!mimetype) {
|
|
mimetype =
|
|
mime.lookup(clientUrl) ||
|
|
(type?.startsWith('image') && 'image/jpeg') ||
|
|
(type?.startsWith('video') && 'video/mp4') ||
|
|
'application/octet-stream';
|
|
}
|
|
|
|
const ext = mime.extension(mimetype) || 'bin';
|
|
const baseName = safe(filename || msgId || filehash?.slice(0,16) || `file_${t||Date.now()}`);
|
|
const rawPath = path.join(rawDir , `${baseName}.enc`);
|
|
const decPath = path.join(outputDir, `${baseName}.${ext}`);
|
|
|
|
if (fs.existsSync(decPath)) return decPath;
|
|
|
|
fs.mkdirSync(rawDir , { recursive: true });
|
|
fs.mkdirSync(outputDir, { recursive: true });
|
|
|
|
try {
|
|
/* ───── descarga RAW (solo si no existe) ───── */
|
|
if (!fs.existsSync(rawPath)) {
|
|
const { data } = await axios
|
|
.get(clientUrl, { responseType: 'arraybuffer' })
|
|
.catch(e => {
|
|
if (e.response?.status === 410) throw new Error('URL expirada (410)');
|
|
throw e;
|
|
});
|
|
fs.writeFileSync(rawPath, Buffer.from(data));
|
|
}
|
|
|
|
/* ───── inyectar RAW para que decryptMedia no lo vuelva a bajar ───── */
|
|
const fake = {
|
|
...mediaInfo,
|
|
mimetype,
|
|
mimeType: mimetype,
|
|
_data: {
|
|
...mediaInfo,
|
|
mimetype,
|
|
mimeType: mimetype,
|
|
_raw: fs.readFileSync(rawPath)
|
|
}
|
|
};
|
|
|
|
const plain = await decryptMedia(fake);
|
|
if (!plain?.length) throw new Error('descifrado vacío');
|
|
|
|
fs.writeFileSync(decPath, plain);
|
|
log('info', `✔️ ${type || ext} → ${decPath}`);
|
|
return decPath;
|
|
} catch (e) {
|
|
log('error', `❌ decryptMedia falló → ${e.message}`);
|
|
return null;
|
|
}
|
|
}
|