00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028
00029
00030
00031
00032
00033
00034 #include "asterisk.h"
00035
00036 ASTERISK_FILE_VERSION(__FILE__, "$Revision: 328209 $")
00037
00038 #include "asterisk/channel.h"
00039 #include "asterisk/pbx.h"
00040 #include "asterisk/module.h"
00041 #include "asterisk/file.h"
00042 #include "asterisk/app.h"
00043 #include "asterisk/chanvars.h"
00044 #include "asterisk/utils.h"
00045 #include "asterisk/devicestate.h"
00046 #include "asterisk/dial.h"
00047
00048
00049
00050
00051
00052
00053
00054
00055
00056
00057
00058
00059
00060
00061
00062
00063
00064
00065
00066
00067
00068
00069
00070
00071
00072
00073
00074
00075
00076
00077
00078
00079
00080
00081
00082
00083
00084
00085
00086
00087
00088
00089
00090
00091
00092
00093
00094
00095
00096
00097
00098
00099
00100
00101
00102
00103
00104
00105
00106
00107
00108
00109
00110
00111
00112 static const char * const app_page= "Page";
00113
00114 enum page_opt_flags {
00115 PAGE_DUPLEX = (1 << 0),
00116 PAGE_QUIET = (1 << 1),
00117 PAGE_RECORD = (1 << 2),
00118 PAGE_SKIP = (1 << 3),
00119 PAGE_IGNORE_FORWARDS = (1 << 4),
00120 PAGE_ANNOUNCE = (1 << 5),
00121 PAGE_NOCALLERANNOUNCE = (1 << 6),
00122 };
00123
00124 enum {
00125 OPT_ARG_ANNOUNCE = 0,
00126 OPT_ARG_ARRAY_SIZE = 1,
00127 };
00128
00129 AST_APP_OPTIONS(page_opts, {
00130 AST_APP_OPTION('d', PAGE_DUPLEX),
00131 AST_APP_OPTION('q', PAGE_QUIET),
00132 AST_APP_OPTION('r', PAGE_RECORD),
00133 AST_APP_OPTION('s', PAGE_SKIP),
00134 AST_APP_OPTION('i', PAGE_IGNORE_FORWARDS),
00135 AST_APP_OPTION('i', PAGE_IGNORE_FORWARDS),
00136 AST_APP_OPTION_ARG('A', PAGE_ANNOUNCE, OPT_ARG_ANNOUNCE),
00137 AST_APP_OPTION('n', PAGE_NOCALLERANNOUNCE),
00138 });
00139
00140
00141 static int page_exec(struct ast_channel *chan, const char *data)
00142 {
00143 char *tech, *resource, *tmp;
00144 char meetmeopts[128], originator[AST_CHANNEL_NAME], *opts[OPT_ARG_ARRAY_SIZE];
00145 struct ast_flags flags = { 0 };
00146 unsigned int confid = ast_random();
00147 struct ast_app *app;
00148 int res = 0, pos = 0, i = 0;
00149 struct ast_dial **dial_list;
00150 unsigned int num_dials;
00151 int timeout = 0;
00152 char *parse;
00153
00154 AST_DECLARE_APP_ARGS(args,
00155 AST_APP_ARG(devices);
00156 AST_APP_ARG(options);
00157 AST_APP_ARG(timeout);
00158 );
00159
00160 if (ast_strlen_zero(data)) {
00161 ast_log(LOG_WARNING, "This application requires at least one argument (destination(s) to page)\n");
00162 return -1;
00163 }
00164
00165 if (!(app = pbx_findapp("MeetMe"))) {
00166 ast_log(LOG_WARNING, "There is no MeetMe application available!\n");
00167 return -1;
00168 };
00169
00170 parse = ast_strdupa(data);
00171
00172 AST_STANDARD_APP_ARGS(args, parse);
00173
00174 ast_copy_string(originator, chan->name, sizeof(originator));
00175 if ((tmp = strchr(originator, '-'))) {
00176 *tmp = '\0';
00177 }
00178
00179 if (!ast_strlen_zero(args.options)) {
00180 ast_app_parse_options(page_opts, &flags, opts, args.options);
00181 }
00182
00183 if (!ast_strlen_zero(args.timeout)) {
00184 timeout = atoi(args.timeout);
00185 }
00186
00187 if (ast_test_flag(&flags, PAGE_ANNOUNCE) && !ast_strlen_zero(opts[OPT_ARG_ANNOUNCE])) {
00188 snprintf(meetmeopts, sizeof(meetmeopts), "MeetMe,%ud,%s%sqxdw(5)G(%s)", confid, (ast_test_flag(&flags, PAGE_DUPLEX) ? "" : "m"),
00189 (ast_test_flag(&flags, PAGE_RECORD) ? "r" : ""), opts[OPT_ARG_ANNOUNCE] );
00190 } else {
00191 snprintf(meetmeopts, sizeof(meetmeopts), "MeetMe,%ud,%s%sqxdw(5)", confid, (ast_test_flag(&flags, PAGE_DUPLEX) ? "" : "m"),
00192 (ast_test_flag(&flags, PAGE_RECORD) ? "r" : "") );
00193 }
00194
00195
00196 num_dials = 1;
00197 tmp = args.devices;
00198 while (*tmp) {
00199 if (*tmp == '&') {
00200 num_dials++;
00201 }
00202 tmp++;
00203 }
00204
00205 if (!(dial_list = ast_calloc(num_dials, sizeof(struct ast_dial *)))) {
00206 ast_log(LOG_ERROR, "Can't allocate %ld bytes for dial list\n", (long)(sizeof(struct ast_dial *) * num_dials));
00207 return -1;
00208 }
00209
00210
00211 while ((tech = strsep(&args.devices, "&"))) {
00212 int state = 0;
00213 struct ast_dial *dial = NULL;
00214
00215
00216 if (!strcasecmp(tech, originator))
00217 continue;
00218
00219
00220 if (!(resource = strchr(tech, '/'))) {
00221 ast_log(LOG_WARNING, "Incomplete destination '%s' supplied.\n", tech);
00222 continue;
00223 }
00224
00225
00226 if (ast_test_flag(&flags, PAGE_SKIP)) {
00227 state = ast_device_state(tech);
00228 if (state == AST_DEVICE_UNKNOWN) {
00229 ast_log(LOG_WARNING, "Destination '%s' has device state '%s'. Paging anyway.\n", tech, ast_devstate2str(state));
00230 } else if (state != AST_DEVICE_NOT_INUSE) {
00231 ast_log(LOG_WARNING, "Destination '%s' has device state '%s'.\n", tech, ast_devstate2str(state));
00232 continue;
00233 }
00234 }
00235
00236 *resource++ = '\0';
00237
00238
00239 if (!(dial = ast_dial_create())) {
00240 ast_log(LOG_WARNING, "Failed to create dialing structure.\n");
00241 continue;
00242 }
00243
00244
00245 if (ast_dial_append(dial, tech, resource) == -1) {
00246 ast_log(LOG_ERROR, "Failed to add %s to outbound dial\n", tech);
00247 continue;
00248 }
00249
00250
00251 ast_dial_option_global_enable(dial, AST_DIAL_OPTION_ANSWER_EXEC, meetmeopts);
00252
00253 if (timeout) {
00254 ast_dial_set_global_timeout(dial, timeout * 1000);
00255 }
00256
00257 if (ast_test_flag(&flags, PAGE_IGNORE_FORWARDS)) {
00258 ast_dial_option_global_enable(dial, AST_DIAL_OPTION_DISABLE_CALL_FORWARDING, NULL);
00259 }
00260
00261
00262 ast_dial_run(dial, chan, 1);
00263
00264
00265 dial_list[pos++] = dial;
00266 }
00267
00268 if (!ast_test_flag(&flags, PAGE_QUIET)) {
00269 res = ast_streamfile(chan, "beep", chan->language);
00270 if (!res)
00271 res = ast_waitstream(chan, "");
00272 }
00273
00274 if (!res) {
00275
00276 snprintf(meetmeopts, sizeof(meetmeopts), "%ud,A%s%sqxd", confid, (ast_test_flag(&flags, PAGE_DUPLEX) ? "" : "t"),
00277 (ast_test_flag(&flags, PAGE_RECORD) ? "r" : "") );
00278 if (ast_test_flag(&flags, PAGE_ANNOUNCE) && !ast_strlen_zero(opts[OPT_ARG_ANNOUNCE]) &&
00279 !ast_test_flag(&flags, PAGE_NOCALLERANNOUNCE)) {
00280 snprintf(meetmeopts, sizeof(meetmeopts), "%ud,A%s%sqxdG(%s)", confid, (ast_test_flag(&flags, PAGE_DUPLEX) ? "" : "t"),
00281 (ast_test_flag(&flags, PAGE_RECORD) ? "r" : ""), opts[OPT_ARG_ANNOUNCE] );
00282 }
00283 pbx_exec(chan, app, meetmeopts);
00284 }
00285
00286
00287 for (i = 0; i < pos; i++) {
00288 struct ast_dial *dial = dial_list[i];
00289
00290
00291 ast_dial_join(dial);
00292
00293
00294 ast_dial_hangup(dial);
00295
00296
00297 ast_dial_destroy(dial);
00298 }
00299
00300 return -1;
00301 }
00302
00303 static int unload_module(void)
00304 {
00305 return ast_unregister_application(app_page);
00306 }
00307
00308 static int load_module(void)
00309 {
00310 return ast_register_application_xml(app_page, page_exec);
00311 }
00312
00313 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Page Multiple Phones");
00314