Skinny: Basic MWI

With following limitations:
- only first line is handled
- only works well when domain name = profile name

diff --git a/src/mod/endpoints/mod_skinny/mod_skinny.c b/src/mod/endpoints/mod_skinny/mod_skinny.c
index fa9cf0dd083aa7369ec2d10ea2ba6a0aec0ffe94..029ab4a3179dad2354077bd8f3a8f01b6835b977 100644 (file)
--- a/src/mod/endpoints/mod_skinny/mod_skinny.c
+++ b/src/mod/endpoints/mod_skinny/mod_skinny.c
@@ -1815,6 +1815,95 @@ static void skinny_call_state_event_handler(switch_event_t *event)
        }
 }
 
+struct skinny_message_waiting_event_handler_helper {
+       skinny_profile_t *profile;
+       switch_bool_t yn;
+       int total_new_messages;
+       int total_saved_messages;
+       int total_new_urgent_messages;
+       int total_saved_urgent_messages;
+};
+
+int skinny_message_waiting_event_handler_callback(void *pArg, int argc, char **argv, char **columnNames)
+{
+       char *device_name = argv[0];
+       uint32_t device_instance = atoi(argv[1]);
+
+       struct skinny_message_waiting_event_handler_helper *helper = pArg;
+       listener_t *listener = NULL;
+
+       skinny_profile_find_listener_by_device_name_and_instance(helper->profile,
+               device_name, device_instance, &listener);
+
+       if (listener) {
+               if (helper->yn == SWITCH_TRUE) {
+                       char buffer[32];
+                       send_set_lamp(listener, SKINNY_BUTTON_VOICEMAIL, 0, SKINNY_LAMP_ON);
+                       sprintf(buffer, "%s: (%d/%d urgents)", SKINNY_DISP_YOU_HAVE_VOICEMAIL, helper->total_new_messages, helper->total_new_urgent_messages);
+                       send_display_pri_notify(listener, 5, 10, buffer);
+               } else {
+                       send_set_lamp(listener, SKINNY_BUTTON_VOICEMAIL, 0, SKINNY_LAMP_OFF);
+                       send_clear_prompt_status(listener, 0, 0);
+               }
+       }
+       return 0;
+}
+
+static void skinny_message_waiting_event_handler(switch_event_t *event)
+{
+       char *account, *dup_account, *yn, *host, *user, *count_str;
+       char *pname = NULL;
+       skinny_profile_t *profile = NULL;
+       char *sql;
+
+       if (!(account = switch_event_get_header(event, "mwi-message-account"))) {
+               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing required Header 'MWI-Message-Account'\n");
+               return;
+       }
+
+       if (!(yn = switch_event_get_header(event, "mwi-messages-waiting"))) {
+               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Missing required Header 'MWI-Messages-Waiting'\n");
+               return;
+       }
+       dup_account = strdup(account);
+       switch_assert(dup_account != NULL);
+       switch_split_user_domain(dup_account, &user, &host);
+
+
+       if ((pname = switch_event_get_header(event, "skinny-profile"))) {
+               if (!(profile = skinny_find_profile(pname))) {
+                       switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "No profile %s\n", pname);
+               }
+       }
+
+       if (!profile) {
+               if (!host || !(profile = skinny_find_profile(host))) {
+                       switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot find profile %s\n", switch_str_nil(host));
+                       switch_safe_free(dup_account);
+                       return;
+               }
+       }
+
+       count_str = switch_event_get_header(event, "mwi-voice-message");
+
+       if ((sql = switch_mprintf(
+                       "SELECT device_name, device_instance FROM skinny_lines "
+                               "WHERE value='%s' AND line_instance=1", user))) {
+               struct skinny_message_waiting_event_handler_helper helper = {0};
+               helper.profile = profile;
+               helper.yn = switch_true(yn);
+               if (count_str) {
+                       sscanf(count_str,"%d/%d (%d/%d)",
+                               &helper.total_new_messages, &helper.total_saved_messages,
+                               &helper.total_new_urgent_messages, &helper.total_saved_urgent_messages);
+               }
+               skinny_execute_sql_callback(profile, profile->sql_mutex, sql,  skinny_message_waiting_event_handler_callback, &helper);
+               switch_safe_free(sql);
+       }
+
+       switch_safe_free(dup_account);
+}
+
 
 /*****************************************************************************/
 SWITCH_MODULE_LOAD_FUNCTION(mod_skinny_load)
@@ -1842,6 +1931,10 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_skinny_load)
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind our call_state handler!\n");
                return SWITCH_STATUS_TERM;
        }
+       if ((switch_event_bind_removable(modname, SWITCH_EVENT_MESSAGE_WAITING, NULL, skinny_message_waiting_event_handler, NULL, &globals.message_waiting_node) != SWITCH_STATUS_SUCCESS)) {
+               switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind our message waiting handler!\n");
+               /* Not such severe to prevent loading */
+       }
 
        /* reserve events */
        if (switch_event_reserve_subclass(SKINNY_EVENT_REGISTER) != SWITCH_STATUS_SUCCESS) {
@@ -1907,6 +2000,7 @@ SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_skinny_shutdown)
        /* release events */
        switch_event_unbind(&globals.heartbeat_node);
        switch_event_unbind(&globals.call_state_node);
+       switch_event_unbind(&globals.message_waiting_node);
        switch_event_free_subclass(SKINNY_EVENT_REGISTER);
        switch_event_free_subclass(SKINNY_EVENT_UNREGISTER);
        switch_event_free_subclass(SKINNY_EVENT_EXPIRE);

diff --git a/src/mod/endpoints/mod_skinny/mod_skinny.h b/src/mod/endpoints/mod_skinny/mod_skinny.h
index a8d192987ae12599c7c6f92b6891da113ffba464..323d1bd3a24164d6cff6ce3ba3979625b79559f2 100644 (file)
--- a/src/mod/endpoints/mod_skinny/mod_skinny.h
+++ b/src/mod/endpoints/mod_skinny/mod_skinny.h
@@ -51,6 +51,7 @@ struct skinny_globals {
     switch_hash_t *profile_hash;
     switch_event_node_t *heartbeat_node;
     switch_event_node_t *call_state_node;
+    switch_event_node_t *message_waiting_node;
 };
 typedef struct skinny_globals skinny_globals_t;
 

diff --git a/src/mod/endpoints/mod_skinny/skinny_server.c b/src/mod/endpoints/mod_skinny/skinny_server.c
index 351dcc31e48826dda37c837f3f115c0d3162a74d..ca5c911b8605f296536383efef995a957406ad3b 100644 (file)
--- a/src/mod/endpoints/mod_skinny/skinny_server.c
+++ b/src/mod/endpoints/mod_skinny/skinny_server.c
@@ -1018,13 +1018,22 @@ switch_status_t skinny_handle_register(listener_t *listener, skinny_message_t *r
                                                                "ring_on_idle, ring_on_active, busy_trigger, "
                                                                "forward_all, forward_busy, forward_noanswer, noanswer_duration) "
                                                                "VALUES('%s', %d, %d, %d, '%s', '%s', '%s', %d, %d, %d, '%s', '%s', '%s', %d)",
-                                                       request->data.reg.device_name, request->data.reg.instance, position, line_instance++,
+                                                       request->data.reg.device_name, request->data.reg.instance, position, line_instance,
                                                        label, value, caller_name,
                                                        ring_on_idle, ring_on_active, busy_trigger,
                                                        forward_all, forward_busy, forward_noanswer, noanswer_duration))) {
                                                skinny_execute_sql(profile, sql, profile->sql_mutex);
                                                switch_safe_free(sql);
                                        }
+                                       if (line_instance == 1) {
+                                               switch_event_t *message_query_event = NULL;
+                                               if (switch_event_create(&message_query_event, SWITCH_EVENT_MESSAGE_QUERY) == SWITCH_STATUS_SUCCESS) {
+                                                       switch_event_add_header(message_query_event, SWITCH_STACK_BOTTOM, "Message-Account", "skinny:%s@%s", value, profile->domain);
+                                                       switch_event_add_header_string(message_query_event, SWITCH_STACK_BOTTOM, "VM-Skinny-Profile", profile->name);
+                                                       switch_event_fire(&message_query_event);
+                                               }
+                                       }
+                                       line_instance++;
                                } else {
                                        const char *settings = switch_xml_attr_soft(xbutton, "settings");
                                        if ((sql = switch_mprintf(