/**
 * Run one oruk file request and print the complete JSON response.
 * Node.js 22+, tsx, @oruk-ai/sdk 0.2.5+. Set ORUK_API_KEY, then:
 *   npx tsx analyze-file.mts recording.wav --task analysis
 *   npx tsx analyze-file.mts recording.wav --task analysis --diarize
 *   npx tsx analyze-file.mts speaking.wav --task proficiency
 * This calls the metered file API, not the separate realtime WebSocket API.
 * For local fixtures/private deployments only, set ORUK_API_BASE_URL.
 */
import { readFile, stat } from 'node:fs/promises'
import { basename, extname } from 'node:path'
import { parseArgs } from 'node:util'
import { Oruk, OrukApiError } from '@oruk-ai/sdk'
import type { AudioRequest, OrukModel, OrukTask } from '@oruk-ai/sdk'

const tasks: OrukTask[] = ['analysis', 'transcriptions', 'emotions', 'styles', 'affect', 'proficiency']
const models: OrukModel[] = ['oruk-resonance', 'oruk-fourier', 'oruk-proficiency-1']

async function main() {
  const { values, positionals } = parseArgs({
    allowPositionals: true,
    options: {
      task: { type: 'string', default: 'analysis' },
      model: { type: 'string' },
      diarize: { type: 'boolean', default: false },
      'num-speakers': { type: 'string' },
      'transcript-file': { type: 'string' },
      'request-id': { type: 'string' },
      help: { type: 'boolean', short: 'h' },
    },
  })
  if (values.help) {
    console.log(`Usage: npx tsx analyze-file.mts recording.wav [options]
  --task ${tasks.join('|')} (default: analysis)
  --model ${models.join('|')} (default follows task)
  --diarize                 Resonance file endpoints only
  --num-speakers 1..32       Known speaker count; requires --diarize
  --transcript-file FILE     UTF-8 transcript for proficiency only
  --request-id ID            Optional trace ID, reused across SDK retries
Set ORUK_API_KEY in the environment. One command processes one file request.`)
    return
  }
  if (positionals.length !== 1) throw new Error('Supply one audio file; use --help for options.')
  const task = values.task as OrukTask
  if (!tasks.includes(task)) throw new Error('Unknown task; use --help for supported endpoints.')
  const model = (values.model || (task === 'proficiency' ? 'oruk-proficiency-1' : 'oruk-resonance')) as OrukModel
  if (!models.includes(model)) throw new Error('Unknown model; use --help for supported models.')
  if ((task === 'proficiency') !== (model === 'oruk-proficiency-1')) {
    throw new Error('proficiency requires oruk-proficiency-1; other tasks use Resonance or Fourier.')
  }
  if (values.diarize && model !== 'oruk-resonance') throw new Error('--diarize requires a Resonance file endpoint.')
  const speakerValue = values['num-speakers']
  const numSpeakers = speakerValue === undefined ? undefined : Number(speakerValue)
  if (numSpeakers !== undefined && (!values.diarize || !/^\d+$/.test(speakerValue!) || !Number.isInteger(numSpeakers) || numSpeakers < 1 || numSpeakers > 32)) {
    throw new Error('--num-speakers requires --diarize and a count from 1 to 32.')
  }
  const transcriptFile = values['transcript-file']
  if (transcriptFile && task !== 'proficiency') throw new Error('--transcript-file is supported only for proficiency.')
  const apiKey = process.env.ORUK_API_KEY
  if (!apiKey) throw new Error('Set ORUK_API_KEY in the environment; do not put keys in source.')
  const filePath = positionals[0]
  if (!(await stat(filePath)).isFile()) throw new Error('Supply a local audio file.')
  const bytes = await readFile(filePath)
  const mimeTypes: Record<string, string> = {
    '.wav': 'audio/wav', '.flac': 'audio/flac', '.mp3': 'audio/mpeg',
    '.m4a': 'audio/mp4', '.ogg': 'audio/ogg', '.webm': 'audio/webm',
  }
  const request: AudioRequest = {
    file: new Blob([new Uint8Array(bytes)], { type: mimeTypes[extname(filePath).toLowerCase()] || 'application/octet-stream' }),
    filename: basename(filePath), model, requestId: values['request-id'],
    diarize: values.diarize, numSpeakers,
  }
  const client = new Oruk({ apiKey, baseUrl: process.env.ORUK_API_BASE_URL || 'https://speech-api.oruk.ai' })
  const transcript = transcriptFile ? await readFile(transcriptFile, 'utf8') : undefined
  if (transcript !== undefined && !transcript.trim()) throw new Error('--transcript-file must contain the recording’s transcript.')
  const result = task === 'proficiency'
    ? await client.proficiency({ ...request, transcript })
    : await client.request(task, request)
  // Preserve empty labels, reference usage fields, and proficiency check.status.
  // Reference estimated_cost_usd is not the subscription invoice.
  console.log(JSON.stringify(result, null, 2))
}

main().catch((error: unknown) => {
  if (error instanceof OrukApiError) {
    console.error(JSON.stringify({ status: error.status, code: error.code,
      request_id: error.requestId, message: error.message }))
  } else {
    console.error(`Request failed: ${error instanceof Error ? error.message : String(error)}`)
  }
  process.exitCode = 1
})