FS-10666: [mod_callcenter] Adding callcenter_break agent api

callcenter_break agent <uuid> can be called with an uuid that represents
an outbound session created to call an agent.

The current behavior of mod_callcenter is to keep watching this channel
until it is hangup, once the hangup happens the bridge-agent-end and
member-queue-end events are fired, agent is released on the database
so it can receive more calls and member is also updated on database.

If you do not want to the agent channel hangup to release the agent you can
call this app with the agent session uuid and the agent will be released and
available to receive more calls. This is useful when the agent is located on a
remote freeswitch box and transfer the call internally, the original leg between
the first FreeSWITCH and the remote box remains live and the agent will only be
Available when the original call hangup.

diff --git a/src/mod/applications/mod_callcenter/mod_callcenter.c b/src/mod/applications/mod_callcenter/mod_callcenter.c
index 81c49f399dc5f89373bacdf61872364d8982b993..e004a21a10a9b9d97d4e7061faaa41530f50486a 100644 (file)
--- a/src/mod/applications/mod_callcenter/mod_callcenter.c
+++ b/src/mod/applications/mod_callcenter/mod_callcenter.c
@@ -178,7 +178,8 @@ static struct cc_member_cancel_reason_table MEMBER_CANCEL_REASON_CHART[] = {
 };
 
 typedef enum {
-    CC_APP_AGENT_CONNECTING = (1 << 0)
+    CC_APP_AGENT_CONNECTING = (1 << 0),
+       CC_APP_SHOULD_BREAK = (1 << 1)
 } cc_app_flag_t;
 
 static char members_sql[] =
@@ -1928,13 +1929,18 @@ static void *SWITCH_THREAD_FUNC outbound_agent_thread_run(switch_thread_t *threa
 
                }
                switch_channel_clear_app_flag_key(CC_APP_KEY, member_channel, CC_APP_AGENT_CONNECTING);
-               /* Wait until the agent hangup.  This will quit also if the agent transfer the call */
+               /* Wait until the agent hangup.  This will quit also if the agent transfer the call or callcenter_break is used*/
                while(bridged && switch_channel_up(agent_channel) && globals.running) {
                        if (!strcasecmp(h->agent_type, CC_AGENT_TYPE_UUID_STANDBY)) {
                                if (!switch_channel_test_flag(agent_channel, CF_BRIDGED)) {
                                        break;
                                }
                        }
+                       if (switch_channel_test_app_flag_key(CC_APP_KEY, agent_channel, CC_APP_SHOULD_BREAK)) {
+                               switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(agent_session), SWITCH_LOG_DEBUG, "callcenter_break requested at agent channel, releasing agent %s\n", h->agent_name);
+                               switch_channel_clear_app_flag_key(CC_APP_KEY, agent_channel, CC_APP_SHOULD_BREAK);
+                               break;
+                       }
                        switch_yield(100000);
                }
                tiers_state = CC_TIER_STATE_READY;
@@ -3893,6 +3899,43 @@ done:
        return SWITCH_STATUS_SUCCESS;
 }
 
+SWITCH_STANDARD_API(cc_break_api_function)
+{
+       char *argv[2] = { 0 };
+       char *mydata = NULL;
+       const char *uuid = NULL;
+       switch_core_session_t *break_session = NULL;
+       switch_channel_t *channel = NULL;
+       switch_bool_t status = SWITCH_STATUS_SUCCESS;
+
+       if (!zstr(cmd)) {
+               mydata = strdup(cmd);
+               switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0])));
+       } else {
+               stream->write_function(stream, "-ERR Usage: callcenter_break agent <uuid>\n");
+               goto end;
+       }
+
+       uuid = argv[1];
+       if (!uuid) {
+               stream->write_function(stream, "-ERR Usage: callcenter_break agent <uuid>\n");
+               goto end;
+       }
+       break_session = switch_core_session_locate(uuid);
+       if (!break_session) {
+               stream->write_function(stream, "-ERR Session not found for uuid %s\n", uuid);
+               goto end;
+       }
+       channel = switch_core_session_get_channel(break_session);
+       switch_channel_set_app_flag_key(CC_APP_KEY, channel, CC_APP_SHOULD_BREAK);
+
+end:
+       if (break_session) {
+               switch_core_session_rwunlock(break_session);
+       }
+       switch_safe_free(mydata);
+       return status;
+}
 
 SWITCH_STANDARD_JSON_API(json_callcenter_config_function)
 {
@@ -4097,6 +4140,7 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_callcenter_load)
        SWITCH_ADD_APP(app_interface, "callcenter", "CallCenter", CC_DESC, callcenter_function, CC_USAGE, SAF_NONE);
        SWITCH_ADD_APP(app_interface, "callcenter_track", "CallCenter Track Call", "Track external mod_callcenter calls to avoid place new calls", callcenter_track, CC_USAGE, SAF_NONE);
        SWITCH_ADD_API(api_interface, "callcenter_config", "Config of callcenter", cc_config_api_function, CC_CONFIG_API_SYNTAX);
+       SWITCH_ADD_API(api_interface, "callcenter_break", "Stop watching an uuid and release agent", cc_break_api_function, "callcenter_break agent <uuid>");
 
        SWITCH_ADD_JSON_API(json_api_interface, "callcenter_config", "JSON Callcenter API", json_callcenter_config_function, "");
 
@@ -4134,6 +4178,8 @@ SWITCH_MODULE_LOAD_FUNCTION(mod_callcenter_load)
        switch_console_set_complete("add callcenter_config queue count members");
        switch_console_set_complete("add callcenter_config queue count tiers");
 
+       switch_console_set_complete("add callcenter_break agent");
+
        /* indicate that the module should continue to be loaded */
        return SWITCH_STATUS_SUCCESS;
 }