convert speech with ffmpeg

Author: clairton

src/jobs/speecher.ts

@@ -3,6 +3,7 @@ import { getConfig } from '../services/config'
 import logger from '../services/logger'
 import { DATA_URL_TTL } from '../defaults'
 import { Incoming } from '../services/incoming'
+import { fromBuffer } from '../utils/audio_converter'
 
 export class SpeecherJob {
   private service: Incoming
@@ -22,9 +23,9 @@ export class SpeecherJob {
       model: config.openaiApiSpeechModel!,
       voice: config.openaiApiSpeechVoice!,
       input: payload.speech.body,
-      response_format: 'opus'
     })
-    const buffer = Buffer.from(await audio.arrayBuffer())
+    const openaiBuffer = Buffer.from(await audio.arrayBuffer())
+    const { buffer } = await fromBuffer(openaiBuffer)
     const { mediaStore } = await config.getStore(phone, config)
     const fileName = `${phone}/${id}.ogg`
     await mediaStore.saveMediaBuffer(fileName, buffer)

src/utils/audio_converter.ts

@@ -14,6 +14,10 @@ export default async function (url: string): Promise<{ buffer: Buffer; waveform:
     throw `Erro on open ${url}: ${await response?.text()}`
   }
   const inputBuffer = Buffer.from(await response.arrayBuffer())
+  return fromBuffer(inputBuffer)
+}
+
+export async function fromBuffer(inputBuffer: Buffer): Promise<{ buffer: Buffer; waveform: Uint8Array | undefined }> {
   const inputFile = path.join(os.tmpdir(), `${uuid()}`)
   const outputFile = path.join(os.tmpdir(), `${uuid()}`)
   await writeFileSync(inputFile, inputBuffer)