1 files changed, 72 insertions, 0 deletions
diff --git a/src/vox.c b/src/vox.c
new file mode 100644
index 0000000..502d79b
--- /dev/null
+++ b/src/vox.c
@@ -0,0 +1,72 @@
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/wait.h>
+
+#include <xas/vox.h>
+
+static void voice_cleanup(xas_vox_voice *voice, xas_audio_stream *stream) {
+    int status;
+
+    if (voice->flags & XAS_VOX_VOICE_ACTIVE) {
+        if (voice->pid >= 0) {
+            (void)waitpid(voice->pid, &status, 0);
+        }
+
+        if (voice->stdout >= 0) {
+            (void)close(voice->stdout);
+        }
+    }
+}
+
+static ssize_t voice_fill(xas_vox_voice *voice,
+                          int16_t *samples,
+                          size_t count,
+                          xas_audio_stream *stream) {
+    size_t i;
+
+    for (i=0; i<count; i++) {
+        samples[i] = 0;
+    }
+
+    return i;
+}
+
+xas_audio_stream *xas_vox_new(const char *text2wave_path,
+                                  size_t sample_size,
+                                  size_t sample_rate,
+                                  size_t buffer_size,
+                                  void *ctx) {
+    xas_audio_stream *stream;
+    xas_vox_voice *voice;
+
+    if ((voice = malloc(sizeof(*voice))) == NULL) {
+        goto error_malloc_voice;
+    }
+
+    voice->text2wave_path = text2wave_path;
+    voice->sample_size    = sample_size;
+    voice->sample_rate    = sample_rate;
+    voice->ctx            = ctx;
+    voice->flags          = XAS_VOX_VOICE_IDLE;
+
+    voice->pid    = -1;
+    voice->stdout = -1;
+
+    if ((stream = xas_audio_stream_new_source((xas_audio_fill)voice_fill,
+                                                (xas_audio_cleanup)voice_cleanup,
+                                                voice,
+                                                sample_size,
+                                                sample_rate,
+                                                XAS_AUDIO_STREAM_MONO,
+                                                buffer_size)) == NULL) {
+        goto error_audio_stream_new_source;
+    }
+
+    return stream;
+
+error_audio_stream_new_source:
+    free(voice);
+
+error_malloc_voice:
+    return NULL;
+}