119 lines
3.3 KiB
JavaScript
119 lines
3.3 KiB
JavaScript
import { fetchBlobURL } from './utils';
|
|
import FfmpegWorker from './ffmpeg.worker.js?worker'
|
|
const ffmpegBase = 'https://unpkg.com/@ffmpeg/core/dist/esm';
|
|
const coreJs = `${ffmpegBase}/ffmpeg-core.js`;
|
|
const coreWasm = `${ffmpegBase}/ffmpeg-core.wasm`;
|
|
|
|
class FfmpegError extends Error {
|
|
constructor(message) {
|
|
super(message);
|
|
this.name = 'FfmpegError';
|
|
this.code = 'FFMPEG_FAILED';
|
|
}
|
|
}
|
|
|
|
export function loadFfmpeg() {
|
|
return (
|
|
loadFfmpeg.promise ||
|
|
(loadFfmpeg.promise = (async () => {
|
|
const data = {
|
|
coreURL: await fetchBlobURL(coreJs),
|
|
wasmURL: await fetchBlobURL(coreWasm),
|
|
};
|
|
|
|
return data;
|
|
})())
|
|
);
|
|
}
|
|
|
|
async function ffmpegWorker(
|
|
audioBlob,
|
|
args = {},
|
|
outputName = 'output',
|
|
outputMime = 'application/octet-stream',
|
|
onProgress = null,
|
|
signal = null
|
|
) {
|
|
const audioData = await audioBlob.arrayBuffer();
|
|
const assets = loadFfmpeg();
|
|
|
|
return new Promise((resolve, reject) => {
|
|
const worker = new FfmpegWorker();
|
|
|
|
// Handle abort signal
|
|
const abortHandler = () => {
|
|
worker.terminate();
|
|
reject(new FfmpegError('FFMPEG aborted'));
|
|
};
|
|
|
|
if (signal) {
|
|
if (signal.aborted) {
|
|
abortHandler();
|
|
return;
|
|
}
|
|
signal.addEventListener('abort', abortHandler);
|
|
}
|
|
|
|
worker.onmessage = (e) => {
|
|
const { type, blob, message, stage, progress } = e.data;
|
|
|
|
if (type === 'complete') {
|
|
if (signal) signal.removeEventListener('abort', abortHandler);
|
|
worker.terminate();
|
|
resolve(blob);
|
|
} else if (type === 'error') {
|
|
if (signal) signal.removeEventListener('abort', abortHandler);
|
|
worker.terminate();
|
|
reject(new FfmpegError(message));
|
|
} else if (type === 'progress' && onProgress) {
|
|
onProgress({ stage, message, progress });
|
|
} else if (type === 'log') {
|
|
console.log('[FFmpeg]', message);
|
|
}
|
|
};
|
|
|
|
worker.onerror = (error) => {
|
|
if (signal) signal.removeEventListener('abort', abortHandler);
|
|
worker.terminate();
|
|
reject(new FfmpegError('Worker failed: ' + error.message));
|
|
};
|
|
|
|
(async () => {
|
|
worker.postMessage(
|
|
{
|
|
audioData,
|
|
...args,
|
|
output: {
|
|
name: outputName,
|
|
mime: outputMime,
|
|
},
|
|
loadOptions: await assets,
|
|
},
|
|
[audioData]
|
|
);
|
|
})();
|
|
});
|
|
}
|
|
|
|
export async function ffmpeg(
|
|
audioBlob,
|
|
args = {},
|
|
outputName = 'output',
|
|
outputMime = 'application/octet-stream',
|
|
onProgress = null,
|
|
signal = null
|
|
) {
|
|
try {
|
|
// Use Web Worker for non-blocking FFmpeg encoding
|
|
if (typeof Worker !== 'undefined') {
|
|
return await ffmpegWorker(audioBlob, args, outputName, outputMime, onProgress, signal);
|
|
}
|
|
|
|
throw new FfmpegError('Web Workers are required for FFMPEG');
|
|
} catch (error) {
|
|
console.error('FFMPEG failed:', error);
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
export { FfmpegError };
|