2 * Asterisk -- An open source telephony toolkit.
4 * Copyright (C) 2004 - 2005
6 * SMS queuing application for use with asterisk app_sms
9 * See http://www.asterisk.org for more information about
10 * the Asterisk project. Please do not directly contact
11 * any of the maintainers of this project for assistance;
12 * the project provides a web site, mailing lists and IRC
13 * channels for your use.
15 * This program is free software, distributed under the terms of
16 * the GNU General Public License Version 2. See the LICENSE file
17 * at the top of the source tree.
30 #define POPT_ARGFLAG_SHOW_DEFAULT 0x00800000
32 #if !defined(POPT_ARGFLAG_SHOW_DEFAULT)
33 #define POPT_ARGFLAG_SHOW_DEFAULT 0x00800000
38 * \brief reads next USC character from null terminated UTF-8 string and advanced pointer
39 * for non valid UTF-8 sequences.
40 * \return character as is Does \b NOT advance pointer for null termination
42 static int utf8decode (unsigned char **pp
)
44 unsigned char *p
= *pp
;
46 return 0; /* null termination of string */
49 return *p
; /* ascii or continuation character */
52 if (*p
< 0xC2 || (p
[1] & 0xC0) != 0x80)
53 return *p
; /* not valid UTF-8 */
55 return ((*p
& 0x1F) << 6) + (p
[1] & 0x3F);
59 if ((*p
== 0xE0 && p
[1] < 0xA0) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80)
60 return *p
; /* not valid UTF-8 */
62 return ((*p
& 0x0F) << 12) + ((p
[1] & 0x3F) << 6) + (p
[2] & 0x3F);
66 if ((*p
== 0xF0 && p
[1] < 0x90) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80)
67 return *p
; /* not valid UTF-8 */
69 return ((*p
& 0x07) << 18) + ((p
[1] & 0x3F) << 12) + ((p
[2] & 0x3F) << 6) + (p
[3] & 0x3F);
73 if ((*p
== 0xF8 && p
[1] < 0x88) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80
74 || (p
[4] & 0xC0) != 0x80)
75 return *p
; /* not valid UTF-8 */
77 return ((*p
& 0x03) << 24) + ((p
[1] & 0x3F) << 18) + ((p
[2] & 0x3F) << 12) + ((p
[3] & 0x3F) << 6) + (p
[4] & 0x3F);
81 if ((*p
== 0xFC && p
[1] < 0x84) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80
82 || (p
[4] & 0xC0) != 0x80 || (p
[5] & 0xC0) != 0x80)
83 return *p
; /* not valid UTF-8 */
85 return ((*p
& 0x01) << 30) + ((p
[1] & 0x3F) << 24) + ((p
[2] & 0x3F) << 18) + ((p
[3] & 0x3F) << 12) + ((p
[4] & 0x3F) << 6) +
88 return *p
; /* not sensible */
92 * \brief check for any queued messages in specific queue (queue="" means any queue)
93 * \param dir,queue,subaddress,channel,callerid,wait,delay,retries,concurrent
94 * \retval 0 if nothing queued
95 * \retval 1 if queued and outgoing set up OK
96 * \retval 2 of outgoing exists
98 static char txqcheck (char *dir
, char *queue
, char subaddress
, char *channel
, char *callerid
, int wait
, int delay
, int retries
, int concurrent
)
106 int ql
= strlen (queue
), qfl
= ql
;
108 snprintf (dirname
, sizeof(dirname
), "sms/%s", dir
);
109 d
= opendir (dirname
);
112 while ((fn
= readdir (d
))
113 && !(*fn
->d_name
!= '.'
114 && ((!ql
&& (p
= strchr (fn
->d_name
, '.'))) || (ql
&& !strncmp (fn
->d_name
, queue
, ql
) && fn
->d_name
[ql
] == '.'))));
121 { /* not searching any specific queue, so use whatr we found as the queue */
123 qfl
= ql
= p
- queue
;
125 p
= strchr (queue
, '-');
126 if (p
&& p
< queue
+ ql
)
131 snprintf (temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
132 f
= fopen (temp
, "w");
139 fprintf (f
, "Channel: ");
141 fprintf (f
, "Local/%.*s\n", ql
, queue
);
144 p
= strchr (channel
, '/');
149 fprintf (f
, "%.*s%c%s\n", (int)(p
- channel
), channel
, subaddress
, p
+ 1);
151 fprintf (f
, "%s\n", channel
);
153 fprintf (f
, "Callerid: SMS <");
155 fprintf (f
, "%.*s", ql
, queue
);
158 p
= strchr (callerid
, 'X');
160 fprintf (f
, "%.*s%c%s", (int)(p
- callerid
), callerid
, subaddress
, p
+ 1);
162 fprintf (f
, "%s", callerid
);
165 fprintf (f
, "Application: SMS\n");
166 fprintf (f
, "Data: %.*s", qfl
, queue
);
169 fprintf (f
, "\nMaxRetries: %d\n", retries
);
170 fprintf (f
, "RetryTime: %d\n", delay
);
171 fprintf (f
, "WaitTime: %d\n", wait
);
176 while (try < concurrent
)
179 snprintf(ogname
, sizeof(ogname
), "outgoing/smsq.%s.%s.%d", dir
, queue
, try);
180 if (!link (temp
, ogname
))
187 /* failed to create call queue */
193 * \brief Process received queue entries
194 * Run through a process, setting environment variables
196 static void rxqcheck (char *dir
, char *queue
, char *process
)
203 int ql
= strlen (queue
);
205 snprintf(temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
206 snprintf(dirname
, sizeof(dirname
), "sms/%s", dir
);
207 d
= opendir (dirname
);
210 while ((fn
= readdir (d
)))
211 if ((*fn
->d_name
!= '.'
212 && ((!ql
&& (p
= strchr (fn
->d_name
, '.'))) || (ql
&& !strncmp (fn
->d_name
, queue
, ql
) && fn
->d_name
[ql
] == '.'))))
216 unsigned short ud
[160];
217 unsigned char udl
= 0;
219 snprintf (filename
, sizeof(filename
), "sms/%s/%s", dir
, fn
->d_name
);
220 if (rename (filename
, temp
))
221 continue; /* cannot access file */
222 f
= fopen (temp
, "r");
247 setenv ("queue", queue
, 1);
249 while (fgets (line
, sizeof (line
), f
))
251 for (p
= line
; *p
&& *p
!= '\n' && *p
!= '\r'; p
++);
252 *p
= 0; /* strip eoln */
254 if (!*p
|| *p
== ';')
255 continue; /* blank line or comment, ignore */
266 if (!strcmp (line
, "oa") || !strcmp (line
, "da") || !strcmp (line
, "scts") || !strcmp (line
, "pid")
267 || !strcmp (line
, "dcs") || !strcmp (line
, "mr") || !strcmp (line
, "vp"))
269 else if ((!strcmp (line
, "srr") || !strcmp (line
, "rp")) && atoi (p
))
270 setenv (line
, "", 1);
271 else if (!strcmp (line
, "ud"))
272 { /* read the user data as UTF-8 */
275 while ((v
= utf8decode (pp
)) && udl
< 160)
276 if (v
&& v
<= 0xFFFF)
279 } else if (*p
== '#')
285 if (!strcmp (line
, "udh"))
287 else if (!strcmp (line
, "ud"))
288 { /* read user data UCS-2 */
290 while (*p
&& udl
< 160)
292 if (isxdigit (*p
) && isxdigit (p
[1]) && isxdigit (p
[2]) && isxdigit (p
[3]))
295 (((isalpha (*p
) ? 9 : 0) + (*p
& 0xF)) << 12) +
296 (((isalpha (p
[1]) ? 9 : 0) + (p
[1] & 0xF)) << 8) +
297 (((isalpha (p
[2]) ? 9 : 0) + (p
[2] & 0xF)) << 4) + ((isalpha (p
[3]) ? 9 : 0) + (p
[3] & 0xF));
305 if (!strcmp (line
, "ud"))
306 { /* read user data UCS-1 */
308 while (*p
&& udl
< 160)
310 if (isxdigit (*p
) && isxdigit (p
[1]))
312 ud
[udl
++] = (((isalpha (*p
) ? 9 : 0) + (*p
& 0xF)) << 4) + ((isalpha (p
[1]) ? 9 : 0) + (p
[1] & 0xF));
322 /* set up user data variables */
327 for (n
= 0, p
= 0; p
< udl
; p
++)
329 unsigned short v
= ud
[p
];
336 temp
[n
++] = (0xC0 + (v
>> 6));
337 temp
[n
++] = (0x80 + (v
& 0x3F));
340 temp
[n
++] = (0xE0 + (v
>> 12));
341 temp
[n
++] = (0x80 + ((v
>> 6) & 0x3F));
342 temp
[n
++] = (0x80 + (v
& 0x3F));
347 setenv ("ud", temp
, 1);
348 for (n
= 0, p
= 0; p
< udl
; p
++)
350 unsigned short v
= ud
[p
];
351 if (v
< ' ' || v
== '\\')
366 temp
[n
++] = '0' + (v
>> 6);
367 temp
[n
++] = '0' + ((v
>> 3) & 7);
368 temp
[n
++] = '0' + (v
& 7);
374 temp
[n
++] = (0xC0 + (v
>> 6));
375 temp
[n
++] = (0x80 + (v
& 0x3F));
378 temp
[n
++] = (0xE0 + (v
>> 12));
379 temp
[n
++] = (0x80 + ((v
>> 6) & 0x3F));
380 temp
[n
++] = (0x80 + (v
& 0x3F));
384 setenv ("ude", temp
, 1);
385 for (p
= 0; p
< udl
&& ud
[p
] < 0x100; p
++);
388 for (n
= 0, p
= 0; p
< udl
; p
++)
390 sprintf (temp
+ n
, "%02X", ud
[p
]);
393 setenv ("ud8", temp
, 1);
395 for (n
= 0, p
= 0; p
< udl
; p
++)
397 sprintf (temp
+ n
, "%04X", ud
[p
]);
400 setenv ("ud16", temp
, 1);
402 /* run the command */
410 main (int argc
, const char *argv
[])
436 unsigned short ud
[160];
437 unsigned char *uds
= 0,
444 *spooldir
= "/var/spool/asterisk",
445 *motxchannel
= "Local/1709400X",
448 *mttxcallerid
= "080058752X0",
449 *defaultsubaddress
= "9",
452 poptContext optCon
; /* context for parsing command-line options */
453 const struct poptOption optionsTable
[] = {
454 {"queue", 'q', POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &queue
, 0, "Queue [inc sub address]", "number[-X]"},
455 {"da", 'd', POPT_ARG_STRING
, &da
, 0, "Destination address", "number"},
456 {"oa", 'o', POPT_ARG_STRING
, &oa
, 0, "Origination address", "number"},
457 {"ud", 'm', POPT_ARG_STRING
, &uds
, 0, "Message", "text"},
458 {"ud-file", 'f', POPT_ARG_STRING
, &udfile
, 0, "Message file", "filename"},
459 {"UTF-8", 0, POPT_ARG_NONE
, &utf8
, 0, "File treated as null terminated UTF-8 (default)", 0},
460 {"UCS-1", 0, POPT_ARG_NONE
, &ucs1
, 0, "File treated as UCS-1", 0},
461 {"UCS-2", 0, POPT_ARG_NONE
, &ucs2
, 0, "File treated as UCS-2", 0},
462 {"mt", 't', POPT_ARG_NONE
, &mt
, 0, "Mobile Terminated", 0},
463 {"mo", 0, POPT_ARG_NONE
, &mo
, 0, "Mobile Originated", 0},
464 {"tx", 0, POPT_ARG_NONE
, &tx
, 0, "Send message", 0},
465 {"rx", 'r', POPT_ARG_NONE
, &rx
, 0, "Queue for receipt", 0},
466 {"process", 'e', POPT_ARG_STRING
, &process
, 0, "Rx queue process command", "command"},
467 {"no-dial", 'x', POPT_ARG_NONE
, &nodial
, 0, "Do not dial", 0},
468 {"no-wait", 0, POPT_ARG_NONE
, &nowait
, 0, "Do not wait if already calling", 0},
469 {"concurrent", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &concurrent
, 0, "Number of concurrent calls to allow", "n"},
470 {"motx-channel", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxchannel
, 0, "Channel for motx calls", "channel"},
471 {"motx-callerid", 0, POPT_ARG_STRING
, &motxcallerid
, 0,
472 "Caller ID for motx calls (default is queue name without sub address)", "number"},
473 {"motx-wait", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxwait
, 0, "Time to wait for motx call to answer",
475 {"motx-delay", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxdelay
, 0, "Time between motx call retries", "seconds"},
476 {"motx-retries", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxretries
, 0, "Number of retries for motx call", "n"},
477 {"mttx-channel", 0, POPT_ARG_STRING
, &mttxchannel
, 0,
478 "Channel for mttx calls (default is Local/ and queue name without sub address)", "channel"},
479 {"mttx-callerid", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxcallerid
, 0,
480 "Caller ID for mttx calls (default is queue name without sub address)", "number"},
481 {"mttx-wait", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxwait
, 0, "Time to wait for mttx call to answer",
483 {"mttx-delay", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxdelay
, 0, "Time between mttx call retries", "seconds"},
484 {"mttx-retries", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxretries
, 0, "Number of retries for mttx call", "n"},
485 {"mr", 'n', POPT_ARG_INT
, &mr
, 0, "Message reference", "n"},
486 {"pid", 'p', POPT_ARG_INT
, &pid
, 0, "Protocol ID", "n"},
487 {"dcs", 'c', POPT_ARG_INT
, &dcs
, 0, "Data Coding Scheme", "n"},
488 {"udh", 0, POPT_ARG_STRING
, &udh
, 0, "User data header", "hex"},
489 {"srr", 0, POPT_ARG_NONE
, &srr
, 0, "Status Report Request", 0},
490 {"rp", 0, POPT_ARG_NONE
, &rp
, 0, "Return Path request", 0},
491 {"v", 0, POPT_ARG_INT
, &vp
, 0, "Validity Period", "seconds"},
492 {"scts", 0, POPT_ARG_STRING
, &scts
, 0, "Timestamp", "YYYY-MM-SSTHH:MM:SS"},
493 {"default-sub-address", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &defaultsubaddress
, 0, "Default sub address", "X"},
494 {"spool-dir", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &spooldir
, 0, "Asterisk spool dir", "dirname"},
495 POPT_AUTOHELP
{NULL
, 0, 0, NULL
, 0}
498 optCon
= poptGetContext (NULL
, argc
, argv
, optionsTable
, 0);
499 poptSetOtherOptionHelp (optCon
, "<oa/da> <message>");
501 /* Now do options processing, get portname */
502 if ((c
= poptGetNextOpt (optCon
)) < -1)
504 /* an error occurred during option processing */
505 fprintf (stderr
, "%s: %s\n", poptBadOption (optCon
, POPT_BADOPTION_NOALIAS
), poptStrerror (c
));
510 if (utf8
+ ucs1
+ ucs2
> 1)
512 fprintf (stderr
, "Pick one of UTF-8, UCS-1 or UCS-2 only\n");
515 if (!udfile
&& (ucs1
|| ucs2
))
517 fprintf (stderr
, "Command line arguments always treated as UTF-8\n");
520 /* if (!where && poptPeekArg (optCon)) where = (char *) poptGetArg (optCon); */
521 if (!mt
&& !mo
&& process
)
523 if (!mt
&& !mo
&& oa
)
529 fprintf (stderr
, "Cannot be --mt and --mo\n");
532 if (!rx
&& !tx
&& process
)
538 fprintf (stderr
, "Cannot be --tx and --rx\n");
545 fprintf (stderr
, "Cannot have --ud and --ud-file\n");
548 if (mo
&& !da
&& poptPeekArg (optCon
))
549 da
= (char *) poptGetArg (optCon
);
550 if (mt
&& !oa
&& poptPeekArg (optCon
))
551 oa
= (char *) poptGetArg (optCon
);
554 fprintf (stderr
, "--oa makes no sense with --mo as CLI is used (i.e. queue name)\n");
559 fprintf (stderr
, "--da makes no sense with --mt as called number is used (i.e. queue name)\n");
562 if (da
&& strlen (da
) > 20)
564 fprintf (stderr
, "--da too long\n");
567 if (oa
&& strlen (oa
) > 20)
569 fprintf (stderr
, "--oa too long\n");
572 if (queue
&& strlen (queue
) > 20)
574 fprintf (stderr
, "--queue name too long\n");
579 fprintf (stderr
, "scts is set my service centre\n");
583 { /* simple user data command line option in \UTF-8 */
584 while (udl
< 160 && *uds
)
586 int v
= utf8decode (&uds
);
589 fprintf (stderr
, "Invalid character U+%X at %d\n", v
, udl
);
595 if (!uds
&& !udfile
&& poptPeekArg (optCon
))
596 { /* multiple command line arguments in UTF-8 */
597 while (poptPeekArg (optCon
) && udl
< 160)
599 unsigned char *a
= (unsigned char *) poptGetArg (optCon
);
600 if (udl
&& udl
< 160)
601 ud
[udl
++] = ' '; /* space between arguments */
602 while (udl
< 160 && *a
)
604 int v
= utf8decode (&a
);
607 fprintf (stderr
, "Invalid character U+%X at %d\n", v
, udl
);
614 if (poptPeekArg (optCon
))
616 fprintf (stderr
, "Unknown argument %s\n", poptGetArg (optCon
));
620 { /* get message from file */
621 unsigned char dat
[1204],
627 f
= open (udfile
, O_RDONLY
);
635 n
= read (f
, dat
, sizeof (dat
));
646 while (p
< e
&& udl
< 160 && *p
)
647 ud
[udl
++] = utf8decode (&p
);
650 while (p
< e
&& udl
< 160)
654 while (p
+ 1 < e
&& udl
< 160)
656 ud
[udl
++] = (*p
<< 8) + p
[1];
663 char *d
= strrchr (queue
, '-');
667 subaddress
= *defaultsubaddress
;
670 if (chdir (spooldir
))
680 *dir
= (mo
? rx
? "sms/morx" : "sms/motx" : rx
? "sms/mtrx" : "sms/mttx");
682 snprintf (temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
683 mkdir ("sms", 0777); /* ensure directory exists */
684 mkdir (dir
, 0777); /* ensure directory exists */
685 snprintf (queuename
, sizeof(queuename
), "%s/%s.%ld-%d", dir
, *queue
? queue
: "0", (long)time (0), (int)getpid ());
686 f
= fopen (temp
, "w");
693 fprintf (f
, "oa=%s\n", oa
);
695 fprintf (f
, "da=%s\n", da
);
697 fprintf (f
, "scts=%s\n", scts
);
699 fprintf (f
, "pid=%d\n", pid
);
701 fprintf (f
, "dcs=%d\n", dcs
);
703 fprintf (f
, "mr=%d\n", mr
);
705 fprintf (f
, "srr=1\n");
707 fprintf (f
, "rp=1\n");
709 fprintf (f
, "udh#%s\n", udh
);
711 fprintf (f
, "vp=%d\n", vp
);
715 for (p
= 0; p
< udl
&& ud
[p
] < 0x100; p
++);
718 for (p
= 0; p
< udl
&& ud
[p
] < 0x80 && ud
[p
] >= 0x20; p
++);
722 for (p
= 0; p
< udl
; p
++)
725 { /* use one byte hex */
727 for (p
= 0; p
< udl
; p
++)
728 fprintf (f
, "%02X", ud
[p
]);
731 { /* use two byte hex */
733 for (p
= 0; p
< udl
; p
++)
734 fprintf (f
, "%04X", ud
[p
]);
739 if (rename (temp
, queuename
))
747 if (!nodial
&& tx
&& !process
)
748 { /* dial to send messages */
756 ret
= txqcheck ("motx", queue
, subaddress
, motxchannel
, motxcallerid
, motxwait
, motxdelay
, motxretries
, concurrent
);
758 ret
= txqcheck ("mttx", queue
, subaddress
, mttxchannel
, mttxcallerid
, mttxwait
, mttxdelay
, mttxretries
, concurrent
);
760 break; /* sent, or queued OK */
764 if (ret
== 2 && !nowait
)
765 fprintf (stderr
, "No call scheduled as already sending\n");
768 rxqcheck (mo
? rx
? "morx" : "motx" : rx
? "mtrx" : "mttx", queue
, process
);