Skinny: Milestone 1: Devices management

- handle unregister message
- send skinny::unregister event
- send skinny::expire event

git-svn-id: http://svn.freeswitch.org/svn/freeswitch/trunk@16758 d0543943-73ff-0310-b7d9-9358b9ac24b2

diff --git a/src/mod/endpoints/mod_skinny/mod_skinny.c b/src/mod/endpoints/mod_skinny/mod_skinny.c
index d655bde902a1de9811fbf4346207fc1b136dbf8b..c6f3ccf5b17325fa14f7e05d0aef570781519257 100644 (file)
--- a/src/mod/endpoints/mod_skinny/mod_skinny.c
+++ b/src/mod/endpoints/mod_skinny/mod_skinny.c
@@ -37,6 +37,8 @@ SWITCH_MODULE_RUNTIME_FUNCTION(mod_skinny_runtime);
 
 SWITCH_MODULE_DEFINITION(mod_skinny, mod_skinny_load, mod_skinny_shutdown, mod_skinny_runtime);
 #define SKINNY_EVENT_REGISTER "skinny::register"
+#define SKINNY_EVENT_UNREGISTER "skinny::unregister"
+#define SKINNY_EVENT_EXPIRE "skinny::expire"
 
 
 switch_endpoint_interface_t *skinny_endpoint_interface;
@@ -145,6 +147,9 @@ struct capabilities_res_message {
        struct station_capabilities caps[SWITCH_MAX_CODECS];
 };
 
+/* UnregisterMessage */
+#define UNREGISTER_MESSAGE 0x0027
+
 /* RegisterAckMessage */
 #define REGISTER_ACK_MESSAGE 0x0081
 struct register_ack_message {
@@ -1061,6 +1066,7 @@ static switch_status_t skinny_handle_line_stat_request(listener_t *listener, ski
                strcpy(message->data.line_res.shortname, device->line[i-1].shortname);
                strcpy(message->data.line_res.displayname, device->line[i-1].displayname);
        } else {
+               message->data.line_res.number = i;
                strcpy(message->data.line_res.name, "");
                strcpy(message->data.line_res.shortname, "");
                strcpy(message->data.line_res.displayname, "");
@@ -1081,6 +1087,16 @@ static switch_status_t skinny_handle_keep_alive_message(listener_t *listener, sk
        return SWITCH_STATUS_SUCCESS;
 }
 
+
+static switch_status_t skinny_handle_unregister(listener_t *listener, skinny_message_t *request)
+{
+       switch_event_t *event = NULL;
+       /* skinny::unregister event */
+       skinny_device_event(listener, &event, SWITCH_EVENT_CUSTOM, SKINNY_EVENT_UNREGISTER);
+       switch_event_fire(&event);
+       return SWITCH_STATUS_SUCCESS;
+}
+
 static switch_status_t skinny_handle_request(listener_t *listener, skinny_message_t *request)
 {
        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO,
@@ -1101,6 +1117,8 @@ static switch_status_t skinny_handle_request(listener_t *listener, skinny_messag
                        return skinny_handle_line_stat_request(listener, request);
                case KEEP_ALIVE_MESSAGE:
                        return skinny_handle_keep_alive_message(listener, request);
+               case UNREGISTER_MESSAGE:
+                       return skinny_handle_unregister(listener, request);
                default:
                        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, 
                                "Unknown request type: %x (length=%d).\n", request->type, request->length);
@@ -1242,7 +1260,12 @@ static switch_status_t kill_listener(listener_t *listener, void *pvt)
 
 static switch_status_t kill_expired_listener(listener_t *listener, void *pvt)
 {
+       switch_event_t *event = NULL;
+
        if(listener->expire_time < switch_epoch_time_now(NULL)) {
+               /* skinny::expire event */
+               skinny_device_event(listener, &event, SWITCH_EVENT_CUSTOM, SKINNY_EVENT_EXPIRE);
+               switch_event_fire(&event);
                return kill_listener(listener, pvt);
        }
        return SWITCH_STATUS_SUCCESS;