stack-chan

/* eslint-disable prefer-const */
import AudioOut from 'pins/audioout'
import ResourceStreamer from 'resourcestreamer'
import calculatePower from 'calculate-power'

/* global trace, SharedArrayBuffer */

export type TTSProperty = {
  onPlayed: (number) => void
  onDone: () => void
} | {
  onPlayed: (number) => void
  onDone: () => void
  host: string
  port: number
}

export class TTS {
  streamer?: ResourceStreamer
  audio?: AudioOut
  onPlayed: (number) => void
  onDone: () => void
  constructor(props: TTSProperty) {
    this.onPlayed = props.onPlayed
    this.onDone = props.onDone
    this.audio = new AudioOut({ streams: 1 })
  }
  async stream(key: string): Promise<void> {
    return new Promise((resolve, reject) => {
      if (this.streamer != null) {
        reject(new Error('already playing'))
        return
      }
      const that = this
      this.streamer = new ResourceStreamer({
        path: `${key}.maud`,
        audio: {
          out: this.audio,
          stream: 0,
          sampleRate: 11025,
        },
        onPlayed(buffer) {
          const power = calculatePower(buffer)
          that.onPlayed?.(power)
        },
        onReady(state) {
          trace(`Ready: ${state}\n`)
          if (state) {
            this.audio.start()
          } else {
            this.audio.stop()
          }
        },
        onError(e) {
          trace('ERROR: ', e, '\n')
          that.streamer = undefined
          reject(new Error('unknown error occured'))
        },
        onDone() {
          trace('DONE\n')
          that.streamer?.close()
          that.streamer = undefined
          that.onDone?.()
          resolve()
        },
      })
    })
  }
}