add pyttsx and return wav

Author: proppy

Dockerfile

@@ -2,7 +2,7 @@
 # single application.
 FROM google/appengine-python27
 
-RUN apt-get update && apt-get install -y fortunes
+RUN apt-get update && apt-get install -y fortunes libespeak-dev
 ADD requirements.txt /home/vmagent/app/
 RUN pip install -r requirements.txt
 

main.py

@@ -1,16 +1,24 @@
 from flask import Flask, helpers
 import subprocess
+import tempfile
 
-app = Flask(__name__)
+from synth import Synth
+
+app= Flask(__name__)
+app.debug = True
+
+synth = Synth()
 
 MESSAGES = '/tmp/messages.txt'
 
 @app.route("/")
 def fortune():
   msg = subprocess.check_output('/usr/games/fortune')
   with open(MESSAGES, 'a') as f: f.write(msg)
-  return msg
+  with tempfile.NamedTemporaryFile() as f:
+    synth.say(msg, out=f)
+    return helpers.send_file(f.name, mimetype="audio/wav", as_attachment=False)
 
 @app.route("/messages")
 def messages():
-  return helpers.send_file(MESSAGES)
+  return helpers.send_file(MESSAGES)

requirements.txt

@@ -0,0 +1,2 @@
+Flask==0.10.1
+pyttsx==1.1

synth.py

@@ -0,0 +1,36 @@
+from pyttsx.drivers import _espeak
+import ctypes
+import wave
+import time
+import threading
+import StringIO
+
+class Synth(object):
+    _done = False
+    def __init__(self):
+        self.rate = _espeak.Initialize(_espeak.AUDIO_OUTPUT_RETRIEVAL, 1000)
+        assert self.rate != -1, 'could not initialize espeak'
+        _espeak.SetSynthCallback(self)
+        self.lock = threading.Lock()
+
+    def __call__(self, wav, numsamples, events):
+        if self._done:
+            return 0
+        data = ctypes.string_at(wav, numsamples*2)
+        if len(data) == 0:
+            self._done = True
+            return 0
+        self.wav.writeframes(data)
+        return 0
+
+    def say(self, say, out):
+        with self.lock:
+            self.wav = wave.open(out, 'w')
+            self.wav.setnchannels(1)
+            self.wav.setsampwidth(2)
+            self.wav.setframerate(self.rate)
+            self._done = False
+            _espeak.Synth(say)
+            while not self._done:
+                time.sleep(0)
+            self.wav.close()