mirror of
https://github.com/rhasspy/espeak-ng.git
synced 2026-10-31 05:35:35 +00:00
Adding emscripten files
This commit is contained in:
Alberto Pettarin
@@ -0,0 +1,257 @@
|
||||
/*
|
||||
* Copyright (C) 2014-2016 Eitan Isaacson
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, see: <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
/* An audio node that can have audio chunks pushed to it */
|
||||
|
||||
function PushAudioNode(context, start_callback, end_callback, buffer_size) {
|
||||
this.context = context;
|
||||
this.start_callback = start_callback;
|
||||
this.end_callback = end_callback;
|
||||
this.buffer_size = buffer_size || 4096;
|
||||
this.samples_queue = [];
|
||||
this.scriptNode = context.createScriptProcessor(this.buffer_size, 1, 1);
|
||||
this.connected = false;
|
||||
this.sinks = [];
|
||||
this.startTime = 0;
|
||||
this.closed = false;
|
||||
this.track_callbacks = new Map();
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.push = function(chunk) {
|
||||
if (this.closed) {
|
||||
throw 'Cannot push more chunks after node was closed';
|
||||
}
|
||||
this.samples_queue.push(chunk);
|
||||
if (!this.connected) {
|
||||
if (!this.sinks.length) {
|
||||
throw 'No destination set for PushAudioNode';
|
||||
}
|
||||
this._do_connect();
|
||||
}
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.close = function() {
|
||||
this.closed = true;
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.connect = function(dest) {
|
||||
this.sinks.push(dest);
|
||||
if (this.samples_queue.length) {
|
||||
this._do_connect();
|
||||
}
|
||||
}
|
||||
|
||||
PushAudioNode.prototype._do_connect = function() {
|
||||
if (this.connected) return;
|
||||
this.connected = true;
|
||||
for (var dest of this.sinks) {
|
||||
this.scriptNode.connect(dest);
|
||||
}
|
||||
this.scriptNode.onaudioprocess = this.handleEvent.bind(this);
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.disconnect = function() {
|
||||
this.scriptNode.onaudioprocess = null;
|
||||
this.scriptNode.disconnect();
|
||||
this.connected = false;
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.addTrackCallback = function(aTimestamp, aCallback) {
|
||||
var callbacks = this.track_callbacks.get(aTimestamp) || [];
|
||||
callbacks.push(aCallback);
|
||||
this.track_callbacks.set(aTimestamp, callbacks);
|
||||
}
|
||||
|
||||
PushAudioNode.prototype.handleEvent = function(evt) {
|
||||
if (!this.startTime) {
|
||||
this.startTime = evt.playbackTime;
|
||||
if (this.start_callback) {
|
||||
this.start_callback();
|
||||
}
|
||||
}
|
||||
|
||||
var currentTime = evt.playbackTime - this.startTime;
|
||||
var playbackDuration = this.scriptNode.bufferSize / this.context.sampleRate;
|
||||
for (var entry of this.track_callbacks) {
|
||||
var timestamp = entry[0];
|
||||
var callbacks = entry[1];
|
||||
if (timestamp < currentTime) {
|
||||
this.track_callbacks.delete(timestamp);
|
||||
} else if (timestamp < currentTime + playbackDuration) {
|
||||
for (var cb of callbacks) {
|
||||
cb();
|
||||
}
|
||||
this.track_callbacks.delete(timestamp);
|
||||
}
|
||||
}
|
||||
|
||||
var offset = 0;
|
||||
while (this.samples_queue.length && offset < evt.target.bufferSize) {
|
||||
var chunk = this.samples_queue[0];
|
||||
var to_copy = chunk.subarray(0, evt.target.bufferSize - offset);
|
||||
if (evt.outputBuffer.copyToChannel) {
|
||||
evt.outputBuffer.copyToChannel(to_copy, 0, offset);
|
||||
} else {
|
||||
evt.outputBuffer.getChannelData(0).set(to_copy, offset);
|
||||
}
|
||||
offset += to_copy.length;
|
||||
chunk = chunk.subarray(to_copy.length);
|
||||
if (chunk.length)
|
||||
this.samples_queue[0] = chunk;
|
||||
else
|
||||
this.samples_queue.shift();
|
||||
}
|
||||
|
||||
if (!this.samples_queue.length && this.closed) {
|
||||
if (this.end_callback) {
|
||||
this.end_callback(evt.playbackTime - this.startTime);
|
||||
}
|
||||
this.disconnect();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
/* Code specific to the demo */
|
||||
|
||||
var ctx = new (window.AudioContext || window.webkitAudioContext)();
|
||||
var tts;
|
||||
var pusher;
|
||||
var pusher_buffer_size = 4096;
|
||||
var chunkID = 0;
|
||||
|
||||
function stop() {
|
||||
console.log('Inside stop()');
|
||||
if (pusher) {
|
||||
console.log(' Calling pusher.disconnect...');
|
||||
pusher.disconnect();
|
||||
console.log(' Calling pusher.disconnect... done');
|
||||
pusher = null;
|
||||
}
|
||||
console.log('Leaving stop()');
|
||||
} // end of stop()
|
||||
|
||||
function speak() {
|
||||
console.log('Inside speak()');
|
||||
|
||||
console.log(' Stopping...');
|
||||
stop();
|
||||
console.log(' Stopping... done');
|
||||
|
||||
console.log(' Setting rate...');
|
||||
tts.set_rate(Number(document.getElementById('rate').value));
|
||||
console.log(' Setting rate... done');
|
||||
console.log(' Setting pitch...');
|
||||
tts.set_pitch(Number(document.getElementById('pitch').value));
|
||||
console.log(' Setting pitch... done');
|
||||
console.log(' Setting voice...');
|
||||
tts.set_voice.apply(tts, (document.getElementById('voice').value.split(',')));
|
||||
console.log(' Setting voice... done');
|
||||
|
||||
var now = Date.now();
|
||||
chunkID = 0;
|
||||
|
||||
console.log(' Creating pusher...');
|
||||
pusher = new PushAudioNode(
|
||||
ctx,
|
||||
function() {
|
||||
//console.log('PushAudioNode started!', ctx.currentTime, pusher.startTime);
|
||||
},
|
||||
function() {
|
||||
//console.log('PushAudioNode ended!', ctx.currentTime - pusher.startTime);
|
||||
},
|
||||
pusher_buffer_size
|
||||
);
|
||||
pusher.connect(ctx.destination);
|
||||
console.log(' Creating pusher... done');
|
||||
|
||||
// actual synthesis
|
||||
console.log(' Calling synthesize...');
|
||||
tts.synthesize(
|
||||
document.getElementById('texttospeak').value,
|
||||
function cb(samples, events) {
|
||||
//console.log(' Inside synt cb');
|
||||
if (!samples) {
|
||||
if (pusher) {
|
||||
pusher.close();
|
||||
}
|
||||
return;
|
||||
}
|
||||
if (pusher) {
|
||||
//console.log(' Pushing chunk ' + chunkID, Date.now());
|
||||
pusher.push(new Float32Array(samples));
|
||||
++chunkID;
|
||||
}
|
||||
if (now) {
|
||||
//console.log(' Latency:', Date.now() - now);
|
||||
now = 0;
|
||||
}
|
||||
//console.log(' Leaving synt cb');
|
||||
} // end of function cb
|
||||
); // end of tts.synthesize()
|
||||
console.log(' Calling synthesize... done');
|
||||
|
||||
console.log('Leaving speak()');
|
||||
} // end of speak()
|
||||
|
||||
function resetPitch() {
|
||||
document.getElementById('pitch').value = 50;
|
||||
}
|
||||
|
||||
function resetRate() {
|
||||
document.getElementById('rate').value = 175;
|
||||
}
|
||||
|
||||
function resetVoice() {
|
||||
document.getElementById('default-voice').selected = true;
|
||||
}
|
||||
|
||||
function initializeDemo() {
|
||||
console.log('Creating eSpeakNG instance...');
|
||||
tts = new eSpeakNG(
|
||||
'js/espeakng.worker.js',
|
||||
function cb1() {
|
||||
console.log('Inside cb1');
|
||||
tts.list_voices(
|
||||
function cb2(result) {
|
||||
console.log('Inside cb2');
|
||||
var sel = document.getElementById('voice');
|
||||
var index = 0;
|
||||
for (voice of result) {
|
||||
for (lang of voice.languages) {
|
||||
var opt = document.createElement('option');
|
||||
opt.text = voice.name + ' (' + lang.name + ')';
|
||||
opt.value = [voice.name, lang.name];
|
||||
console.log('Adding voice: ' + opt.text);
|
||||
sel.add(opt);
|
||||
if (voice.name === 'default') {
|
||||
opt.id = 'default-voice';
|
||||
opt.selected = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
console.log('Leaving cb2');
|
||||
} // end of function cb2
|
||||
);
|
||||
console.log('Removing loading class...');
|
||||
document.body.classList.remove('loading');
|
||||
console.log('Removing loading class... done');
|
||||
console.log('Leaving cb1');
|
||||
} // end of function cb1
|
||||
);
|
||||
console.log('Creating eSpeakNG instance... done');
|
||||
}
|
||||
@@ -0,0 +1,69 @@
|
||||
/*
|
||||
* Copyright (C) 2014-2016 Eitan Isaacson
|
||||
*
|
||||
* This program is free software; you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation; either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program; if not, see: <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
function eSpeakNG(worker_path, ready_cb) {
|
||||
this.worker = new Worker(worker_path);
|
||||
this.ready = false;
|
||||
this.worker.onmessage = function(e) {
|
||||
if (e.data !== 'ready') {
|
||||
return;
|
||||
}
|
||||
this.worker.onmessage = null;
|
||||
this.worker.addEventListener('message', this);
|
||||
this.ready = true;
|
||||
if (ready_cb) {
|
||||
ready_cb();
|
||||
}
|
||||
}.bind(this);
|
||||
}
|
||||
|
||||
eSpeakNG.prototype.handleEvent = function (evt) {
|
||||
var callback = evt.data.callback;
|
||||
if (callback && this[callback]) {
|
||||
this[callback].apply(this, evt.data.result);
|
||||
if (evt.data.done) {
|
||||
delete this[callback];
|
||||
}
|
||||
return;
|
||||
}
|
||||
};
|
||||
|
||||
function _createAsyncMethod(method) {
|
||||
return function() {
|
||||
var lastArg = arguments[arguments.length - 1];
|
||||
var message = { method: method, args: Array.prototype.slice.call(arguments, 0) };
|
||||
if (typeof lastArg == 'function') {
|
||||
var callback = '_' + method + '_' + Math.random().toString().substring(2) +'_cb';
|
||||
this[callback] = lastArg;
|
||||
message.args.pop();
|
||||
message.callback = callback;
|
||||
}
|
||||
this.worker.postMessage(message);
|
||||
};
|
||||
}
|
||||
|
||||
for (var method of [
|
||||
'list_voices',
|
||||
'get_rate',
|
||||
'get_pitch',
|
||||
'set_rate',
|
||||
'set_pitch',
|
||||
'set_voice',
|
||||
'synthesize'
|
||||
]) {
|
||||
eSpeakNG.prototype[method] = _createAsyncMethod(method);
|
||||
}
|
||||
Reference in New Issue
Block a user