Stream transcription and phrase emotion with Node.js

ffmpeg -i recording.wav -ar 16000 -ac 1 -f s16le recording.pcm
curl --fail -O https://oruk.ai/examples/realtime-phrase-emotions.mjs
# Set ORUK_API_KEY in your environment, then run:
node realtime-phrase-emotions.mjs recording.pcm

// Node.js 22+; run on your server, where ORUK_API_KEY can remain private.
// Usage: ORUK_API_KEY=... node realtime-phrase-emotions.mjs recording.pcm
// Input: raw mono signed PCM16, little-endian, 16,000 Hz (no WAV header).
import { readFile } from 'node:fs/promises'

const file = process.argv[2]
const key = process.env.ORUK_API_KEY
if (!key || !file) throw new Error('Set ORUK_API_KEY and pass a .pcm filename.')
const pcm = await readFile(file)
if (!pcm.length || pcm.length % 2) throw new Error('Expected nonempty PCM16 audio.')

const socket = new WebSocket(
  'wss://speech-api.oruk.ai/v1/realtime?model=oruk-realtime',
  ['oruk-realtime', `oruk-api-key.${key}`],
)
await new Promise((resolve, reject) => {
  let settled = false
  let started = false
  const timer = setTimeout(() => finish(new Error('Realtime session timed out.')), 60_000)
  function finish(error) {
    if (settled) return
    settled = true
    clearTimeout(timer)
    socket.close()
    if (error) reject(error)
    else resolve()
  }
  socket.addEventListener('message', ({ data }) => {
    if (typeof data !== 'string') return
    let event
    try { event = JSON.parse(data) } catch { return }
    if (event.type === 'session.created' && !started) {
      started = true
      socket.send(JSON.stringify({
        type: 'session.update',
        session: {
          model: 'oruk-realtime', language: 'auto', sample_rate: 16000,
          word_timestamps: true, phrase_emotions: true,
          phrase_silence_ms: 600, diarize: false,
        },
      }))
      // A saved clip can be uploaded immediately. A microphone sends chunks
      // as they become available, using the same binary-frame format.
      for (let offset = 0; offset < pcm.length; offset += 10240) {
        socket.send(pcm.subarray(offset, offset + 10240))
      }
      socket.send(JSON.stringify({ type: 'input_audio_buffer.commit' }))
    }
    if (['conversation.item.input_audio_transcription.completed',
      'conversation.item.input_audio_emotion.completed',
      'conversation.item.input_audio_emotion.failed', 'session.usage'].includes(event.type)) {
      console.log(JSON.stringify(event))
    }
    if (event.type === 'error') finish(new Error(event.error?.code ?? 'realtime_error'))
    if (event.type === 'session.usage') finish()
  })
  socket.addEventListener('error', () => finish(new Error('Realtime connection failed.')))
  socket.addEventListener('close', () => {
    if (!settled) finish(new Error('Realtime closed before session.usage.'))
  })
})