Merged revisions 47850 via svnmerge from
[asterisk/asterisk.git] / apps / app_directed_pickup.c
index c79bad2..9aba195 100644 (file)
@@ -41,6 +41,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 #include "asterisk/module.h"
 #include "asterisk/lock.h"
 #include "asterisk/app.h"
+#include "asterisk/options.h"
 
 #define PICKUPMARK "PICKUPMARK"
 
@@ -50,108 +51,120 @@ static const char *descrip =
 "  Pickup(extension[@context][&extension2@context...]): This application can pickup any ringing channel\n"
 "that is calling the specified extension. If no context is specified, the current\n"
 "context will be used. If you use the special string \"PICKUPMARK\" for the context parameter, for example\n"
-"10@PICKUPMARK, this application tries to find a channel which has defined a channel variable with the same context\n"
+"10@PICKUPMARK, this application tries to find a channel which has defined a channel variable with the same content\n"
 "as \"extension\".";
 
-LOCAL_USER_DECL;
-
-static int pickup_exec(struct ast_channel *chan, void *data)
+/* Perform actual pickup between two channels */
+static int pickup_do(struct ast_channel *chan, struct ast_channel *target)
 {
        int res = 0;
-       struct localuser *u = NULL;
-       struct ast_channel *origin = NULL, *target = NULL;
-       char *tmp = NULL, *exten = NULL, *context = NULL, *rest=data;
-       char workspace[256] = "";
-       const char *tmp2 = NULL;
 
-       if (ast_strlen_zero(data)) {
-               ast_log(LOG_WARNING, "Pickup requires an argument (extension) !\n");
-               return -1;      
+       if (option_debug)
+               ast_log(LOG_DEBUG, "Call pickup on '%s' by '%s'\n", target->name, chan->name);
+
+       if ((res = ast_answer(chan))) {
+               ast_log(LOG_WARNING, "Unable to answer '%s'\n", chan->name);
+               return -1;
        }
 
-       LOCAL_USER_ADD(u);
-       
-       while (!target && (exten = rest) ) {
-               res = 0;
-               rest = strchr(exten, '&');
-               if (rest)
-                       *rest++ = 0;
-
-               /* Get the extension and context if present */
-               context = strchr(exten, '@');
-               if (context)
-                       *context++ = '\0';
+       if ((res = ast_queue_control(chan, AST_CONTROL_ANSWER))) {
+               ast_log(LOG_WARNING, "Unable to queue answer on '%s'\n", chan->name);
+               return -1;
+       }
 
-               /* If the context is the pickup mark, iterate through all channels finding the right origin one */
-               if (context && !strcmp(context, PICKUPMARK)) {
-                       while ((origin = ast_channel_walk_locked(origin))) {
-                               if (origin) {
-                                       tmp2 = pbx_builtin_getvar_helper(origin, PICKUPMARK);
-                                       if (tmp2 && !strcmp(tmp2, exten))
-                                               break;
-                                       ast_mutex_unlock(&origin->lock);
-                               }
-                       }
-               } else {
-                       /* Use the classic mode of searching */
-                       origin = ast_get_channel_by_exten_locked(exten, context);
+       if ((res = ast_channel_masquerade(target, chan))) {
+               ast_log(LOG_WARNING, "Unable to masquerade '%s' into '%s'\n", chan->name, target->name);
+               return -1;
+       }
+
+       return res;
+}
+
+/* Helper function that determines whether a channel is capable of being picked up */
+static int can_pickup(struct ast_channel *chan)
+{
+       if (!chan->pbx && (chan->_state == AST_STATE_RINGING || chan->_state == AST_STATE_RING))
+               return 1;
+       else
+               return 0;
+}
+
+/* Attempt to pick up specified extension with context */
+static int pickup_by_exten(struct ast_channel *chan, char *exten, char *context)
+{
+       int res = -1;
+       struct ast_channel *target = NULL;
+
+       while ((target = ast_channel_walk_locked(target))) {
+               if (!strcasecmp(target->exten, exten) &&
+                   !strcasecmp(target->dialcontext, context) &&
+                   can_pickup(target)) {
+                       res = pickup_do(chan, target);
+                       ast_channel_unlock(target);
+                       break;
                }
+               ast_channel_unlock(target);
+       }
 
-               if (origin) {
-                       ast_cdr_getvar(origin->cdr, "dstchannel", &tmp, workspace,
-                                       sizeof(workspace), 0, 0);
-                       if (tmp) {
-                               /* We have a possible channel... now we need to find it! */
-                               target = ast_get_channel_by_name_locked(tmp);
-                       } else {
-                               ast_log(LOG_NOTICE, "No target channel found for %s.\n", exten);
-                               res = -1;
-                       }
-                       ast_mutex_unlock(&origin->lock);
+       return res;
+}
 
-               } else {
-                       ast_log(LOG_DEBUG, "No originating channel found.\n");
+/* Attempt to pick up specified mark */
+static int pickup_by_mark(struct ast_channel *chan, char *mark)
+{
+       int res = -1;
+       const char *tmp = NULL;
+       struct ast_channel *target = NULL;
+
+       while ((target = ast_channel_walk_locked(target))) {
+               if ((tmp = pbx_builtin_getvar_helper(target, PICKUPMARK)) &&
+                   !strcasecmp(tmp, mark) &&
+                   can_pickup(target)) {
+                       res = pickup_do(chan, target);
+                       ast_channel_unlock(target);
+                       break;
                }
+               ast_channel_unlock(target);
+       }
 
-               if (res)
-                       continue;
+       return res;
+}
 
-               if (target && (!target->pbx) && ((target->_state == AST_STATE_RINGING) || (target->_state == AST_STATE_RING) ) ) {
-                       ast_log(LOG_DEBUG, "Call pickup on chan '%s' by '%s'\n", target->name,
-                                       chan->name);
-                       res = ast_answer(chan);
-                       if (res) {
-                               ast_log(LOG_WARNING, "Unable to answer '%s'\n", chan->name);
-                               res = -1;
-                               break;
-                       }
-                       res = ast_queue_control(chan, AST_CONTROL_ANSWER);
-                       if (res) {
-                               ast_log(LOG_WARNING, "Unable to queue answer on '%s'\n",
-                                               chan->name);
-                               res = -1;
-                               break;
-                       }
-                       res = ast_channel_masquerade(target, chan);
-                       if (res) {
-                               ast_log(LOG_WARNING, "Unable to masquerade '%s' into '%s'\n", chan->name, target->name);
-                               res = -1;
+/* Main application entry point */
+static int pickup_exec(struct ast_channel *chan, void *data)
+{
+       int res = 0;
+       struct ast_module_user *u = NULL;
+       char *tmp = ast_strdupa(data);
+       char *exten = NULL, *context = NULL;
+
+       if (ast_strlen_zero(data)) {
+               ast_log(LOG_WARNING, "Pickup requires an argument (extension)!\n");
+               return -1;      
+       }
+
+       u = ast_module_user_add(chan);
+       
+       /* Parse extension (and context if there) */
+       while (!ast_strlen_zero(tmp) && (exten = strsep(&tmp, "&"))) {
+               if ((context = strchr(exten, '@')))
+                       *context++ = '\0';
+               if (context && !strcasecmp(context, PICKUPMARK)) {
+                       if (!pickup_by_mark(chan, exten))
                                break;
-                       }
                } else {
-                       ast_log(LOG_NOTICE, "No call pickup possible for %s...\n", exten);
-                       res = -1;
+                       if (!pickup_by_exten(chan, exten, context ? context : chan->context))
+                               break;
                }
+               ast_log(LOG_NOTICE, "No target channel found for %s.\n", exten);
        }
-       if (target) 
-               ast_mutex_unlock(&target->lock);
-       
-       LOCAL_USER_REMOVE(u);
+
+       ast_module_user_remove(u);
 
        return res;
 }
 
-static int unload_module(void *mod)
+static int unload_module(void)
 {
        int res;
 
@@ -160,20 +173,9 @@ static int unload_module(void *mod)
        return res;
 }
 
-static int load_module(void *mod)
+static int load_module(void)
 {
-       __mod_desc = mod;
        return ast_register_application(app, pickup_exec, synopsis, descrip);
 }
 
-static const char *description(void)
-{
-       return "Directed Call Pickup Application";
-}
-
-static const char *key(void)
-{
-       return ASTERISK_GPL_KEY;
-}
-
-STD_MOD(MOD_1, NULL, NULL, NULL);
+AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Directed Call Pickup Application");