Spaces:
Running
Running
| // Encodes PCM chunks to MP3 off the main thread, as they arrive. | |
| import { Mp3Encoder } from '../vendor/lamejs/lamejs.js'; | |
| let enc = null, parts = [], job = 0; | |
| onmessage = ({ data }) => { | |
| if (data.type === 'start') { | |
| job = data.job; parts = []; | |
| enc = new Mp3Encoder(1, data.sampleRate, data.kbps || 64); | |
| } else if (data.type === 'chunk' && data.job === job && enc) { | |
| const pcm = data.pcm, step = 1152 * 16; | |
| for (let i = 0; i < pcm.length; i += step) { | |
| const b = enc.encodeBuffer(pcm.subarray(i, i + step)); | |
| if (b.length) parts.push(b); | |
| } | |
| postMessage({ type: 'encoded', job, index: data.index }); | |
| } else if (data.type === 'finish' && data.job === job && enc) { | |
| const b = enc.flush(); | |
| if (b.length) parts.push(b); | |
| postMessage({ type: 'done', job, blob: new Blob(parts, { type: 'audio/mpeg' }) }); | |
| enc = null; parts = []; | |
| } | |
| }; | |