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.
22 #include <sys/types.h>
32 #include <asterisk/compat.h>
34 #define POPT_ARGFLAG_SHOW_DEFAULT 0x00800000
36 #if !defined(POPT_ARGFLAG_SHOW_DEFAULT)
37 #define POPT_ARGFLAG_SHOW_DEFAULT 0x00800000
41 /* reads next USC character from null terminated UTF-8 string and advanced pointer */
42 /* for non valid UTF-8 sequences, returns character as is */
43 /* Does not advance pointer for null termination */
44 static int utf8decode (unsigned char **pp
)
46 unsigned char *p
= *pp
;
48 return 0; /* null termination of string */
51 return *p
; /* ascii or continuation character */
54 if (*p
< 0xC2 || (p
[1] & 0xC0) != 0x80)
55 return *p
; /* not valid UTF-8 */
57 return ((*p
& 0x1F) << 6) + (p
[1] & 0x3F);
61 if ((*p
== 0xE0 && p
[1] < 0xA0) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80)
62 return *p
; /* not valid UTF-8 */
64 return ((*p
& 0x0F) << 12) + ((p
[1] & 0x3F) << 6) + (p
[2] & 0x3F);
68 if ((*p
== 0xF0 && p
[1] < 0x90) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80)
69 return *p
; /* not valid UTF-8 */
71 return ((*p
& 0x07) << 18) + ((p
[1] & 0x3F) << 12) + ((p
[2] & 0x3F) << 6) + (p
[3] & 0x3F);
75 if ((*p
== 0xF8 && p
[1] < 0x88) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80
76 || (p
[4] & 0xC0) != 0x80)
77 return *p
; /* not valid UTF-8 */
79 return ((*p
& 0x03) << 24) + ((p
[1] & 0x3F) << 18) + ((p
[2] & 0x3F) << 12) + ((p
[3] & 0x3F) << 6) + (p
[4] & 0x3F);
83 if ((*p
== 0xFC && p
[1] < 0x84) || (p
[1] & 0xC0) != 0x80 || (p
[2] & 0xC0) != 0x80 || (p
[3] & 0xC0) != 0x80
84 || (p
[4] & 0xC0) != 0x80 || (p
[5] & 0xC0) != 0x80)
85 return *p
; /* not valid UTF-8 */
87 return ((*p
& 0x01) << 30) + ((p
[1] & 0x3F) << 24) + ((p
[2] & 0x3F) << 18) + ((p
[3] & 0x3F) << 12) + ((p
[4] & 0x3F) << 6) +
90 return *p
; /* not sensible */
93 /* check for any queued messages in specific queue (queue="" means any queue) */
94 /* returns 0 if nothing queued, 1 if queued and outgoing set up OK, 2 of outgoing exists */
95 static char txqcheck (char *dir
, char *queue
, char subaddress
, char *channel
, char *callerid
, int wait
, int delay
, int retries
, int concurrent
)
103 int ql
= strlen (queue
), qfl
= ql
;
105 snprintf (dirname
, sizeof(dirname
), "sms/%s", dir
);
106 d
= opendir (dirname
);
109 while ((fn
= readdir (d
))
110 && !(*fn
->d_name
!= '.'
111 && ((!ql
&& (p
= strchr (fn
->d_name
, '.'))) || (ql
&& !strncmp (fn
->d_name
, queue
, ql
) && fn
->d_name
[ql
] == '.'))));
118 { /* not searching any specific queue, so use whatr we found as the queue */
120 qfl
= ql
= p
- queue
;
122 p
= strchr (queue
, '-');
123 if (p
&& p
< queue
+ ql
)
128 snprintf (temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
129 f
= fopen (temp
, "w");
136 fprintf (f
, "Channel: ");
138 fprintf (f
, "Local/%.*s\n", ql
, queue
);
141 p
= strchr (channel
, '/');
146 fprintf (f
, "%.*s%c%s\n", (int)(p
- channel
), channel
, subaddress
, p
+ 1);
148 fprintf (f
, "%s\n", channel
);
150 fprintf (f
, "Callerid: SMS <");
152 fprintf (f
, "%.*s", ql
, queue
);
155 p
= strchr (callerid
, 'X');
157 fprintf (f
, "%.*s%c%s", (int)(p
- callerid
), callerid
, subaddress
, p
+ 1);
159 fprintf (f
, "%s", callerid
);
162 fprintf (f
, "Application: SMS\n");
163 fprintf (f
, "Data: %.*s", qfl
, queue
);
166 fprintf (f
, "\nMaxRetries: %d\n", retries
);
167 fprintf (f
, "RetryTime: %d\n", delay
);
168 fprintf (f
, "WaitTime: %d\n", wait
);
173 while (try < concurrent
)
176 snprintf(ogname
, sizeof(ogname
), "outgoing/smsq.%s.%s.%d", dir
, queue
, try);
177 if (!link (temp
, ogname
))
184 /* failed to create call queue */
189 /* Process received queue entries and run through a process, setting environment variables */
190 static void rxqcheck (char *dir
, char *queue
, char *process
)
197 int ql
= strlen (queue
);
199 snprintf(temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
200 snprintf(dirname
, sizeof(dirname
), "sms/%s", dir
);
201 d
= opendir (dirname
);
204 while ((fn
= readdir (d
)))
205 if ((*fn
->d_name
!= '.'
206 && ((!ql
&& (p
= strchr (fn
->d_name
, '.'))) || (ql
&& !strncmp (fn
->d_name
, queue
, ql
) && fn
->d_name
[ql
] == '.'))))
210 unsigned short ud
[160];
211 unsigned char udl
= 0;
213 snprintf (filename
, sizeof(filename
), "sms/%s/%s", dir
, fn
->d_name
);
214 if (rename (filename
, temp
))
215 continue; /* cannot access file */
216 f
= fopen (temp
, "r");
241 setenv ("queue", queue
, 1);
243 while (fgets (line
, sizeof (line
), f
))
245 for (p
= line
; *p
&& *p
!= '\n' && *p
!= '\r'; p
++);
246 *p
= 0; /* strip eoln */
248 if (!*p
|| *p
== ';')
249 continue; /* blank line or comment, ignore */
260 if (!strcmp (line
, "oa") || !strcmp (line
, "da") || !strcmp (line
, "scts") || !strcmp (line
, "pid")
261 || !strcmp (line
, "dcs") || !strcmp (line
, "mr") || !strcmp (line
, "vp"))
263 else if ((!strcmp (line
, "srr") || !strcmp (line
, "rp")) && atoi (p
))
264 setenv (line
, "", 1);
265 else if (!strcmp (line
, "ud"))
266 { /* read the user data as UTF-8 */
269 while ((v
= utf8decode (pp
)) && udl
< 160)
270 if (v
&& v
<= 0xFFFF)
273 } else if (*p
== '#')
279 if (!strcmp (line
, "udh"))
281 else if (!strcmp (line
, "ud"))
282 { /* read user data UCS-2 */
284 while (*p
&& udl
< 160)
286 if (isxdigit (*p
) && isxdigit (p
[1]) && isxdigit (p
[2]) && isxdigit (p
[3]))
289 (((isalpha (*p
) ? 9 : 0) + (*p
& 0xF)) << 12) +
290 (((isalpha (p
[1]) ? 9 : 0) + (p
[1] & 0xF)) << 8) +
291 (((isalpha (p
[2]) ? 9 : 0) + (p
[2] & 0xF)) << 4) + ((isalpha (p
[3]) ? 9 : 0) + (p
[3] & 0xF));
299 if (!strcmp (line
, "ud"))
300 { /* read user data UCS-1 */
302 while (*p
&& udl
< 160)
304 if (isxdigit (*p
) && isxdigit (p
[1]))
306 ud
[udl
++] = (((isalpha (*p
) ? 9 : 0) + (*p
& 0xF)) << 4) + ((isalpha (p
[1]) ? 9 : 0) + (p
[1] & 0xF));
316 /* set up user data variables */
321 for (n
= 0, p
= 0; p
< udl
; p
++)
323 unsigned short v
= ud
[p
];
330 temp
[n
++] = (0xC0 + (v
>> 6));
331 temp
[n
++] = (0x80 + (v
& 0x3F));
334 temp
[n
++] = (0xE0 + (v
>> 12));
335 temp
[n
++] = (0x80 + ((v
>> 6) & 0x3F));
336 temp
[n
++] = (0x80 + (v
& 0x3F));
341 setenv ("ud", temp
, 1);
342 for (n
= 0, p
= 0; p
< udl
; p
++)
344 unsigned short v
= ud
[p
];
345 if (v
< ' ' || v
== '\\')
360 temp
[n
++] = '0' + (v
>> 6);
361 temp
[n
++] = '0' + ((v
>> 3) & 7);
362 temp
[n
++] = '0' + (v
& 7);
368 temp
[n
++] = (0xC0 + (v
>> 6));
369 temp
[n
++] = (0x80 + (v
& 0x3F));
372 temp
[n
++] = (0xE0 + (v
>> 12));
373 temp
[n
++] = (0x80 + ((v
>> 6) & 0x3F));
374 temp
[n
++] = (0x80 + (v
& 0x3F));
378 setenv ("ude", temp
, 1);
379 for (p
= 0; p
< udl
&& ud
[p
] < 0x100; p
++);
382 for (n
= 0, p
= 0; p
< udl
; p
++)
384 sprintf (temp
+ n
, "%02X", ud
[p
]);
387 setenv ("ud8", temp
, 1);
389 for (n
= 0, p
= 0; p
< udl
; p
++)
391 sprintf (temp
+ n
, "%04X", ud
[p
]);
394 setenv ("ud16", temp
, 1);
396 /* run the command */
404 main (int argc
, const char *argv
[])
430 unsigned short ud
[160];
431 unsigned char *uds
= 0,
438 *spooldir
= "/var/spool/asterisk",
439 *motxchannel
= "Local/1709400X",
442 *mttxcallerid
= "080058752X0",
443 *defaultsubaddress
= "9",
446 poptContext optCon
; /* context for parsing command-line options */
447 const struct poptOption optionsTable
[] = {
448 {"queue", 'q', POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &queue
, 0, "Queue [inc sub address]", "number[-X]"},
449 {"da", 'd', POPT_ARG_STRING
, &da
, 0, "Destination address", "number"},
450 {"oa", 'o', POPT_ARG_STRING
, &oa
, 0, "Origination address", "number"},
451 {"ud", 'm', POPT_ARG_STRING
, &uds
, 0, "Message", "text"},
452 {"ud-file", 'f', POPT_ARG_STRING
, &udfile
, 0, "Message file", "filename"},
453 {"UTF-8", 0, POPT_ARG_NONE
, &utf8
, 0, "File treated as null terminated UTF-8 (default)", 0},
454 {"UCS-1", 0, POPT_ARG_NONE
, &ucs1
, 0, "File treated as UCS-1", 0},
455 {"UCS-2", 0, POPT_ARG_NONE
, &ucs2
, 0, "File treated as UCS-2", 0},
456 {"mt", 't', POPT_ARG_NONE
, &mt
, 0, "Mobile Terminated", 0},
457 {"mo", 0, POPT_ARG_NONE
, &mo
, 0, "Mobile Originated", 0},
458 {"tx", 0, POPT_ARG_NONE
, &tx
, 0, "Send message", 0},
459 {"rx", 'r', POPT_ARG_NONE
, &rx
, 0, "Queue for receipt", 0},
460 {"process", 'e', POPT_ARG_STRING
, &process
, 0, "Rx queue process command", "command"},
461 {"no-dial", 'x', POPT_ARG_NONE
, &nodial
, 0, "Do not dial", 0},
462 {"no-wait", 0, POPT_ARG_NONE
, &nowait
, 0, "Do not wait if already calling", 0},
463 {"concurrent", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &concurrent
, 0, "Number of concurrent calls to allow", "n"},
464 {"motx-channel", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxchannel
, 0, "Channel for motx calls", "channel"},
465 {"motx-callerid", 0, POPT_ARG_STRING
, &motxcallerid
, 0,
466 "Caller ID for motx calls (default is queue name without sub address)", "number"},
467 {"motx-wait", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxwait
, 0, "Time to wait for motx call to answer",
469 {"motx-delay", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxdelay
, 0, "Time between motx call retries", "seconds"},
470 {"motx-retries", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &motxretries
, 0, "Number of retries for motx call", "n"},
471 {"mttx-channel", 0, POPT_ARG_STRING
, &mttxchannel
, 0,
472 "Channel for mttx calls (default is Local/ and queue name without sub address)", "channel"},
473 {"mttx-callerid", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxcallerid
, 0,
474 "Caller ID for mttx calls (default is queue name without sub address)", "number"},
475 {"mttx-wait", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxwait
, 0, "Time to wait for mttx call to answer",
477 {"mttx-delay", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxdelay
, 0, "Time between mttx call retries", "seconds"},
478 {"mttx-retries", 0, POPT_ARG_INT
| POPT_ARGFLAG_SHOW_DEFAULT
, &mttxretries
, 0, "Number of retries for mttx call", "n"},
479 {"mr", 'n', POPT_ARG_INT
, &mr
, 0, "Message reference", "n"},
480 {"pid", 'p', POPT_ARG_INT
, &pid
, 0, "Protocol ID", "n"},
481 {"dcs", 'c', POPT_ARG_INT
, &dcs
, 0, "Data Coding Scheme", "n"},
482 {"udh", 0, POPT_ARG_STRING
, &udh
, 0, "User data header", "hex"},
483 {"srr", 0, POPT_ARG_NONE
, &srr
, 0, "Status Report Request", 0},
484 {"rp", 0, POPT_ARG_NONE
, &rp
, 0, "Return Path request", 0},
485 {"v", 0, POPT_ARG_INT
, &vp
, 0, "Validity Period", "seconds"},
486 {"scts", 0, POPT_ARG_STRING
, &scts
, 0, "Timestamp", "YYYY-MM-SSTHH:MM:SS"},
487 {"default-sub-address", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &defaultsubaddress
, 0, "Default sub address", "X"},
488 {"spool-dir", 0, POPT_ARG_STRING
| POPT_ARGFLAG_SHOW_DEFAULT
, &spooldir
, 0, "Asterisk spool dir", "dirname"},
489 POPT_AUTOHELP
{NULL
, 0, 0, NULL
, 0}
492 optCon
= poptGetContext (NULL
, argc
, argv
, optionsTable
, 0);
493 poptSetOtherOptionHelp (optCon
, "<oa/da> <message>");
495 /* Now do options processing, get portname */
496 if ((c
= poptGetNextOpt (optCon
)) < -1)
498 /* an error occurred during option processing */
499 fprintf (stderr
, "%s: %s\n", poptBadOption (optCon
, POPT_BADOPTION_NOALIAS
), poptStrerror (c
));
504 if (utf8
+ ucs1
+ ucs2
> 1)
506 fprintf (stderr
, "Pick one of UTF-8, UCS-1 or UCS-2 only\n");
509 if (!udfile
&& (ucs1
|| ucs2
))
511 fprintf (stderr
, "Command line arguments always treated as UTF-8\n");
514 /* if (!where && poptPeekArg (optCon)) where = (char *) poptGetArg (optCon); */
515 if (!mt
&& !mo
&& process
)
517 if (!mt
&& !mo
&& oa
)
523 fprintf (stderr
, "Cannot be --mt and --mo\n");
526 if (!rx
&& !tx
&& process
)
532 fprintf (stderr
, "Cannot be --tx and --rx\n");
539 fprintf (stderr
, "Cannot have --ud and --ud-file\n");
542 if (mo
&& !da
&& poptPeekArg (optCon
))
543 da
= (char *) poptGetArg (optCon
);
544 if (mt
&& !oa
&& poptPeekArg (optCon
))
545 oa
= (char *) poptGetArg (optCon
);
548 fprintf (stderr
, "--oa makes no sense with --mo as CLI is used (i.e. queue name)\n");
553 fprintf (stderr
, "--da makes no sense with --mt as called number is used (i.e. queue name)\n");
556 if (da
&& strlen (da
) > 20)
558 fprintf (stderr
, "--da too long\n");
561 if (oa
&& strlen (oa
) > 20)
563 fprintf (stderr
, "--oa too long\n");
566 if (queue
&& strlen (queue
) > 20)
568 fprintf (stderr
, "--queue name too long\n");
573 fprintf (stderr
, "scts is set my service centre\n");
577 { /* simple user data command line option in \UTF-8 */
578 while (udl
< 160 && *uds
)
580 int v
= utf8decode (&uds
);
583 fprintf (stderr
, "Invalid character U+%X at %d\n", v
, udl
);
589 if (!uds
&& !udfile
&& poptPeekArg (optCon
))
590 { /* multiple command line arguments in UTF-8 */
591 while (poptPeekArg (optCon
) && udl
< 160)
593 unsigned char *a
= (unsigned char *) poptGetArg (optCon
);
594 if (udl
&& udl
< 160)
595 ud
[udl
++] = ' '; /* space between arguments */
596 while (udl
< 160 && *a
)
598 int v
= utf8decode (&a
);
601 fprintf (stderr
, "Invalid character U+%X at %d\n", v
, udl
);
608 if (poptPeekArg (optCon
))
610 fprintf (stderr
, "Unknown argument %s\n", poptGetArg (optCon
));
614 { /* get message from file */
615 unsigned char dat
[1204],
621 f
= open (udfile
, O_RDONLY
);
629 n
= read (f
, dat
, sizeof (dat
));
640 while (p
< e
&& udl
< 160 && *p
)
641 ud
[udl
++] = utf8decode (&p
);
644 while (p
< e
&& udl
< 160)
648 while (p
+ 1 < e
&& udl
< 160)
650 ud
[udl
++] = (*p
<< 8) + p
[1];
657 char *d
= strrchr (queue
, '-');
661 subaddress
= *defaultsubaddress
;
664 if (chdir (spooldir
))
674 *dir
= (mo
? rx
? "sms/morx" : "sms/motx" : rx
? "sms/mtrx" : "sms/mttx");
676 snprintf (temp
, sizeof(temp
), "sms/.smsq-%d", (int)getpid ());
677 mkdir ("sms", 0777); /* ensure directory exists */
678 mkdir (dir
, 0777); /* ensure directory exists */
679 snprintf (queuename
, sizeof(queuename
), "%s/%s.%ld-%d", dir
, *queue
? queue
: "0", (long)time (0), (int)getpid ());
680 f
= fopen (temp
, "w");
687 fprintf (f
, "oa=%s\n", oa
);
689 fprintf (f
, "da=%s\n", da
);
691 fprintf (f
, "scts=%s\n", scts
);
693 fprintf (f
, "pid=%d\n", pid
);
695 fprintf (f
, "dcs=%d\n", dcs
);
697 fprintf (f
, "mr=%d\n", mr
);
699 fprintf (f
, "srr=1\n");
701 fprintf (f
, "rp=1\n");
703 fprintf (f
, "udh#%s\n", udh
);
705 fprintf (f
, "vp=%d\n", vp
);
709 for (p
= 0; p
< udl
&& ud
[p
] < 0x100; p
++);
712 for (p
= 0; p
< udl
&& ud
[p
] < 0x80 && ud
[p
] >= 0x20; p
++);
716 for (p
= 0; p
< udl
; p
++)
719 { /* use one byte hex */
721 for (p
= 0; p
< udl
; p
++)
722 fprintf (f
, "%02X", ud
[p
]);
725 { /* use two byte hex */
727 for (p
= 0; p
< udl
; p
++)
728 fprintf (f
, "%04X", ud
[p
]);
733 if (rename (temp
, queuename
))
741 if (!nodial
&& tx
&& !process
)
742 { /* dial to send messages */
750 ret
= txqcheck ("motx", queue
, subaddress
, motxchannel
, motxcallerid
, motxwait
, motxdelay
, motxretries
, concurrent
);
752 ret
= txqcheck ("mttx", queue
, subaddress
, mttxchannel
, mttxcallerid
, mttxwait
, mttxdelay
, mttxretries
, concurrent
);
754 break; /* sent, or queued OK */
758 if (ret
== 2 && !nowait
)
759 fprintf (stderr
, "No call scheduled as already sending\n");
762 rxqcheck (mo
? rx
? "morx" : "motx" : rx
? "mtrx" : "mttx", queue
, process
);