diff --git a/src/mod/endpoints/mod_gsmopen/configs/asound.conf b/src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/asound.conf similarity index 100% rename from src/mod/endpoints/mod_gsmopen/configs/asound.conf rename to src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/asound.conf diff --git a/src/mod/endpoints/mod_gsmopen/configs/gsmopen.conf.xml b/src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/gsmopen.conf.xml similarity index 100% rename from src/mod/endpoints/mod_gsmopen/configs/gsmopen.conf.xml rename to src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/gsmopen.conf.xml diff --git a/src/mod/endpoints/mod_gsmopen/configs/gsmopen.conf.xml.motorola b/src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/gsmopen.conf.xml.motorola similarity index 100% rename from src/mod/endpoints/mod_gsmopen/configs/gsmopen.conf.xml.motorola rename to src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/configs/gsmopen.conf.xml.motorola diff --git a/src/mod/endpoints/mod_gsmopen/usb-cm-108-2.txt b/src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/usb-cm-108-2.txt similarity index 100% rename from src/mod/endpoints/mod_gsmopen/usb-cm-108-2.txt rename to src/mod/endpoints/mod_gsmopen/alsa_nogsmlib_nocplusplus/mod_gsmopen/usb-cm-108-2.txt diff --git a/src/mod/endpoints/mod_gsmopen/filtra48down8.c b/src/mod/endpoints/mod_gsmopen/filtra48down8.c deleted file mode 100644 index 615f80295b..0000000000 --- a/src/mod/endpoints/mod_gsmopen/filtra48down8.c +++ /dev/null @@ -1,71 +0,0 @@ -/* Copyright (C) 2007 Jean-Marc Valin - - File: testresample.c - Testing the resampling code - - Redistribution and use in source and binary forms, with or without - modification, are permitted provided that the following conditions are - met: - - 1. Redistributions of source code must retain the above copyright notice, - this list of conditions and the following disclaimer. - - 2. Redistributions in binary form must reproduce the above copyright - notice, this list of conditions and the following disclaimer in the - documentation and/or other materials provided with the distribution. - - 3. The name of the author may not be used to endorse or promote products - derived from this software without specific prior written permission. - - THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR - IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES - OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE - DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, - INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES - (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR - SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) - HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, - STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN - ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE - POSSIBILITY OF SUCH DAMAGE. -*/ - -#include -#include -#include - -#define NN 256 - -int main() -{ - short *in; - short *out; - int i; - int a; - - in = malloc(NN*sizeof(short)); - out = malloc(NN*sizeof(short)/6); - while (1) - { - fread(in, sizeof(short), NN, stdin); - if (feof(stdin)) - break; - - a=0; - for (i=0;i -//#include "speex/speex_resampler.h" -#include -#include - -#define NN 256 - -int main() -{ - short *in; - short *out; - int i; - int a; - - in = malloc(NN*sizeof(short)); - out = malloc(NN*sizeof(short)*6); - while (1) - { - fread(in, sizeof(short), NN, stdin); - if (feof(stdin)) - break; - - a=0; - for (i=0;i - * - * 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. - * - * The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application - * - * The Initial Developer of the Original Code is - * Anthony Minessale II - * Portions created by the Initial Developer are Copyright (C) - * the Initial Developer. All Rights Reserved. - * - * This module (mod_gsmopen) has been contributed by: - * - * Giovanni Maruzzelli (gmaruzz@gmail.com) - * - * - * Further Contributors: - * - * - * - * mod_gsmopen.c -- GSM compatible Endpoint Module - * - */ - -#include "gsmopen.h" - -#if 0 -#ifdef WIN32 -/***************/ -// from http://www.openasthra.com/c-tidbits/gettimeofday-function-for-windows/ - -#include - -#if defined(_MSC_VER) || defined(_MSC_EXTENSIONS) -#define DELTA_EPOCH_IN_MICROSECS 11644473600000000Ui64 -#else /* */ -#define DELTA_EPOCH_IN_MICROSECS 11644473600000000ULL -#endif /* */ -struct sk_timezone { - int tz_minuteswest; /* minutes W of Greenwich */ - int tz_dsttime; /* type of dst correction */ -}; -int gettimeofday(struct timeval *tv, struct sk_timezone *tz) -{ - FILETIME ft; - unsigned __int64 tmpres = 0; - static int tzflag; - if (NULL != tv) { - GetSystemTimeAsFileTime(&ft); - tmpres |= ft.dwHighDateTime; - tmpres <<= 32; - tmpres |= ft.dwLowDateTime; - - /*converting file time to unix epoch */ - tmpres /= 10; /*convert into microseconds */ - tmpres -= DELTA_EPOCH_IN_MICROSECS; - tv->tv_sec = (long) (tmpres / 1000000UL); - tv->tv_usec = (long) (tmpres % 1000000UL); - } - if (NULL != tz) { - if (!tzflag) { - _tzset(); - tzflag++; - } - tz->tz_minuteswest = _timezone / 60; - tz->tz_dsttime = _daylight; - } - return 0; -} - -/***************/ -#endif /* WIN32 */ -#endif //0 -SWITCH_BEGIN_EXTERN_C SWITCH_MODULE_LOAD_FUNCTION(mod_gsmopen_load); -SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_gsmopen_shutdown); -SWITCH_MODULE_DEFINITION(mod_gsmopen, mod_gsmopen_load, mod_gsmopen_shutdown, NULL); -SWITCH_END_EXTERN_C -#define GSMOPEN_CHAT_PROTO "sms" -#if 1 - SWITCH_STANDARD_API(gsm_function); -/* BEGIN: Changes here */ -#define GSM_SYNTAX "list [full] || console || AT_command || remove < interface_name | interface_id > || reload" -/* END: Changes heres */ -SWITCH_STANDARD_API(gsmopen_function); -#define GSMOPEN_SYNTAX "interface_name AT_command" -#endif //0 - -SWITCH_STANDARD_API(gsmopen_boost_audio_function); -#define GSMOPEN_BOOST_AUDIO_SYNTAX "interface_name [ ]" -SWITCH_STANDARD_API(sendsms_function); -#define SENDSMS_SYNTAX "gsmopen_sendsms interface_name destination_number SMS_text" -SWITCH_STANDARD_API(gsmopen_dump_function); -#define GSMOPEN_DUMP_SYNTAX "gsmopen_dump " -/* BEGIN: Changes here */ -#define FULL_RELOAD 0 -#define SOFT_RELOAD 1 -/* END: Changes heres */ - -const char *interface_status[] = { /* should match GSMOPEN_STATE_xxx in gsmopen.h */ - "IDLE", - "DOWN", - "RING", - "DIALING", - "BUSY", - "UP", - "RINGING", - "PRERING", - "DOUBLE", - "SELECTD", - "HANG_RQ", - "PREANSW" -}; - -const char *phone_callflow[] = { /* should match CALLFLOW_XXX in gsmopen.h */ - "CALL_IDLE", - "CALL_DOWN", - "INCOMING_RNG", - "CALL_DIALING", - "CALL_LINEBUSY", - "CALL_ACTIVE", - "INCOMING_HNG", - "CALL_RLEASD", - "CALL_NOCARR", - "CALL_INFLUX", - "CALL_INCOMING", - "CALL_FAILED", - "CALL_NOSRVC", - "CALL_OUTRESTR", - "CALL_SECFAIL", - "CALL_NOANSWER", - "STATUS_FNSHED", - "STATUS_CANCLED", - "STATUS_FAILED", - "STATUS_REFUSED", - "STATUS_RINGING", - "STATUS_INPROGRS", - "STATUS_UNPLACD", - "STATUS_ROUTING", - "STATUS_EARLYMD", - "INCOMING_CLID", - "STATUS_RMTEHOLD" -}; - -static struct { - int debug; - char *ip; - int port; - char *dialplan; - char *destination; - char *context; - char *codec_string; - char *codec_order[SWITCH_MAX_CODECS]; - int codec_order_last; - char *codec_rates_string; - char *codec_rates[SWITCH_MAX_CODECS]; - int codec_rates_last; - unsigned int flags; - int fd; - int calls; - int real_interfaces; - int next_interface; - char hold_music[256]; - private_t GSMOPEN_INTERFACES[GSMOPEN_MAX_INTERFACES]; - switch_mutex_t *mutex; - private_t *gsm_console; -} globals; - -switch_endpoint_interface_t *gsmopen_endpoint_interface; -switch_memory_pool_t *gsmopen_module_pool = NULL; -int running = 0; - -SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_dialplan, globals.dialplan); -SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_context, globals.context); -SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_destination, globals.destination); -//SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_codec_string, globals.codec_string); -//SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_codec_rates_string, globals.codec_rates_string); - -/* BEGIN: Changes here */ -static switch_status_t interface_exists(char *the_interface); -#if 1 -static switch_status_t remove_interface(char *the_interface); -#endif //0 -/* END: Changes here */ - -static switch_status_t channel_on_init(switch_core_session_t *session); -static switch_status_t channel_on_hangup(switch_core_session_t *session); -static switch_status_t channel_on_destroy(switch_core_session_t *session); -static switch_status_t channel_on_routing(switch_core_session_t *session); -static switch_status_t channel_on_exchange_media(switch_core_session_t *session); -static switch_status_t channel_on_consume_media(switch_core_session_t *session); -static switch_status_t channel_on_soft_execute(switch_core_session_t *session); -static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *session, - switch_event_t *var_event, - switch_caller_profile_t *outbound_profile, - switch_core_session_t **new_session, switch_memory_pool_t **pool, switch_originate_flag_t flags, - switch_call_cause_t *cancel_cause); -static switch_status_t channel_read_frame(switch_core_session_t *session, switch_frame_t **frame, switch_io_flag_t flags, int stream_id); -static switch_status_t channel_write_frame(switch_core_session_t *session, switch_frame_t *frame, switch_io_flag_t flags, int stream_id); -static switch_status_t channel_kill_channel(switch_core_session_t *session, int sig); -static switch_status_t gsmopen_tech_init(private_t *tech_pvt, switch_core_session_t *session); - -static switch_status_t gsmopen_codec(private_t *tech_pvt, int sample_rate, int codec_ms) -{ - switch_core_session_t *session = NULL; - - if (switch_core_codec_init - (&tech_pvt->read_codec, "L16", NULL, sample_rate, codec_ms, 1, - SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, NULL) != SWITCH_STATUS_SUCCESS) { - ERRORA("Can't load codec?\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - - if (switch_core_codec_init - (&tech_pvt->write_codec, "L16", NULL, sample_rate, codec_ms, 1, - SWITCH_CODEC_FLAG_ENCODE | SWITCH_CODEC_FLAG_DECODE, NULL, NULL) != SWITCH_STATUS_SUCCESS) { - ERRORA("Can't load codec?\n", GSMOPEN_P_LOG); - switch_core_codec_destroy(&tech_pvt->read_codec); - return SWITCH_STATUS_FALSE; - } - - tech_pvt->read_frame.rate = sample_rate; - tech_pvt->read_frame.codec = &tech_pvt->read_codec; - - session = switch_core_session_locate(tech_pvt->session_uuid_str); - - if (session) { - switch_core_session_set_read_codec(session, &tech_pvt->read_codec); - switch_core_session_set_write_codec(session, &tech_pvt->write_codec); - switch_core_session_rwunlock(session); - } else { - ERRORA("no session\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - - return SWITCH_STATUS_SUCCESS; - -} - -switch_status_t gsmopen_tech_init(private_t *tech_pvt, switch_core_session_t *session) -{ - - switch_assert(tech_pvt != NULL); - switch_assert(session != NULL); - tech_pvt->read_frame.data = tech_pvt->databuf; - tech_pvt->read_frame.buflen = sizeof(tech_pvt->databuf); - switch_mutex_init(&tech_pvt->mutex, SWITCH_MUTEX_NESTED, switch_core_session_get_pool(session)); - switch_mutex_init(&tech_pvt->flag_mutex, SWITCH_MUTEX_NESTED, switch_core_session_get_pool(session)); - switch_core_session_set_private(session, tech_pvt); - switch_copy_string(tech_pvt->session_uuid_str, switch_core_session_get_uuid(session), sizeof(tech_pvt->session_uuid_str)); - if (!strlen(tech_pvt->session_uuid_str)) { - ERRORA("no tech_pvt->session_uuid_str\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - if (gsmopen_codec(tech_pvt, SAMPLERATE_GSMOPEN, 20) != SWITCH_STATUS_SUCCESS) { - ERRORA("gsmopen_codec FAILED\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - //teletone_dtmf_detect_init(&tech_pvt->dtmf_detect, tech_pvt->read_codec.implementation->actual_samples_per_second); - //teletone_dtmf_detect_init(&tech_pvt->dtmf_detect, 8000); - dtmf_rx_init(&tech_pvt->dtmf_state, NULL, NULL); - dtmf_rx_parms(&tech_pvt->dtmf_state, 0, 10, 10, -99); - - if (tech_pvt->no_sound == 0) { - if (serial_audio_init(tech_pvt)) { - ERRORA("serial_audio_init failed\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - - } - } - - if (switch_core_timer_init(&tech_pvt->timer_read, "soft", 20, tech_pvt->read_codec.implementation->samples_per_packet, gsmopen_module_pool) != - SWITCH_STATUS_SUCCESS) { - ERRORA("setup timer failed\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - - switch_core_timer_sync(&tech_pvt->timer_read); - - if (switch_core_timer_init(&tech_pvt->timer_write, "soft", 20, tech_pvt->write_codec.implementation->samples_per_packet, gsmopen_module_pool) != - SWITCH_STATUS_SUCCESS) { - ERRORA("setup timer failed\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - - switch_core_timer_sync(&tech_pvt->timer_write); - - switch_clear_flag(tech_pvt, TFLAG_HANGUP); - DEBUGA_GSMOPEN("gsmopen_codec SUCCESS\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_SUCCESS; -} - -/* BEGIN: Changes here */ -static switch_status_t interface_exists(char *the_interface) -{ - int i; - int interface_id; - - if (*the_interface == '#') { /* look by interface id or interface name */ - the_interface++; - switch_assert(the_interface); - interface_id = atoi(the_interface); - - /* take a number as interface id */ - if (interface_id > 0 || (interface_id == 0 && strcmp(the_interface, "0") == 0)) { - if (strlen(globals.GSMOPEN_INTERFACES[interface_id].name)) { - return SWITCH_STATUS_SUCCESS; - } - } else { - /* interface name */ - for (interface_id = 0; interface_id < GSMOPEN_MAX_INTERFACES; interface_id++) { - if (strcmp(globals.GSMOPEN_INTERFACES[interface_id].name, the_interface) == 0) { - return SWITCH_STATUS_SUCCESS; - break; - } - } - } - } else { /* look by gsmopen_user */ - - for (i = 0; i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].gsmopen_user)) { - if (strcmp(globals.GSMOPEN_INTERFACES[i].gsmopen_user, the_interface) == 0) { - return SWITCH_STATUS_SUCCESS; - } - } - } - } - return SWITCH_STATUS_FALSE; -} - -#if 1 -static switch_status_t remove_interface(char *the_interface) -{ - int x = 10; - unsigned int howmany = 8; - int interface_id = -1; - private_t *tech_pvt = NULL; - switch_status_t status; - - //running = 0; - - //XXX if (*the_interface == '#') { /* remove by interface id or interface name */ - //XXX the_interface++; - switch_assert(the_interface); - interface_id = atoi(the_interface); - - if (interface_id > 0 || (interface_id == 0 && strcmp(the_interface, "0") == 0)) { - /* take a number as interface id */ - tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - } else { - - for (interface_id = 0; interface_id < GSMOPEN_MAX_INTERFACES; interface_id++) { - if (strcmp(globals.GSMOPEN_INTERFACES[interface_id].name, the_interface) == 0) { - tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - break; - } - } - } - //XXX } //else { /* remove by gsmopen_user */ - //for (interface_id = 0; interface_id < GSMOPEN_MAX_INTERFACES; interface_id++) { - //if (strcmp(globals.GSMOPEN_INTERFACES[interface_id].gsmopen_user, the_interface) == 0) { - //tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - //break; - //} - //} - //} - - if (!tech_pvt) { - DEBUGA_GSMOPEN("interface '%s' does not exist\n", GSMOPEN_P_LOG, the_interface); - goto end; - } - - if (strlen(globals.GSMOPEN_INTERFACES[interface_id].session_uuid_str)) { - DEBUGA_GSMOPEN("interface '%s' is busy\n", GSMOPEN_P_LOG, the_interface); - goto end; - } - - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread) { -#if 1 -#ifdef WIN32 - switch_file_write(tech_pvt->GSMopenHandles.fdesc[1], "sciutati", &howmany); // let's the controldev_thread die -#else /* WIN32 */ - howmany = write(tech_pvt->GSMopenHandles.fdesc[1], "sciutati", howmany); -#endif /* WIN32 */ -#endif //0 - DEBUGA_GSMOPEN("HERE will shutdown gsmopen_signaling_thread of '%s'\n", GSMOPEN_P_LOG, the_interface); - } - - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread) { -#if 0 -#ifdef WIN32 - if (SendMessage(tech_pvt->GSMopenHandles.win32_hInit_MainWindowHandle, WM_DESTROY, 0, 0) == FALSE) { // let's the gsmopen_api_thread_func die - DEBUGA_GSMOPEN("got FALSE here, thread probably was already dead. GetLastError returned: %d\n", GSMOPEN_P_LOG, GetLastError()); - globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread = NULL; - } -#else - XEvent e; - Atom atom1 = XInternAtom(tech_pvt->GSMopenHandles.disp, "GSMOPENCONTROLAPI_MESSAGE_BEGIN", False); - memset(&e, 0, sizeof(e)); - e.xclient.type = ClientMessage; - e.xclient.message_type = atom1; /* leading message */ - e.xclient.display = tech_pvt->GSMopenHandles.disp; - e.xclient.window = tech_pvt->GSMopenHandles.gsmopen_win; - e.xclient.format = 8; - - XSendEvent(tech_pvt->GSMopenHandles.disp, tech_pvt->GSMopenHandles.win, False, 0, &e); - XSync(tech_pvt->GSMopenHandles.disp, False); -#endif //WIN32 -#endif //0 - - DEBUGA_GSMOPEN("HERE will shutdown gsmopen_api_thread of '%s'\n", GSMOPEN_P_LOG, the_interface); - } - - while (x) { - x--; - switch_yield(50000); - } - - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread) { - switch_thread_join(&status, globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread); - } - - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread) { - switch_thread_join(&status, globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread); - } - - switch_mutex_lock(globals.mutex); - if (globals.gsm_console == &globals.GSMOPEN_INTERFACES[interface_id]) { - DEBUGA_GSMOPEN("interface '%s' no more console\n", GSMOPEN_P_LOG, the_interface); - globals.gsm_console = NULL; - } else { - DEBUGA_GSMOPEN("interface '%s' STILL console\n", GSMOPEN_P_LOG, the_interface); - } - memset(&globals.GSMOPEN_INTERFACES[interface_id], '\0', sizeof(private_t)); - globals.real_interfaces--; - switch_mutex_unlock(globals.mutex); - - DEBUGA_GSMOPEN("interface '%s' deleted successfully\n", GSMOPEN_P_LOG, the_interface); - globals.GSMOPEN_INTERFACES[interface_id].running = 1; - end: - //running = 1; - return SWITCH_STATUS_SUCCESS; -} -#endif //0 - -/* END: Changes here */ - -/* - State methods they get called when the state changes to the specific state - returning SWITCH_STATUS_SUCCESS tells the core to execute the standard state method next - so if you fully implement the state you can return SWITCH_STATUS_FALSE to skip it. -*/ -static switch_status_t channel_on_init(switch_core_session_t *session) -{ - switch_channel_t *channel; - private_t *tech_pvt = NULL; - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - //ERRORA("%s CHANNEL INIT\n", GSMOPEN_P_LOG, tech_pvt->name); - switch_set_flag(tech_pvt, TFLAG_IO); - - /* Move channel's state machine to ROUTING. This means the call is trying - to get from the initial start where the call because, to the point - where a destination has been identified. If the channel is simply - left in the initial state, nothing will happen. */ - switch_channel_set_state(channel, CS_ROUTING); - switch_mutex_lock(globals.mutex); - globals.calls++; - - switch_mutex_unlock(globals.mutex); - DEBUGA_GSMOPEN("%s CHANNEL INIT %s\n", GSMOPEN_P_LOG, tech_pvt->name, switch_core_session_get_uuid(session)); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_destroy(switch_core_session_t *session) -{ - private_t *tech_pvt = NULL; - - tech_pvt = (private_t *) switch_core_session_get_private(session); - - if (tech_pvt) { - DEBUGA_GSMOPEN("%s CHANNEL DESTROY %s\n", GSMOPEN_P_LOG, tech_pvt->name, switch_core_session_get_uuid(session)); - - if (switch_core_codec_ready(&tech_pvt->read_codec)) { - switch_core_codec_destroy(&tech_pvt->read_codec); - } - - if (switch_core_codec_ready(&tech_pvt->write_codec)) { - switch_core_codec_destroy(&tech_pvt->write_codec); - } - - switch_core_timer_destroy(&tech_pvt->timer_read); - switch_core_timer_destroy(&tech_pvt->timer_write); - - if (tech_pvt->no_sound == 0) { - serial_audio_shutdown(tech_pvt); - } - - *tech_pvt->session_uuid_str = '\0'; - tech_pvt->interface_state = GSMOPEN_STATE_IDLE; - if (tech_pvt->phone_callflow == CALLFLOW_STATUS_FINISHED) { - tech_pvt->phone_callflow = CALLFLOW_CALL_IDLE; - } - switch_core_session_set_private(session, NULL); - } else { - DEBUGA_GSMOPEN("!!!!!!NO tech_pvt!!!! CHANNEL DESTROY %s\n", GSMOPEN_P_LOG, switch_core_session_get_uuid(session)); - } - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_hangup(switch_core_session_t *session) -{ - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - tech_pvt->phone_callflow = CALLFLOW_CALL_HANGUP_REQUESTED; - - if (!switch_channel_test_flag(channel, CF_ANSWERED)) { - if (switch_channel_direction(channel) == SWITCH_CALL_DIRECTION_OUTBOUND) { - tech_pvt->ob_failed_calls++; - } else { - tech_pvt->ib_failed_calls++; - } - } - - DEBUGA_GSMOPEN("%s CHANNEL HANGUP\n", GSMOPEN_P_LOG, tech_pvt->name); - switch_clear_flag(tech_pvt, TFLAG_IO); - switch_clear_flag(tech_pvt, TFLAG_VOICE); - switch_set_flag(tech_pvt, TFLAG_HANGUP); - - gsmopen_hangup(tech_pvt); - - //memset(tech_pvt->session_uuid_str, '\0', sizeof(tech_pvt->session_uuid_str)); - //*tech_pvt->session_uuid_str = '\0'; - DEBUGA_GSMOPEN("%s CHANNEL HANGUP\n", GSMOPEN_P_LOG, tech_pvt->name); - switch_mutex_lock(globals.mutex); - globals.calls--; - if (globals.calls < 0) { - globals.calls = 0; - } - - tech_pvt->interface_state = GSMOPEN_STATE_IDLE; - //FIXME if (tech_pvt->phone_callflow == CALLFLOW_STATUS_FINISHED) { - tech_pvt->phone_callflow = CALLFLOW_CALL_IDLE; - //FIXME } - switch_mutex_unlock(globals.mutex); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_routing(switch_core_session_t *session) -{ - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - DEBUGA_GSMOPEN("%s CHANNEL ROUTING\n", GSMOPEN_P_LOG, tech_pvt->name); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_execute(switch_core_session_t *session) -{ - - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - DEBUGA_GSMOPEN("%s CHANNEL EXECUTE\n", GSMOPEN_P_LOG, tech_pvt->name); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_kill_channel(switch_core_session_t *session, int sig) -{ - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - DEBUGA_GSMOPEN("%s CHANNEL KILL_CHANNEL\n", GSMOPEN_P_LOG, tech_pvt->name); - switch (sig) { - case SWITCH_SIG_KILL: - DEBUGA_GSMOPEN("%s CHANNEL got SWITCH_SIG_KILL\n", GSMOPEN_P_LOG, switch_channel_get_name(channel)); - //switch_mutex_lock(tech_pvt->flag_mutex); - switch_clear_flag(tech_pvt, TFLAG_IO); - switch_clear_flag(tech_pvt, TFLAG_VOICE); - switch_set_flag(tech_pvt, TFLAG_HANGUP); - //switch_mutex_unlock(tech_pvt->flag_mutex); - break; - case SWITCH_SIG_BREAK: - DEBUGA_GSMOPEN("%s CHANNEL got SWITCH_SIG_BREAK\n", GSMOPEN_P_LOG, switch_channel_get_name(channel)); - //switch_set_flag(tech_pvt, TFLAG_BREAK); - //switch_mutex_lock(tech_pvt->flag_mutex); - switch_set_flag(tech_pvt, TFLAG_BREAK); - //switch_mutex_unlock(tech_pvt->flag_mutex); - break; - default: - break; - } - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_consume_media(switch_core_session_t *session) -{ - private_t *tech_pvt = NULL; - - tech_pvt = (private_t *) switch_core_session_get_private(session); - - DEBUGA_GSMOPEN("%s CHANNEL CONSUME_MEDIA\n", GSMOPEN_P_LOG, tech_pvt->name); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_exchange_media(switch_core_session_t *session) -{ - private_t *tech_pvt = NULL; - tech_pvt = (private_t *) switch_core_session_get_private(session); - DEBUGA_GSMOPEN("%s CHANNEL EXCHANGE_MEDIA\n", GSMOPEN_P_LOG, tech_pvt->name); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_on_soft_execute(switch_core_session_t *session) -{ - private_t *tech_pvt = NULL; - tech_pvt = (private_t *) switch_core_session_get_private(session); - DEBUGA_GSMOPEN("%s CHANNEL SOFT_EXECUTE\n", GSMOPEN_P_LOG, tech_pvt->name); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_send_dtmf(switch_core_session_t *session, const switch_dtmf_t *dtmf) -{ - private_t *tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - DEBUGA_GSMOPEN("%s CHANNEL SEND_DTMF\n", GSMOPEN_P_LOG, tech_pvt->name); - DEBUGA_GSMOPEN("DTMF: %c\n", GSMOPEN_P_LOG, dtmf->digit); - - gsmopen_senddigit(tech_pvt, dtmf->digit); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_read_frame(switch_core_session_t *session, switch_frame_t **frame, switch_io_flag_t flags, int stream_id) -{ - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - switch_byte_t *data; - - int samples; - int samples2; - char digit_str[256]; - char buffer2[640]; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - if (!switch_channel_ready(channel) || !switch_test_flag(tech_pvt, TFLAG_IO)) { - ERRORA("channel not ready \n", GSMOPEN_P_LOG); - //TODO: kill the bastard - return SWITCH_STATUS_FALSE; - } - - tech_pvt->read_frame.flags = SFF_NONE; - *frame = NULL; - - if (switch_test_flag(tech_pvt, TFLAG_HANGUP)) { - return SWITCH_STATUS_FALSE; - } - - switch_core_timer_next(&tech_pvt->timer_read); - - if (tech_pvt->no_sound == 1) { - goto cng; - } -// if ((samples = tech_pvt->serialPort_serial_audio->Read((char *) tech_pvt->read_frame.data, 320)) >0) - - if ((samples = tech_pvt->serialPort_serial_audio->Read(buffer2, 640)) >= 320) { - tech_pvt->buffer2_full = 0; - - if (samples >= 640) { - DEBUGA_GSMOPEN("samples=%d\n", GSMOPEN_P_LOG, samples); - memcpy(tech_pvt->buffer2, buffer2 + 320, 320); - tech_pvt->buffer2_full = 1; - } - samples = 320; - - memcpy(tech_pvt->read_frame.data, buffer2, 320); - tech_pvt->read_frame.datalen = samples; - tech_pvt->read_frame.samples = samples / 2; - - tech_pvt->read_frame.timestamp = tech_pvt->timer_read.samplecount; - - *frame = &tech_pvt->read_frame; - - //if ((samples2 = tech_pvt->serialPort_serial_audio->Read((char *) tech_pvt->read_frame.data, 320)) >0){ - // WARNINGA("samples2=%d\n", GSMOPEN_P_LOG, samples2); - //} - //status = SWITCH_STATUS_SUCCESS; - switch_set_flag(tech_pvt, TFLAG_VOICE); - } else { - DEBUGA_GSMOPEN("MINGA samples=%d\n", GSMOPEN_P_LOG, samples); - if (tech_pvt->buffer2_full) { - memcpy(tech_pvt->read_frame.data, tech_pvt->buffer2, 320); - tech_pvt->buffer2_full = 0; - samples = 320; - DEBUGA_GSMOPEN("samples=%d FROM BUFFER\n", GSMOPEN_P_LOG, samples); - - tech_pvt->read_frame.datalen = samples; - tech_pvt->read_frame.samples = samples / 2; - - tech_pvt->read_frame.timestamp = tech_pvt->timer_read.samplecount; - - *frame = &tech_pvt->read_frame; - - //if ((samples2 = tech_pvt->serialPort_serial_audio->Read((char *) tech_pvt->read_frame.data, 320)) >0){ - // WARNINGA("samples2=%d\n", GSMOPEN_P_LOG, samples2); - //} - //status = SWITCH_STATUS_SUCCESS; - switch_set_flag(tech_pvt, TFLAG_VOICE); - } - - } - //WARNINGA("samples=%d\n", GSMOPEN_P_LOG, samples); - if (samples != 320) { - DEBUGA_GSMOPEN("samples=%d\n", GSMOPEN_P_LOG, samples); - goto cng; - } -//DEBUGA_GSMOPEN("samples=%d tech_pvt->read_frame.timestamp=%d\n", GSMOPEN_P_LOG, samples, tech_pvt->read_frame.timestamp); - -//usleep(17000); -//usleep(17000); - - memset(digit_str, 0, sizeof(digit_str)); - //teletone_dtmf_detect(&tech_pvt->dtmf_detect, (int16_t *) tech_pvt->read_frame.data, tech_pvt->read_frame.samples); - //teletone_dtmf_get(&tech_pvt->dtmf_detect, digit_str, sizeof(digit_str)); - dtmf_rx(&tech_pvt->dtmf_state, (int16_t *) tech_pvt->read_frame.data, tech_pvt->read_frame.samples); - dtmf_rx_get(&tech_pvt->dtmf_state, digit_str, sizeof(digit_str)); - - gsmopen_sound_boost(tech_pvt->read_frame.data, tech_pvt->read_frame.samples, tech_pvt->capture_boost); - - if (digit_str[0]) { - switch_time_t new_dtmf_timestamp = switch_time_now(); - if ((new_dtmf_timestamp - tech_pvt->old_dtmf_timestamp) > 350000) { //FIXME: make it configurable - char *p = digit_str; - switch_channel_t *channel = switch_core_session_get_channel(session); - - while (p && *p) { - switch_dtmf_t dtmf = { 0 }; - dtmf.digit = *p; - dtmf.duration = SWITCH_DEFAULT_DTMF_DURATION; - switch_channel_queue_dtmf(channel, &dtmf); - p++; - } - NOTICA("DTMF DETECTED: [%s] new_dtmf_timestamp: %u, delta_t: %u\n", GSMOPEN_P_LOG, digit_str, (unsigned int) new_dtmf_timestamp, - (unsigned int) (new_dtmf_timestamp - tech_pvt->old_dtmf_timestamp)); - tech_pvt->old_dtmf_timestamp = new_dtmf_timestamp; - } - } - while (switch_test_flag(tech_pvt, TFLAG_IO)) { - if (switch_test_flag(tech_pvt, TFLAG_BREAK)) { - switch_clear_flag(tech_pvt, TFLAG_BREAK); - DEBUGA_GSMOPEN("CHANNEL READ FRAME goto CNG\n", GSMOPEN_P_LOG); - goto cng; - } - - if (!switch_test_flag(tech_pvt, TFLAG_IO)) { - DEBUGA_GSMOPEN("CHANNEL READ FRAME not IO\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - } - - if (switch_test_flag(tech_pvt, TFLAG_IO) && switch_test_flag(tech_pvt, TFLAG_VOICE)) { - switch_clear_flag(tech_pvt, TFLAG_VOICE); - if (!tech_pvt->read_frame.datalen) { - DEBUGA_GSMOPEN("CHANNEL READ CONTINUE\n", GSMOPEN_P_LOG); - continue; - } - *frame = &tech_pvt->read_frame; -#ifdef BIGENDIAN - if (switch_test_flag(tech_pvt, TFLAG_LINEAR)) { - switch_swap_linear((int16_t *) (*frame)->data, (int) (*frame)->datalen / 2); - } -#endif - //WARNINGA("HERE\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_SUCCESS; - } - - WARNINGA("HERE\n", GSMOPEN_P_LOG); - DEBUGA_GSMOPEN("CHANNEL READ no TFLAG_VOICE\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - - } - - DEBUGA_GSMOPEN("CHANNEL READ FALSE\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_FALSE; - cng: - data = (switch_byte_t *) tech_pvt->read_frame.data; - data[0] = 65; - data[1] = 0; - tech_pvt->read_frame.datalen = 2; - tech_pvt->read_frame.flags = SFF_CNG; - *frame = &tech_pvt->read_frame; - return SWITCH_STATUS_SUCCESS; - -} - -static switch_status_t channel_write_frame(switch_core_session_t *session, switch_frame_t *frame, switch_io_flag_t flags, int stream_id) -{ - switch_channel_t *channel = NULL; - private_t *tech_pvt = NULL; - - unsigned int sent; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - if (!switch_channel_ready(channel) || !switch_test_flag(tech_pvt, TFLAG_IO)) { - ERRORA("channel not ready \n", GSMOPEN_P_LOG); - //TODO: kill the bastard - return SWITCH_STATUS_FALSE; - } -#ifdef BIGENDIAN - if (switch_test_flag(tech_pvt, TFLAG_LINEAR)) { -#ifdef WIN32 - switch_swap_linear((int16_t *) frame->data, (int) frame->datalen / 2); -#else - switch_swap_linear(frame->data, (int) frame->datalen / 2); -#endif //WIN32 - } -#endif - - //switch_core_timer_next(&tech_pvt->timer_write); - //sent = frame->datalen; - - //ERRORA("PLAY \n", GSMOPEN_P_LOG); - - gsmopen_sound_boost(frame->data, frame->samples, tech_pvt->playback_boost); - sent = tech_pvt->serialPort_serial_audio->Write((char *) frame->data, (int) (frame->datalen)); - - if (sent && sent != frame->datalen && sent != -1) { - DEBUGA_GSMOPEN("sent %d\n", GSMOPEN_P_LOG, sent); - } - //NOTICA("sent=%d\n", GSMOPEN_P_LOG, sent); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_answer_channel(switch_core_session_t *session) -{ - private_t *tech_pvt; - switch_channel_t *channel = NULL; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - //ERRORA("%s CHANNEL INIT\n", GSMOPEN_P_LOG, tech_pvt->name); - switch_set_flag(tech_pvt, TFLAG_IO); - gsmopen_serial_answer(tech_pvt); - - /* Move channel's state machine to ROUTING. This means the call is trying - to get from the initial start where the call because, to the point - where a destination has been identified. If the channel is simply - left in the initial state, nothing will happen. */ - switch_channel_set_state(channel, CS_ROUTING); - switch_mutex_lock(globals.mutex); - globals.calls++; - - switch_mutex_unlock(globals.mutex); - DEBUGA_GSMOPEN("%s CHANNEL ANSWER %s\n", GSMOPEN_P_LOG, tech_pvt->name, switch_core_session_get_uuid(session)); - - DEBUGA_GSMOPEN("ANSWERED! \n", GSMOPEN_P_LOG); - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_receive_message(switch_core_session_t *session, switch_core_session_message_t *msg) -{ - switch_channel_t *channel; - private_t *tech_pvt; - - channel = switch_core_session_get_channel(session); - switch_assert(channel != NULL); - - tech_pvt = (private_t *) switch_core_session_get_private(session); - switch_assert(tech_pvt != NULL); - - switch (msg->message_id) { - case SWITCH_MESSAGE_INDICATE_ANSWER: - { - DEBUGA_GSMOPEN("MSG_ID=%d, TO BE ANSWERED!\n", GSMOPEN_P_LOG, msg->message_id); - channel_answer_channel(session); - } - break; - case SWITCH_MESSAGE_INDICATE_AUDIO_SYNC: - - DEBUGA_GSMOPEN("%s CHANNEL got SWITCH_MESSAGE_INDICATE_AUDIO_SYNC\n", GSMOPEN_P_LOG, switch_channel_get_name(channel)); - switch_core_timer_sync(&tech_pvt->timer_read); - switch_core_timer_sync(&tech_pvt->timer_write); - - break; - - default: - { - DEBUGA_GSMOPEN("MSG_ID=%d\n", GSMOPEN_P_LOG, msg->message_id); - } - break; - } - - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t channel_receive_event(switch_core_session_t *session, switch_event_t *event) -{ - struct private_object *tech_pvt = (struct private_object *) switch_core_session_get_private(session); - char *body = switch_event_get_body(event); - switch_assert(tech_pvt != NULL); - - if (!body) { - body = (char *) ""; - } - - WARNINGA("event: |||%s|||\n", GSMOPEN_P_LOG, body); - - return SWITCH_STATUS_SUCCESS; -} - -switch_state_handler_table_t gsmopen_state_handlers = { - /*.on_init */ channel_on_init, - /*.on_routing */ channel_on_routing, - /*.on_execute */ channel_on_execute, - /*.on_hangup */ channel_on_hangup, - /*.on_exchange_media */ channel_on_exchange_media, - /*.on_soft_execute */ channel_on_soft_execute, - /*.on_consume_media */ channel_on_consume_media, - /*.on_hibernate */ NULL, - /*.on_reset */ NULL, - /*.on_park */ NULL, - /*.on_reporting */ NULL, - /*.on_destroy */ channel_on_destroy -}; - -switch_io_routines_t gsmopen_io_routines = { - /*.outgoing_channel */ channel_outgoing_channel, - /*.read_frame */ channel_read_frame, - /*.write_frame */ channel_write_frame, - /*.kill_channel */ channel_kill_channel, - /*.send_dtmf */ channel_send_dtmf, - /*.receive_message */ channel_receive_message, - /*.receive_event */ channel_receive_event -}; - -static switch_call_cause_t channel_outgoing_channel(switch_core_session_t *session, - switch_event_t *var_event, - switch_caller_profile_t *outbound_profile, - switch_core_session_t **new_session, switch_memory_pool_t **pool, switch_originate_flag_t flags, - switch_call_cause_t *cancel_cause) -{ - private_t *tech_pvt = NULL; - if ((*new_session = switch_core_session_request(gsmopen_endpoint_interface, SWITCH_CALL_DIRECTION_OUTBOUND, flags, pool)) != 0) { - switch_channel_t *channel = NULL; - switch_caller_profile_t *caller_profile; - char *rdest; - int found = 0; - char interface_name[256]; - - DEBUGA_GSMOPEN("1 SESSION_REQUEST %s\n", GSMOPEN_P_LOG, switch_core_session_get_uuid(*new_session)); - switch_core_session_add_stream(*new_session, NULL); - - if (!zstr(outbound_profile->destination_number)) { - int i; - char *slash; - - switch_copy_string(interface_name, outbound_profile->destination_number, 255); - slash = strrchr(interface_name, '/'); - *slash = '\0'; - - switch_mutex_lock(globals.mutex); - if (strncmp("ANY", interface_name, strlen(interface_name)) == 0 || strncmp("RR", interface_name, strlen(interface_name)) == 0) { - /* we've been asked for the "ANY" interface, let's find the first idle interface */ - //DEBUGA_GSMOPEN("Finding one available gsmopen interface\n", GSMOPEN_P_LOG); - //tech_pvt = find_available_gsmopen_interface(NULL); - //if (tech_pvt) - //found = 1; - //} else if (strncmp("RR", interface_name, strlen(interface_name)) == 0) { - /* Find the first idle interface using Round Robin */ - DEBUGA_GSMOPEN("Finding one available gsmopen interface RR\n", GSMOPEN_P_LOG); - tech_pvt = find_available_gsmopen_interface_rr(NULL); - if (tech_pvt) { - found = 1; - DEBUGA_GSMOPEN("FOUND one available gsmopen interface RR\n", GSMOPEN_P_LOG); - } - } - - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, interface_name, strlen(interface_name)) == 0)) { - if (strlen(globals.GSMOPEN_INTERFACES[i].session_uuid_str)) { - DEBUGA_GSMOPEN - ("globals.GSMOPEN_INTERFACES[%d].name=|||%s||| session_uuid_str=|||%s||| is BUSY\n", - GSMOPEN_P_LOG, i, globals.GSMOPEN_INTERFACES[i].name, globals.GSMOPEN_INTERFACES[i].session_uuid_str); - DEBUGA_GSMOPEN("1 SESSION_DESTROY %s\n", GSMOPEN_P_LOG, switch_core_session_get_uuid(*new_session)); - switch_core_session_destroy(new_session); - switch_mutex_unlock(globals.mutex); - return SWITCH_CAUSE_NORMAL_CIRCUIT_CONGESTION; - } - - DEBUGA_GSMOPEN("globals.GSMOPEN_INTERFACES[%d].name=|||%s|||?\n", GSMOPEN_P_LOG, i, globals.GSMOPEN_INTERFACES[i].name); - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - found = 1; - break; - } - - } - - } else { - ERRORA("Doh! no destination number?\n", GSMOPEN_P_LOG); - switch_core_session_destroy(new_session); - return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; - } - - if (!found) { - DEBUGA_GSMOPEN("Doh! no available interface for |||%s|||?\n", GSMOPEN_P_LOG, interface_name); - DEBUGA_GSMOPEN("2 SESSION_DESTROY %s\n", GSMOPEN_P_LOG, switch_core_session_get_uuid(*new_session)); - switch_core_session_destroy(new_session); - switch_mutex_unlock(globals.mutex); - //return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; - return SWITCH_CAUSE_NORMAL_CIRCUIT_CONGESTION; - } - - channel = switch_core_session_get_channel(*new_session); - if (!channel) { - ERRORA("Doh! no channel?\n", GSMOPEN_P_LOG); - switch_core_session_destroy(new_session); - switch_mutex_unlock(globals.mutex); - return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; - } - if (gsmopen_tech_init(tech_pvt, *new_session) != SWITCH_STATUS_SUCCESS) { - ERRORA("Doh! no tech_init?\n", GSMOPEN_P_LOG); - switch_core_session_destroy(new_session); - switch_mutex_unlock(globals.mutex); - return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; - } - - if (outbound_profile) { - char name[128]; - - snprintf(name, sizeof(name), "gsmopen/%s", outbound_profile->destination_number); - //snprintf(name, sizeof(name), "gsmopen/%s", tech_pvt->name); - switch_channel_set_name(channel, name); - caller_profile = switch_caller_profile_clone(*new_session, outbound_profile); - switch_channel_set_caller_profile(channel, caller_profile); - tech_pvt->caller_profile = caller_profile; - } else { - ERRORA("Doh! no caller profile\n", GSMOPEN_P_LOG); - switch_core_session_destroy(new_session); - switch_mutex_unlock(globals.mutex); - return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; - } - - tech_pvt->ob_calls++; - - rdest = strchr(caller_profile->destination_number, '/'); - *rdest++ = '\0'; - - //gsmopen_call(tech_pvt, rdest, 30); - - switch_copy_string(tech_pvt->session_uuid_str, switch_core_session_get_uuid(*new_session), sizeof(tech_pvt->session_uuid_str)); - caller_profile = tech_pvt->caller_profile; - caller_profile->destination_number = rdest; - - switch_set_flag(tech_pvt, TFLAG_OUTBOUND); - switch_channel_set_state(channel, CS_INIT); - gsmopen_call(tech_pvt, rdest, 30); - switch_mutex_unlock(globals.mutex); - return SWITCH_CAUSE_SUCCESS; - } - - ERRORA("Doh! no new_session\n", GSMOPEN_P_LOG); - return SWITCH_CAUSE_DESTINATION_OUT_OF_ORDER; -} - -/*! - * \brief This thread runs during a call, and monitor the interface for signaling, like hangup, caller id, etc most of signaling is handled inside the gsmopen_signaling_read function - * - */ - -static switch_status_t load_config(int reload_type) -{ - const char *cf = "gsmopen.conf"; - switch_xml_t cfg, xml, global_settings, param, interfaces, myinterface; - private_t *tech_pvt = NULL; - - switch_mutex_init(&globals.mutex, SWITCH_MUTEX_NESTED, gsmopen_module_pool); - if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) { - ERRORA("open of %s failed\n", GSMOPEN_P_LOG, cf); - running = 0; - switch_xml_free(xml); - return SWITCH_STATUS_TERM; - } - - switch_mutex_lock(globals.mutex); - if ((global_settings = switch_xml_child(cfg, "global_settings"))) { - for (param = switch_xml_child(global_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, "debug")) { - DEBUGA_GSMOPEN("globals.debug=%d\n", GSMOPEN_P_LOG, globals.debug); - globals.debug = atoi(val); - DEBUGA_GSMOPEN("globals.debug=%d\n", GSMOPEN_P_LOG, globals.debug); - } else if (!strcasecmp(var, "hold-music")) { - switch_set_string(globals.hold_music, val); - DEBUGA_GSMOPEN("globals.hold_music=%s\n", GSMOPEN_P_LOG, globals.hold_music); - } else if (!strcmp(var, "dialplan")) { - set_global_dialplan(val); - DEBUGA_GSMOPEN("globals.dialplan=%s\n", GSMOPEN_P_LOG, globals.dialplan); - } else if (!strcmp(var, "destination")) { - set_global_destination(val); - DEBUGA_GSMOPEN("globals.destination=%s\n", GSMOPEN_P_LOG, globals.destination); - } else if (!strcmp(var, "context")) { - set_global_context(val); - DEBUGA_GSMOPEN("globals.context=%s\n", GSMOPEN_P_LOG, globals.context); - - } - - } - } - - if ((interfaces = switch_xml_child(cfg, "per_interface_settings"))) { - int i = 0; - - for (myinterface = switch_xml_child(interfaces, "interface"); myinterface; myinterface = myinterface->next) { - char *id = (char *) switch_xml_attr(myinterface, "id"); - char *name = (char *) switch_xml_attr(myinterface, "name"); - const char *context = "default"; - const char *dialplan = "XML"; - const char *destination = "5000"; - const char *controldevice_name = "/dev/ttyACM0"; - const char *controldevice_audio_name = "/dev/ttyUSB2"; - char *digit_timeout = NULL; - char *max_digits = NULL; - char *hotline = NULL; - char *dial_regex = NULL; - char *hold_music = NULL; - char *fail_dial_regex = NULL; - const char *enable_callerid = "true"; - - const char *at_dial_pre_number = "ATD"; - const char *at_dial_post_number = ";"; - const char *at_dial_expect = "OK"; - const char *at_hangup = "ATH"; - const char *at_hangup_expect = "OK"; - const char *at_answer = "ATA"; - const char *at_answer_expect = "OK"; - const char *at_send_dtmf = "AT+VTS"; - const char *at_preinit_1 = ""; - const char *at_preinit_1_expect = ""; - const char *at_preinit_2 = ""; - const char *at_preinit_2_expect = ""; - const char *at_preinit_3 = ""; - const char *at_preinit_3_expect = ""; - const char *at_preinit_4 = ""; - const char *at_preinit_4_expect = ""; - const char *at_preinit_5 = ""; - const char *at_preinit_5_expect = ""; - const char *at_postinit_1 = "at+cmic=0,9"; - const char *at_postinit_1_expect = "OK"; - const char *at_postinit_2 = "AT+CKPD=\"EEE\""; - const char *at_postinit_2_expect = "OK"; - const char *at_postinit_3 = "AT+CSSN=1,0"; - const char *at_postinit_3_expect = "OK"; - const char *at_postinit_4 = "at+sidet=0"; - const char *at_postinit_4_expect = "OK"; - const char *at_postinit_5 = "at+clvl=3"; - const char *at_postinit_5_expect = "OK"; - const char *at_query_battchg = "AT+CBC"; - const char *at_query_battchg_expect = "OK"; - const char *at_query_signal = "AT+CSQ"; - const char *at_query_signal_expect = "OK"; - const char *at_call_idle = "+MCST: 1"; - const char *at_call_incoming = "RING"; - const char *at_call_active = "^CONN:1,0"; - const char *at_call_failed = "+MCST: 65"; - const char *at_call_calling = "^ORIG:1,0"; - const char *at_indicator_noservice_string = "CIEV: 2;0"; - const char *at_indicator_nosignal_string = "CIEV: 5;0"; - const char *at_indicator_lowsignal_string = "CIEV: 5;1"; - const char *at_indicator_lowbattchg_string = "CIEV: 0;1"; - const char *at_indicator_nobattchg_string = "CIEV: 0;0"; - const char *at_indicator_callactive_string = "CIEV: 3;1"; - const char *at_indicator_nocallactive_string = "CIEV: 3;0"; - const char *at_indicator_nocallsetup_string = "CIEV: 6;0"; - const char *at_indicator_callsetupincoming_string = "CIEV: 6;1"; - const char *at_indicator_callsetupoutgoing_string = "CIEV: 6;2"; - const char *at_indicator_callsetupremoteringing_string = "CIEV: 6;3"; - //const char *sms_receiving_program = "/usr/local/bin/ciapalo"; - const char *at_early_audio = "0"; - const char *at_after_preinit_pause = "500000"; - const char *at_initial_pause = "500000"; - const char *at_has_clcc = "0"; - const char *at_has_ecam = "0"; - const char *gsmopen_sound_rate = "8000"; - const char *capture_boost = "0"; - const char *playback_boost = "0"; - const char *no_sound = "0"; - const char *portaudiocindex = "1"; - const char *portaudiopindex = "1"; - const char *speexecho = "1"; - const char *speexpreprocess = "1"; - - uint32_t interface_id = 0; - int controldevice_speed = 115200; //FIXME TODO - int controldevice_audio_speed = 115200; //FIXME TODO - uint32_t controldevprotocol = PROTOCOL_AT; //FIXME TODO - uint32_t running = 1; //FIXME TODO - const char *gsmopen_serial_sync_period = "300"; //FIXME TODO - - tech_pvt = NULL; - - for (param = switch_xml_child(myinterface, "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, "id")) { - id = val; - } else if (!strcasecmp(var, "name")) { - name = val; - } else if (!strcasecmp(var, "context")) { - context = val; - } else if (!strcasecmp(var, "dialplan")) { - dialplan = val; - } else if (!strcasecmp(var, "destination")) { - destination = val; - } else if (!strcasecmp(var, "controldevice_name")) { - controldevice_name = val; - } else if (!strcasecmp(var, "controldevice_audio_name")) { - controldevice_audio_name = val; - } else if (!strcasecmp(var, "digit_timeout")) { - digit_timeout = val; - } else if (!strcasecmp(var, "max_digits")) { - max_digits = val; - } else if (!strcasecmp(var, "hotline")) { - hotline = val; - } else if (!strcasecmp(var, "dial_regex")) { - dial_regex = val; - } else if (!strcasecmp(var, SWITCH_HOLD_MUSIC_VARIABLE)) { - hold_music = val; - } else if (!strcasecmp(var, "fail_dial_regex")) { - fail_dial_regex = val; - } else if (!strcasecmp(var, "enable_callerid")) { - enable_callerid = val; - } else if (!strcasecmp(var, "at_dial_pre_number")) { - at_dial_pre_number = val; - } else if (!strcasecmp(var, "at_dial_post_number")) { - at_dial_post_number = val; - } else if (!strcasecmp(var, "at_dial_expect")) { - at_dial_expect = val; - } else if (!strcasecmp(var, "at_hangup")) { - at_hangup = val; - } else if (!strcasecmp(var, "at_hangup_expect")) { - at_hangup_expect = val; - } else if (!strcasecmp(var, "at_answer")) { - at_answer = val; - } else if (!strcasecmp(var, "at_answer_expect")) { - at_answer_expect = val; - } else if (!strcasecmp(var, "at_send_dtmf")) { - at_send_dtmf = val; - } else if (!strcasecmp(var, "at_preinit_1")) { - at_preinit_1 = val; - } else if (!strcasecmp(var, "at_preinit_1_expect")) { - at_preinit_1_expect = val; - } else if (!strcasecmp(var, "at_preinit_2")) { - at_preinit_2 = val; - } else if (!strcasecmp(var, "at_preinit_2_expect")) { - at_preinit_2_expect = val; - } else if (!strcasecmp(var, "at_preinit_3")) { - at_preinit_3 = val; - } else if (!strcasecmp(var, "at_preinit_3_expect")) { - at_preinit_3_expect = val; - } else if (!strcasecmp(var, "at_preinit_4")) { - at_preinit_4 = val; - } else if (!strcasecmp(var, "at_preinit_4_expect")) { - at_preinit_4_expect = val; - } else if (!strcasecmp(var, "at_preinit_5")) { - at_preinit_5 = val; - } else if (!strcasecmp(var, "at_preinit_5_expect")) { - at_preinit_5_expect = val; - } else if (!strcasecmp(var, "at_postinit_1")) { - at_postinit_1 = val; - } else if (!strcasecmp(var, "at_postinit_1_expect")) { - at_postinit_1_expect = val; - } else if (!strcasecmp(var, "at_postinit_2")) { - at_postinit_2 = val; - } else if (!strcasecmp(var, "at_postinit_2_expect")) { - at_postinit_2_expect = val; - } else if (!strcasecmp(var, "at_postinit_3")) { - at_postinit_3 = val; - } else if (!strcasecmp(var, "at_postinit_3_expect")) { - at_postinit_3_expect = val; - } else if (!strcasecmp(var, "at_postinit_4")) { - at_postinit_4 = val; - } else if (!strcasecmp(var, "at_postinit_4_expect")) { - at_postinit_4_expect = val; - } else if (!strcasecmp(var, "at_postinit_5")) { - at_postinit_5 = val; - } else if (!strcasecmp(var, "at_postinit_5_expect")) { - at_postinit_5_expect = val; - } else if (!strcasecmp(var, "at_query_battchg")) { - at_query_battchg = val; - } else if (!strcasecmp(var, "at_query_battchg_expect")) { - at_query_battchg_expect = val; - } else if (!strcasecmp(var, "at_query_signal")) { - at_query_signal = val; - } else if (!strcasecmp(var, "at_query_signal_expect")) { - at_query_signal_expect = val; - } else if (!strcasecmp(var, "at_call_idle")) { - at_call_idle = val; - } else if (!strcasecmp(var, "at_call_incoming")) { - at_call_incoming = val; - } else if (!strcasecmp(var, "at_call_active")) { - at_call_active = val; - } else if (!strcasecmp(var, "at_call_failed")) { - at_call_failed = val; - } else if (!strcasecmp(var, "at_call_calling")) { - at_call_calling = val; - } else if (!strcasecmp(var, "at_indicator_noservice_string")) { - at_indicator_noservice_string = val; - } else if (!strcasecmp(var, "at_indicator_nosignal_string")) { - at_indicator_nosignal_string = val; - } else if (!strcasecmp(var, "at_indicator_lowsignal_string")) { - at_indicator_lowsignal_string = val; - } else if (!strcasecmp(var, "at_indicator_lowbattchg_string")) { - at_indicator_lowbattchg_string = val; - } else if (!strcasecmp(var, "at_indicator_nobattchg_string")) { - at_indicator_nobattchg_string = val; - } else if (!strcasecmp(var, "at_indicator_callactive_string")) { - at_indicator_callactive_string = val; - } else if (!strcasecmp(var, "at_indicator_nocallactive_string")) { - at_indicator_nocallactive_string = val; - } else if (!strcasecmp(var, "at_indicator_nocallsetup_string")) { - at_indicator_nocallsetup_string = val; - } else if (!strcasecmp(var, "at_indicator_callsetupincoming_string")) { - at_indicator_callsetupincoming_string = val; - } else if (!strcasecmp(var, "at_indicator_callsetupoutgoing_string")) { - at_indicator_callsetupoutgoing_string = val; - } else if (!strcasecmp(var, "at_indicator_callsetupremoteringing_string")) { - at_indicator_callsetupremoteringing_string = val; - //} else if (!strcasecmp(var, "sms_receiving_program")) { - //sms_receiving_program = val; - } else if (!strcasecmp(var, "portaudiocindex")) { - portaudiocindex = val; - } else if (!strcasecmp(var, "portaudiopindex")) { - portaudiopindex = val; - } else if (!strcasecmp(var, "speexecho")) { - speexecho = val; - } else if (!strcasecmp(var, "speexpreprocess")) { - speexpreprocess = val; - } else if (!strcasecmp(var, "at_early_audio")) { - at_early_audio = val; - } else if (!strcasecmp(var, "at_after_preinit_pause")) { - at_after_preinit_pause = val; - } else if (!strcasecmp(var, "at_initial_pause")) { - at_initial_pause = val; - } else if (!strcasecmp(var, "at_has_clcc")) { - at_has_clcc = val; - } else if (!strcasecmp(var, "at_has_ecam")) { - at_has_ecam = val; - } else if (!strcasecmp(var, "gsmopen_sound_rate")) { - gsmopen_sound_rate = val; - } else if (!strcasecmp(var, "capture_boost")) { - capture_boost = val; - } else if (!strcasecmp(var, "playback_boost")) { - playback_boost = val; - } else if (!strcasecmp(var, "no_sound")) { - no_sound = val; - } else if (!strcasecmp(var, "gsmopen_serial_sync_period")) { - gsmopen_serial_sync_period = val; - } - - } - - /* BEGIN: Changes here */ - if (reload_type == SOFT_RELOAD) { - char the_interface[256]; - sprintf(the_interface, "#%s", name); - - if (interface_exists(the_interface) == SWITCH_STATUS_SUCCESS) { - continue; - } - } - /* END: Changes here */ - - if (!id) { - ERRORA("interface missing REQUIRED param 'id'\n", GSMOPEN_P_LOG); - continue; - } - - if (switch_is_number(id)) { - interface_id = atoi(id); - } else { - ERRORA("interface param 'id' MUST be a number, now id='%s'\n", GSMOPEN_P_LOG, id); - continue; - } - - if (!switch_is_number(at_early_audio)) { - ERRORA("interface param 'at_early_audio' MUST be a number, now at_early_audio='%s'\n", GSMOPEN_P_LOG, at_early_audio); - continue; - } - if (!switch_is_number(at_after_preinit_pause)) { - ERRORA("interface param 'at_after_preinit_pause' MUST be a number, now at_after_preinit_pause='%s'\n", GSMOPEN_P_LOG, - at_after_preinit_pause); - continue; - } - if (!switch_is_number(at_initial_pause)) { - ERRORA("interface param 'at_initial_pause' MUST be a number, now at_initial_pause='%s'\n", GSMOPEN_P_LOG, at_initial_pause); - continue; - } - if (!switch_is_number(at_has_clcc)) { - ERRORA("interface param 'at_has_clcc' MUST be a number, now at_has_clcc='%s'\n", GSMOPEN_P_LOG, at_has_clcc); - continue; - } - if (!switch_is_number(at_has_ecam)) { - ERRORA("interface param 'at_has_ecam' MUST be a number, now at_has_ecam='%s'\n", GSMOPEN_P_LOG, at_has_ecam); - continue; - } - if (!switch_is_number(gsmopen_sound_rate)) { - ERRORA("interface param 'gsmopen_sound_rate' MUST be a number, now gsmopen_sound_rate='%s'\n", GSMOPEN_P_LOG, gsmopen_sound_rate); - continue; - } - if (!switch_is_number(capture_boost)) { - ERRORA("interface param 'capture_boost' MUST be a number, now capture_boost='%s'\n", GSMOPEN_P_LOG, capture_boost); - continue; - } - if (!switch_is_number(playback_boost)) { - ERRORA("interface param 'playback_boost' MUST be a number, now playback_boost='%s'\n", GSMOPEN_P_LOG, playback_boost); - continue; - } - if (!switch_is_number(no_sound)) { - ERRORA("interface param 'no_sound' MUST be a number, now no_sound='%s'\n", GSMOPEN_P_LOG, no_sound); - continue; - } - if (!switch_is_number(gsmopen_serial_sync_period)) { - ERRORA("interface param 'gsmopen_serial_sync_period' MUST be a number, now gsmopen_serial_sync_period='%s'\n", GSMOPEN_P_LOG, - gsmopen_serial_sync_period); - continue; - } - - if (interface_id && interface_id < GSMOPEN_MAX_INTERFACES) { - private_t newconf; - switch_threadattr_t *gsmopen_api_thread_attr = NULL; - int res = 0; - - memset(&newconf, '\0', sizeof(newconf)); - globals.GSMOPEN_INTERFACES[interface_id] = newconf; - - tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - - switch_mutex_init(&globals.GSMOPEN_INTERFACES[interface_id].controldev_lock, SWITCH_MUTEX_NESTED, gsmopen_module_pool); - switch_mutex_init(&globals.GSMOPEN_INTERFACES[interface_id].controldev_audio_lock, SWITCH_MUTEX_NESTED, gsmopen_module_pool); - - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].id, id); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].name, name); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].context, context); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].dialplan, dialplan); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].destination, destination); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].controldevice_name, controldevice_name); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].controldevice_audio_name, controldevice_audio_name); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].dial_regex, dial_regex); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].hold_music, hold_music); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].fail_dial_regex, fail_dial_regex); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_dial_pre_number, at_dial_pre_number); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_dial_post_number, at_dial_post_number); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_dial_expect, at_dial_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_hangup, at_hangup); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_hangup_expect, at_hangup_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_answer, at_answer); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_answer_expect, at_answer_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_send_dtmf, at_send_dtmf); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_1, at_preinit_1); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_1_expect, at_preinit_1_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_2, at_preinit_2); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_2_expect, at_preinit_2_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_3, at_preinit_3); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_3_expect, at_preinit_3_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_4, at_preinit_4); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_4_expect, at_preinit_4_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_5, at_preinit_5); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_preinit_5_expect, at_preinit_5_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_1, at_postinit_1); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_1_expect, at_postinit_1_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_2, at_postinit_2); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_2_expect, at_postinit_2_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_3, at_postinit_3); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_3_expect, at_postinit_3_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_4, at_postinit_4); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_4_expect, at_postinit_4_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_5, at_postinit_5); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_postinit_5_expect, at_postinit_5_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_query_battchg, at_query_battchg); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_query_battchg_expect, at_query_battchg_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_query_signal, at_query_signal); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_query_signal_expect, at_query_signal_expect); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_call_idle, at_call_idle); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_call_incoming, at_call_incoming); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_call_active, at_call_active); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_call_failed, at_call_failed); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_call_calling, at_call_calling); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_noservice_string, at_indicator_noservice_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_nosignal_string, at_indicator_nosignal_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_lowsignal_string, at_indicator_lowsignal_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_lowbattchg_string, at_indicator_lowbattchg_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_nobattchg_string, at_indicator_nobattchg_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_callactive_string, at_indicator_callactive_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_nocallactive_string, at_indicator_nocallactive_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_nocallsetup_string, at_indicator_nocallsetup_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_callsetupincoming_string, at_indicator_callsetupincoming_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_callsetupoutgoing_string, at_indicator_callsetupoutgoing_string); - switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].at_indicator_callsetupremoteringing_string, - at_indicator_callsetupremoteringing_string); - //switch_set_string(globals.GSMOPEN_INTERFACES[interface_id].sms_receiving_program, sms_receiving_program); - globals.GSMOPEN_INTERFACES[interface_id].at_early_audio = atoi(at_early_audio); - globals.GSMOPEN_INTERFACES[interface_id].at_after_preinit_pause = atoi(at_after_preinit_pause); - globals.GSMOPEN_INTERFACES[interface_id].at_initial_pause = atoi(at_initial_pause); - globals.GSMOPEN_INTERFACES[interface_id].at_has_clcc = atoi(at_has_clcc); - globals.GSMOPEN_INTERFACES[interface_id].at_has_ecam = atoi(at_has_ecam); - globals.GSMOPEN_INTERFACES[interface_id].capture_boost = atoi(capture_boost); - globals.GSMOPEN_INTERFACES[interface_id].playback_boost = atoi(playback_boost); - globals.GSMOPEN_INTERFACES[interface_id].no_sound = atoi(no_sound); - globals.GSMOPEN_INTERFACES[interface_id].gsmopen_serial_sync_period = atoi(gsmopen_serial_sync_period); - - globals.GSMOPEN_INTERFACES[interface_id].controldevice_speed = controldevice_speed; //FIXME - globals.GSMOPEN_INTERFACES[interface_id].controldevprotocol = controldevprotocol; //FIXME - globals.GSMOPEN_INTERFACES[interface_id].running = running; //FIXME - - WARNINGA("STARTING interface_id=%d\n", GSMOPEN_P_LOG, interface_id); - DEBUGA_GSMOPEN("id=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].id); - DEBUGA_GSMOPEN("name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].name); - DEBUGA_GSMOPEN("hold-music=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].hold_music); - DEBUGA_GSMOPEN("context=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].context); - DEBUGA_GSMOPEN("dialplan=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].dialplan); - DEBUGA_GSMOPEN("destination=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].destination); - DEBUGA_GSMOPEN("controldevice_name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].controldevice_name); - DEBUGA_GSMOPEN("controldevice_audio_name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[interface_id].controldevice_audio_name); - DEBUGA_GSMOPEN("gsmopen_serial_sync_period=%d\n", GSMOPEN_P_LOG, - (int) globals.GSMOPEN_INTERFACES[interface_id].gsmopen_serial_sync_period); - - /* init the serial port */ - if (globals.GSMOPEN_INTERFACES[interface_id].controldevprotocol != PROTOCOL_NO_SERIAL) { - globals.GSMOPEN_INTERFACES[interface_id].controldevfd = - gsmopen_serial_init(&globals.GSMOPEN_INTERFACES[interface_id], globals.GSMOPEN_INTERFACES[interface_id].controldevice_speed); - if (globals.GSMOPEN_INTERFACES[interface_id].controldevfd == -1) { - ERRORA("gsmopen_serial_init failed\n", GSMOPEN_P_LOG); - ERRORA("STARTING interface_id=%d FAILED\n", GSMOPEN_P_LOG, interface_id); - //return SWITCH_STATUS_FALSE; - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - alarm_event(&globals.GSMOPEN_INTERFACES[interface_id], ALARM_FAILED_INTERFACE, "gsmopen_serial_init failed"); - globals.GSMOPEN_INTERFACES[interface_id].active = 0; - globals.GSMOPEN_INTERFACES[interface_id].name[0] = '\0'; - continue; - } - } - - /* config the phone/modem on the serial port */ - if (globals.GSMOPEN_INTERFACES[interface_id].controldevprotocol != PROTOCOL_NO_SERIAL) { - res = gsmopen_serial_config(&globals.GSMOPEN_INTERFACES[interface_id]); - if (res) { - int count = 0; - ERRORA("gsmopen_serial_config failed, let's try again\n", GSMOPEN_P_LOG); - while (res && count < 5) { - switch_sleep(100000); //0.1 seconds - res = gsmopen_serial_config(&globals.GSMOPEN_INTERFACES[interface_id]); - count++; - if (res) { - ERRORA("%d: gsmopen_serial_config failed, let's try again\n", GSMOPEN_P_LOG, count); - } - } - if (res) { - ERRORA("STARTING interface_id=%d FAILED\n", GSMOPEN_P_LOG, interface_id); - //return SWITCH_STATUS_FALSE; - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - alarm_event(&globals.GSMOPEN_INTERFACES[interface_id], ALARM_FAILED_INTERFACE, "gsmopen_serial_config failed"); - globals.GSMOPEN_INTERFACES[interface_id].active = 0; - globals.GSMOPEN_INTERFACES[interface_id].name[0] = '\0'; - continue; - } - } - } - - if (globals.GSMOPEN_INTERFACES[interface_id].no_sound == 0) { - if (serial_audio_init(&globals.GSMOPEN_INTERFACES[interface_id])) { - ERRORA("serial_audio_init failed\n", GSMOPEN_P_LOG); - ERRORA("STARTING interface_id=%d FAILED\n", GSMOPEN_P_LOG, interface_id); - //return SWITCH_STATUS_FALSE; - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - alarm_event(&globals.GSMOPEN_INTERFACES[interface_id], ALARM_FAILED_INTERFACE, "serial_audio_init failed"); - globals.GSMOPEN_INTERFACES[interface_id].active = 0; - globals.GSMOPEN_INTERFACES[interface_id].name[0] = '\0'; - continue; - - } - - if (serial_audio_shutdown(&globals.GSMOPEN_INTERFACES[interface_id])) { - ERRORA("serial_audio_shutdown failed\n", GSMOPEN_P_LOG); - ERRORA("STARTING interface_id=%d FAILED\n", GSMOPEN_P_LOG, interface_id); - //return SWITCH_STATUS_FALSE; - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - alarm_event(&globals.GSMOPEN_INTERFACES[interface_id], ALARM_FAILED_INTERFACE, "serial_audio_shutdown failed"); - globals.GSMOPEN_INTERFACES[interface_id].active = 0; - globals.GSMOPEN_INTERFACES[interface_id].name[0] = '\0'; - continue; - - } - - } - - globals.GSMOPEN_INTERFACES[interface_id].active = 1; - - //gsmopen_store_boost((char *)"5", &globals.GSMOPEN_INTERFACES[interface_id].capture_boost); //FIXME - //gsmopen_store_boost((char *)"10", &globals.GSMOPEN_INTERFACES[interface_id].playback_boost); //FIXME - gsmopen_store_boost((char *) capture_boost, &globals.GSMOPEN_INTERFACES[interface_id].capture_boost); //FIXME - gsmopen_store_boost((char *) playback_boost, &globals.GSMOPEN_INTERFACES[interface_id].playback_boost); //FIXME - - switch_sleep(100000); - switch_threadattr_create(&gsmopen_api_thread_attr, gsmopen_module_pool); - switch_threadattr_stacksize_set(gsmopen_api_thread_attr, SWITCH_THREAD_STACKSIZE); - switch_thread_create(&globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread, gsmopen_api_thread_attr, gsmopen_do_gsmopenapi_thread, - &globals.GSMOPEN_INTERFACES[interface_id], gsmopen_module_pool); - - switch_sleep(100000); - WARNINGA("STARTED interface_id=%d\n", GSMOPEN_P_LOG, interface_id); - - } else { - ERRORA("interface id %d is higher than GSMOPEN_MAX_INTERFACES (%d)\n", GSMOPEN_P_LOG, interface_id, GSMOPEN_MAX_INTERFACES); - alarm_event(&globals.GSMOPEN_INTERFACES[interface_id], ALARM_FAILED_INTERFACE, "interface id is higher than GSMOPEN_MAX_INTERFACES"); - continue; - } - - } - - for (i = 0; i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name)) { - /* How many real intterfaces */ - globals.real_interfaces = i + 1; - - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - - DEBUGA_GSMOPEN("id=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].id); - DEBUGA_GSMOPEN("name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].name); - DEBUGA_GSMOPEN("context=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].context); - DEBUGA_GSMOPEN("hold-music=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].hold_music); - DEBUGA_GSMOPEN("dialplan=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].dialplan); - DEBUGA_GSMOPEN("destination=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].destination); - DEBUGA_GSMOPEN("controldevice_name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].controldevice_name); - DEBUGA_GSMOPEN("gsmopen_serial_sync_period=%d\n", GSMOPEN_P_LOG, (int) globals.GSMOPEN_INTERFACES[i].gsmopen_serial_sync_period); - DEBUGA_GSMOPEN("controldevice_audio_name=%s\n", GSMOPEN_P_LOG, globals.GSMOPEN_INTERFACES[i].controldevice_audio_name); - } - } - } - - switch_mutex_unlock(globals.mutex); - switch_xml_free(xml); - - return SWITCH_STATUS_SUCCESS; -} - -//static switch_status_t chat_send(const char *proto, const char *from, const char *to, const char *subject, const char *body, const char *type, const char *hint) -static switch_status_t chat_send(switch_event_t *message_event) -{ - char *user, *host, *f_user = NULL, *f_host = NULL, *f_resource = NULL; - private_t *tech_pvt = NULL; - int i = 0, found = 0; - - const char *proto; - const char *from; - const char *to; - const char *subject; - const char *body; - //const char *type; - const char *hint; - - proto = switch_event_get_header(message_event, "proto"); - from = switch_event_get_header(message_event, "from"); - to = switch_event_get_header(message_event, "to"); - subject = switch_event_get_header(message_event, "subject"); - body = switch_event_get_body(message_event); - //type = switch_event_get_header(message_event, "type"); - hint = switch_event_get_header(message_event, "hint"); - - switch_assert(proto != NULL); - - DEBUGA_GSMOPEN("chat_send(proto=%s, from=%s, to=%s, subject=%s, body=%s, hint=%s)\n", GSMOPEN_P_LOG, proto, from, to, subject, body, - hint ? hint : "NULL"); - - if (!to || !strlen(to)) { - ERRORA("Missing To: header.\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_SUCCESS; - } - - if ((!from && !hint) || (!strlen(from) && !strlen(hint))) { - ERRORA("Missing From: AND Hint: headers.\n", GSMOPEN_P_LOG); - return SWITCH_STATUS_SUCCESS; - } - - if (from && (f_user = strdup(from))) { - if ((f_host = strchr(f_user, '@'))) { - *f_host++ = '\0'; - if ((f_resource = strchr(f_host, '/'))) { - *f_resource++ = '\0'; - } - } - } - - if (hint == NULL || !strlen(hint)) { //FIXME FIXME FIXME - hint = from; - } - if (to && (user = strdup(to))) { - if ((host = strchr(user, '@'))) { - *host++ = '\0'; - } - - DEBUGA_GSMOPEN("chat_send(proto=%s, from=%s, to=%s, subject=%s, body=%s, hint=%s)\n", GSMOPEN_P_LOG, proto, from, to, subject, body, - hint ? hint : "NULL"); - if (hint && strlen(hint)) { - //in hint we receive the interface name to use - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, hint, strlen(hint)) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - DEBUGA_GSMOPEN("Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", GSMOPEN_P_LOG, i, - globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - } - } /* FIXME add a tech_pvt member for the SIM telephone number //else { - //we have no a predefined interface name to use (hint is NULL), so let's choose an interface from the username (from) - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].skype_user, from, strlen(from)) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - DEBUGA_GSMOPEN("Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", GSMOPEN_P_LOG, i, globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - } - } - */ - if (!found) { - ERRORA("ERROR: A GSMopen interface with name='%s' or one with SIM_number='%s' was not found\n", GSMOPEN_P_LOG, hint ? hint : "NULL", - from ? from : "NULL"); - goto end; - } else { - gsmopen_sendsms(tech_pvt, (char *) to, (char *) body); - } - } - end: - switch_safe_free(user); - switch_safe_free(f_user); - return SWITCH_STATUS_SUCCESS; -} - -static switch_status_t compat_chat_send(const char *proto, const char *from, const char *to, - const char *subject, const char *body, const char *type, const char *hint) -{ - switch_event_t *message_event; - switch_status_t status; - - if (switch_event_create(&message_event, SWITCH_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "proto", proto); - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "from", from); - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "to", to); - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "subject", subject); - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "type", type); - switch_event_add_header_string(message_event, SWITCH_STACK_BOTTOM, "hint", hint); - - if (body) { - switch_event_add_body(message_event, "%s", body); - } - } else { - abort(); - } - - status = chat_send(message_event); - switch_event_destroy(&message_event); - - return status; - -} - -SWITCH_MODULE_LOAD_FUNCTION(mod_gsmopen_load) -{ - switch_api_interface_t *commands_api_interface; - switch_chat_interface_t *chat_interface; - - gsmopen_module_pool = pool; - memset(&globals, '\0', sizeof(globals)); - - running = 1; - - if (load_config(FULL_RELOAD) != SWITCH_STATUS_SUCCESS) { - running = 0; - return SWITCH_STATUS_FALSE; - } - - if (switch_event_reserve_subclass(MY_EVENT_INCOMING_SMS) != SWITCH_STATUS_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't register subclass!\n"); - return SWITCH_STATUS_GENERR; - } - - *module_interface = switch_loadable_module_create_module_interface(pool, modname); - gsmopen_endpoint_interface = (switch_endpoint_interface_t *) switch_loadable_module_create_interface(*module_interface, SWITCH_ENDPOINT_INTERFACE); - gsmopen_endpoint_interface->interface_name = "gsmopen"; - gsmopen_endpoint_interface->io_routines = &gsmopen_io_routines; - gsmopen_endpoint_interface->state_handler = &gsmopen_state_handlers; - - if (running) { - -#if 1 - SWITCH_ADD_API(commands_api_interface, "gsm", "gsm console AT_command", gsm_function, GSM_SYNTAX); - SWITCH_ADD_API(commands_api_interface, "gsmopen", "gsmopen interface AT_command", gsmopen_function, GSMOPEN_SYNTAX); -#endif //0 - SWITCH_ADD_API(commands_api_interface, "gsmopen_boost_audio", "gsmopen_boost_audio interface AT_command", gsmopen_boost_audio_function, - GSMOPEN_BOOST_AUDIO_SYNTAX); - SWITCH_ADD_API(commands_api_interface, "gsmopen_dump", "gsmopen_dump interface", gsmopen_dump_function, GSMOPEN_DUMP_SYNTAX); - SWITCH_ADD_API(commands_api_interface, "gsmopen_sendsms", "gsmopen_sendsms interface destination_number SMS_text", sendsms_function, - SENDSMS_SYNTAX); - SWITCH_ADD_CHAT(chat_interface, GSMOPEN_CHAT_PROTO, chat_send); - - /* indicate that the module should continue to be loaded */ - return SWITCH_STATUS_SUCCESS; - } else - return SWITCH_STATUS_FALSE; -} - -SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_gsmopen_shutdown) -{ - int x; - private_t *tech_pvt = NULL; - switch_status_t status; - unsigned int howmany = 8; - int interface_id; - int fd; - - running = 0; - - for (interface_id = 0; interface_id < GSMOPEN_MAX_INTERFACES; interface_id++) { - tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - - if (strlen(globals.GSMOPEN_INTERFACES[interface_id].name)) { - WARNINGA("SHUTDOWN interface_id=%d\n", GSMOPEN_P_LOG, interface_id); - globals.GSMOPEN_INTERFACES[interface_id].running = 0; - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread) { -#ifdef WIN32 - switch_file_write(tech_pvt->GSMopenHandles.fdesc[1], "sciutati", &howmany); // let's the controldev_thread die -#else /* WIN32 */ - howmany = write(tech_pvt->GSMopenHandles.fdesc[1], "sciutati", howmany); -#endif /* WIN32 */ - } - x = 10; - while (x) { //FIXME 0.5 seconds? - x--; - switch_yield(50000); - } - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread) { - switch_thread_join(&status, globals.GSMOPEN_INTERFACES[interface_id].gsmopen_signaling_thread); - } - if (globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread) { - switch_thread_join(&status, globals.GSMOPEN_INTERFACES[interface_id].gsmopen_api_thread); - } - - x = 10; - while (x) { //FIXME 0.5 seconds? - x--; - switch_yield(50000); - } - fd = tech_pvt->controldevfd; - //DEBUGA_GSMOPEN("SHUTDOWN tech_pvt->controldevfd=%d\n", GSMOPEN_P_LOG, tech_pvt->controldevfd); - if (fd) { - //close(fd); - //tech_pvt->controldevfd = -1; - DEBUGA_GSMOPEN("SHUTDOWN tech_pvt->controldevfd=%d\n", GSMOPEN_P_LOG, tech_pvt->controldevfd); - } -#ifndef WIN32 - shutdown(tech_pvt->audiogsmopenpipe[0], 2); - close(tech_pvt->audiogsmopenpipe[0]); - shutdown(tech_pvt->audiogsmopenpipe[1], 2); - close(tech_pvt->audiogsmopenpipe[1]); - shutdown(tech_pvt->audiopipe[0], 2); - close(tech_pvt->audiopipe[0]); - shutdown(tech_pvt->audiopipe[1], 2); - close(tech_pvt->audiopipe[1]); - shutdown(tech_pvt->GSMopenHandles.fdesc[0], 2); - close(tech_pvt->GSMopenHandles.fdesc[0]); - shutdown(tech_pvt->GSMopenHandles.fdesc[1], 2); - close(tech_pvt->GSMopenHandles.fdesc[1]); -#endif /* WIN32 */ - } - - } - - switch_event_free_subclass(MY_EVENT_INCOMING_SMS); - - switch_safe_free(globals.dialplan); - switch_safe_free(globals.context); - switch_safe_free(globals.destination); - switch_safe_free(globals.codec_string); - switch_safe_free(globals.codec_rates_string); - - return SWITCH_STATUS_SUCCESS; -} - -void *SWITCH_THREAD_FUNC gsmopen_do_gsmopenapi_thread(switch_thread_t *thread, void *obj) -{ - return gsmopen_do_gsmopenapi_thread_func(obj); -} - -int dtmf_received(private_t *tech_pvt, char *value) -{ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - - session = switch_core_session_locate(tech_pvt->session_uuid_str); - channel = switch_core_session_get_channel(session); - - if (channel) { - - if (!switch_channel_test_flag(channel, CF_BRIDGED)) { - - switch_dtmf_t dtmf = { (char) value[0], switch_core_default_dtmf_duration(0) }; - DEBUGA_GSMOPEN("received DTMF %c on channel %s\n", GSMOPEN_P_LOG, dtmf.digit, switch_channel_get_name(channel)); - switch_mutex_lock(tech_pvt->flag_mutex); - //FIXME: why sometimes DTMFs from here do not seems to be get by FS? - switch_channel_queue_dtmf(channel, &dtmf); - switch_set_flag(tech_pvt, TFLAG_DTMF); - switch_mutex_unlock(tech_pvt->flag_mutex); - } else { - DEBUGA_GSMOPEN - ("received a DTMF on channel %s, but we're BRIDGED, so let's NOT relay it out of band\n", GSMOPEN_P_LOG, switch_channel_get_name(channel)); - } - } else { - WARNINGA("received %c DTMF, but no channel?\n", GSMOPEN_P_LOG, value[0]); - } - switch_core_session_rwunlock(session); - - return 0; -} - -int new_inbound_channel(private_t *tech_pvt) -{ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - - switch_assert(tech_pvt != NULL); - tech_pvt->ib_calls++; - if ((session = switch_core_session_request(gsmopen_endpoint_interface, SWITCH_CALL_DIRECTION_INBOUND, SOF_NONE, NULL)) != 0) { - DEBUGA_GSMOPEN("2 SESSION_REQUEST %s\n", GSMOPEN_P_LOG, switch_core_session_get_uuid(session)); - switch_core_session_add_stream(session, NULL); - channel = switch_core_session_get_channel(session); - if (!channel) { - ERRORA("Doh! no channel?\n", GSMOPEN_P_LOG); - switch_core_session_destroy(&session); - return 0; - } - if (gsmopen_tech_init(tech_pvt, session) != SWITCH_STATUS_SUCCESS) { - ERRORA("Doh! no tech_init?\n", GSMOPEN_P_LOG); - switch_core_session_destroy(&session); - return 0; - } - - if ((tech_pvt->caller_profile = - switch_caller_profile_new(switch_core_session_get_pool(session), "gsmopen", - tech_pvt->dialplan, tech_pvt->callid_name, - tech_pvt->callid_number, NULL, NULL, NULL, NULL, "mod_gsmopen", tech_pvt->context, tech_pvt->destination)) != 0) { - char name[128]; - //switch_snprintf(name, sizeof(name), "gsmopen/%s/%s", tech_pvt->name, tech_pvt->caller_profile->destination_number); - switch_snprintf(name, sizeof(name), "gsmopen/%s", tech_pvt->name); - switch_channel_set_name(channel, name); - switch_channel_set_caller_profile(channel, tech_pvt->caller_profile); - } - switch_channel_set_state(channel, CS_INIT); - if (switch_core_session_thread_launch(session) != SWITCH_STATUS_SUCCESS) { - ERRORA("Error spawning thread\n", GSMOPEN_P_LOG); - switch_core_session_destroy(&session); - return 0; - } - } - if (channel) { - //switch_channel_mark_answered(channel); - } - - DEBUGA_GSMOPEN("new_inbound_channel\n", GSMOPEN_P_LOG); - - return 0; -} - -int remote_party_is_ringing(private_t *tech_pvt) -{ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - - if (!zstr(tech_pvt->session_uuid_str)) { - session = switch_core_session_locate(tech_pvt->session_uuid_str); - } else { - ERRORA("No session???\n", GSMOPEN_P_LOG); - goto done; - } - if (session) { - channel = switch_core_session_get_channel(session); - } else { - ERRORA("No session???\n", GSMOPEN_P_LOG); - goto done; - } - if (channel) { - switch_channel_mark_ring_ready(channel); - DEBUGA_GSMOPEN("gsmopen_call: REMOTE PARTY RINGING\n", GSMOPEN_P_LOG); - } else { - ERRORA("No channel???\n", GSMOPEN_P_LOG); - } - - switch_core_session_rwunlock(session); - - done: - return 0; -} - -int remote_party_is_early_media(private_t *tech_pvt) -{ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - - if (!zstr(tech_pvt->session_uuid_str)) { - session = switch_core_session_locate(tech_pvt->session_uuid_str); - } else { - ERRORA("No session???\n\n\n", GSMOPEN_P_LOG); - //TODO: kill the bastard - goto done; - } - if (session) { - channel = switch_core_session_get_channel(session); - switch_core_session_add_stream(session, NULL); - } else { - ERRORA("No session???\n", GSMOPEN_P_LOG); - //TODO: kill the bastard - goto done; - } - if (channel) { - switch_channel_mark_pre_answered(channel); - DEBUGA_GSMOPEN("gsmopen_call: REMOTE PARTY EARLY MEDIA\n", GSMOPEN_P_LOG); - } else { - ERRORA("No channel???\n", GSMOPEN_P_LOG); - //TODO: kill the bastard - } - - switch_core_session_rwunlock(session); - - done: - return 0; -} - -int outbound_channel_answered(private_t *tech_pvt) -{ - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - - if (!zstr(tech_pvt->session_uuid_str)) { - session = switch_core_session_locate(tech_pvt->session_uuid_str); - } else { - ERRORA("No session???\n", GSMOPEN_P_LOG); - goto done; - } - if (session) { - channel = switch_core_session_get_channel(session); - } else { - ERRORA("No channel???\n", GSMOPEN_P_LOG); - goto done; - } - if (channel) { - switch_channel_mark_answered(channel); - tech_pvt->phone_callflow = GSMOPEN_STATE_UP; - tech_pvt->interface_state = GSMOPEN_STATE_UP; - //DEBUGA_GSMOPEN("gsmopen_call: %s, answered\n", GSMOPEN_P_LOG, id); - } else { - ERRORA("No channel???\n", GSMOPEN_P_LOG); - } - - switch_core_session_rwunlock(session); - - done: - DEBUGA_GSMOPEN("outbound_channel_answered!\n", GSMOPEN_P_LOG); - - return 0; -} - -private_t *find_available_gsmopen_interface_rr(private_t *tech_pvt_calling) -{ - private_t *tech_pvt = NULL; - int i; - //int num_interfaces = GSMOPEN_MAX_INTERFACES; - //int num_interfaces = globals.real_interfaces; - - switch_mutex_lock(globals.mutex); - - /* Fact is the real interface start from 1 */ - //XXX no, is just a convention, but you can have it start from 0. I do not, for aestetic reasons :-) - //if (globals.next_interface == 0) globals.next_interface = 1; - - for (i = 0; i < GSMOPEN_MAX_INTERFACES; i++) { - int interface_id; - - interface_id = globals.next_interface; - //interface_id = interface_id < GSMOPEN_MAX_INTERFACES ? interface_id : interface_id - GSMOPEN_MAX_INTERFACES + 1; - globals.next_interface = interface_id + 1 < GSMOPEN_MAX_INTERFACES ? interface_id + 1 : 0; - - if (strlen(globals.GSMOPEN_INTERFACES[interface_id].name)) { - int gsmopen_state = 0; - - tech_pvt = &globals.GSMOPEN_INTERFACES[interface_id]; - gsmopen_state = tech_pvt->interface_state; - DEBUGA_GSMOPEN("gsmopen interface: %d, name: %s, state: %d\n", GSMOPEN_P_LOG, interface_id, globals.GSMOPEN_INTERFACES[interface_id].name, - gsmopen_state); - if ((tech_pvt_calling ? strcmp(tech_pvt->gsmopen_user, tech_pvt_calling->gsmopen_user) : 1) - && (GSMOPEN_STATE_DOWN == gsmopen_state || 0 == gsmopen_state) && (tech_pvt->phone_callflow == CALLFLOW_STATUS_FINISHED - || 0 == tech_pvt->phone_callflow)) { - DEBUGA_GSMOPEN("returning as available gsmopen interface name: %s, state: %d callflow: %d\n", GSMOPEN_P_LOG, tech_pvt->name, gsmopen_state, - tech_pvt->phone_callflow); - /*set to Dialing state to avoid other thread fint it, don't know if it is safe */ - //XXX no, it's not safe - if (tech_pvt_calling == NULL) { - tech_pvt->interface_state = GSMOPEN_STATE_SELECTED; - } - - switch_mutex_unlock(globals.mutex); - return tech_pvt; - } - } // else { - //DEBUGA_GSMOPEN("GSM interface: %d blank!! A hole here means we cannot hunt the last interface.\n", GSMOPEN_P_LOG, interface_id); - //} - } - - switch_mutex_unlock(globals.mutex); - return NULL; -} - -#if 1 -SWITCH_STANDARD_API(gsm_function) -{ - char *mycmd = NULL, *argv[10] = { 0 }; - int argc = 0; - - if (globals.gsm_console) - stream->write_function(stream, "gsm console is: |||%s|||\n", globals.gsm_console->name); - else - stream->write_function(stream, "gsm console is NOT yet assigned\n"); - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (!argc || !argv[0]) { - stream->write_function(stream, "%s", GSM_SYNTAX); - goto end; - } - - if (!strcasecmp(argv[0], "list")) { - int i; - char next_flag_char = ' '; - - stream->write_function(stream, "F ID\t Name \tIB (F/T) OB (F/T)\tState\tCallFlw\t\tUUID\n"); - stream->write_function(stream, "= ====\t ======== \t======= =======\t======\t============\t======\n"); - - for (i = 0; i < GSMOPEN_MAX_INTERFACES; i++) { - next_flag_char = i == globals.next_interface ? '*' : ' '; - - if (strlen(globals.GSMOPEN_INTERFACES[i].name)) { - stream->write_function(stream, - "%c %d\t[%s]\t%3ld/%ld\t%6ld/%ld\t%s\t%s\t%s\n", - next_flag_char, - i, globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].ib_failed_calls, - globals.GSMOPEN_INTERFACES[i].ib_calls, - globals.GSMOPEN_INTERFACES[i].ob_failed_calls, - globals.GSMOPEN_INTERFACES[i].ob_calls, - interface_status[globals.GSMOPEN_INTERFACES[i].interface_state], - phone_callflow[globals.GSMOPEN_INTERFACES[i].phone_callflow], globals.GSMOPEN_INTERFACES[i].session_uuid_str); - } else if (argc > 1 && !strcasecmp(argv[1], "full")) { - stream->write_function(stream, "%c\t%d\n", next_flag_char, i); - } - - } - stream->write_function(stream, "\nTotal: %d\n", globals.real_interfaces - 1); - - } else if (!strcasecmp(argv[0], "console")) { - int i; - int found = 0; - - if (argc == 2) { - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[1], strlen(argv[1])) == 0)) { - globals.gsm_console = &globals.GSMOPEN_INTERFACES[i]; - stream->write_function(stream, "gsm console is now: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", i, - globals.GSMOPEN_INTERFACES[i].name); - stream->write_function(stream, "gsm console is: |||%s|||\n", globals.gsm_console->name); - found = 1; - break; - } - - } - if (!found) - stream->write_function(stream, "ERROR: A GSMopen interface with name='%s' was not found\n", argv[1]); - } else { - - stream->write_function(stream, "-ERR Usage: gsm console interface_name\n"); - goto end; - } - - } else if (!strcasecmp(argv[0], "ciapalino")) { - -/* BEGIN: Changes heres */ - } else if (!strcasecmp(argv[0], "reload")) { - if (load_config(SOFT_RELOAD) != SWITCH_STATUS_SUCCESS) { - stream->write_function(stream, "gsm reload failed\n"); - } else { - stream->write_function(stream, "gsm reload success\n"); - } - } else if (!strcasecmp(argv[0], "remove")) { - if (argc == 2) { - if (remove_interface(argv[1]) == SWITCH_STATUS_SUCCESS) { - if (interface_exists(argv[1]) == SWITCH_STATUS_SUCCESS) { - stream->write_function(stream, "gsm remove '%s' failed\n", argv[1]); - } else { - stream->write_function(stream, "gsm remove '%s' success\n", argv[1]); - } - } - } else { - stream->write_function(stream, "-ERR Usage: gsm remove interface_name\n"); - goto end; - } -/* END: Changes heres */ - - } else { - if (globals.gsm_console) - gsmopen_serial_write_AT_noack(globals.gsm_console, (char *) cmd); - else - stream->write_function(stream, "gsm console is NOT yet assigned\n"); - } - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} - -SWITCH_STANDARD_API(gsmopen_function) -{ - char *mycmd = NULL, *argv[10] = { 0 }; - int argc = 0; - private_t *tech_pvt = NULL; - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (!argc) { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_SYNTAX); - goto end; - } - - if (argc < 2) { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_SYNTAX); - goto end; - } - - if (argv[0]) { - int i; - int found = 0; - - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[0], strlen(argv[0])) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - stream->write_function(stream, "Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", i, globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - - } - if (!found) { - stream->write_function(stream, "ERROR: A GSMopen interface with name='%s' was not found\n", argv[0]); - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; - } else { - gsmopen_serial_write_AT_noack(tech_pvt, (char *) &cmd[strlen(argv[0]) + 1]); - } - } else { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_SYNTAX); - } - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} -#endif //0 -SWITCH_STANDARD_API(gsmopen_dump_function) -{ - char *mycmd = NULL, *argv[10] = { 0 }; - int argc = 0; - private_t *tech_pvt = NULL; - char value[512]; - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (!argc) { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_DUMP_SYNTAX); - goto end; - } - if (argc == 1) { - int i; - int found = 0; - - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[0], strlen(argv[0])) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - //stream->write_function(stream, "Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", i, globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - - } - if (!found && (strcmp("list", argv[0]) == 0)) { - int i; - stream->write_function(stream, "gsmopen_dump LIST\n\n"); - for (i = 0; i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name)) { - stream->write_function(stream, "dumping interface '%s'\n\n", globals.GSMOPEN_INTERFACES[i].name); - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - - stream->write_function(stream, "interface_name = %s\n", tech_pvt->name); - stream->write_function(stream, "interface_id = %s\n", tech_pvt->id); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->active); - stream->write_function(stream, "active = %s\n", value); - if (!tech_pvt->network_creg_not_supported) { - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->not_registered); - stream->write_function(stream, "not_registered = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->home_network_registered); - stream->write_function(stream, "home_network_registered = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->roaming_registered); - stream->write_function(stream, "roaming_registered = %s\n", value); - } else { - stream->write_function(stream, "not_registered = %s\n", "N/A"); - stream->write_function(stream, "home_network_registered = %s\n", "N/A"); - stream->write_function(stream, "roaming_registered = %s\n", "N/A"); - } - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->got_signal); - stream->write_function(stream, "got_signal = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->running); - stream->write_function(stream, "running = %s\n", value); - stream->write_function(stream, "imei = %s\n", tech_pvt->imei); - stream->write_function(stream, "imsi = %s\n", tech_pvt->imsi); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->controldev_dead); - stream->write_function(stream, "controldev_dead = %s\n", value); - stream->write_function(stream, "controldevice_name = %s\n", tech_pvt->controldevice_name); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->no_sound); - stream->write_function(stream, "no_sound = %s\n", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->playback_boost); - stream->write_function(stream, "playback_boost = %s\n", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->capture_boost); - stream->write_function(stream, "capture_boost = %s\n", value); - stream->write_function(stream, "dialplan = %s\n", tech_pvt->dialplan); - stream->write_function(stream, "context = %s\n", tech_pvt->context); - stream->write_function(stream, "destination = %s\n", tech_pvt->destination); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_calls); - stream->write_function(stream, "ib_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_calls); - stream->write_function(stream, "ob_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_failed_calls); - stream->write_function(stream, "ib_failed_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_failed_calls); - stream->write_function(stream, "ob_failed_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->interface_state); - stream->write_function(stream, "interface_state = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->phone_callflow); - stream->write_function(stream, "phone_callflow = %s\n", value); - stream->write_function(stream, "session_uuid_str = %s\n", tech_pvt->session_uuid_str); - stream->write_function(stream, "\n"); - - dump_event(tech_pvt); - } - - } - - } else if (found) { - stream->write_function(stream, "dumping interface '%s'\n\n", argv[0]); - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - - stream->write_function(stream, "interface_name = %s\n", tech_pvt->name); - stream->write_function(stream, "interface_id = %s\n", tech_pvt->id); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->active); - stream->write_function(stream, "active = %s\n", value); - if (!tech_pvt->network_creg_not_supported) { - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->not_registered); - stream->write_function(stream, "not_registered = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->home_network_registered); - stream->write_function(stream, "home_network_registered = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->roaming_registered); - stream->write_function(stream, "roaming_registered = %s\n", value); - } else { - stream->write_function(stream, "not_registered = %s\n", "N/A"); - stream->write_function(stream, "home_network_registered = %s\n", "N/A"); - stream->write_function(stream, "roaming_registered = %s\n", "N/A"); - } - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->got_signal); - stream->write_function(stream, "got_signal = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->running); - stream->write_function(stream, "running = %s\n", value); - stream->write_function(stream, "imei = %s\n", tech_pvt->imei); - stream->write_function(stream, "imsi = %s\n", tech_pvt->imsi); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->controldev_dead); - stream->write_function(stream, "controldev_dead = %s\n", value); - stream->write_function(stream, "controldevice_name = %s\n", tech_pvt->controldevice_name); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->no_sound); - stream->write_function(stream, "no_sound = %s\n", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->playback_boost); - stream->write_function(stream, "playback_boost = %s\n", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->capture_boost); - stream->write_function(stream, "capture_boost = %s\n", value); - stream->write_function(stream, "dialplan = %s\n", tech_pvt->dialplan); - stream->write_function(stream, "context = %s\n", tech_pvt->context); - stream->write_function(stream, "destination = %s\n", tech_pvt->destination); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_calls); - stream->write_function(stream, "ib_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_calls); - stream->write_function(stream, "ob_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_failed_calls); - stream->write_function(stream, "ib_failed_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_failed_calls); - stream->write_function(stream, "ob_failed_calls = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->interface_state); - stream->write_function(stream, "interface_state = %s\n", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->phone_callflow); - stream->write_function(stream, "phone_callflow = %s\n", value); - stream->write_function(stream, "session_uuid_str = %s\n", tech_pvt->session_uuid_str); - stream->write_function(stream, "\n"); - - dump_event(tech_pvt); - } else { - stream->write_function(stream, "interface '%s' was not found\n", argv[0]); - } - } else { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_DUMP_SYNTAX); - } - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} - -SWITCH_STANDARD_API(gsmopen_boost_audio_function) -{ - char *mycmd = NULL, *argv[10] = { 0 }; - int argc = 0; - private_t *tech_pvt = NULL; - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (argc == 1 || argc == 3) { - int i; - int found = 0; - - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[0], strlen(argv[0])) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - stream->write_function(stream, "Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", i, globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - - } - if (!found) { - stream->write_function(stream, "ERROR: A GSMopen interface with name='%s' was not found\n", argv[0]); - - } else { - if (argc == 1) { - stream->write_function(stream, "[%s] capture boost is %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].capture_boost); - stream->write_function(stream, "[%s] playback boost is %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].playback_boost); - stream->write_function(stream, "%s usage: %s", argv[0], GSMOPEN_BOOST_AUDIO_SYNTAX); - goto end; - } else if ((strncmp("play", argv[1], strlen(argv[1])) == 0)) { - if (switch_is_number(argv[2])) { - stream->write_function(stream, "[%s] playback boost was %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].playback_boost); - gsmopen_store_boost(argv[2], &globals.GSMOPEN_INTERFACES[i].playback_boost); //FIXME - stream->write_function(stream, "[%s] playback boost is now %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].playback_boost); - } - } else if ((strncmp("capt", argv[1], strlen(argv[1])) == 0)) { - if (switch_is_number(argv[2])) { - stream->write_function(stream, "[%s] capture boost was %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].capture_boost); - gsmopen_store_boost(argv[2], &globals.GSMOPEN_INTERFACES[i].capture_boost); //FIXME - stream->write_function(stream, "[%s] capture boost is now %f\n", globals.GSMOPEN_INTERFACES[i].name, - globals.GSMOPEN_INTERFACES[i].capture_boost); - } - } else { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_BOOST_AUDIO_SYNTAX); - } - } - } else { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_BOOST_AUDIO_SYNTAX); - } - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} - -#if 0 -int gsmopen_transfer(private_t *tech_pvt, char *id, char *value) -{ - char msg_to_gsmopen[1024]; - int i; - int found = 0; - private_t *giovatech; - struct timeval timenow; - - switch_mutex_lock(globals.mutex); - - gettimeofday(&timenow, NULL); - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name)) { - - giovatech = &globals.GSMOPEN_INTERFACES[i]; - //NOTICA("gsmopen interface: %d, name: %s, state: %d, value=%s, giovatech->callid_number=%s, giovatech->gsmopen_user=%s\n", GSMOPEN_P_LOG, i, giovatech->name, giovatech->interface_state, value, giovatech->callid_number, giovatech->gsmopen_user); - //FIXME check a timestamp here - if (strlen(giovatech->gsmopen_call_id) && (giovatech->interface_state != GSMOPEN_STATE_DOWN) && (!strcmp(giovatech->gsmopen_user, tech_pvt->gsmopen_user)) && (!strcmp(giovatech->callid_number, value)) && ((((timenow.tv_sec - giovatech->answer_time.tv_sec) * 1000000) + (timenow.tv_usec - giovatech->answer_time.tv_usec)) < 500000)) { //0.5sec - found = 1; - DEBUGA_GSMOPEN - ("FOUND (name=%s, giovatech->interface_state=%d != GSMOPEN_STATE_DOWN) && (giovatech->gsmopen_user=%s == tech_pvt->gsmopen_user=%s) && (giovatech->callid_number=%s == value=%s)\n", - GSMOPEN_P_LOG, giovatech->name, giovatech->interface_state, giovatech->gsmopen_user, tech_pvt->gsmopen_user, giovatech->callid_number, - value) - break; - } - } - } - - if (found) { - //tech_pvt->callid_number[0]='\0'; - //sprintf(msg_to_gsmopen, "ALTER CALL %s END HANGUP", id); - //gsmopen_signaling_write(tech_pvt, msg_to_gsmopen); - switch_mutex_unlock(globals.mutex); - return 0; - } - DEBUGA_GSMOPEN("NOT FOUND\n", GSMOPEN_P_LOG); - - if (!tech_pvt || !tech_pvt->gsmopen_call_id || !strlen(tech_pvt->gsmopen_call_id)) { - /* we are not inside an active call */ - DEBUGA_GSMOPEN("We're NO MORE in a call now %s\n", GSMOPEN_P_LOG, (tech_pvt && tech_pvt->gsmopen_call_id) ? tech_pvt->gsmopen_call_id : ""); - switch_mutex_unlock(globals.mutex); - - } else { - - /* we're owned, we're in a call, let's try to transfer */ - /************************** TODO - Checking here if it is possible to transfer this call to Test2 - -> GET CALL 288 CAN_TRANSFER Test2 - <- CALL 288 CAN_TRANSFER test2 TRUE - **********************************/ - - private_t *available_gsmopen_interface = NULL; - - gettimeofday(&timenow, NULL); - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - if (strlen(globals.GSMOPEN_INTERFACES[i].name)) { - - giovatech = &globals.GSMOPEN_INTERFACES[i]; - //NOTICA("gsmopen interface: %d, name: %s, state: %d, value=%s, giovatech->callid_number=%s, giovatech->gsmopen_user=%s\n", GSMOPEN_P_LOG, i, giovatech->name, giovatech->interface_state, value, giovatech->callid_number, giovatech->gsmopen_user); - //FIXME check a timestamp here - if (strlen(giovatech->gsmopen_transfer_call_id) && (giovatech->interface_state != GSMOPEN_STATE_DOWN) && (!strcmp(giovatech->gsmopen_user, tech_pvt->gsmopen_user)) && (!strcmp(giovatech->transfer_callid_number, value)) && ((((timenow.tv_sec - giovatech->transfer_time.tv_sec) * 1000000) + (timenow.tv_usec - giovatech->transfer_time.tv_usec)) < 1000000)) { //1.0 sec - found = 1; - DEBUGA_GSMOPEN - ("FOUND (name=%s, giovatech->interface_state=%d != GSMOPEN_STATE_DOWN) && (giovatech->gsmopen_user=%s == tech_pvt->gsmopen_user=%s) && (giovatech->transfer_callid_number=%s == value=%s)\n", - GSMOPEN_P_LOG, giovatech->name, giovatech->interface_state, - giovatech->gsmopen_user, tech_pvt->gsmopen_user, giovatech->transfer_callid_number, value) - break; - } - } - } - - if (found) { - //tech_pvt->callid_number[0]='\0'; - //sprintf(msg_to_gsmopen, "ALTER CALL %s END HANGUP", id); - //gsmopen_signaling_write(tech_pvt, msg_to_gsmopen); - switch_mutex_unlock(globals.mutex); - return 0; - } - DEBUGA_GSMOPEN("NOT FOUND\n", GSMOPEN_P_LOG); - - available_gsmopen_interface = find_available_gsmopen_interface_rr(tech_pvt); - if (available_gsmopen_interface) { - /* there is a gsmopen interface idle, let's transfer the call to it */ - - //FIXME write a timestamp here - gettimeofday(&tech_pvt->transfer_time, NULL); - switch_copy_string(tech_pvt->gsmopen_transfer_call_id, id, sizeof(tech_pvt->gsmopen_transfer_call_id) - 1); - - switch_copy_string(tech_pvt->transfer_callid_number, value, sizeof(tech_pvt->transfer_callid_number) - 1); - - DEBUGA_GSMOPEN - ("Let's transfer the gsmopen_call %s to %s interface (with gsmopen_user: %s), because we are already in a gsmopen call(%s)\n", - GSMOPEN_P_LOG, tech_pvt->gsmopen_call_id, available_gsmopen_interface->name, available_gsmopen_interface->gsmopen_user, id); - - //FIXME why this? the inbound call will come, eventually, on that other interface - //available_gsmopen_interface->ib_calls++; - - sprintf(msg_to_gsmopen, "ALTER CALL %s TRANSFER %s", id, available_gsmopen_interface->gsmopen_user); - //gsmopen_signaling_write(tech_pvt, msg_to_gsmopen); - if (tech_pvt->interface_state == GSMOPEN_STATE_SELECTED) { - tech_pvt->interface_state = GSMOPEN_STATE_IDLE; //we marked it GSMOPEN_STATE_SELECTED just in case it has to make an outbound call - } - } else { - /* no gsmopen interfaces idle, do nothing */ - DEBUGA_GSMOPEN - ("Not answering the gsmopen_call %s, because we are already in a gsmopen call(%s) and not transferring, because no other gsmopen interfaces are available\n", - GSMOPEN_P_LOG, id, tech_pvt->gsmopen_call_id); - sprintf(msg_to_gsmopen, "ALTER CALL %s END HANGUP", id); - //gsmopen_signaling_write(tech_pvt, msg_to_gsmopen); - } - switch_sleep(10000); - DEBUGA_GSMOPEN - ("We have NOT answered a GSM RING from gsmopen_call %s, because we are already in a gsmopen call (%s)\n", - GSMOPEN_P_LOG, id, tech_pvt->gsmopen_call_id); - - switch_mutex_unlock(globals.mutex); - } - return 0; -} -#endif //0 - -void *gsmopen_do_gsmopenapi_thread_func(void *obj) -{ - - private_t *tech_pvt = (private_t *) obj; - time_t now_timestamp; - - //if (gsmopen_present(GSMopenHandles)) - while (running && tech_pvt->running) { - int res; - //gsmopen_sleep(1000000); //1 sec - //DEBUGA_GSMOPEN("ciao!\n", GSMOPEN_P_LOG); - res = gsmopen_serial_read(tech_pvt); - if (res == -1) { //manage the graceful interface shutdown - tech_pvt->controldev_dead = 1; - close(tech_pvt->controldevfd); - ERRORA("gsmopen_serial_monitor failed, declaring %s dead\n", GSMOPEN_P_LOG, tech_pvt->controldevice_name); - tech_pvt->running = 0; - alarm_event(tech_pvt, ALARM_FAILED_INTERFACE, "gsmopen_serial_monitor failed, declaring interface dead"); - tech_pvt->active = 0; - tech_pvt->name[0] = '\0'; - switch_sleep(1000000); - } else if (tech_pvt->controldevprotocol != PROTOCOL_NO_SERIAL && tech_pvt->interface_state == GSMOPEN_STATE_RING - && tech_pvt->phone_callflow != CALLFLOW_CALL_HANGUP_REQUESTED) { - //WARNINGA("INCOMING RING\n", GSMOPEN_P_LOG); - - gsmopen_ring(tech_pvt); - - //FIXME gsmopen_answer(tech_pvt); - //new_inbound_channel(tech_pvt); - //FIXME if (!gsmopen_new(p, AST_STATE_RING, tech_pvt->context)) { - //FIXME ERRORA("gsmopen_new failed! BAD BAD BAD\n", GSMOPEN_P_LOG); - //FIXME } - - } else if (tech_pvt->controldevprotocol != PROTOCOL_NO_SERIAL && tech_pvt->interface_state == GSMOPEN_STATE_DIALING) { - WARNINGA("WE'RE DIALING, let's take the earlymedia\n", GSMOPEN_P_LOG); - tech_pvt->interface_state = CALLFLOW_STATUS_EARLYMEDIA; - remote_party_is_early_media(tech_pvt); - //new_inbound_channel(tech_pvt); - //FIXME if (!gsmopen_new(p, AST_STATE_RING, tech_pvt->context)) { - //FIXME ERRORA("gsmopen_new failed! BAD BAD BAD\n", GSMOPEN_P_LOG); - //FIXME } - - } else if (tech_pvt->interface_state == CALLFLOW_CALL_REMOTEANSWER) { - WARNINGA("REMOTE PARTY ANSWERED\n", GSMOPEN_P_LOG); - outbound_channel_answered(tech_pvt); - //new_inbound_channel(tech_pvt); - //FIXME if (!gsmopen_new(p, AST_STATE_RING, tech_pvt->context)) { - //FIXME ERRORA("gsmopen_new failed! BAD BAD BAD\n", GSMOPEN_P_LOG); - //FIXME } - } - switch_sleep(100); //give other threads a chance - time(&now_timestamp); - - if ((now_timestamp - tech_pvt->gsmopen_serial_synced_timestamp) > tech_pvt->gsmopen_serial_sync_period) { //TODO find a sensible period. 5min? in config? - gsmopen_serial_sync(tech_pvt); - gsmopen_serial_getstatus_AT(tech_pvt); - } - } - DEBUGA_GSMOPEN("EXIT\n", GSMOPEN_P_LOG); - //running = 0; - return NULL; - -} - -SWITCH_STANDARD_API(sendsms_function) -{ - char *mycmd = NULL, *argv[3] = { 0 }; - int argc = 0; - private_t *tech_pvt = NULL; - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (!argc) { - stream->write_function(stream, "ERROR, usage: %s", SENDSMS_SYNTAX); - goto end; - } - - if (argc < 3) { - stream->write_function(stream, "ERROR, usage: %s", SENDSMS_SYNTAX); - goto end; - } - - if (argv[0]) { - int i; - int found = 0; - - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[0], strlen(argv[0])) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - stream->write_function(stream, "Trying to send your SMS: interface=%s, dest=%s, text=%s\n", argv[0], argv[1], argv[2]); - found = 1; - break; - } - - } - if (!found) { - stream->write_function(stream, "ERROR: A GSMopen interface with name='%s' was not found\n", argv[0]); - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; - } else { - //gsmopen_sendsms(tech_pvt, (char *) argv[1], (char *) argv[2]); - NOTICA("chat_send(proto=%s, from=%s, to=%s, subject=%s, body=%s, type=NULL, hint=%s)\n", GSMOPEN_P_LOG, GSMOPEN_CHAT_PROTO, tech_pvt->name, - argv[1], "SIMPLE MESSAGE", switch_str_nil(argv[2]), tech_pvt->name); - - compat_chat_send(GSMOPEN_CHAT_PROTO, tech_pvt->name, argv[1], "SIMPLE MESSAGE", switch_str_nil(argv[2]), NULL, tech_pvt->name); - } - } else { - stream->write_function(stream, "ERROR, usage: %s", SENDSMS_SYNTAX); - } - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} - -int dump_event_full(private_t *tech_pvt, int is_alarm, int alarm_code, const char *alarm_message) -{ - switch_event_t *event; - char value[512]; - switch_core_session_t *session = NULL; - switch_channel_t *channel = NULL; - switch_status_t status; - - session = switch_core_session_locate(tech_pvt->session_uuid_str); - if (session) { - channel = switch_core_session_get_channel(session); - } - - if (is_alarm) { - ERRORA("ALARM on interface %s: \n", GSMOPEN_P_LOG, tech_pvt->name); - status = switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, MY_EVENT_ALARM); - } else { - DEBUGA_GSMOPEN("DUMP on interface %s: \n", GSMOPEN_P_LOG, tech_pvt->name); - status = switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, MY_EVENT_DUMP); - } - if (status == SWITCH_STATUS_SUCCESS) { - if (is_alarm) { - snprintf(value, sizeof(value) - 1, "%d", alarm_code); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm_code", value); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alarm_message", alarm_message); - } - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "interface_name", tech_pvt->name); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "interface_id", tech_pvt->id); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->active); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "active", value); - if (!tech_pvt->network_creg_not_supported) { - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->not_registered); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "not_registered", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->home_network_registered); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "home_network_registered", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->roaming_registered); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "roaming_registered", value); - } else { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "not_registered", "N/A"); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "home_network_registered", "N/A"); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "roaming_registered", "N/A"); - } - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->got_signal); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "got_signal", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->running); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "running", value); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "imei", tech_pvt->imei); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "imsi", tech_pvt->imsi); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->controldev_dead); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "controldev_dead", value); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "controldevice_name", tech_pvt->controldevice_name); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->no_sound); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "no_sound", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->playback_boost); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "playback_boost", value); - snprintf(value, sizeof(value) - 1, "%f", tech_pvt->capture_boost); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "capture_boost", value); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "dialplan", tech_pvt->dialplan); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "context", tech_pvt->context); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "destination", tech_pvt->destination); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_calls); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "ib_calls", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_calls); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "ob_calls", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ib_failed_calls); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "ib_failed_calls", value); - snprintf(value, sizeof(value) - 1, "%lu", tech_pvt->ob_failed_calls); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "ob_failed_calls", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->interface_state); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "interface_state", value); - snprintf(value, sizeof(value) - 1, "%d", tech_pvt->phone_callflow); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "phone_callflow", value); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "session_uuid_str", tech_pvt->session_uuid_str); - if (strlen(tech_pvt->session_uuid_str)) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "true"); - } else { //no session - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "false"); - } - if (channel) { - switch_channel_event_set_data(channel, event); - } - switch_event_fire(&event); - } else { - ERRORA("cannot create event on interface %s. WHY?????\n", GSMOPEN_P_LOG, tech_pvt->name); - } - - if (session) { - switch_core_session_rwunlock(session); - } - return 0; -} - -int dump_event(private_t *tech_pvt) -{ - return dump_event_full(tech_pvt, 0, 0, NULL); -} - -int alarm_event(private_t *tech_pvt, int alarm_code, const char *alarm_message) -{ - return dump_event_full(tech_pvt, 1, alarm_code, alarm_message); -} - -int sms_incoming(private_t *tech_pvt) -{ - switch_event_t *event; - switch_core_session_t *session = NULL; - int event_sent_to_esl = 0; - - //DEBUGA_GSMOPEN("received SMS on interface %s: %s\n", GSMOPEN_P_LOG, tech_pvt->name, tech_pvt->sms_message); - DEBUGA_GSMOPEN("received SMS on interface %s: DATE=%s, SENDER=%s, BODY=%s|\n", GSMOPEN_P_LOG, tech_pvt->name, tech_pvt->sms_date, tech_pvt->sms_sender, - tech_pvt->sms_body); - - if (!zstr(tech_pvt->session_uuid_str)) { - session = switch_core_session_locate(tech_pvt->session_uuid_str); - } - if (switch_event_create(&event, SWITCH_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", GSMOPEN_CHAT_PROTO); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", tech_pvt->name); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "hint", tech_pvt->chatmessages[which].from_dispname); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from", tech_pvt->sms_sender); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "date", tech_pvt->sms_date); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "datacodingscheme", tech_pvt->sms_datacodingscheme); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "servicecentreaddress", tech_pvt->sms_servicecentreaddress); - switch_event_add_header(event, SWITCH_STACK_BOTTOM, "messagetype", "%d", tech_pvt->sms_messagetype); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "chatname", tech_pvt->chatmessages[which].chatname); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "id", tech_pvt->chatmessages[which].id); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "subject", "SIMPLE MESSAGE"); - switch_event_add_body(event, "%s\n", tech_pvt->sms_body); - if (session) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "true"); - if (switch_core_session_queue_event(session, &event) != SWITCH_STATUS_SUCCESS) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "delivery-failure", "true"); - switch_event_fire(&event); - } - } else { //no session - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "false"); - switch_event_fire(&event); - event_sent_to_esl = 1; - } - - } else { - ERRORA("cannot create event on interface %s. WHY?????\n", GSMOPEN_P_LOG, tech_pvt->name); - } - - if (!event_sent_to_esl) { - - if (switch_event_create(&event, SWITCH_EVENT_MESSAGE) == SWITCH_STATUS_SUCCESS) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", GSMOPEN_CHAT_PROTO); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", tech_pvt->name); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "hint", tech_pvt->chatmessages[which].from_dispname); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from", tech_pvt->chatmessages[which].from_handle); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from", tech_pvt->sms_sender); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "date", tech_pvt->sms_date); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "datacodingscheme", tech_pvt->sms_datacodingscheme); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "servicecentreaddress", tech_pvt->sms_servicecentreaddress); - switch_event_add_header(event, SWITCH_STACK_BOTTOM, "messagetype", "%d", tech_pvt->sms_messagetype); - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "subject", "SIMPLE MESSAGE"); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "chatname", tech_pvt->chatmessages[which].chatname); - //switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "id", tech_pvt->chatmessages[which].id); - switch_event_add_body(event, "%s\n", tech_pvt->sms_body); - if (session) { - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "true"); - } else { //no session - switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "during-call", "false"); - } - switch_event_fire(&event); - } else { - ERRORA("cannot create event on interface %s. WHY?????\n", GSMOPEN_P_LOG, tech_pvt->name); - } - } - - if (session) { - switch_core_session_rwunlock(session); - } - //memset(&tech_pvt->chatmessages[which], '\0', sizeof(&tech_pvt->chatmessages[which]) ); - //memset(tech_pvt->sms_message, '\0', sizeof(tech_pvt->sms_message)); - return 0; -} - -#ifdef NOTDEF -SWITCH_STANDARD_API(gsmopen_chat_function) -{ - char *mycmd = NULL, *argv[10] = { 0 }; - int argc = 0; - private_t *tech_pvt = NULL; - //int tried =0; - int i; - int found = 0; - //char skype_msg[1024]; - - if (!zstr(cmd) && (mycmd = strdup(cmd))) { - argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); - } - - if (!argc) { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_CHAT_SYNTAX); - goto end; - } - - if (argc < 3) { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_CHAT_SYNTAX); - goto end; - } - - if (argv[0]) { - for (i = 0; !found && i < GSMOPEN_MAX_INTERFACES; i++) { - /* we've been asked for a normal interface name, or we have not found idle interfaces to serve as the "ANY" interface */ - if (strlen(globals.GSMOPEN_INTERFACES[i].name) - && (strncmp(globals.GSMOPEN_INTERFACES[i].name, argv[0], strlen(argv[0])) == 0)) { - tech_pvt = &globals.GSMOPEN_INTERFACES[i]; - stream->write_function(stream, "Using interface: globals.GSMOPEN_INTERFACES[%d].name=|||%s|||\n", i, globals.GSMOPEN_INTERFACES[i].name); - found = 1; - break; - } - - } - if (!found) { - stream->write_function(stream, "ERROR: A GSMopen interface with name='%s' was not found\n", argv[0]); - goto end; - } else { - - //chat_send(const char *proto, const char *from, const char *to, const char *subject, const char *body, const char *type, const char *hint); - //chat_send(p*roto, const char *from, const char *to, const char *subject, const char *body, const char *type, const char *hint); - //chat_send(GSMOPEN_CHAT_PROTO, tech_pvt->skype_user, argv[1], "SIMPLE MESSAGE", switch_str_nil((char *) &cmd[strlen(argv[0]) + 1 + strlen(argv[1]) + 1]), NULL, hint); - - NOTICA("chat_send(proto=%s, from=%s, to=%s, subject=%s, body=%s, type=NULL, hint=%s)\n", GSMOPEN_P_LOG, GSMOPEN_CHAT_PROTO, - tech_pvt->skype_user, argv[1], "SIMPLE MESSAGE", switch_str_nil((char *) &cmd[strlen(argv[0]) + 1 + strlen(argv[1]) + 1]), - tech_pvt->name); - - chat_send(GSMOPEN_CHAT_PROTO, tech_pvt->skype_user, argv[1], "SIMPLE MESSAGE", - switch_str_nil((char *) &cmd[strlen(argv[0]) + 1 + strlen(argv[1]) + 1]), NULL, tech_pvt->name); - - //NOTICA("TEXT is: %s\n", GSMOPEN_P_LOG, (char *) &cmd[strlen(argv[0]) + 1 + strlen(argv[1]) + 1] ); - //snprintf(skype_msg, sizeof(skype_msg), "CHAT CREATE %s", argv[1]); - //gsmopen_signaling_write(tech_pvt, skype_msg); - //switch_sleep(100); - } - } else { - stream->write_function(stream, "ERROR, usage: %s", GSMOPEN_CHAT_SYNTAX); - goto end; - } - -#ifdef NOTDEF - - found = 0; - - while (!found) { - for (i = 0; i < MAX_CHATS; i++) { - if (!strcmp(tech_pvt->chats[i].dialog_partner, argv[1])) { - snprintf(skype_msg, sizeof(skype_msg), "CHATMESSAGE %s %s", tech_pvt->chats[i].chatname, - (char *) &cmd[strlen(argv[0]) + 1 + strlen(argv[1]) + 1]); - gsmopen_signaling_write(tech_pvt, skype_msg); - found = 1; - break; - } - } - if (found) { - break; - } - if (tried > 1000) { - stream->write_function(stream, "ERROR: no chat with dialog_partner='%s' was found\n", argv[1]); - break; - } - switch_sleep(1000); - } -#endif //NOTDEF - - end: - switch_safe_free(mycmd); - - return SWITCH_STATUS_SUCCESS; -} -#endif // NOTDEF - -/* For Emacs: - * Local Variables: - * mode:c - * indent-tabs-mode:t - * tab-width:4 - * c-basic-offset:4 - * End: - * For VIM: - * vim:set softtabstop=4 shiftwidth=4 tabstop=4 expandtab: - */