added mod_curl_tts
This commit is contained in:
aks
parent
93d5d3158b
commit
1340dc8ca4
|
|
@ -0,0 +1,11 @@
|
||||||
|
|
||||||
|
include $(top_srcdir)/build/modmake.rulesam
|
||||||
|
MODNAME=mod_curl_tts
|
||||||
|
|
||||||
|
mod_LTLIBRARIES = mod_curl_tts.la
|
||||||
|
mod_curl_tts_la_SOURCES = mod_curl_tts.c utils.c curl.c
|
||||||
|
mod_curl_tts_la_CFLAGS = $(AM_CFLAGS) -I.
|
||||||
|
mod_curl_tts_la_LIBADD = $(switch_builddir)/libfreeswitch.la
|
||||||
|
mod_curl_tts_la_LDFLAGS = -avoid-version -module -no-undefined -shared
|
||||||
|
|
||||||
|
$(am_mod_curl_tts_la_OBJECTS): mod_curl_tts.h
|
||||||
|
|
@ -0,0 +1,22 @@
|
||||||
|
<configuration name="curl_tts.conf" description="">
|
||||||
|
<settings>
|
||||||
|
<param name="api-url" value="http://127.0.0.1/default_tts" />
|
||||||
|
<!-- <param name="api-key" value="YOUR-API-KEY" /> -->
|
||||||
|
|
||||||
|
<!-- curl settings -->
|
||||||
|
<param name="connect-timeout" value="10" />
|
||||||
|
<param name="request-timeout" value="25" />
|
||||||
|
<param name="file-size-max" value="2097152" />
|
||||||
|
<param name="log-http-errors" value="true" />
|
||||||
|
<param name="voice-name-as-language" value="true" />
|
||||||
|
<!-- <param name="proxy" value="http://proxy:port" /> -->
|
||||||
|
<!-- <param name="proxy-credentials" value="" /> -->
|
||||||
|
<!-- <param name="user-agent" value="Mozilla/1.0" /> -->
|
||||||
|
|
||||||
|
<!-- cache -->
|
||||||
|
<param name="cache-path" value="/tmp/curl-tts-cache" />
|
||||||
|
<param name="cache-enable" value="false" />
|
||||||
|
|
||||||
|
</settings>
|
||||||
|
|
||||||
|
</configuration>
|
||||||
|
|
@ -0,0 +1,8 @@
|
||||||
|
|
||||||
|
<extension name="curl-tts">
|
||||||
|
<condition field="destination_number" expression="^(3123)$">
|
||||||
|
<action application="answer"/>
|
||||||
|
<action application="speak" data="curl|en|Hello world!"/>
|
||||||
|
<action application="hangup"/>
|
||||||
|
</condition>
|
||||||
|
</extension>
|
||||||
|
|
@ -0,0 +1,185 @@
|
||||||
|
/*
|
||||||
|
* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
|
||||||
|
* Copyright (C) 2005-2014, Anthony Minessale II <anthm@freeswitch.org>
|
||||||
|
*
|
||||||
|
* Version: MPL 1.1
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Mozilla Public License Version
|
||||||
|
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||||
|
* the License. You may obtain a copy of the License at
|
||||||
|
* http://www.mozilla.org/MPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||||
|
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||||
|
* for the specific language governing rights and limitations under the
|
||||||
|
* License.
|
||||||
|
*
|
||||||
|
* Module Contributor(s):
|
||||||
|
* Konstantin Alexandrin <akscfx@gmail.com>
|
||||||
|
*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
#include "mod_curl_tts.h"
|
||||||
|
|
||||||
|
extern globals_t globals;
|
||||||
|
|
||||||
|
static size_t curl_io_write_callback(char *buffer, size_t size, size_t nitems, void *user_data) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)user_data;
|
||||||
|
size_t len = (size * nitems);
|
||||||
|
|
||||||
|
if(len > 0 && tts_ctx->curl_recv_buffer) {
|
||||||
|
switch_buffer_write(tts_ctx->curl_recv_buffer, buffer, len);
|
||||||
|
}
|
||||||
|
|
||||||
|
return len;
|
||||||
|
}
|
||||||
|
|
||||||
|
static size_t curl_io_read_callback(char *buffer, size_t size, size_t nitems, void *user_data) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)user_data;
|
||||||
|
size_t nmax = (size * nitems);
|
||||||
|
size_t ncur = (tts_ctx->curl_send_buffer_len > nmax) ? nmax : tts_ctx->curl_send_buffer_len;
|
||||||
|
|
||||||
|
memmove(buffer, tts_ctx->curl_send_buffer_ref, ncur);
|
||||||
|
tts_ctx->curl_send_buffer_ref += ncur;
|
||||||
|
tts_ctx->curl_send_buffer_len -= ncur;
|
||||||
|
|
||||||
|
return ncur;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
switch_status_t curl_perform(tts_ctx_t *tts_ctx, char *text) {
|
||||||
|
switch_status_t status = SWITCH_STATUS_SUCCESS;
|
||||||
|
CURL *curl_handle = NULL;
|
||||||
|
switch_curl_slist_t *headers = NULL;
|
||||||
|
switch_CURLcode curl_ret = 0;
|
||||||
|
long http_resp = 0;
|
||||||
|
char *pdata = NULL;
|
||||||
|
char *qtext = NULL;
|
||||||
|
|
||||||
|
if(!tts_ctx->api_url) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "api_url not determined\n");
|
||||||
|
return SWITCH_STATUS_FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(text) {
|
||||||
|
qtext = escape_dquotes(text);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(tts_ctx->curl_params && !switch_core_hash_empty(tts_ctx->curl_params)) {
|
||||||
|
const void *hkey = NULL; void *hval = NULL;
|
||||||
|
switch_hash_index_t *hidx = NULL;
|
||||||
|
cJSON *jopts = NULL;
|
||||||
|
|
||||||
|
jopts = cJSON_CreateObject();
|
||||||
|
for(hidx = switch_core_hash_first_iter(tts_ctx->curl_params, hidx); hidx; hidx = switch_core_hash_next(&hidx)) {
|
||||||
|
switch_core_hash_this(hidx, &hkey, NULL, &hval);
|
||||||
|
if(hkey && hval) {
|
||||||
|
cJSON_AddItemToObject(jopts, (char *)hkey, cJSON_CreateString((char *)hval));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
cJSON_AddItemToObject(jopts, "language", cJSON_CreateString((char *)tts_ctx->language));
|
||||||
|
cJSON_AddItemToObject(jopts, "text", cJSON_CreateString((char *)qtext));
|
||||||
|
|
||||||
|
pdata = cJSON_PrintUnformatted(jopts);
|
||||||
|
cJSON_Delete(jopts);
|
||||||
|
} else {
|
||||||
|
cJSON *jopts = NULL;
|
||||||
|
|
||||||
|
jopts = cJSON_CreateObject();
|
||||||
|
|
||||||
|
cJSON_AddItemToObject(jopts, "language", cJSON_CreateString((char *)tts_ctx->language));
|
||||||
|
cJSON_AddItemToObject(jopts, "text", cJSON_CreateString((char *)qtext));
|
||||||
|
|
||||||
|
pdata = cJSON_PrintUnformatted(jopts);
|
||||||
|
cJSON_Delete(jopts);
|
||||||
|
}
|
||||||
|
|
||||||
|
// switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "POST: [%s]\n", pdata);
|
||||||
|
|
||||||
|
tts_ctx->media_ctype = NULL;
|
||||||
|
tts_ctx->curl_send_buffer_len = strlen(pdata);
|
||||||
|
tts_ctx->curl_send_buffer_ref = pdata;
|
||||||
|
|
||||||
|
curl_handle = switch_curl_easy_init();
|
||||||
|
|
||||||
|
headers = switch_curl_slist_append(headers, "Content-Type: application/json; charset=utf-8");
|
||||||
|
headers = switch_curl_slist_append(headers, "Expect:");
|
||||||
|
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_HTTPHEADER, headers);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_POST, 1);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_NOSIGNAL, 1);
|
||||||
|
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_POSTFIELDSIZE, tts_ctx->curl_send_buffer_len);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_POSTFIELDS, (void *) pdata);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_READFUNCTION, curl_io_read_callback);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_READDATA, (void *) tts_ctx);
|
||||||
|
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_WRITEFUNCTION, curl_io_write_callback);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_WRITEDATA, (void *) tts_ctx);
|
||||||
|
|
||||||
|
if(globals.connect_timeout > 0) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_CONNECTTIMEOUT, globals.connect_timeout);
|
||||||
|
}
|
||||||
|
if(globals.request_timeout > 0) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_TIMEOUT, globals.request_timeout);
|
||||||
|
}
|
||||||
|
if(globals.user_agent) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_USERAGENT, globals.user_agent);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(strncasecmp(tts_ctx->api_url, "https", 5) == 0) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYPEER, 0);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYHOST, 0);
|
||||||
|
}
|
||||||
|
if(globals.proxy) {
|
||||||
|
if(globals.proxy_credentials != NULL) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_PROXYAUTH, CURLAUTH_ANY);
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_PROXYUSERPWD, globals.proxy_credentials);
|
||||||
|
}
|
||||||
|
if(strncasecmp(globals.proxy, "https", 5) == 0) {
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_PROXY_SSL_VERIFYPEER, 0);
|
||||||
|
}
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_PROXY, globals.proxy);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(tts_ctx->api_key) {
|
||||||
|
curl_easy_setopt(curl_handle, CURLOPT_XOAUTH2_BEARER, tts_ctx->api_key);
|
||||||
|
curl_easy_setopt(curl_handle, CURLOPT_HTTPAUTH, CURLAUTH_BEARER);
|
||||||
|
}
|
||||||
|
|
||||||
|
switch_curl_easy_setopt(curl_handle, CURLOPT_URL, tts_ctx->api_url);
|
||||||
|
|
||||||
|
curl_ret = switch_curl_easy_perform(curl_handle);
|
||||||
|
if(!curl_ret) {
|
||||||
|
switch_curl_easy_getinfo(curl_handle, CURLINFO_RESPONSE_CODE, &http_resp);
|
||||||
|
if(!http_resp) { switch_curl_easy_getinfo(curl_handle, CURLINFO_HTTP_CONNECTCODE, &http_resp); }
|
||||||
|
} else {
|
||||||
|
http_resp = curl_ret;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(http_resp != 200) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "http-error=[%ld] (%s)\n", http_resp, tts_ctx->api_url);
|
||||||
|
status = SWITCH_STATUS_FALSE;
|
||||||
|
} else {
|
||||||
|
char *ct = NULL;
|
||||||
|
if(!curl_easy_getinfo(curl_handle, CURLINFO_CONTENT_TYPE, &ct) && ct) {
|
||||||
|
tts_ctx->media_ctype = switch_core_strdup(tts_ctx->pool, ct);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if(tts_ctx->curl_recv_buffer) {
|
||||||
|
if(switch_buffer_inuse(tts_ctx->curl_recv_buffer) > 0) {
|
||||||
|
switch_buffer_write(tts_ctx->curl_recv_buffer, "\0", 1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if(curl_handle) { switch_curl_easy_cleanup(curl_handle); }
|
||||||
|
if(headers) { switch_curl_slist_free_all(headers); }
|
||||||
|
|
||||||
|
switch_safe_free(pdata);
|
||||||
|
switch_safe_free(qtext);
|
||||||
|
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
@ -0,0 +1,302 @@
|
||||||
|
/*
|
||||||
|
* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
|
||||||
|
* Copyright (C) 2005-2014, Anthony Minessale II <anthm@freeswitch.org>
|
||||||
|
*
|
||||||
|
* Version: MPL 1.1
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Mozilla Public License Version
|
||||||
|
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||||
|
* the License. You may obtain a copy of the License at
|
||||||
|
* http://www.mozilla.org/MPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||||
|
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||||
|
* for the specific language governing rights and limitations under the
|
||||||
|
* License.
|
||||||
|
*
|
||||||
|
* Module Contributor(s):
|
||||||
|
* Konstantin Alexandrin <akscfx@gmail.com>
|
||||||
|
*
|
||||||
|
* Provides the ability to interact with TTS services over HTTP
|
||||||
|
*
|
||||||
|
* Development repository:
|
||||||
|
* https://github.com/akscf/mod_curl_tts
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
#include "mod_curl_tts.h"
|
||||||
|
|
||||||
|
globals_t globals;
|
||||||
|
|
||||||
|
SWITCH_MODULE_LOAD_FUNCTION(mod_curl_tts_load);
|
||||||
|
SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_curl_tts_shutdown);
|
||||||
|
SWITCH_MODULE_DEFINITION(mod_curl_tts, mod_curl_tts_load, mod_curl_tts_shutdown, NULL);
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------------------------------------------------------------------------
|
||||||
|
// speech api
|
||||||
|
// ---------------------------------------------------------------------------------------------------------------------------------------------
|
||||||
|
static switch_status_t speech_open(switch_speech_handle_t *sh, const char *voice, int samplerate, int channels, switch_speech_flag_t *flags) {
|
||||||
|
switch_status_t status = SWITCH_STATUS_SUCCESS;
|
||||||
|
tts_ctx_t *tts_ctx = NULL;
|
||||||
|
|
||||||
|
tts_ctx = switch_core_alloc(sh->memory_pool, sizeof(tts_ctx_t));
|
||||||
|
tts_ctx->pool = sh->memory_pool;
|
||||||
|
tts_ctx->fhnd = switch_core_alloc(tts_ctx->pool, sizeof(switch_file_handle_t));
|
||||||
|
tts_ctx->language = (globals.fl_voice_name_as_language && voice) ? switch_core_strdup(sh->memory_pool, voice) : NULL;
|
||||||
|
tts_ctx->samplerate = samplerate;
|
||||||
|
tts_ctx->channels = channels;
|
||||||
|
tts_ctx->api_url = globals.api_url;
|
||||||
|
tts_ctx->api_key = globals.api_key;
|
||||||
|
|
||||||
|
sh->private_info = tts_ctx;
|
||||||
|
|
||||||
|
if((status = switch_buffer_create_dynamic(&tts_ctx->curl_recv_buffer, 1024, 8192, globals.file_size_max)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "switch_buffer_create_dynamic() fail\n");
|
||||||
|
goto out;
|
||||||
|
}
|
||||||
|
|
||||||
|
if((status = switch_core_hash_init(&tts_ctx->curl_params)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "switch_core_hash_init()\n");
|
||||||
|
switch_goto_status(SWITCH_STATUS_GENERR, out);
|
||||||
|
}
|
||||||
|
|
||||||
|
out:
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
static switch_status_t speech_close(switch_speech_handle_t *sh, switch_speech_flag_t *flags) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *) sh->private_info;
|
||||||
|
assert(tts_ctx != NULL);
|
||||||
|
|
||||||
|
if(switch_test_flag(tts_ctx->fhnd, SWITCH_FILE_OPEN)) {
|
||||||
|
switch_core_file_close(tts_ctx->fhnd);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(tts_ctx->curl_recv_buffer) {
|
||||||
|
switch_buffer_destroy(&tts_ctx->curl_recv_buffer);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(!globals.fl_cache_enabled) {
|
||||||
|
if(tts_ctx->mp3_name) unlink(tts_ctx->mp3_name);
|
||||||
|
if(tts_ctx->wav_name) unlink(tts_ctx->wav_name);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(tts_ctx->curl_params) {
|
||||||
|
switch_core_hash_destroy(&tts_ctx->curl_params);
|
||||||
|
}
|
||||||
|
|
||||||
|
return SWITCH_STATUS_SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
static switch_status_t speech_feed_tts(switch_speech_handle_t *sh, char *text, switch_speech_flag_t *flags) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)sh->private_info;
|
||||||
|
switch_status_t status = SWITCH_STATUS_SUCCESS;
|
||||||
|
char digest[SWITCH_MD5_DIGEST_STRING_SIZE + 1] = { 0 };
|
||||||
|
const void *ptr = NULL;
|
||||||
|
uint32_t recv_len = 0;
|
||||||
|
|
||||||
|
assert(tts_ctx != NULL);
|
||||||
|
|
||||||
|
switch_md5_string(digest, (void *)text, strlen(text));
|
||||||
|
if(!tts_ctx->mp3_name) {
|
||||||
|
tts_ctx->mp3_name = switch_core_sprintf(sh->memory_pool, "%s%s%s.mp3", globals.cache_path, SWITCH_PATH_SEPARATOR, digest);
|
||||||
|
}
|
||||||
|
if(!tts_ctx->wav_name) {
|
||||||
|
tts_ctx->wav_name = switch_core_sprintf(sh->memory_pool, "%s%s%s.wav", globals.cache_path, SWITCH_PATH_SEPARATOR, digest);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(switch_file_exists(tts_ctx->mp3_name, tts_ctx->pool) == SWITCH_STATUS_SUCCESS) {
|
||||||
|
if((status = switch_core_file_open(tts_ctx->fhnd, tts_ctx->mp3_name, tts_ctx->channels, tts_ctx->samplerate,
|
||||||
|
(SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT), sh->memory_pool)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to open file: %s\n", tts_ctx->mp3_name);
|
||||||
|
status = SWITCH_STATUS_FALSE;
|
||||||
|
goto out;
|
||||||
|
}
|
||||||
|
} else if(switch_file_exists(tts_ctx->wav_name, tts_ctx->pool) == SWITCH_STATUS_SUCCESS) {
|
||||||
|
if((status = switch_core_file_open(tts_ctx->fhnd, tts_ctx->wav_name, tts_ctx->channels, tts_ctx->samplerate,
|
||||||
|
(SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT), sh->memory_pool)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to open file: %s\n", tts_ctx->wav_name);
|
||||||
|
status = SWITCH_STATUS_FALSE;
|
||||||
|
goto out;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
switch_buffer_zero(tts_ctx->curl_recv_buffer);
|
||||||
|
status = curl_perform(tts_ctx , text);
|
||||||
|
recv_len = switch_buffer_peek_zerocopy(tts_ctx->curl_recv_buffer, &ptr);
|
||||||
|
|
||||||
|
if(status == SWITCH_STATUS_SUCCESS) {
|
||||||
|
char *dst_name = NULL;
|
||||||
|
|
||||||
|
if(strcasecmp(tts_ctx->media_ctype, "audio/mpeg") == 0) {
|
||||||
|
dst_name = tts_ctx->mp3_name;
|
||||||
|
} else if(strcasecmp(tts_ctx->media_ctype, "audio/wav") == 0) {
|
||||||
|
dst_name = tts_ctx->wav_name;
|
||||||
|
} else {
|
||||||
|
status = SWITCH_STATUS_FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(status == SWITCH_STATUS_SUCCESS) {
|
||||||
|
if((status = write_file(dst_name, (switch_byte_t *)ptr, recv_len)) == SWITCH_STATUS_SUCCESS) {
|
||||||
|
if((status = switch_core_file_open(tts_ctx->fhnd, dst_name, tts_ctx->channels, tts_ctx->samplerate,
|
||||||
|
(SWITCH_FILE_FLAG_READ | SWITCH_FILE_DATA_SHORT), sh->memory_pool)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to open file: %s\n", dst_name);
|
||||||
|
goto out;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
if(!dst_name) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unsupported media-type (%s)\n", tts_ctx->media_ctype);
|
||||||
|
} else if(globals.fl_log_http_error) {
|
||||||
|
if(recv_len > 0) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Services response: %s\n", (char *)ptr);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
out:
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
static switch_status_t speech_read_tts(switch_speech_handle_t *sh, void *data, size_t *data_len, switch_speech_flag_t *flags) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)sh->private_info;
|
||||||
|
size_t len = (*data_len / sizeof(int16_t));
|
||||||
|
|
||||||
|
assert(tts_ctx != NULL);
|
||||||
|
|
||||||
|
if(tts_ctx->fhnd->file_interface == NULL) {
|
||||||
|
return SWITCH_STATUS_FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
if(switch_core_file_read(tts_ctx->fhnd, data, &len) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_core_file_close(tts_ctx->fhnd);
|
||||||
|
return SWITCH_STATUS_FALSE;
|
||||||
|
}
|
||||||
|
|
||||||
|
*data_len = (len * sizeof(int16_t));
|
||||||
|
if(!data_len) {
|
||||||
|
switch_core_file_close(tts_ctx->fhnd);
|
||||||
|
return SWITCH_STATUS_BREAK;
|
||||||
|
}
|
||||||
|
|
||||||
|
return SWITCH_STATUS_SUCCESS;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void speech_flush_tts(switch_speech_handle_t *sh) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)sh->private_info;
|
||||||
|
|
||||||
|
assert(tts_ctx != NULL);
|
||||||
|
|
||||||
|
if(tts_ctx->fhnd != NULL && tts_ctx->fhnd->file_interface != NULL) {
|
||||||
|
switch_core_file_close(tts_ctx->fhnd);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void speech_text_param_tts(switch_speech_handle_t *sh, char *param, const char *val) {
|
||||||
|
tts_ctx_t *tts_ctx = (tts_ctx_t *)sh->private_info;
|
||||||
|
|
||||||
|
assert(tts_ctx != NULL);
|
||||||
|
|
||||||
|
if(strcasecmp(param, "url") == 0) {
|
||||||
|
if(val) tts_ctx->api_url = switch_core_strdup(sh->memory_pool, val);
|
||||||
|
} else if(strcasecmp(param, "key") == 0) {
|
||||||
|
if(val) tts_ctx->api_key = switch_core_strdup(sh->memory_pool, val);
|
||||||
|
} else if(strcasecmp(param, "language") == 0) {
|
||||||
|
if(val) tts_ctx->api_key = switch_core_strdup(sh->memory_pool, val);
|
||||||
|
} else if(strcasecmp(param, "text") == 0) {
|
||||||
|
// reserved (ignore)
|
||||||
|
} else {
|
||||||
|
if(tts_ctx->curl_params && val) {
|
||||||
|
switch_core_hash_insert(tts_ctx->curl_params, param, switch_core_strdup(sh->memory_pool, val));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void speech_numeric_param_tts(switch_speech_handle_t *sh, char *param, int val) {
|
||||||
|
}
|
||||||
|
|
||||||
|
static void speech_float_param_tts(switch_speech_handle_t *sh, char *param, double val) {
|
||||||
|
}
|
||||||
|
|
||||||
|
// ---------------------------------------------------------------------------------------------------------------------------------------------
|
||||||
|
// main
|
||||||
|
// ---------------------------------------------------------------------------------------------------------------------------------------------
|
||||||
|
SWITCH_MODULE_LOAD_FUNCTION(mod_curl_tts_load) {
|
||||||
|
switch_status_t status = SWITCH_STATUS_SUCCESS;
|
||||||
|
switch_xml_t cfg, xml, settings, param;
|
||||||
|
switch_speech_interface_t *speech_interface;
|
||||||
|
|
||||||
|
memset(&globals, 0, sizeof(globals));
|
||||||
|
switch_mutex_init(&globals.mutex, SWITCH_MUTEX_NESTED, pool);
|
||||||
|
|
||||||
|
if((xml = switch_xml_open_cfg(MOD_CONFIG_NAME, &cfg, NULL)) == NULL) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to open configuration: %s\n", MOD_CONFIG_NAME);
|
||||||
|
switch_goto_status(SWITCH_STATUS_GENERR, out);
|
||||||
|
}
|
||||||
|
|
||||||
|
if((settings = switch_xml_child(cfg, "settings"))) {
|
||||||
|
for (param = switch_xml_child(settings, "param"); param; param = param->next) {
|
||||||
|
char *var = (char *) switch_xml_attr_soft(param, "name");
|
||||||
|
char *val = (char *) switch_xml_attr_soft(param, "value");
|
||||||
|
|
||||||
|
if(!strcasecmp(var, "api-url")) {
|
||||||
|
if(val) globals.api_url = switch_core_strdup(pool, val);
|
||||||
|
} else if(!strcasecmp(var, "api-key")) {
|
||||||
|
if(val) globals.api_key = switch_core_strdup(pool, val);
|
||||||
|
} else if(!strcasecmp(var, "cache-path")) {
|
||||||
|
if(val) globals.cache_path = switch_core_strdup(pool, val);
|
||||||
|
} else if(!strcasecmp(var, "user-agent")) {
|
||||||
|
if(val) globals.user_agent = switch_core_strdup(pool, val);
|
||||||
|
} else if(!strcasecmp(var, "request-timeout")) {
|
||||||
|
if(val) globals.request_timeout = atoi(val);
|
||||||
|
} else if(!strcasecmp(var, "connect-timeout")) {
|
||||||
|
if(val) globals.connect_timeout = atoi(val);
|
||||||
|
} else if(!strcasecmp(var, "voice-name-as-language")) {
|
||||||
|
if(val) globals.fl_voice_name_as_language = switch_true(val);
|
||||||
|
} else if(!strcasecmp(var, "log-http-errors")) {
|
||||||
|
if(val) globals.fl_log_http_error = switch_true(val);
|
||||||
|
} else if(!strcasecmp(var, "cache-enable")) {
|
||||||
|
if(val) globals.fl_cache_enabled = switch_true(val);
|
||||||
|
} else if(!strcasecmp(var, "file-size-max")) {
|
||||||
|
if(val) globals.file_size_max = atoi(val);
|
||||||
|
} else if(!strcasecmp(var, "proxy")) {
|
||||||
|
if(val) globals.proxy = switch_core_strdup(pool, val);
|
||||||
|
} else if(!strcasecmp(var, "proxy-credentials")) {
|
||||||
|
if(val) globals.proxy_credentials = switch_core_strdup(pool, val);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
globals.tmp_path = SWITCH_GLOBAL_dirs.temp_dir;
|
||||||
|
globals.cache_path = (globals.cache_path == NULL ? "/tmp/curl-tts-cache" : globals.cache_path);
|
||||||
|
globals.file_size_max = globals.file_size_max > 0 ? globals.file_size_max : FILE_SIZE_MAX;
|
||||||
|
|
||||||
|
if(switch_directory_exists(globals.cache_path, NULL) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_dir_make(globals.cache_path, SWITCH_FPROT_OS_DEFAULT, NULL);
|
||||||
|
}
|
||||||
|
|
||||||
|
*module_interface = switch_loadable_module_create_module_interface(pool, modname);
|
||||||
|
speech_interface = switch_loadable_module_create_interface(*module_interface, SWITCH_SPEECH_INTERFACE);
|
||||||
|
speech_interface->interface_name = "curl";
|
||||||
|
|
||||||
|
speech_interface->speech_open = speech_open;
|
||||||
|
speech_interface->speech_close = speech_close;
|
||||||
|
speech_interface->speech_feed_tts = speech_feed_tts;
|
||||||
|
speech_interface->speech_read_tts = speech_read_tts;
|
||||||
|
speech_interface->speech_flush_tts = speech_flush_tts;
|
||||||
|
|
||||||
|
speech_interface->speech_text_param_tts = speech_text_param_tts;
|
||||||
|
speech_interface->speech_numeric_param_tts = speech_numeric_param_tts;
|
||||||
|
speech_interface->speech_float_param_tts = speech_float_param_tts;
|
||||||
|
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "CURL-TTS (%s)\n", MOD_VERSION);
|
||||||
|
out:
|
||||||
|
if(xml) {
|
||||||
|
switch_xml_free(xml);
|
||||||
|
}
|
||||||
|
return status;
|
||||||
|
}
|
||||||
|
|
||||||
|
SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_curl_tts_shutdown) {
|
||||||
|
|
||||||
|
return SWITCH_STATUS_SUCCESS;
|
||||||
|
}
|
||||||
|
|
@ -0,0 +1,72 @@
|
||||||
|
/*
|
||||||
|
* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
|
||||||
|
* Copyright (C) 2005-2014, Anthony Minessale II <anthm@freeswitch.org>
|
||||||
|
*
|
||||||
|
* Version: MPL 1.1
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Mozilla Public License Version
|
||||||
|
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||||
|
* the License. You may obtain a copy of the License at
|
||||||
|
* http://www.mozilla.org/MPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||||
|
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||||
|
* for the specific language governing rights and limitations under the
|
||||||
|
* License.
|
||||||
|
*
|
||||||
|
* Module Contributor(s):
|
||||||
|
* Konstantin Alexandrin <akscfx@gmail.com>
|
||||||
|
*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
#ifndef MOD_CURL_TTS_H
|
||||||
|
#define MOD_CURL_TTS_H
|
||||||
|
|
||||||
|
#include <switch.h>
|
||||||
|
#include <switch_curl.h>
|
||||||
|
|
||||||
|
#define MOD_VERSION "1.0.0"
|
||||||
|
#define MOD_CONFIG_NAME "curl_tts.conf"
|
||||||
|
#define FILE_SIZE_MAX (2*1024*1024)
|
||||||
|
|
||||||
|
typedef struct {
|
||||||
|
switch_mutex_t *mutex;
|
||||||
|
char *cache_path;
|
||||||
|
char *tmp_path;
|
||||||
|
char *user_agent;
|
||||||
|
char *api_url;
|
||||||
|
char *api_key;
|
||||||
|
char *proxy;
|
||||||
|
char *proxy_credentials;
|
||||||
|
uint32_t file_size_max;
|
||||||
|
uint32_t request_timeout; // seconds
|
||||||
|
uint32_t connect_timeout; // seconds
|
||||||
|
uint8_t fl_voice_name_as_language;
|
||||||
|
uint8_t fl_log_http_error;
|
||||||
|
uint8_t fl_cache_enabled;
|
||||||
|
} globals_t;
|
||||||
|
|
||||||
|
typedef struct {
|
||||||
|
switch_memory_pool_t *pool;
|
||||||
|
switch_file_handle_t *fhnd;
|
||||||
|
switch_buffer_t *curl_recv_buffer;
|
||||||
|
switch_hash_t *curl_params;
|
||||||
|
char *curl_send_buffer_ref;
|
||||||
|
char *api_url;
|
||||||
|
char *api_key;
|
||||||
|
char *language;
|
||||||
|
char *mp3_name;
|
||||||
|
char *wav_name;
|
||||||
|
char *media_ctype;
|
||||||
|
uint32_t samplerate;
|
||||||
|
uint32_t channels;
|
||||||
|
size_t curl_send_buffer_len;
|
||||||
|
} tts_ctx_t;
|
||||||
|
|
||||||
|
|
||||||
|
char *escape_dquotes(const char *string);
|
||||||
|
switch_status_t write_file(char *file_name, switch_byte_t *buf, uint32_t buf_len);
|
||||||
|
switch_status_t curl_perform(tts_ctx_t *tts_ctx, char *text);
|
||||||
|
|
||||||
|
|
||||||
|
#endif
|
||||||
|
|
@ -0,0 +1,80 @@
|
||||||
|
/*
|
||||||
|
* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
|
||||||
|
* Copyright (C) 2005-2014, Anthony Minessale II <anthm@freeswitch.org>
|
||||||
|
*
|
||||||
|
* Version: MPL 1.1
|
||||||
|
*
|
||||||
|
* The contents of this file are subject to the Mozilla Public License Version
|
||||||
|
* 1.1 (the "License"); you may not use this file except in compliance with
|
||||||
|
* the License. You may obtain a copy of the License at
|
||||||
|
* http://www.mozilla.org/MPL/
|
||||||
|
*
|
||||||
|
* Software distributed under the License is distributed on an "AS IS" basis,
|
||||||
|
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
|
||||||
|
* for the specific language governing rights and limitations under the
|
||||||
|
* License.
|
||||||
|
*
|
||||||
|
* Module Contributor(s):
|
||||||
|
* Konstantin Alexandrin <akscfx@gmail.com>
|
||||||
|
*
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
#include "mod_curl_tts.h"
|
||||||
|
|
||||||
|
char *escape_dquotes(const char *string) {
|
||||||
|
size_t string_len = strlen(string);
|
||||||
|
size_t i;
|
||||||
|
size_t n = 0;
|
||||||
|
size_t dest_len = 0;
|
||||||
|
char *dest;
|
||||||
|
|
||||||
|
dest_len = strlen(string) + 1;
|
||||||
|
for (i = 0; i < string_len; i++) {
|
||||||
|
switch (string[i]) {
|
||||||
|
case '\"': dest_len += 1; break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
dest = (char *) malloc(sizeof(char) * dest_len);
|
||||||
|
switch_assert(dest);
|
||||||
|
|
||||||
|
for (i = 0; i < string_len; i++) {
|
||||||
|
switch (string[i]) {
|
||||||
|
case '\"':
|
||||||
|
dest[n++] = '\\';
|
||||||
|
dest[n++] = '\"';
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
dest[n++] = string[i];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
dest[n++] = '\0';
|
||||||
|
|
||||||
|
switch_assert(n == dest_len);
|
||||||
|
return dest;
|
||||||
|
}
|
||||||
|
|
||||||
|
switch_status_t write_file(char *file_name, switch_byte_t *buf, uint32_t buf_len) {
|
||||||
|
switch_status_t status = SWITCH_STATUS_SUCCESS;
|
||||||
|
switch_memory_pool_t *pool = NULL;
|
||||||
|
switch_size_t len = buf_len;
|
||||||
|
switch_file_t *fd = NULL;
|
||||||
|
|
||||||
|
if(switch_core_new_memory_pool(&pool) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "switch_core_new_memory_pool() fail\n");
|
||||||
|
switch_goto_status(SWITCH_STATUS_GENERR, out);
|
||||||
|
}
|
||||||
|
if((status = switch_file_open(&fd, file_name, (SWITCH_FOPEN_WRITE | SWITCH_FOPEN_TRUNCATE | SWITCH_FOPEN_CREATE), SWITCH_FPROT_OS_DEFAULT, pool)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Open fail: %s\n", file_name);
|
||||||
|
goto out;
|
||||||
|
}
|
||||||
|
if((status = switch_file_write(fd, buf, &len)) != SWITCH_STATUS_SUCCESS) {
|
||||||
|
switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Write fail (%s)\n", file_name);
|
||||||
|
}
|
||||||
|
switch_file_close(fd);
|
||||||
|
out:
|
||||||
|
if(pool) {
|
||||||
|
switch_core_destroy_memory_pool(&pool);
|
||||||
|
}
|
||||||
|
return status;
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue