File size: 3,006 Bytes
346a09e
0524ab0
346a09e
0524ab0
 
 
 
 
 
 
 
 
 
 
 
 
346a09e
 
0524ab0
 
 
 
 
346a09e
 
 
 
 
 
 
 
 
 
 
 
 
 
0524ab0
 
346a09e
 
 
 
 
 
 
 
 
0524ab0
346a09e
 
 
 
 
 
 
 
 
0524ab0
 
 
346a09e
0524ab0
 
 
 
 
 
 
346a09e
0524ab0
 
346a09e
0524ab0
 
346a09e
0524ab0
 
 
 
 
346a09e
 
3596123
 
 
 
 
346a09e
3596123
 
 
 
 
346a09e
3596123
 
 
 
 
 
 
 
 
 
0524ab0
346a09e
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
import { mkdtempSync, writeFileSync } from 'fs'
import { tmpdir } from 'os'
import path from 'node:path'

export type TTSResult = {
  success: boolean
  audioPath?: string
  error?: string
}

export type TTSSpeakOptions = {
  voice?: string
  outputPath?: string
}

/**
 * Text-to-speech using the `node-edge-tts` Node package (no Python required).
 * Synthesizes `text` to a local audio file and resolves with its path.
 */
export async function speakWithEdgeTTS(
  text: string,
  options?: TTSSpeakOptions,
): Promise<TTSResult> {
  try {
    const { EdgeTTS } = await import('node-edge-tts')
    const audioPath =
      options?.outputPath ??
      path.join(
        mkdtempSync(path.join(tmpdir(), 'codev-tts-')),
        `voice-${Date.now()}.mp3`,
      )
    const tts = new EdgeTTS({ voice: options?.voice ?? 'en-US-JennyNeural' })
    await tts.ttsPromise(text, audioPath)
    return { success: true, audioPath }
  } catch (err) {
    return { success: false, error: String(err) }
  }
}

/** Check if `node-edge-tts` can be loaded. */
export async function checkEdgeTTSAvailable(): Promise<boolean> {
  try {
    await import('node-edge-tts')
    return true
  } catch {
    return false
  }
}

/**
 * Synthesize text to a temporary .mp3 using `node-edge-tts`.
 * Returns the audio file path on success.
 */
export async function edgeTts(opts: {
  text: string
  voice?: string
}): Promise<{ success: boolean; audioPath?: string; error?: string }> {
  return speakWithEdgeTTS(opts.text, { voice: opts.voice })
}

/** Play an audio file using system player. */
export function playAudioFile(filePath: string): Promise<void> {
  return new Promise((resolve, reject) => {
    const platform = process.platform
    let cmd: string
    let args: string[]

    if (platform === 'darwin') {
      cmd = 'afplay'
      args = [filePath]
    } else if (platform === 'linux') {
      cmd = 'ffplay'
      args = ['-nodisp', '-autoexit', '-infbuf', filePath]
    } else if (platform === 'win32') {
      cmd = 'start'
      args = [filePath]
    } else {
      reject(new Error(`Unsupported platform: ${platform}`))
      return
    }

    const { spawn } = require('child_process') as typeof import('child_process')

    if (platform === 'linux') {
      const killProc = spawn('pkill', ['-9', 'ffplay'], { stdio: 'ignore' })
      killProc.on('close', () => {
        setTimeout(() => {
          const proc = spawn(cmd, args, { stdio: 'ignore' })
          proc.on('close', () => resolve())
          proc.on('error', () => resolve())
        }, 50)
      })
      killProc.on('error', () => {
        const proc = spawn(cmd, args, { stdio: 'ignore' })
        proc.on('close', () => resolve())
        proc.on('error', () => resolve())
      })
    } else {
      const proc = spawn(cmd, args, { stdio: 'ignore' })
      proc.on('close', code => {
        if (code === 0) resolve()
        else reject(new Error(`Playback exited with code ${code}`))
      })
      proc.on('error', reject)
    }
  })
}