diff options
| -rwxr-xr-x | apps/app_sms.c | 2741 |
1 files changed, 1305 insertions, 1436 deletions
diff --git a/apps/app_sms.c b/apps/app_sms.c index 401d20fea..f2a6c7569 100755 --- a/apps/app_sms.c +++ b/apps/app_sms.c @@ -30,7 +30,7 @@ #include "astconf.h" /* output using Alaw rather than linear */ -/*#define OUTALAW */ +/* #define OUTALAW */ /* ToDo */ /* Add full VP support */ @@ -51,24 +51,28 @@ static char *app = "SMS"; static char *synopsis = "Communicates with SMS service centres and SMS capable analogue phones"; static char *descrip = - " SMS(name|[a][s]): SMS handles exchange of SMS data with a call to/from SMS capabale\n" - "phone or SMS PSTN service centre. Can send and/or receive SMS messages.\n" - "Returns 0 if call handled correctly, or -1 if there were any problems.\n" - "Works to ETSI ES 201 912 compatible with BT SMS PSTN service in UK\n" - "Typical usage is to use to handle called from the SMS service centre CLI,\n" - "or to set up a call using 'outgoing' or manager interface to connect service centre to SMS()\n" - "name is the name of the queue used in /var/spool/asterisk/sms\n" - "Argument 'a' means answer, i.e. send initial FSK packet.\n" - "Argument 's' means act as service centre talking to a phone.\n" - "Messages are processed as per text file message queues.\n" "smsq is a command to generate message queues and send messages.\n"; - -static signed short wave[] = - { 0, 392, 782, 1167, 1545, 1913, 2270, 2612, 2939, 3247, 3536, 3802, 4045, 4263, 4455, 4619, 4755, 4862, 4938, 4985, - 5000, 4985, 4938, 4862, 4755, 4619, 4455, 4263, 4045, 3802, 3536, 3247, 2939, 2612, 2270, 1913, 1545, 1167, 782, 392, - 0, -392, -782, -1167, - -1545, -1913, -2270, -2612, -2939, -3247, -3536, -3802, -4045, -4263, -4455, -4619, -4755, -4862, -4938, -4985, -5000, - -4985, -4938, -4862, - -4755, -4619, -4455, -4263, -4045, -3802, -3536, -3247, -2939, -2612, -2270, -1913, -1545, -1167, -782, -392 + " SMS(name|[a][s]): SMS handles exchange of SMS data with a call to/from SMS capabale\n" + "phone or SMS PSTN service centre. Can send and/or receive SMS messages.\n" + "Returns 0 if call handled correctly, or -1 if there were any problems.\n" + "Works to ETSI ES 201 912 compatible with BT SMS PSTN service in UK\n" + "Typical usage is to use to handle called from the SMS service centre CLI,\n" + "or to set up a call using 'outgoing' or manager interface to connect\n" + "service centre to SMS()\n" + "name is the name of the queue used in /var/spool/asterisk/sms\n" + "Arguments:\n" + " a: answer, i.e. send initial FSK packet.\n" + " s: act as service centre talking to a phone.\n" + "Messages are processed as per text file message queues.\n" + "smsq (a separate software) is a command to generate message\n" + "queues and send messages.\n"; + +static signed short wave[] = { + 0, 392, 782, 1167, 1545, 1913, 2270, 2612, 2939, 3247, 3536, 3802, 4045, 4263, 4455, 4619, 4755, 4862, 4938, 4985, + 5000, 4985, 4938, 4862, 4755, 4619, 4455, 4263, 4045, 3802, 3536, 3247, 2939, 2612, 2270, 1913, 1545, 1167, 782, 392, + 0, -392, -782, -1167, + -1545, -1913, -2270, -2612, -2939, -3247, -3536, -3802, -4045, -4263, -4455, -4619, -4755, -4862, -4938, -4985, -5000, + -4985, -4938, -4862, + -4755, -4619, -4455, -4263, -4045, -3802, -3536, -3247, -2939, -2612, -2270, -1913, -1545, -1167, -782, -392 }; #ifdef OUTALAW @@ -81,84 +85,84 @@ LOCAL_USER_DECL; /* SMS 7 bit character mapping to UCS-2 */ static const unsigned short defaultalphabet[] = { - 0x0040, 0x00A3, 0x0024, 0x00A5, 0x00E8, 0x00E9, 0x00F9, 0x00EC, - 0x00F2, 0x00E7, 0x000A, 0x00D8, 0x00F8, 0x000D, 0x00C5, 0x00E5, - 0x0394, 0x005F, 0x03A6, 0x0393, 0x039B, 0x03A9, 0x03A0, 0x03A8, - 0x03A3, 0x0398, 0x039E, 0x00A0, 0x00C6, 0x00E6, 0x00DF, 0x00C9, - ' ', '!', '"', '#', 164, '%', '&', 39, '(', ')', '*', '+', ',', '-', '.', '/', - '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', ':', ';', '<', '=', '>', '?', - 161, 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', - 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 196, 214, 209, 220, 167, - 191, 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', - 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', 228, 246, 241, 252, 224, + 0x0040, 0x00A3, 0x0024, 0x00A5, 0x00E8, 0x00E9, 0x00F9, 0x00EC, + 0x00F2, 0x00E7, 0x000A, 0x00D8, 0x00F8, 0x000D, 0x00C5, 0x00E5, + 0x0394, 0x005F, 0x03A6, 0x0393, 0x039B, 0x03A9, 0x03A0, 0x03A8, + 0x03A3, 0x0398, 0x039E, 0x00A0, 0x00C6, 0x00E6, 0x00DF, 0x00C9, + ' ', '!', '"', '#', 164, '%', '&', 39, '(', ')', '*', '+', ',', '-', '.', '/', + '0', '1', '2', '3', '4', '5', '6', '7', '8', '9', ':', ';', '<', '=', '>', '?', + 161, 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J', 'K', 'L', 'M', 'N', 'O', + 'P', 'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 'Y', 'Z', 196, 214, 209, 220, 167, + 191, 'a', 'b', 'c', 'd', 'e', 'f', 'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 'o', + 'p', 'q', 'r', 's', 't', 'u', 'v', 'w', 'x', 'y', 'z', 228, 246, 241, 252, 224, }; static const unsigned short escapes[] = { - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x000C, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0x005E, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0, 0, 0, 0, 0x007B, 0x007D, 0, 0, 0, 0, 0, 0x005C, - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x005B, 0x007E, 0x005D, 0, - 0x007C, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0, 0x20AC, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, - 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x000C, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0x005E, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 0, 0, 0, 0x007B, 0x007D, 0, 0, 0, 0, 0, 0x005C, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0x005B, 0x007E, 0x005D, 0, + 0x007C, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 0x20AC, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, + 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, }; #define SMSLEN 160 /* max SMS length */ typedef struct sms_s { - unsigned char hangup; /* we are done... */ - unsigned char err; /* set for any errors */ - unsigned char smsc:1; /* we are SMSC */ - unsigned char rx:1; /* this is a received message */ - char queue[30]; /* queue name */ - char oa[20]; /* originating address */ - char da[20]; /* destination address */ - time_t scts; /* time stamp, UTC */ - unsigned char pid; /* protocol ID */ - unsigned char dcs; /* data coding scheme */ - short mr; /* message reference - actually a byte, but usde -1 for not set */ - int udl; /* user data length */ - int udhl; /* user data header length */ - unsigned char srr:1; /* Status Report request */ - unsigned char udhi:1; /* User Data Header required, even if length 0 */ - unsigned char rp:1; /* Reply Path */ - unsigned int vp; /* validity period in minutes, 0 for not set */ - unsigned short ud[SMSLEN]; /* user data (message), UCS-2 coded */ - unsigned char udh[SMSLEN]; /* user data header */ - unsigned char cli[20]; /* caller ID */ - unsigned char ophase; /* phase (0-79) for 0 and 1 frequencies (1300Hz and 2100Hz) */ - unsigned char ophasep; /* phase (0-79) for 1200 bps */ - unsigned char obyte; /* byte being sent */ - unsigned int opause; /* silent pause before sending (in sample periods) */ - unsigned char obitp; /* bit in byte */ - unsigned char osync; /* sync bits to send */ - unsigned char obytep; /* byte in data */ - unsigned char obyten; /* bytes in data */ - unsigned char omsg[256]; /* data buffer (out) */ - unsigned char imsg[200]; /* data buffer (in) */ - signed long long ims0, - imc0, - ims1, - imc1; /* magnitude averages sin/cos 0/1 */ - unsigned int idle; - unsigned short imag; /* signal level */ - unsigned char ips0, - ips1, - ipc0, - ipc1; /* phase sin/cos 0/1 */ - unsigned char ibitl; /* last bit */ - unsigned char ibitc; /* bit run length count */ - unsigned char iphasep; /* bit phase (0-79) for 1200 bps */ - unsigned char ibitn; /* bit number in byte being received */ - unsigned char ibytev; /* byte value being received */ - unsigned char ibytep; /* byte pointer in messafe */ - unsigned char ibytec; /* byte checksum for message */ - unsigned char ierr; /* error flag */ - unsigned char ibith; /* history of last bits */ - unsigned char ibitt; /* total of 1's in last 3 bites */ - /* more to go here */ + unsigned char hangup; /* we are done... */ + unsigned char err; /* set for any errors */ + unsigned char smsc:1; /* we are SMSC */ + unsigned char rx:1; /* this is a received message */ + char queue[30]; /* queue name */ + char oa[20]; /* originating address */ + char da[20]; /* destination address */ + time_t scts; /* time stamp, UTC */ + unsigned char pid; /* protocol ID */ + unsigned char dcs; /* data coding scheme */ + short mr; /* message reference - actually a byte, but usde -1 for not set */ + int udl; /* user data length */ + int udhl; /* user data header length */ + unsigned char srr:1; /* Status Report request */ + unsigned char udhi:1; /* User Data Header required, even if length 0 */ + unsigned char rp:1; /* Reply Path */ + unsigned int vp; /* validity period in minutes, 0 for not set */ + unsigned short ud[SMSLEN]; /* user data (message), UCS-2 coded */ + unsigned char udh[SMSLEN]; /* user data header */ + unsigned char cli[20]; /* caller ID */ + unsigned char ophase; /* phase (0-79) for 0 and 1 frequencies (1300Hz and 2100Hz) */ + unsigned char ophasep; /* phase (0-79) for 1200 bps */ + unsigned char obyte; /* byte being sent */ + unsigned int opause; /* silent pause before sending (in sample periods) */ + unsigned char obitp; /* bit in byte */ + unsigned char osync; /* sync bits to send */ + unsigned char obytep; /* byte in data */ + unsigned char obyten; /* bytes in data */ + unsigned char omsg[256]; /* data buffer (out) */ + unsigned char imsg[200]; /* data buffer (in) */ + signed long long ims0, + imc0, + ims1, + imc1; /* magnitude averages sin/cos 0/1 */ + unsigned int idle; + unsigned short imag; /* signal level */ + unsigned char ips0, + ips1, + ipc0, + ipc1; /* phase sin/cos 0/1 */ + unsigned char ibitl; /* last bit */ + unsigned char ibitc; /* bit run length count */ + unsigned char iphasep; /* bit phase (0-79) for 1200 bps */ + unsigned char ibitn; /* bit number in byte being received */ + unsigned char ibytev; /* byte value being received */ + unsigned char ibytep; /* byte pointer in messafe */ + unsigned char ibytec; /* byte checksum for message */ + unsigned char ierr; /* error flag */ + unsigned char ibith; /* history of last bits */ + unsigned char ibitt; /* total of 1's in last 3 bites */ + /* more to go here */ } sms_t; /* different types of encoding */ @@ -166,1495 +170,1360 @@ typedef struct sms_s #define is8bit(dcs) (((dcs)&0xC0)?(((dcs)&4)):(((dcs)&12)==4)) #define is16bit(dcs) (((dcs)&0xC0)?0:(((dcs)&12)==8)) -static void * -sms_alloc (struct ast_channel *chan, void *params) +static void *sms_alloc (struct ast_channel *chan, void *params) { - return params; + return params; } -static void -sms_release (struct ast_channel *chan, void *data) +static void sms_release (struct ast_channel *chan, void *data) { - return; + return; } static void sms_messagetx (sms_t * h); -/* copy number, skipping non digits apart from leading + */ -static void -numcpy (char *d, char *s) +/*--- numcpy: copy number, skipping non digits apart from leading + */ +static void numcpy (char *d, char *s) { - if (*s == '+') - *d++ = *s++; - while (*s) - { - if (isdigit (*s)) - *d++ = *s; - s++; - } - *d = 0; + if (*s == '+') + *d++ = *s++; + while (*s) { + if (isdigit (*s)) + *d++ = *s; + s++; + } + *d = 0; } -static char * -isodate (time_t t) -{ /* static, return a date/time in ISO format */ - static char date[20]; - strftime (date, sizeof (date), "%Y-%m-%dT%H:%M:%S", localtime (&t)); - return date; +/*--- isodate: static, return a date/time in ISO format */ +static char * isodate (time_t t) +{ + static char date[20]; + strftime (date, sizeof (date), "%Y-%m-%dT%H:%M:%S", localtime (&t)); + return date; } -/* reads next UCS character from null terminated UTF-8 string and advanced pointer */ +/*--- utf8decode: reads next UCS character from null terminated UTF-8 string and advanced pointer */ /* for non valid UTF-8 sequences, returns character as is */ /* Does not advance pointer for null termination */ -static long -utf8decode (unsigned char **pp) +static long utf8decode (unsigned char **pp) { - unsigned char *p = *pp; - if (!*p) - return 0; /* null termination of string */ - (*pp)++; - if (*p < 0xC0) - return *p; /* ascii or continuation character */ - if (*p < 0xE0) - { - if (*p < 0xC2 || (p[1] & 0xC0) != 0x80) - return *p; /* not valid UTF-8 */ - (*pp)++; - return ((*p & 0x1F) << 6) + (p[1] & 0x3F); - } - if (*p < 0xF0) - { - if ((*p == 0xE0 && p[1] < 0xA0) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80) - return *p; /* not valid UTF-8 */ - (*pp) += 2; - return ((*p & 0x0F) << 12) + ((p[1] & 0x3F) << 6) + (p[2] & 0x3F); - } - if (*p < 0xF8) - { - if ((*p == 0xF0 && p[1] < 0x90) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80) - return *p; /* not valid UTF-8 */ - (*pp) += 3; - return ((*p & 0x07) << 18) + ((p[1] & 0x3F) << 12) + ((p[2] & 0x3F) << 6) + (p[3] & 0x3F); - } - if (*p < 0xFC) - { - if ((*p == 0xF8 && p[1] < 0x88) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80 - || (p[4] & 0xC0) != 0x80) - return *p; /* not valid UTF-8 */ - (*pp) += 4; - return ((*p & 0x03) << 24) + ((p[1] & 0x3F) << 18) + ((p[2] & 0x3F) << 12) + ((p[3] & 0x3F) << 6) + (p[4] & 0x3F); - } - if (*p < 0xFE) - { - if ((*p == 0xFC && p[1] < 0x84) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80 - || (p[4] & 0xC0) != 0x80 || (p[5] & 0xC0) != 0x80) - return *p; /* not valid UTF-8 */ - (*pp) += 5; - return ((*p & 0x01) << 30) + ((p[1] & 0x3F) << 24) + ((p[2] & 0x3F) << 18) + ((p[3] & 0x3F) << 12) + ((p[4] & 0x3F) << 6) + - (p[5] & 0x3F); - } - return *p; /* not sensible */ + unsigned char *p = *pp; + if (!*p) + return 0; /* null termination of string */ + (*pp)++; + if (*p < 0xC0) + return *p; /* ascii or continuation character */ + if (*p < 0xE0) { + if (*p < 0xC2 || (p[1] & 0xC0) != 0x80) + return *p; /* not valid UTF-8 */ + (*pp)++; + return ((*p & 0x1F) << 6) + (p[1] & 0x3F); + } + if (*p < 0xF0) { + if ((*p == 0xE0 && p[1] < 0xA0) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80) + return *p; /* not valid UTF-8 */ + (*pp) += 2; + return ((*p & 0x0F) << 12) + ((p[1] & 0x3F) << 6) + (p[2] & 0x3F); + } + if (*p < 0xF8) { + if ((*p == 0xF0 && p[1] < 0x90) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80) + return *p; /* not valid UTF-8 */ + (*pp) += 3; + return ((*p & 0x07) << 18) + ((p[1] & 0x3F) << 12) + ((p[2] & 0x3F) << 6) + (p[3] & 0x3F); + } + if (*p < 0xFC) { + if ((*p == 0xF8 && p[1] < 0x88) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80 + || (p[4] & 0xC0) != 0x80) + return *p; /* not valid UTF-8 */ + (*pp) += 4; + return ((*p & 0x03) << 24) + ((p[1] & 0x3F) << 18) + ((p[2] & 0x3F) << 12) + ((p[3] & 0x3F) << 6) + (p[4] & 0x3F); + } + if (*p < 0xFE) { + if ((*p == 0xFC && p[1] < 0x84) || (p[1] & 0xC0) != 0x80 || (p[2] & 0xC0) != 0x80 || (p[3] & 0xC0) != 0x80 + || (p[4] & 0xC0) != 0x80 || (p[5] & 0xC0) != 0x80) + return *p; /* not valid UTF-8 */ + (*pp) += 5; + return ((*p & 0x01) << 30) + ((p[1] & 0x3F) << 24) + ((p[2] & 0x3F) << 18) + ((p[3] & 0x3F) << 12) + ((p[4] & 0x3F) << 6) + (p[5] & 0x3F); + } + return *p; /* not sensible */ } -/* This takes a binary header (udhl bytes at udh) and UCS-2 message (udl characters at ud) and packs in to o using SMS 7 bit character codes */ +/*--- packsms7: takes a binary header (udhl bytes at udh) and UCS-2 message (udl characters at ud) and packs in to o using SMS 7 bit character codes */ /* The return value is the number of septets packed in to o, which is internally limited to SMSLEN */ /* o can be null, in which case this is used to validate or count only */ /* if the input contains invalid characters then the return value is -1 */ -static int -packsms7 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) +static int packsms7 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) { - unsigned char p = 0, - b = 0, - n = 0; - if (udhl) - { /* header */ - if (o) - o[p++] = udhl; - b = 1; - n = 1; - while (udhl--) - { - if (o) - o[p++] = *udh++; - b += 8; - while (b >= 7) - { - b -= 7; - n++; - } - if (n >= SMSLEN) - return n; - } - if (b) - { - b = 7 - b; - if (++n >= SMSLEN) - return n; - }; /* filling to septet boundary */ - } - if (o) - o[p] = 0; - /* message */ - while (udl--) - { - long u; - unsigned char v; - u = *ud++; - for (v = 0; v < 128 && defaultalphabet[v] != u; v++); - if (v == 128 && u && n + 1 < SMSLEN) - { - for (v = 0; v < 128 && escapes[v] != u; v++); - if (v < 128) - { /* escaped sequence */ - if (o) - o[p] |= (27 << b); - b += 7; - if (b >= 8) - { - b -= 8; - p++; - if (o) - o[p] = (27 >> (7 - b)); - } - n++; - } - } - if (v == 128) - return -1; /* invalid character */ - if (o) - o[p] |= (v << b); - b += 7; - if (b >= 8) - { - b -= 8; - p++; - if (o) - o[p] = (v >> (7 - b)); - } - if (++n >= SMSLEN) - return n; - } - return n; + unsigned char p = 0, b = 0, n = 0; + + if (udhl) { /* header */ + if (o) + o[p++] = udhl; + b = 1; + n = 1; + while (udhl--) { + if (o) + o[p++] = *udh++; + b += 8; + while (b >= 7) { + b -= 7; + n++; + } + if (n >= SMSLEN) + return n; + } + if (b) { + b = 7 - b; + if (++n >= SMSLEN) + return n; + }; /* filling to septet boundary */ + } + if (o) + o[p] = 0; + /* message */ + while (udl--) { + long u; + unsigned char v; + u = *ud++; + for (v = 0; v < 128 && defaultalphabet[v] != u; v++); + if (v == 128 && u && n + 1 < SMSLEN) { + for (v = 0; v < 128 && escapes[v] != u; v++); + if (v < 128) { /* escaped sequence */ + if (o) + o[p] |= (27 << b); + b += 7; + if (b >= 8) { + b -= 8; + p++; + if (o) + o[p] = (27 >> (7 - b)); + } + n++; + } + } + if (v == 128) + return -1; /* invalid character */ + if (o) + o[p] |= (v << b); + b += 7; + if (b >= 8) { + b -= 8; + p++; + if (o) + o[p] = (v >> (7 - b)); + } + if (++n >= SMSLEN) + return n; + } + return n; } -/* This takes a binary header (udhl bytes at udh) and UCS-2 message (udl characters at ud) and packs in to o using 8 bit character codes */ +/*--- packsms8: takes a binary header (udhl bytes at udh) and UCS-2 message (udl characters at ud) and packs in to o using 8 bit character codes */ /* The return value is the number of bytes packed in to o, which is internally limited to 140 */ /* o can be null, in which case this is used to validate or count only */ /* if the input contains invalid characters then the return value is -1 */ -static int -packsms8 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) +static int packsms8 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) { - unsigned char p = 0; - /* header - no encoding */ - if (udhl) - { - if (o) - o[p++] = udhl; - while (udhl--) - { - if (o) - o[p++] = *udh++; - if (p >= 140) - return p; - } - } - while (udl--) - { - long u; - u = *ud++; - if (u < 0 || u > 0xFF) - return -1; /* not valid */ - if (o) - o[p++] = u; - if (p >= 140) - return p; - } - return p; + unsigned char p = 0; + + /* header - no encoding */ + if (udhl) { + if (o) + o[p++] = udhl; + while (udhl--) { + if (o) + o[p++] = *udh++; + if (p >= 140) + return p; + } + } + while (udl--) { + long u; + u = *ud++; + if (u < 0 || u > 0xFF) + return -1; /* not valid */ + if (o) + o[p++] = u; + if (p >= 140) + return p; + } + return p; } -/* This takes a binary header (udhl bytes at udh) and UCS-2 message (udl characters at ud) and packs in to o using 16 bit UCS-2 character codes */ -/* The return value is the number of bytes packed in to o, which is internally limited to 140 */ -/* o can be null, in which case this is used to validate or count only */ -/* if the input contains invalid characters then the return value is -1 */ -static int -packsms16 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) +/*--- packsms16: takes a binary header (udhl bytes at udh) and UCS-2 + message (udl characters at ud) and packs in to o using 16 bit + UCS-2 character codes + The return value is the number of bytes packed in to o, which is + internally limited to 140 + o can be null, in which case this is used to validate or count + only if the input contains invalid characters then + the return value is -1 */ +static int packsms16 (unsigned char *o, int udhl, unsigned char *udh, int udl, unsigned short *ud) { - unsigned char p = 0; - /* header - no encoding */ - if (udhl) - { - if (o) - o[p++] = udhl; - while (udhl--) - { - if (o) - o[p++] = *udh++; - if (p >= 140) - return p; - } - } - while (udl--) - { - long u; - u = *ud++; - if (o) - o[p++] = (u >> 8); - if (p >= 140) - return p - 1; /* could not fit last character */ - if (o) - o[p++] = u; - if (p >= 140) - return p; - } - return p; + unsigned char p = 0; + /* header - no encoding */ + if (udhl) { + if (o) + o[p++] = udhl; + while (udhl--) { + if (o) + o[p++] = *udh++; + if (p >= 140) + return p; + } + } + while (udl--) { + long u; + u = *ud++; + if (o) + o[p++] = (u >> 8); + if (p >= 140) + return p - 1; /* could not fit last character */ + if (o) + o[p++] = u; + if (p >= 140) + return p; + } + return p; } -/* general pack, with length and data, returns number of bytes of target used */ -static int -packsms (unsigned char dcs, unsigned char *base, unsigned int udhl, unsigned char *udh, int udl, unsigned short *ud) +/*--- packsms: general pack, with length and data, + returns number of bytes of target used */ +static int packsms (unsigned char dcs, unsigned char *base, unsigned int udhl, unsigned char *udh, int udl, unsigned short *ud) { - unsigned char *p = base; - if (udl) - { - int l = 0; - if (is7bit (dcs)) - { /* 7 bit */ - l = packsms7 (p + 1, udhl, udh, udl, ud); - if (l < 0) - l = 0; - *p++ = l; - p += (l * 7 + 7) / 8; - } else if (is8bit (dcs)) - { /* 8 bit */ - l = packsms8 (p + 1, udhl, udh, udl, ud); - if (l < 0) - l = 0; - *p++ = l; - p += l; - } else - { /* UCS-2 */ - l = packsms16 (p + 1, udhl, udh, udl, ud); - if (l < 0) - l = 0; - *p++ = l; - p += l; - } - } else - *p++ = 0; /* no user data */ - return p - base; + unsigned char *p = base; + if (udl) { + int l = 0; + if (is7bit (dcs)) { /* 7 bit */ + l = packsms7 (p + 1, udhl, udh, udl, ud); + if (l < 0) + l = 0; + *p++ = l; + p += (l * 7 + 7) / 8; + } else if (is8bit (dcs)) { /* 8 bit */ + l = packsms8 (p + 1, udhl, udh, udl, ud); + if (l < 0) + l = 0; + *p++ = l; + p += l; + } else { /* UCS-2 */ + l = packsms16 (p + 1, udhl, udh, udl, ud); + if (l < 0) + l = 0; + *p++ = l; + p += l; + } + } else + *p++ = 0; /* no user data */ + return p - base; } -/* pack a date and return */ -static void -packdate (unsigned char *o, time_t w) +/*--- packdate: pack a date and return */ +static void packdate (unsigned char *o, time_t w) { - struct tm *t = localtime (&w); + struct tm *t = localtime (&w); #if defined(__FreeBSD__) || defined(__OpenBSD__) || defined( __NetBSD__ ) || defined(__APPLE__) - int z = -t->tm_gmtoff / 60 / 15; + int z = -t->tm_gmtoff / 60 / 15; #else - int z = timezone / 60 / 15; + int z = timezone / 60 / 15; #endif - *o++ = ((t->tm_year % 10) << 4) + (t->tm_year % 100) / 10; - *o++ = (((t->tm_mon + 1) % 10) << 4) + (t->tm_mon + 1) / 10; - *o++ = ((t->tm_mday % 10) << 4) + t->tm_mday / 10; - *o++ = ((t->tm_hour % 10) << 4) + t->tm_hour / 10; - *o++ = ((t->tm_min % 10) << 4) + t->tm_min / 10; - *o++ = ((t->tm_sec % 10) << 4) + t->tm_sec / 10; - if (z < 0) - *o++ = (((-z) % 10) << 4) + (-z) / 10 + 0x08; - else - *o++ = ((z % 10) << 4) + z / 10; + *o++ = ((t->tm_year % 10) << 4) + (t->tm_year % 100) / 10; + *o++ = (((t->tm_mon + 1) % 10) << 4) + (t->tm_mon + 1) / 10; + *o++ = ((t->tm_mday % 10) << 4) + t->tm_mday / 10; + *o++ = ((t->tm_hour % 10) << 4) + t->tm_hour / 10; + *o++ = ((t->tm_min % 10) << 4) + t->tm_min / 10; + *o++ = ((t->tm_sec % 10) << 4) + t->tm_sec / 10; + if (z < 0) + *o++ = (((-z) % 10) << 4) + (-z) / 10 + 0x08; + else + *o++ = ((z % 10) << 4) + z / 10; } -/* unpack a date and return */ -static time_t -unpackdate (unsigned char *i) +/*--- unpackdate: unpack a date and return */ +static time_t unpackdate (unsigned char *i) { - struct tm t; - t.tm_year = 100 + (i[0] & 0xF) * 10 + (i[0] >> 4); - t.tm_mon = (i[1] & 0xF) * 10 + (i[1] >> 4) - 1; - t.tm_mday = (i[2] & 0xF) * 10 + (i[2] >> 4); - t.tm_hour = (i[3] & 0xF) * 10 + (i[3] >> 4); - t.tm_min = (i[4] & 0xF) * 10 + (i[4] >> 4); - t.tm_sec = (i[5] & 0xF) * 10 + (i[5] >> 4); - t.tm_isdst = 0; - if (i[6] & 0x08) - t.tm_min += 15 * ((i[6] & 0x7) * 10 + (i[6] >> 4)); - else - t.tm_min -= 15 * ((i[6] & 0x7) * 10 + (i[6] >> 4)); - return mktime (&t); + struct tm t; + t.tm_year = 100 + (i[0] & 0xF) * 10 + (i[0] >> 4); + t.tm_mon = (i[1] & 0xF) * 10 + (i[1] >> 4) - 1; + t.tm_mday = (i[2] & 0xF) * 10 + (i[2] >> 4); + t.tm_hour = (i[3] & 0xF) * 10 + (i[3] >> 4); + t.tm_min = (i[4] & 0xF) * 10 + (i[4] >> 4); + t.tm_sec = (i[5] & 0xF) * 10 + (i[5] >> 4); + t.tm_isdst = 0; + if (i[6] & 0x08) + t.tm_min += 15 * ((i[6] & 0x7) * 10 + (i[6] >> 4)); + else + t.tm_min -= 15 * ((i[6] & 0x7) * 10 + (i[6] >> 4)); + return mktime (&t); } -/* unpacks bytes (7 bit encoding) at i, len l septets, and places in udh and ud setting udhl and udl. udh not used if udhi not set */ -static void -unpacksms7 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) +/*--- unpacksms7: unpacks bytes (7 bit encoding) at i, len l septets, + and places in udh and ud setting udhl and udl. udh not used + if udhi not set */ +static void unpacksms7 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) { - unsigned char b = 0, - p = 0; - unsigned short *o = ud; - *udhl = 0; - if (udhi && l) - { /* header */ - int h = i[p]; - *udhl = h; - if (h) - { - b = 1; - p++; - l--; - while (h-- && l) - { - *udh++ = i[p++]; - b += 8; - while (b >= 7) - { - b -= 7; - l--; - if (!l) - break; - } - } - /* adjust for fill, septets */ - if (b) - { - b = 7 - b; - l--; - } - } - } - while (l--) - { - unsigned char v; - if (b < 2) - v = ((i[p] >> b) & 0x7F); - else - v = ((((i[p] >> b) + (i[p + 1] << (8 - b)))) & 0x7F); - b += 7; - if (b >= 8) - { - b -= 8; - p++; - } - if (o > ud && o[-1] == 0x00A0 && escapes[v]) - o[-1] = escapes[v]; - else - *o++ = defaultalphabet[v]; - } - *udl = (o - ud); + unsigned char b = 0, p = 0; + unsigned short *o = ud; + *udhl = 0; + if (udhi && l) { /* header */ + int h = i[p]; + *udhl = h; + if (h) { + b = 1; + p++; + l--; + while (h-- && l) { + *udh++ = i[p++]; + b += 8; + while (b >= 7) { + b -= 7; + l--; + if (!l) + break; + } + } + /* adjust for fill, septets */ + if (b) { + b = 7 - b; + l--; + } + } + } + while (l--) { + unsigned char v; + if (b < 2) + v = ((i[p] >> b) & 0x7F); + else + v = ((((i[p] >> b) + (i[p + 1] << (8 - b)))) & 0x7F); + b += 7; + if (b >= 8) { + b -= 8; + p++; + } + if (o > ud && o[-1] == 0x00A0 && escapes[v]) + o[-1] = escapes[v]; + else + *o++ = defaultalphabet[v]; + } + *udl = (o - ud); } -/* unpacks bytes (8 bit encoding) at i, len l septets, and places in udh and ud setting udhl and udl. udh not used if udhi not set */ -static void -unpacksms8 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) +/*--- unpacksms8: unpacks bytes (8 bit encoding) at i, len l septets, + and places in udh and ud setting udhl and udl. udh not used + if udhi not set */ +static void unpacksms8 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) { - unsigned short *o = ud; - *udhl = 0; - if (udhi) - { - int n = *i; - *udhl = n; - if (n) - { - i++; - l--; - while (l && n) - { - l--; - n--; - *udh++ = *i++; - } - } - } - while (l--) - *o++ = *i++; /* not to UTF-8 as explicitely 8 bit coding in DCS */ - *udl = (o - ud); + unsigned short *o = ud; + *udhl = 0; + if (udhi) { + int n = *i; + *udhl = n; + if (n) { + i++; + l--; + while (l && n) { + l--; + n--; + *udh++ = *i++; + } + } + } + while (l--) + *o++ = *i++; /* not to UTF-8 as explicitely 8 bit coding in DCS */ + *udl = (o - ud); } -/* unpacks bytes (16 bit encoding) at i, len l septets, and places in udh and ud setting udhl and udl. udh not used if udhi not set */ -static void -unpacksms16 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) +/*--- unpacksms16: unpacks bytes (16 bit encoding) at i, len l septets, + and places in udh and ud setting udhl and udl. + udh not used if udhi not set */ +static void unpacksms16 (unsigned char *i, unsigned char l, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) { - unsigned short *o = ud; - *udhl = 0; - if (udhi) - { - int n = *i; - *udhl = n; - if (n) - { - i++; - l--; - while (l && n) - { - l--; - n--; - *udh++ = *i++; - } - } - } - while (l--) - { - int v = *i++; - if (l--) - v = (v << 8) + *i++; - *o++ = v; - } - *udl = (o - ud); + unsigned short *o = ud; + *udhl = 0; + if (udhi) { + int n = *i; + *udhl = n; + if (n) { + i++; + l--; + while (l && n) { + l--; + n--; + *udh++ = *i++; + } + } + } + while (l--) { + int v = *i++; + if (l--) + v = (v << 8) + *i++; + *o++ = v; + } + *udl = (o - ud); } -/* general unpack - starts with length byte (octet or septet) and returns number of bytes used, inc length */ -static int -unpacksms (unsigned char dcs, unsigned char *i, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) +/*--- unpacksms: general unpack - starts with length byte (octet or septet) and returns number of bytes used, inc length */ +static int unpacksms (unsigned char dcs, unsigned char *i, unsigned char *udh, int *udhl, unsigned short *ud, int *udl, char udhi) { - int l = *i++; - if (is7bit (dcs)) - { - unpacksms7 (i, l, udh, udhl, ud, udl, udhi); - l = (l * 7 + 7) / 8; /* adjust length to return */ - } else if (is8bit (dcs)) - unpacksms8 (i, l, udh, udhl, ud, udl, udhi); - else - unpacksms16 (i, l, udh, udhl, ud, udl, udhi); - return l + 1; + int l = *i++; + if (is7bit (dcs)) { + unpacksms7 (i, l, udh, udhl, ud, udl, udhi); + l = (l * 7 + 7) / 8; /* adjust length to return */ + } else if (is8bit (dcs)) + unpacksms8 (i, l, udh, udhl, ud, udl, udhi); + else + unpacksms16 (i, l, udh, udhl, ud, udl, udhi); + return l + 1; } -/* unpack an address from i, return byte length, unpack to o */ -static unsigned char -unpackaddress (char *o, unsigned char *i) +/*--- unpackaddress: unpack an address from i, return byte length, unpack to o */ +static unsigned char unpackaddress (char *o, unsigned char *i) { - unsigned char l = i[0], - p; - if (i[1] == 0x91) - *o++ = '+'; - for (p = 0; p < l; p++) - { - if (p & 1) - *o++ = (i[2 + p / 2] >> 4) + '0'; - else - *o++ = (i[2 + p / 2] & 0xF) + '0'; - } - *o = 0; - return (l + 5) / 2; + unsigned char l = i[0], + p; + if (i[1] == 0x91) + *o++ = '+'; + for (p = 0; p < l; p++) { + if (p & 1) + *o++ = (i[2 + p / 2] >> 4) + '0'; + else + *o++ = (i[2 + p / 2] & 0xF) + '0'; + } + *o = 0; + return (l + 5) / 2; } -/* store an address at o, and return number of bytes used */ -static unsigned char -packaddress (unsigned char *o, char *i) +/*--- packaddress: store an address at o, and return number of bytes used */ +static unsigned char packaddress (unsigned char *o, char *i) { - unsigned char p = 2; - o[0] = 0; - if (*i == '+') - { - i++; - o[1] = 0x91; - } else - o[1] = 0x81; - while (*i) - if (isdigit (*i)) - { - if (o[0] & 1) - o[p++] |= ((*i & 0xF) << 4); - else - o[p] = (*i & 0xF); - o[0]++; - i++; - } else - i++; - if (o[0] & 1) - o[p++] |= 0xF0; /* pad */ - return p; + unsigned char p = 2; + o[0] = 0; + if (*i == '+') { + i++; + o[1] = 0x91; + } else + o[1] = 0x81; + while (*i) + if (isdigit (*i)) { + if (o[0] & 1) + o[p++] |= ((*i & 0xF) << 4); + else + o[p] = (*i & 0xF); + o[0]++; + i++; + } else + i++; + if (o[0] & 1) + o[p++] |= 0xF0; /* pad */ + return p; } -static void -sms_log (sms_t * h, char status) -{ /* log the output, and remove file */ - if (*h->oa || *h->da) - { - int o = open (log_file, O_CREAT | O_APPEND | O_WRONLY, 0666); - if (o >= 0) - { - char line[1000], - mrs[3] = "", - *p; - unsigned char n; - if (h->mr >= 0) - snprintf (mrs, sizeof (mrs), "%02X", h->mr); - snprintf (line, sizeof (line), "%s %c%c%c%s %s %s %s ", - isodate (time (0)), status, h->rx ? 'I' : 'O', h->smsc ? 'S' : 'M', mrs, h->queue, *h->oa ? h->oa : "-", - *h->da ? h->da : "-"); - p = line + strlen (line); - for (n = 0; n < h->udl; n++) - if (h->ud[n] == '\\') - { - *p++ = '\\'; - *p++ = '\\'; - } else if (h->ud[n] == '\n') - { - *p++ = '\\'; - *p++ = 'n'; - } else if (h->ud[n] == '\r') - { - *p++ = '\\'; - *p++ = 'r'; - } else if (h->ud[n] < 32 || h->ud[n] == 127) - *p++ = 191; - else - *p++ = h->ud[n]; - *p++ = '\n'; - *p = 0; - write (o, line, strlen (line)); - close (o); - } - *h->oa = *h->da = h->udl = 0; - } +/*--- sms_log: Log the output, and remove file */ +static void sms_log (sms_t * h, char status) +{ + if (*h->oa || *h->da) { + int o = open (log_file, O_CREAT | O_APPEND | O_WRONLY, 0666); + if (o >= 0) { + char line[1000], mrs[3] = "", *p; + unsigned char n; + + if (h->mr >= 0) + snprintf (mrs, sizeof (mrs), "%02X", h->mr); + snprintf (line, sizeof (line), "%s %c%c%c%s %s %s %s ", + isodate (time (0)), status, h->rx ? 'I' : 'O', h->smsc ? 'S' : 'M', mrs, h->queue, *h->oa ? h->oa : "-", + *h->da ? h->da : "-"); + p = line + strlen (line); + for (n = 0; n < h->udl; n++) + if (h->ud[n] == '\\') { + *p++ = '\\'; + *p++ = '\\'; + } else if (h->ud[n] == '\n') { + *p++ = '\\'; + *p++ = 'n'; + } else if (h->ud[n] == '\r') { + *p++ = '\\'; + *p++ = 'r'; + } else if (h->ud[n] < 32 || h->ud[n] == 127) + *p++ = 191; + else + *p++ = h->ud[n]; + *p++ = '\n'; + *p = 0; + write (o, line, strlen (line)); + close (o); + } + *h->oa = *h->da = h->udl = 0; + } } -/* parse and delete a file */ -static void -sms_readfile (sms_t * h, char *fn) +/*--- sms_readfile: parse and delete a file */ +static void sms_readfile (sms_t * h, char *fn) { - char line[1000]; - FILE *s; - char dcsset = 0; /* if DSC set */ - ast_log (LOG_EVENT, "Sending %s\n", fn); - h->rx = h->udl = *h->oa = *h->da = h->pid = h->srr = h->udhi = h->rp = h->vp = h->udhl = 0; - h->mr = -1; - h->dcs = 0xF1; /* normal messages class 1 */ - h->scts = time (0); - s = fopen (fn, "r"); - if (s) - { - if (unlink (fn)) - { /* concurrent access, we lost */ - fclose (s); - return; - } - while (fgets (line, sizeof (line), s)) - { /* process line in file */ - unsigned char *p; - for (p = line; *p && *p != '\n' && *p != '\r'; p++); - *p = 0; /* strip eoln */ - p = line; - if (!*p || *p == ';') - continue; /* blank line or comment, ignore */ - while (isalnum (*p)) - { - *p = tolower (*p); - p++; - } - while (isspace (*p)) - *p++ = 0; - if (*p == '=') - { - *p++ = 0; - if (!strcmp (line, "ud")) - { /* parse message (UTF-8) */ - unsigned char o = 0; - while (*p && o < SMSLEN) - h->ud[o++] = utf8decode (&p); - h->udl = o; - if (*p) - ast_log (LOG_WARNING, "UD too long in %s\n", fn); - } else - { - while (isspace (*p)) - p++; - if (!strcmp (line, "oa") && strlen (p) < sizeof (h->oa)) - numcpy (h->oa, p); - else if (!strcmp (line, "da") && strlen (p) < sizeof (h->oa)) - numcpy (h->da, p); - else if (!strcmp (line, "pid")) - h->pid = atoi (p); - else if (!strcmp (line, "dcs")) - { - h->dcs = atoi (p); - dcsset = 1; - } else if (!strcmp (line, "mr")) - h->mr = atoi (p); - else if (!strcmp (line, "srr")) - h->srr = (atoi (p) ? 1 : 0); - else if (!strcmp (line, "vp")) - h->vp = atoi (p); - else if (!strcmp (line, "rp")) - h->rp = (atoi (p) ? 1 : 0); - else if (!strcmp (line, "scts")) - { /* get date/time */ - int Y, - m, - d, - H, - M, - S; - if (sscanf (p, "%d-%d-%dT%d:%d:%d", &Y, &m, &d, &H, &M, &S) == 6) - { - struct tm t; - t.tm_year = Y - 1900; - t.tm_mon = m - 1; - t.tm_mday = d; - t.tm_hour = H; - t.tm_min = M; - t.tm_sec = S; - t.tm_isdst = -1; - h->scts = mktime (&t); - if (h->scts == (time_t) - 1) - ast_log (LOG_WARNING, "Bad date/timein %s: %s", fn, p); - } - } else - ast_log (LOG_WARNING, "Cannot parse in %s: %s=%si\n", fn, line, p); - } - } else if (*p == '#') - { /* raw hex format */ - *p++ = 0; - if (*p == '#') - { - p++; - if (!strcmp (line, "ud")) - { /* user data */ - int o = 0; - while (*p && o < SMSLEN) - { - if (isxdigit (*p) && isxdigit (p[1]) && isxdigit (p[2]) && isxdigit (p[3])) - { - h->ud[o++] = - (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 12) + - (((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)) << 8) + - (((isalpha (p[2]) ? 9 : 0) + (p[2] & 0xF)) << 4) + ((isalpha (p[3]) ? 9 : 0) + (p[3] & 0xF)); - p += 4; - } else - break; - } - h->udl = o; - if (*p) - ast_log (LOG_WARNING, "UD too long / invalid UCS-2 hex in %s\n", fn); - } else - ast_log (LOG_WARNING, "Only ud can use ## format, %s\n", fn); - } else if (!strcmp (line, "ud")) - { /* user data */ - int o = 0; - while (*p && o < SMSLEN) - { - if (isxdigit (*p) && isxdigit (p[1])) - { - h->ud[o++] = (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 4) + ((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)); - p += 2; - } else - break; - } - h->udl = o; - if (*p) - ast_log (LOG_WARNING, "UD too long / invalid UCS-1 hex in %s\n", fn); - } else if (!strcmp (line, "udh")) - { /* user data header */ - unsigned char o = 0; - h->udhi = 1; - while (*p && o < SMSLEN) - { - if (isxdigit (*p) && isxdigit (p[1])) - { - h->udh[o] = (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 4) + ((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)); - o++; - p += 2; - } else - break; - } - h->udhl = o; - if (*p) - ast_log (LOG_WARNING, "UDH too long / invalid hex in %s\n", fn); - } else - ast_log (LOG_WARNING, "Only ud and udh can use # format, %s\n", fn); - } else - ast_log (LOG_WARNING, "Cannot parse in %s: %s\n", fn, line); - } - fclose (s); - if (!dcsset && packsms7 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - { - if (packsms8 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - { - if (packsms16 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - ast_log (LOG_WARNING, "Invalid UTF-8 message even for UCS-2 (%s)\n", fn); - else - { - h->dcs = 0x08; /* default to 16 bit */ - ast_log (LOG_WARNING, "Sending in 16 bit format (%s)\n", fn); - } - } else - { - h->dcs = 0xF5; /* default to 8 bit */ - ast_log (LOG_WARNING, "Sending in 8 bit format (%s)\n", fn); - } - } - if (is7bit (h->dcs) && packsms7 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - ast_log (LOG_WARNING, "Invalid 7 bit GSM data %s\n", fn); - if (is8bit (h->dcs) && packsms8 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - ast_log (LOG_WARNING, "Invalid 8 bit data %s\n", fn); - if (is16bit (h->dcs) && packsms16 (0, h->udhl, h->udh, h->udl, h->ud) < 0) - ast_log (LOG_WARNING, "Invalid 16 bit data %s\n", fn); - } + char line[1000]; + FILE *s; + char dcsset = 0; /* if DSC set */ + ast_log (LOG_EVENT, "Sending %s\n", fn); + h->rx = h->udl = *h->oa = *h->da = h->pid = h->srr = h->udhi = h->rp = h->vp = h->udhl = 0; + h->mr = -1; + h->dcs = 0xF1; /* normal messages class 1 */ + h->scts = time (0); + s = fopen (fn, "r"); + if (s) + { + if (unlink (fn)) + { /* concurrent access, we lost */ + fclose (s); + return; + } + while (fgets (line, sizeof (line), s)) + { /* process line in file */ + unsigned char *p; + for (p = line; *p && *p != '\n' && *p != '\r'; p++); + *p = 0; /* strip eoln */ + p = line; + if (!*p || *p == ';') + continue; /* blank line or comment, ignore */ + while (isalnum (*p)) + { + *p = tolower (*p); + p++; + } + while (isspace (*p)) + *p++ = 0; + if (*p == '=') + { + *p++ = 0; + if (!strcmp (line, "ud")) + { /* parse message (UTF-8) */ + unsigned char o = 0; + while (*p && o < SMSLEN) + h->ud[o++] = utf8decode (&p); + h->udl = o; + if (*p) + ast_log (LOG_WARNING, "UD too long in %s\n", fn); + } else + { + while (isspace (*p)) + p++; + if (!strcmp (line, "oa") && strlen (p) < sizeof (h->oa)) + numcpy (h->oa, p); + else if (!strcmp (line, "da") && strlen (p) < sizeof (h->oa)) + numcpy (h->da, p); + else if (!strcmp (line, "pid")) + h->pid = atoi (p); + else if (!strcmp (line, "dcs")) + { + h->dcs = atoi (p); + dcsset = 1; + } else if (!strcmp (line, "mr")) + h->mr = atoi (p); + else if (!strcmp (line, "srr")) + h->srr = (atoi (p) ? 1 : 0); + else if (!strcmp (line, "vp")) + h->vp = atoi (p); + else if (!strcmp (line, "rp")) + h->rp = (atoi (p) ? 1 : 0); + else if (!strcmp (line, "scts")) + { /* get date/time */ + int Y, + m, + d, + H, + M, + S; + if (sscanf (p, "%d-%d-%dT%d:%d:%d", &Y, &m, &d, &H, &M, &S) == 6) + { + struct tm t; + t.tm_year = Y - 1900; + t.tm_mon = m - 1; + t.tm_mday = d; + t.tm_hour = H; + t.tm_min = M; + t.tm_sec = S; + t.tm_isdst = -1; + h->scts = mktime (&t); + if (h->scts == (time_t) - 1) + ast_log (LOG_WARNING, "Bad date/timein %s: %s", fn, p); + } + } else + ast_log (LOG_WARNING, "Cannot parse in %s: %s=%si\n", fn, line, p); + } + } else if (*p == '#') + { /* raw hex format */ + *p++ = 0; + if (*p == '#') + { + p++; + if (!strcmp (line, "ud")) + { /* user data */ + int o = 0; + while (*p && o < SMSLEN) + { + if (isxdigit (*p) && isxdigit (p[1]) && isxdigit (p[2]) && isxdigit (p[3])) + { + h->ud[o++] = + (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 12) + + (((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)) << 8) + + (((isalpha (p[2]) ? 9 : 0) + (p[2] & 0xF)) << 4) + ((isalpha (p[3]) ? 9 : 0) + (p[3] & 0xF)); + p += 4; + } else + break; + } + h->udl = o; + if (*p) + ast_log (LOG_WARNING, "UD too long / invalid UCS-2 hex in %s\n", fn); + } else + ast_log (LOG_WARNING, "Only ud can use ## format, %s\n", fn); + } else if (!strcmp (line, "ud")) + { /* user data */ + int o = 0; + while (*p && o < SMSLEN) + { + if (isxdigit (*p) && isxdigit (p[1])) + { + h->ud[o++] = (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 4) + ((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)); + p += 2; + } else + break; + } + h->udl = o; + if (*p) + ast_log (LOG_WARNING, "UD too long / invalid UCS-1 hex in %s\n", fn); + } else if (!strcmp (line, "udh")) + { /* user data header */ + unsigned char o = 0; + h->udhi = 1; + while (*p && o < SMSLEN) + { + if (isxdigit (*p) && isxdigit (p[1])) + { + h->udh[o] = (((isalpha (*p) ? 9 : 0) + (*p & 0xF)) << 4) + ((isalpha (p[1]) ? 9 : 0) + (p[1] & 0xF)); + o++; + p += 2; + } else + break; + } + h->udhl = o; + if (*p) + ast_log (LOG_WARNING, "UDH too long / invalid hex in %s\n", fn); + } else + ast_log (LOG_WARNING, "Only ud and udh can use # format, %s\n", fn); + } else + ast_log (LOG_WARNING, "Cannot parse in %s: %s\n", fn, line); + } + fclose (s); + if (!dcsset && packsms7 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + { + if (packsms8 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + { + if (packsms16 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + ast_log (LOG_WARNING, "Invalid UTF-8 message even for UCS-2 (%s)\n", fn); + else + { + h->dcs = 0x08; /* default to 16 bit */ + ast_log (LOG_WARNING, "Sending in 16 bit format (%s)\n", fn); + } + } else + { + h->dcs = 0xF5; /* default to 8 bit */ + ast_log (LOG_WARNING, "Sending in 8 bit format (%s)\n", fn); + } + } + if (is7bit (h->dcs) && packsms7 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + ast_log (LOG_WARNING, "Invalid 7 bit GSM data %s\n", fn); + if (is8bit (h->dcs) && packsms8 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + ast_log (LOG_WARNING, "Invalid 8 bit data %s\n", fn); + if (is16bit (h->dcs) && packsms16 (0, h->udhl, h->udh, h->udl, h->ud) < 0) + ast_log (LOG_WARNING, "Invalid 16 bit data %s\n", fn); + } } -/* white a received text message to a file */ -static void -sms_writefile (sms_t * h) +/*--- sms_writefile: white a received text message to a file */ +static void sms_writefile (sms_t * h) { - char fn[200] = "", - fn2[200] = ""; - FILE *o; - strncpy (fn, spool_dir, sizeof (fn) - 1); - mkdir (fn, 0777); /* ensure it exists */ - snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", h->smsc ? h->rx ? "morx" : "mttx" : h->rx ? "mtrx" : "motx"); - mkdir (fn, 0777); /* ensure it exists */ - strncpy (fn2, fn, sizeof (fn2) - 1); - snprintf (fn2 + strlen (fn2), sizeof (fn2) - strlen (fn2), "/%s.%s-%d", h->queue, isodate (h->scts), seq++); - snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/.%s", fn2 + strlen (fn) + 1); - o = fopen (fn, "w"); - if (o) - { - if (*h->oa) - fprintf (o, "oa=%s\n", h->oa); - if (*h->da) - fprintf (o, "da=%s\n", h->da); - if (h->udhi) - { - unsigned int p; - fprintf (o, "udh#"); - for (p = 0; p < h->udhl; p++) - fprintf (o, "%02X", h->udh[p]); - fprintf (o, "\n"); - } - if (h->udl) - { - unsigned int p; - for (p = 0; p < h->udl && h->ud[p] >= ' '; p++); - if (p < h->udl) - fputc (';', o); /* cannot use ud=, but include as a comment for human readable */ - fprintf (o, "ud="); - for (p = 0; p < h->udl; p++) - { - unsigned short v = h->ud[p]; - if (v < 32) - fputc (191, o); - else if (v < 0x80) - fputc (v, o); - else if (v < 0x800) - { - fputc (0xC0 + (v >> 6), o); - fputc (0x80 + (v & 0x3F), o); - } else - { - fputc (0xE0 + (v >> 12), o); - fputc (0x80 + ((v >> 6) & 0x3F), o); - fputc (0x80 + (v & 0x3F), o); - } - } - fprintf (o, "\n"); - for (p = 0; p < h->udl && h->ud[p] >= ' '; p++); - if (p < h->udl) - { - for (p = 0; p < h->udl && h->ud[p] < 0x100; p++); - if (p == h->udl) - { /* can write in ucs-1 hex */ - fprintf (o, "ud#"); - for (p = 0; p < h->udl; p++) - fprintf (o, "%02X", h->ud[p]); - fprintf (o, "\n"); - } else - { /* write in UCS-2 */ - fprintf (o, "ud##"); - for (p = 0; p < h->udl; p++) - fprintf (o, "%04X", h->ud[p]); - fprintf (o, "\n"); - } - } - } - if (h->scts) - fprintf (o, "scts=%s\n", isodate (h->scts)); - if (h->pid) - fprintf (o, "pid=%d\n", h->pid); - if (h->dcs != 0xF1) - fprintf (o, "dcs=%d\n", h->dcs); - if (h->vp) - fprintf (o, "vp=%d\n", h->vp); - if (h->srr) - fprintf (o, "srr=1\n"); - if (h->mr >= 0) - fprintf (o, "mr=%d\n", h->mr); - if (h->rp) - fprintf (o, "rp=1\n"); - fclose (o); - if (rename (fn, fn2)) - unlink (fn); - else - ast_log (LOG_EVENT, "Received to %s\n", fn2); - } + char fn[200] = "", fn2[200] = ""; + FILE *o; + strncpy (fn, spool_dir, sizeof (fn) - 1); + mkdir (fn, 0777); /* ensure it exists */ + snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", h->smsc ? h->rx ? "morx" : "mttx" : h->rx ? "mtrx" : "motx"); + mkdir (fn, 0777); /* ensure it exists */ + strncpy (fn2, fn, sizeof (fn2) - 1); + snprintf (fn2 + strlen (fn2), sizeof (fn2) - strlen (fn2), "/%s.%s-%d", h->queue, isodate (h->scts), seq++); + snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/.%s", fn2 + strlen (fn) + 1); + o = fopen (fn, "w"); + if (o) { + if (*h->oa) + fprintf (o, "oa=%s\n", h->oa); + if (*h->da) + fprintf (o, "da=%s\n", h->da); + if (h->udhi) { + unsigned int p; + fprintf (o, "udh#"); + for (p = 0; p < h->udhl; p++) + fprintf (o, "%02X", h->udh[p]); + fprintf (o, "\n"); + } + if (h->udl) { + unsigned int p; + for (p = 0; p < h->udl && h->ud[p] >= ' '; p++); + if (p < h->udl) + fputc (';', o); /* cannot use ud=, but include as a comment for human readable */ + fprintf (o, "ud="); + for (p = 0; p < h->udl; p++) { + unsigned short v = h->ud[p]; + if (v < 32) + fputc (191, o); + else if (v < 0x80) + fputc (v, o); + else if (v < 0x800) + { + fputc (0xC0 + (v >> 6), o); + fputc (0x80 + (v & 0x3F), o); + } else + { + fputc (0xE0 + (v >> 12), o); + fputc (0x80 + ((v >> 6) & 0x3F), o); + fputc (0x80 + (v & 0x3F), o); + } + } + fprintf (o, "\n"); + for (p = 0; p < h->udl && h->ud[p] >= ' '; p++); + if (p < h->udl) { + for (p = 0; p < h->udl && h->ud[p] < 0x100; p++); + if (p == h->udl) { /* can write in ucs-1 hex */ + fprintf (o, "ud#"); + for (p = 0; p < h->udl; p++) + fprintf (o, "%02X", h->ud[p]); + fprintf (o, "\n"); + } else { /* write in UCS-2 */ + fprintf (o, "ud##"); + for (p = 0; p < h->udl; p++) + fprintf (o, "%04X", h->ud[p]); + fprintf (o, "\n"); + } + } + } + if (h->scts) + fprintf (o, "scts=%s\n", isodate (h->scts)); + if (h->pid) + fprintf (o, "pid=%d\n", h->pid); + if (h->dcs != 0xF1) + fprintf (o, "dcs=%d\n", h->dcs); + if (h->vp) + fprintf (o, "vp=%d\n", h->vp); + if (h->srr) + fprintf (o, "srr=1\n"); + if (h->mr >= 0) + fprintf (o, "mr=%d\n", h->mr); + if (h->rp) + fprintf (o, "rp=1\n"); + fclose (o); + if (rename (fn, fn2)) + unlink (fn); + else + ast_log (LOG_EVENT, "Received to %s\n", fn2); + } } -/* read dir skipping dot files... */ -static struct dirent * -readdirqueue (DIR * d, char *queue) +/*--- readdirqueue: read dir skipping dot files... */ +static struct dirent *readdirqueue (DIR * d, char *queue) { struct dirent *f; - do - { + do { f = readdir (d); - } - while (f && (*f->d_name == '.' || strncmp (f->d_name, queue, strlen (queue)) || f->d_name[strlen (queue)] != '.')); + } while (f && (*f->d_name == '.' || strncmp (f->d_name, queue, strlen (queue)) || f->d_name[strlen (queue)] != '.')); return f; } -/* handle the incoming message */ -static unsigned char -sms_handleincoming (sms_t * h) +/*--- sms_handleincoming: handle the incoming message */ +static unsigned char sms_handleincoming (sms_t * h) { - unsigned char p = 3; - if (h->smsc) - { /* SMSC */ - if ((h->imsg[2] & 3) == 1) - { /* SMS-SUBMIT */ - h->udhl = h->udl = 0; - h->vp = 0; - h->srr = ((h->imsg[2] & 0x20) ? 1 : 0); - h->udhi = ((h->imsg[2] & 0x40) ? 1 : 0); - h->rp = ((h->imsg[2] & 0x80) ? 1 : 0); - strncpy (h->oa, h->cli, sizeof (h->oa) - 1); - h->scts = time (0); - h->mr = h->imsg[p++]; - p += unpackaddress (h->da, h->imsg + p); - h->pid = h->imsg[p++]; - h->dcs = h->imsg[p++]; - if ((h->imsg[2] & 0x18) == 0x10) - { /* relative VP */ - if (h->imsg[p] < 144) - h->vp = (h->imsg[p] + 1) * 5; - else if (h->imsg[p] < 168) - h->vp = 720 + (h->imsg[p] - 143) * 30; - else if (h->imsg[p] < 197) - h->vp = (h->imsg[p] - 166) * 1440; - else - h->vp = (h->imsg[p] - 192) * 10080; - p++; - } else if (h->imsg[2] & 0x18) - p += 7; /* ignore enhanced / absolute VP */ - p += unpacksms (h->dcs, h->imsg + p, h->udh, &h->udhl, h->ud, &h->udl, h->udhi); - h->rx = 1; /* received message */ - sms_writefile (h); /* write the file */ - if (p != h->imsg[1] + 2) - { - ast_log (LOG_WARNING, "Mismatch receive unpacking %d/%d\n", p, h->imsg[1] + 2); - return 0xFF; /* duh! */ - } - } else - { - ast_log (LOG_WARNING, "Unknown message type %02X\n", h->imsg[2]); - return 0xFF; - } - } else - { /* client */ - if (!(h->imsg[2] & 3)) - { /* SMS-DELIVER */ - *h->da = h->srr = h->rp = h->vp = h->udhi = h->udhl = h->udl = 0; - h->srr = ((h->imsg[2] & 0x20) ? 1 : 0); - h->udhi = ((h->imsg[2] & 0x40) ? 1 : 0); - h->rp = ((h->imsg[2] & 0x80) ? 1 : 0); - h->mr = -1; - p += unpackaddress (h->oa, h->imsg + p); - h->pid = h->imsg[p++]; - h->dcs = h->imsg[p++]; - h->scts = unpackdate (h->imsg + p); - p += 7; - p += unpacksms (h->dcs, h->imsg + p, h->udh, &h->udhl, h->ud, &h->udl, h->udhi); - h->rx = 1; /* received message */ - sms_writefile (h); /* write the file */ - if (p != h->imsg[1] + 2) - { - ast_log (LOG_WARNING, "Mismatch receive unpacking %d/%d\n", p, h->imsg[1] + 2); - return 0xFF; /* duh! */ - } - } else - { - ast_log (LOG_WARNING, "Unknown message type %02X\n", h->imsg[2]); - return 0xFF; - } - } - return 0; /* no error */ + unsigned char p = 3; + if (h->smsc) { /* SMSC */ + if ((h->imsg[2] & 3) == 1) { /* SMS-SUBMIT */ + h->udhl = h->udl = 0; + h->vp = 0; + h->srr = ((h->imsg[2] & 0x20) ? 1 : 0); + h->udhi = ((h->imsg[2] & 0x40) ? 1 : 0); + h->rp = ((h->imsg[2] & 0x80) ? 1 : 0); + strncpy (h->oa, h->cli, sizeof (h->oa) - 1); + h->scts = time (0); + h->mr = h->imsg[p++]; + p += unpackaddress (h->da, h->imsg + p); + h->pid = h->imsg[p++]; + h->dcs = h->imsg[p++]; + if ((h->imsg[2] & 0x18) == 0x10) { /* relative VP */ + if (h->imsg[p] < 144) + h->vp = (h->imsg[p] + 1) * 5; + else if (h->imsg[p] < 168) + h->vp = 720 + (h->imsg[p] - 143) * 30; + else if (h->imsg[p] < 197) + h->vp = (h->imsg[p] - 166) * 1440; + else + h->vp = (h->imsg[p] - 192) * 10080; + p++; + } else if (h->imsg[2] & 0x18) + p += 7; /* ignore enhanced / absolute VP */ + p += unpacksms (h->dcs, h->imsg + p, h->udh, &h->udhl, h->ud, &h->udl, h->udhi); + h->rx = 1; /* received message */ + sms_writefile (h); /* write the file */ + if (p != h->imsg[1] + 2) { + ast_log (LOG_WARNING, "Mismatch receive unpacking %d/%d\n", p, h->imsg[1] + 2); + return 0xFF; /* duh! */ + } + } else { + ast_log (LOG_WARNING, "Unknown message type %02X\n", h->imsg[2]); + return 0xFF; + } + } else { /* client */ + if (!(h->imsg[2] & 3)) { /* SMS-DELIVER */ + *h->da = h->srr = h->rp = h->vp = h->udhi = h->udhl = h->udl = 0; + h->srr = ((h->imsg[2] & 0x20) ? 1 : 0); + h->udhi = ((h->imsg[2] & 0x40) ? 1 : 0); + h->rp = ((h->imsg[2] & 0x80) ? 1 : 0); + h->mr = -1; + p += unpackaddress (h->oa, h->imsg + p); + h->pid = h->imsg[p++]; + h->dcs = h->imsg[p++]; + h->scts = unpackdate (h->imsg + p); + p += 7; + p += unpacksms (h->dcs, h->imsg + p, h->udh, &h->udhl, h->ud, &h->udl, h->udhi); + h->rx = 1; /* received message */ + sms_writefile (h); /* write the file */ + if (p != h->imsg[1] + 2) { + ast_log (LOG_WARNING, "Mismatch receive unpacking %d/%d\n", p, h->imsg[1] + 2); + return 0xFF; /* duh! */ + } + } else { + ast_log (LOG_WARNING, "Unknown message type %02X\n", h->imsg[2]); + return 0xFF; + } + } + return 0; /* no error */ } #ifdef SOLARIS #define NAME_MAX 1024 #endif -static void -sms_nextoutgoing (sms_t * h) -{ /* find and fill in next message, or send a REL if none waiting */ - char fn[100 + NAME_MAX] = ""; - DIR *d; - char more = 0; - strncpy (fn, spool_dir, sizeof (fn) - 1); - mkdir (fn, 0777); /* ensure it exists */ - h->rx = 0; /* outgoing message */ - snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", h->smsc ? "mttx" : "motx"); - mkdir (fn, 0777); /* ensure it exists */ - d = opendir (fn); - if (d) - { - struct dirent *f = readdirqueue (d, h->queue); - if (f) - { - snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", f->d_name); - sms_readfile (h, fn); - if (readdirqueue (d, h->queue)) - more = 1; /* more to send */ - } - closedir (d); - } - if (*h->da || *h->oa) - { /* message to send */ - unsigned char p = 2; - h->omsg[0] = 0x91; /* SMS_DATA */ - if (h->smsc) - { /* deliver */ - h->omsg[p++] = (more ? 4 : 0); - p += packaddress (h->omsg + p, h->oa); - h->omsg[p++] = h->pid; - h->omsg[p++] = h->dcs; - packdate (h->omsg + p, h->scts); - p += 7; - p += packsms (h->dcs, h->omsg + p, h->udhl, h->udh, h->udl, h->ud); - } else - { /* submit */ - h->omsg[p++] = - 0x01 + (more ? 4 : 0) + (h->srr ? 0x20 : 0) + (h->rp ? 0x80 : 0) + (h->vp ? 0x10 : 0) + (h->udhi ? 0x40 : 0); - if (h->mr < 0) - h->mr = message_ref++; - h->omsg[p++] = h->mr; - p += packaddress (h->omsg + p, h->da); - h->omsg[p++] = h->pid; - h->omsg[p++] = h->dcs; - if (h->vp) - { /* relative VP */ - if (h->vp < 720) - h->omsg[p++] = (h->vp + 4) / 5 - 1; - else if (h->vp < 1440) - h->omsg[p++] = (h->vp - 720 + 29) / 30 + 143; - else if (h->vp < 43200) - h->omsg[p++] = (h->vp + 1439) / 1440 + 166; - else if (h->vp < 635040) - h->omsg[p++] = (h->vp + 10079) / 10080 + 192; - else - h->omsg[p++] = 255; /* max */ - } - p += packsms (h->dcs, h->omsg + p, h->udhl, h->udh, h->udl, h->ud); - } - h->omsg[1] = p - 2; - sms_messagetx (h); - } else - { /* no message */ - h->omsg[0] = 0x94; /* SMS_REL */ - h->omsg[1] = 0; - sms_messagetx (h); - } +/*--- sms_nextoutgoing: find and fill in next message, + or send a REL if none waiting */ +static void sms_nextoutgoing (sms_t * h) +{ + char fn[100 + NAME_MAX] = ""; + DIR *d; + char more = 0; + strncpy (fn, spool_dir, sizeof (fn) - 1); + mkdir (fn, 0777); /* ensure it exists */ + h->rx = 0; /* outgoing message */ + snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", h->smsc ? "mttx" : "motx"); + mkdir (fn, 0777); /* ensure it exists */ + d = opendir (fn); + if (d) { + struct dirent *f = readdirqueue (d, h->queue); + if (f) { + snprintf (fn + strlen (fn), sizeof (fn) - strlen (fn), "/%s", f->d_name); + sms_readfile (h, fn); + if (readdirqueue (d, h->queue)) + more = 1; /* more to send */ + } + closedir (d); + } + if (*h->da || *h->oa) { /* message to send */ + unsigned char p = 2; + h->omsg[0] = 0x91; /* SMS_DATA */ + if (h->smsc) { /* deliver */ + h->omsg[p++] = (more ? 4 : 0); + p += packaddress (h->omsg + p, h->oa); + h->omsg[p++] = h->pid; + h->omsg[p++] = h->dcs; + packdate (h->omsg + p, h->scts); + p += 7; + p += packsms (h->dcs, h->omsg + p, h->udhl, h->udh, h->udl, h->ud); + } else { /* submit */ + h->omsg[p++] = + 0x01 + (more ? 4 : 0) + (h->srr ? 0x20 : 0) + (h->rp ? 0x80 : 0) + (h->vp ? 0x10 : 0) + (h->udhi ? 0x40 : 0); + if (h->mr < 0) + h->mr = message_ref++; + h->omsg[p++] = h->mr; + p += packaddress (h->omsg + p, h->da); + h->omsg[p++] = h->pid; + h->omsg[p++] = h->dcs; + if (h->vp) { /* relative VP */ + if (h->vp < 720) + h->omsg[p++] = (h->vp + 4) / 5 - 1; + else if (h->vp < 1440) + h->omsg[p++] = (h->vp - 720 + 29) / 30 + 143; + else if (h->vp < 43200) + h->omsg[p++] = (h->vp + 1439) / 1440 + 166; + else if (h->vp < 635040) + h->omsg[p++] = (h->vp + 10079) / 10080 + 192; + else + h->omsg[p++] = 255; /* max */ + } + p += packsms (h->dcs, h->omsg + p, h->udhl, h->udh, h->udl, h->ud); + } + h->omsg[1] = p - 2; + sms_messagetx (h); + } else { /* no message */ + h->omsg[0] = 0x94; /* SMS_REL */ + h->omsg[1] = 0; + sms_messagetx (h); + } } -static void -sms_debug (char *dir, unsigned char *msg) +static void sms_debug (char *dir, unsigned char *msg) { - char txt[259 * 3 + 1], - *p = txt; /* always long enough */ - int n = msg[1] + 3, - q = 0; - while (q < n && q < 30) - { - sprintf (p, " %02X", msg[q++]); - p += 3; - } - if (q < n) - sprintf (p, "..."); - ast_verbose (VERBOSE_PREFIX_3 "SMS %s%s\n", dir, txt); + char txt[259 * 3 + 1], + *p = txt; /* always long enough */ + int n = msg[1] + 3, + q = 0; + while (q < n && q < 30) { + sprintf (p, " %02X", msg[q++]); + p += 3; + } + if (q < n) + sprintf (p, "..."); + if (option_verbose > 2) + ast_verbose (VERBOSE_PREFIX_3 "SMS %s%s\n", dir, txt); } -static void -sms_messagerx (sms_t * h) +static void sms_messagerx(sms_t * h) { - sms_debug ("RX", h->imsg); - /* testing */ - switch (h->imsg[0]) - { - case 0x91: /* SMS_DATA */ - { - unsigned char cause = sms_handleincoming (h); - if (!cause) - { - sms_log (h, 'Y'); - h->omsg[0] = 0x95; /* SMS_ACK */ - h->omsg[1] = 0x02; - h->omsg[2] = 0x00; /* deliver report */ - h->omsg[3] = 0x00; /* no parameters */ - } else - { /* NACK */ - sms_log (h, 'N'); - h->omsg[0] = 0x96; /* SMS_NACK */ - h->omsg[1] = 3; - h->omsg[2] = 0; /* delivery report */ - h->omsg[3] = cause; /* cause */ - h->omsg[4] = 0; /* no parameters */ - } - sms_messagetx (h); - } - break; - case 0x92: /* SMS_ERROR */ - h->err = 1; - sms_messagetx (h); /* send whatever we sent again */ - break; - case 0x93: /* SMS_EST */ - sms_nextoutgoing (h); - break; - case 0x94: /* SMS_REL */ - h->hangup = 1; /* hangup */ - break; - case 0x95: /* SMS_ACK */ - sms_log (h, 'Y'); - sms_nextoutgoing (h); - break; - case 0x96: /* SMS_NACK */ - h->err = 1; - sms_log (h, 'N'); - sms_nextoutgoing (h); - break; - default: /* Unknown */ - h->omsg[0] = 0x92; /* SMS_ERROR */ - h->omsg[1] = 1; - h->omsg[2] = 3; /* unknown message type; */ - sms_messagetx (h); - break; - } + sms_debug ("RX", h->imsg); + /* testing */ + switch (h->imsg[0]) { + case 0x91: /* SMS_DATA */ + { + unsigned char cause = sms_handleincoming (h); + if (!cause) { + sms_log (h, 'Y'); + h->omsg[0] = 0x95; /* SMS_ACK */ + h->omsg[1] = 0x02; + h->omsg[2] = 0x00; /* deliver report */ + h->omsg[3] = 0x00; /* no parameters */ + } else { /* NACK */ + sms_log (h, 'N'); + h->omsg[0] = 0x96; /* SMS_NACK */ + h->omsg[1] = 3; + h->omsg[2] = 0; /* delivery report */ + h->omsg[3] = cause; /* cause */ + h->omsg[4] = 0; /* no parameters */ + } + sms_messagetx (h); + } + break; + case 0x92: /* SMS_ERROR */ + h->err = 1; + sms_messagetx (h); /* send whatever we sent again */ + break; + case 0x93: /* SMS_EST */ + sms_nextoutgoing (h); + break; + case 0x94: /* SMS_REL */ + h->hangup = 1; /* hangup */ + break; + case 0x95: /* SMS_ACK */ + sms_log (h, 'Y'); + sms_nextoutgoing (h); + break; + case 0x96: /* SMS_NACK */ + h->err = 1; + sms_log (h, 'N'); + sms_nextoutgoing (h); + break; + default: /* Unknown */ + h->omsg[0] = 0x92; /* SMS_ERROR */ + h->omsg[1] = 1; + h->omsg[2] = 3; /* unknown message type; */ + sms_messagetx (h); + break; + } } -static void -sms_messagetx (sms_t * h) +static void sms_messagetx(sms_t * h) { - unsigned char c = 0, - p; - for (p = 0; p < h->omsg[1] + 2; p++) - c += h->omsg[p]; - h->omsg[h->omsg[1] + 2] = 0 - c; - sms_debug ("TX", h->omsg); - h->obyte = 1; - h->opause = 200; - if (h->omsg[0] == 0x93) - h->opause = 2400; /* initial message delay 300ms (for BT) */ - h->obytep = 0; - h->obitp = 0; - h->osync = 80; - h->obyten = h->omsg[1] + 3; + unsigned char c = 0, p; + for (p = 0; p < h->omsg[1] + 2; p++) + c += h->omsg[p]; + h->omsg[h->omsg[1] + 2] = 0 - c; + sms_debug ("TX", h->omsg); + h->obyte = 1; + h->opause = 200; + if (h->omsg[0] == 0x93) + h->opause = 2400; /* initial message delay 300ms (for BT) */ + h->obytep = 0; + h->obitp = 0; + h->osync = 80; + h->obyten = h->omsg[1] + 3; } -static int -sms_generate (struct ast_channel *chan, void *data, int len, int samples) +static int sms_generate (struct ast_channel *chan, void *data, int len, int samples) { - struct ast_frame f = { 0 }; - unsigned char waste[AST_FRIENDLY_OFFSET]; + struct ast_frame f = { 0 }; + unsigned char waste[AST_FRIENDLY_OFFSET]; #ifdef OUTALAW - unsigned char buf[800]; + unsigned char buf[800]; #else - signed short buf[800]; + signed short buf[800]; #endif - sms_t *h = data; - int i; + sms_t *h = data; + int i; - if (len > sizeof (buf)) - { - ast_log (LOG_WARNING, "Only doing %d bytes (%d bytes requested)\n", sizeof (buf) / sizeof (signed short), len); - len = sizeof (buf); + if (len > sizeof (buf)) { + ast_log (LOG_WARNING, "Only doing %d bytes (%d bytes requested)\n", sizeof (buf) / sizeof (signed short), len); + len = sizeof (buf); #ifdef OUTALAW - samples = len; + samples = len; #else - samples = len / 2; + samples = len / 2; #endif - } - waste[0] = 0; /* make compiler happy */ - f.frametype = AST_FRAME_VOICE; + } + waste[0] = 0; /* make compiler happy */ + f.frametype = AST_FRAME_VOICE; #ifdef OUTALAW - f.subclass = AST_FORMAT_ALAW; - f.datalen = samples; + f.subclass = AST_FORMAT_ALAW; + f.datalen = samples; #else - f.subclass = AST_FORMAT_SLINEAR; - f.datalen = samples * 2; + f.subclass = AST_FORMAT_SLINEAR; + f.datalen = samples * 2; #endif - f.offset = AST_FRIENDLY_OFFSET; - f.mallocd = 0; - f.data = buf; - f.samples = samples; - f.src = "app_sms"; - /* create a buffer containing the digital sms pattern */ - for (i = 0; i < samples; i++) - { + f.offset = AST_FRIENDLY_OFFSET; + f.mallocd = 0; + f.data = buf; + f.samples = samples; + f.src = "app_sms"; + /* create a buffer containing the digital sms pattern */ + for (i = 0; i < samples; i++) { #ifdef OUTALAW - buf[i] = wavea[0]; + buf[i] = wavea[0]; #else - buf[i] = wave[0]; + buf[i] = wave[0]; #endif - if (h->opause) - h->opause--; - else if (h->obyten || h->osync) - { /* sending data */ + if (h->opause) + h->opause--; + else if (h->obyten || h->osync) { /* sending data */ #ifdef OUTALAW - buf[i] = wavea[h->ophase]; + buf[i] = wavea[h->ophase]; #else - buf[i] = wave[h->ophase]; + buf[i] = wave[h->ophase]; #endif - if ((h->ophase += ((h->obyte & 1) ? 13 : 21)) >= 80) - h->ophase -= 80; - if ((h->ophasep += 12) >= 80) - { /* next bit */ - h->ophasep -= 80; - if (h->osync) - h->osync--; /* sending sync bits */ - else - { - h->obyte >>= 1; - h->obitp++; - if (h->obitp == 1) - h->obyte = 0; /* start bit; */ - else if (h->obitp == 2) - h->obyte = h->omsg[h->obytep]; - else if (h->obitp == 10) - { - h->obyte = 1; /* stop bit */ - h->obitp = 0; - h->obytep++; - if (h->obytep == h->obyten) - { - h->obytep = h->obyten = 0; /* sent */ - h->osync = 10; /* trailing marks */ - } - } - } - } - } - } - if (ast_write (chan, &f) < 0) - { - ast_log (LOG_WARNING, "Failed to write frame to '%s': %s\n", chan->name, strerror (errno)); - return -1; - } - return 0; + if ((h->ophase += ((h->obyte & 1) ? 13 : 21)) >= 80) + h->ophase -= 80; + if ((h->ophasep += 12) >= 80) { /* next bit */ + h->ophasep -= 80; + if (h->osync) + h->osync--; /* sending sync bits */ + else { + h->obyte >>= 1; + h->obitp++; + if (h->obitp == 1) + h->obyte = 0; /* start bit; */ + else if (h->obitp == 2) + h->obyte = h->omsg[h->obytep]; + else if (h->obitp == 10) { + h->obyte = 1; /* stop bit */ + h->obitp = 0; + h->obytep++; + if (h->obytep == h->obyten) { + h->obytep = h->obyten = 0; /* sent */ + h->osync = 10; /* trailing marks */ + } + } + } + } + } + } + if (ast_write (chan, &f) < 0) { + ast_log (LOG_WARNING, "Failed to write frame to '%s': %s\n", chan->name, strerror (errno)); + return -1; + } + return 0; } -static void -sms_process (sms_t * h, int samples, signed short *data) +static void sms_process (sms_t * h, int samples, signed short *data) { - if (h->obyten || h->osync) - return; /* sending */ - while (samples--) - { - unsigned long long m0, - m1; - if (abs (*data) > h->imag) - h->imag = abs (*data); - else - h->imag = h->imag * 7 / 8; - if (h->imag > 500) - { - h->idle = 0; - h->ims0 = (h->ims0 * 6 + *data * wave[h->ips0]) / 7; - h->imc0 = (h->imc0 * 6 + *data * wave[h->ipc0]) / 7; - h->ims1 = (h->ims1 * 6 + *data * wave[h->ips1]) / 7; - h->imc1 = (h->imc1 * 6 + *data * wave[h->ipc1]) / 7; - m0 = h->ims0 * h->ims0 + h->imc0 * h->imc0; - m1 = h->ims1 * h->ims1 + h->imc1 * h->imc1; - if ((h->ips0 += 21) >= 80) - h->ips0 -= 80; - if ((h->ipc0 += 21) >= 80) - h->ipc0 -= 80; - if ((h->ips1 += 13) >= 80) - h->ips1 -= 80; - if ((h->ipc1 += 13) >= 80) - h->ipc1 -= 80; - { - char bit; - h->ibith <<= 1; - if (m1 > m0) - h->ibith |= 1; - if (h->ibith & 8) - h->ibitt--; - if (h->ibith & 1) - h->ibitt++; - bit = ((h->ibitt > 1) ? 1 : 0); - if (bit != h->ibitl) - h->ibitc = 1; - else - h->ibitc++; - h->ibitl = bit; - if (!h->ibitn && h->ibitc == 4 && !bit) - { - h->ibitn = 1; - h->iphasep = 0; - } - if (bit && h->ibitc == 200) - { /* sync, restart message */ - h->ierr = h->ibitn = h->ibytep = h->ibytec = 0; - } - if (h->ibitn) - { - h->iphasep += 12; - if (h->iphasep >= 80) - { /* next bit */ - h->iphasep -= 80; - if (h->ibitn++ == 9) - { /* end of byte */ - if (!bit) /* bad stop bit */ - h->ierr = 0xFF; /* unknown error */ - else - { - if (h->ibytep < sizeof (h->imsg)) - { - h->imsg[h->ibytep] = h->ibytev; - h->ibytec += h->ibytev; - h->ibytep++; - } else if (h->ibytep == sizeof (h->imsg)) - h->ierr = 2; /* bad message length */ - if (h->ibytep > 1 && h->ibytep == 3 + h->imsg[1] && !h->ierr) - { - if (!h->ibytec) - sms_messagerx (h); - else - h->ierr = 1; /* bad checksum */ - } - } - h->ibitn = 0; - } - h->ibytev = (h->ibytev >> 1) + (bit ? 0x80 : 0); - } - } - } - } else - { /* lost carrier */ - if (h->idle++ == 80000) - { /* nothing happening */ - ast_log (LOG_EVENT, "No data, hanging up\n"); - h->hangup = 1; - h->err = 1; - } - if (h->ierr) - { /* error */ - h->err = 1; - h->omsg[0] = 0x92; /* error */ - h->omsg[1] = 1; - h->omsg[2] = h->ierr; - sms_messagetx (h); /* send error */ - } - h->ierr = h->ibitn = h->ibytep = h->ibytec = 0; - } - data++; - } + if (h->obyten || h->osync) + return; /* sending */ + while (samples--) { + unsigned long long m0, m1; + if (abs (*data) > h->imag) + h->imag = abs (*data); + else + h->imag = h->imag * 7 / 8; + if (h->imag > 500) { + h->idle = 0; + h->ims0 = (h->ims0 * 6 + *data * wave[h->ips0]) / 7; + h->imc0 = (h->imc0 * 6 + *data * wave[h->ipc0]) / 7; + h->ims1 = (h->ims1 * 6 + *data * wave[h->ips1]) / 7; + h->imc1 = (h->imc1 * 6 + *data * wave[h->ipc1]) / 7; + m0 = h->ims0 * h->ims0 + h->imc0 * h->imc0; + m1 = h->ims1 * h->ims1 + h->imc1 * h->imc1; + if ((h->ips0 += 21) >= 80) + h->ips0 -= 80; + if ((h->ipc0 += 21) >= 80) + h->ipc0 -= 80; + if ((h->ips1 += 13) >= 80) + h->ips1 -= 80; + if ((h->ipc1 += 13) >= 80) + h->ipc1 -= 80; + { + char bit; + h->ibith <<= 1; + if (m1 > m0) + h->ibith |= 1; + if (h->ibith & 8) + h->ibitt--; + if (h->ibith & 1) + h->ibitt++; + bit = ((h->ibitt > 1) ? 1 : 0); + if (bit != h->ibitl) + h->ibitc = 1; + else + h->ibitc++; + h->ibitl = bit; + if (!h->ibitn && h->ibitc == 4 && !bit) { + h->ibitn = 1; + h->iphasep = 0; + } + if (bit && h->ibitc == 200) { /* sync, restart message */ + h->ierr = h->ibitn = h->ibytep = h->ibytec = 0; + } + if (h->ibitn) { + h->iphasep += 12; + if (h->iphasep >= 80) { /* next bit */ + h->iphasep -= 80; + if (h->ibitn++ == 9) { /* end of byte */ + if (!bit) /* bad stop bit */ + h->ierr = 0xFF; /* unknown error */ + else { + if (h->ibytep < sizeof (h->imsg)) { + h->imsg[h->ibytep] = h->ibytev; + h->ibytec += h->ibytev; + h->ibytep++; + } else if (h->ibytep == sizeof (h->imsg)) + h->ierr = 2; /* bad message length */ + if (h->ibytep > 1 && h->ibytep == 3 + h->imsg[1] && !h->ierr) { + if (!h->ibytec) + sms_messagerx (h); + else + h->ierr = 1; /* bad checksum */ + } + } + h->ibitn = 0; + } + h->ibytev = (h->ibytev >> 1) + (bit ? 0x80 : 0); + } + } + } + } else { /* lost carrier */ + if (h->idle++ == 80000) { /* nothing happening */ + ast_log (LOG_EVENT, "No data, hanging up\n"); + h->hangup = 1; + h->err = 1; + } + if (h->ierr) { /* error */ + h->err = 1; + h->omsg[0] = 0x92; /* error */ + h->omsg[1] = 1; + h->omsg[2] = h->ierr; + sms_messagetx (h); /* send error */ + } + h->ierr = h->ibitn = h->ibytep = h->ibytec = 0; + } + data++; + } } static struct ast_generator smsgen = { - alloc:sms_alloc, - release:sms_release, - generate:sms_generate, + alloc:sms_alloc, + release:sms_release, + generate:sms_generate, }; -static int -sms_exec (struct ast_channel *chan, void *data) +static int sms_exec (struct ast_channel *chan, void *data) { - int res = -1; - struct localuser *u; - struct ast_frame *f; - sms_t h = { 0 }; - h.ipc0 = h.ipc1 = 20; /* phase for cosine */ - h.dcs = 0xF1; /* default */ - if (!data) - { - ast_log (LOG_ERROR, "Requires queue name at least\n"); - return -1; - } - - if (chan->cid.cid_num) - strncpy (h.cli, chan->cid.cid_num, sizeof (h.cli) - 1); - - { - unsigned char *d = data, - *p, - answer = 0; - if (!*d || *d == '|') - { - ast_log (LOG_ERROR, "Requires queue name\n"); - return -1; - } - for (p = d; *p && *p != '|'; p++); - if (p - d >= sizeof (h.queue)) - { - ast_log (LOG_ERROR, "Queue name too long\n"); - return -1; - } - strncpy (h.queue, d, p - d); - if (*p == '|') - p++; - d = p; - for (p = h.queue; *p; p++) - if (!isalnum (*p)) - *p = '-'; /* make very safe for filenames */ - while (*d && *d != '|') - { - switch (*d) - { - case 'a': /* we have to send the initial FSK sequence */ - answer = 1; - break; - case 's': /* we are acting as a service centre talking to a phone */ - h.smsc = 1; - break; - /* the following apply if there is an arg3/4 and apply to the created message file */ - case 'r': - h.srr = 1; - break; - case 'o': - h.dcs |= 4; /* octets */ - break; - case '1': - case '2': - case '3': - case '4': - case '5': - case '6': - case '7': /* set the pid for saved local message */ - h.pid = 0x40 + (*d & 0xF); - break; - } - d++; - } - if (*d == '|') - { - /* submitting a message, not taking call. */ - /* depricated, use smsq instead */ - d++; - h.scts = time (0); - for (p = d; *p && *p != '|'; p++); - if (*p) - *p++ = 0; - if (strlen (d) >= sizeof (h.oa)) - { - ast_log (LOG_ERROR, "Address too long %s\n", d); - return 0; - } - if (h.smsc) - { - strncpy (h.oa, d, sizeof (h.oa) - 1); - } else - { - strncpy (h.da, d, sizeof (h.da) - 1); - } - if (!h.smsc) - strncpy (h.oa, h.cli, sizeof (h.oa) - 1); - d = p; - h.udl = 0; - while (*p && h.udl < SMSLEN) - h.ud[h.udl++] = utf8decode (&p); - if (is7bit (h.dcs) && packsms7 (0, h.udhl, h.udh, h.udl, h.ud) < 0) - ast_log (LOG_WARNING, "Invalid 7 bit GSM data\n"); - if (is8bit (h.dcs) && packsms8 (0, h.udhl, h.udh, h.udl, h.ud) < 0) - ast_log (LOG_WARNING, "Invalid 8 bit data\n"); - if (is16bit (h.dcs) && packsms16 (0, h.udhl, h.udh, h.udl, h.ud) < 0) - ast_log (LOG_WARNING, "Invalid 16 bit data\n"); - h.rx = 0; /* sent message */ - h.mr = -1; - sms_writefile (&h); - return 0; - } - - if (answer) - { - /* set up SMS_EST initial message */ - h.omsg[0] = 0x93; - h.omsg[1] = 0; - sms_messagetx (&h); - } - } - - LOCAL_USER_ADD (u); - if (chan->_state != AST_STATE_UP) - ast_answer (chan); + int res = -1; + struct localuser *u; + struct ast_frame *f; + sms_t h = { 0 }; + h.ipc0 = h.ipc1 = 20; /* phase for cosine */ + h.dcs = 0xF1; /* default */ + if (!data) { + ast_log (LOG_ERROR, "Requires queue name at least\n"); + return -1; + } + + if (chan->cid.cid_num) + strncpy (h.cli, chan->cid.cid_num, sizeof (h.cli) - 1); + + { + unsigned char *d = data, + *p, + answer = 0; + if (!*d || *d == '|') { + ast_log (LOG_ERROR, "Requires queue name\n"); + return -1; + } + for (p = d; *p && *p != '|'; p++); + if (p - d >= sizeof (h.queue)) { + ast_log (LOG_ERROR, "Queue name too long\n"); + return -1; + } + strncpy (h.queue, d, p - d); + if (*p == '|') + p++; + d = p; + for (p = h.queue; *p; p++) + if (!isalnum (*p)) + *p = '-'; /* make very safe for filenames */ + while (*d && *d != '|') { + switch (*d) { + case 'a': /* we have to send the initial FSK sequence */ + answer = 1; + break; + case 's': /* we are acting as a service centre talking to a phone */ + h.smsc = 1; + break; + /* the following apply if there is an arg3/4 and apply to the created message file */ + case 'r': + h.srr = 1; + break; + case 'o': + h.dcs |= 4; /* octets */ + break; + case '1': + case '2': + case '3': + case '4': + case '5': + case '6': + case '7': /* set the pid for saved local message */ + h.pid = 0x40 + (*d & 0xF); + break; + } + d++; + } + if (*d == '|') { + /* submitting a message, not taking call. */ + /* depricated, use smsq instead */ + d++; + h.scts = time (0); + for (p = d; *p && *p != '|'; p++); + if (*p) + *p++ = 0; + if (strlen (d) >= sizeof (h.oa)) { + ast_log (LOG_ERROR, "Address too long %s\n", d); + return 0; + } + if (h.smsc) { + strncpy (h.oa, d, sizeof (h.oa) - 1); + } else { + strncpy (h.da, d, sizeof (h.da) - 1); + } + if (!h.smsc) + strncpy (h.oa, h.cli, sizeof (h.oa) - 1); + d = p; + h.udl = 0; + while (*p && h.udl < SMSLEN) + h.ud[h.udl++] = utf8decode (&p); + if (is7bit (h.dcs) && packsms7 (0, h.udhl, h.udh, h.udl, h.ud) < 0) + ast_log (LOG_WARNING, "Invalid 7 bit GSM data\n"); + if (is8bit (h.dcs) && packsms8 (0, h.udhl, h.udh, h.udl, h.ud) < 0) + ast_log (LOG_WARNING, "Invalid 8 bit data\n"); + if (is16bit (h.dcs) && packsms16 (0, h.udhl, h.udh, h.udl, h.ud) < 0) + ast_log (LOG_WARNING, "Invalid 16 bit data\n"); + h.rx = 0; /* sent message */ + h.mr = -1; + sms_writefile (&h); + return 0; + } + + if (answer) { + /* set up SMS_EST initial message */ + h.omsg[0] = 0x93; + h.omsg[1] = 0; + sms_messagetx (&h); + } + } + + LOCAL_USER_ADD (u); + if (chan->_state != AST_STATE_UP) + ast_answer (chan); #ifdef OUTALAW - res = ast_set_write_format (chan, AST_FORMAT_ALAW); + res = ast_set_write_format (chan, AST_FORMAT_ALAW); #else - res = ast_set_write_format (chan, AST_FORMAT_SLINEAR); + res = ast_set_write_format (chan, AST_FORMAT_SLINEAR); #endif - if (res >= 0) - res = ast_set_read_format (chan, AST_FORMAT_SLINEAR); - if (res < 0) - { - LOCAL_USER_REMOVE (u); - ast_log (LOG_ERROR, "Unable to set to linear mode, giving up\n"); - return -1; - } - - if (ast_activate_generator (chan, &smsgen, &h) < 0) - { - LOCAL_USER_REMOVE (u); - ast_log (LOG_ERROR, "Failed to activate generator on '%s'\n", chan->name); - return -1; - } - - /* Do our thing here */ - while (ast_waitfor (chan, -1) > -1 && !h.hangup) - { - f = ast_read (chan); - if (!f) - break; - if (f->frametype == AST_FRAME_VOICE) - { - sms_process (&h, f->samples, f->data); - } - - ast_frfree (f); - } - - sms_log (&h, '?'); /* log incomplete message */ - - LOCAL_USER_REMOVE (u); - return (h.err); + if (res >= 0) + res = ast_set_read_format (chan, AST_FORMAT_SLINEAR); + if (res < 0) { + LOCAL_USER_REMOVE (u); + ast_log (LOG_ERROR, "Unable to set to linear mode, giving up\n"); + return -1; + } + + if (ast_activate_generator (chan, &smsgen, &h) < 0) { + LOCAL_USER_REMOVE (u); + ast_log (LOG_ERROR, "Failed to activate generator on '%s'\n", chan->name); + return -1; + } + + /* Do our thing here */ + while (ast_waitfor (chan, -1) > -1 && !h.hangup) + { + f = ast_read (chan); + if (!f) + break; + if (f->frametype == AST_FRAME_VOICE) { + sms_process (&h, f->samples, f->data); + } + + ast_frfree (f); + } + + sms_log (&h, '?'); /* log incomplete message */ + + LOCAL_USER_REMOVE (u); + return (h.err); } -int -unload_module (void) +int unload_module (void) { - STANDARD_HANGUP_LOCALUSERS; - return ast_unregister_application (app); + STANDARD_HANGUP_LOCALUSERS; + return ast_unregister_application (app); } -int -load_module (void) +int load_module (void) { #ifdef OUTALAW - { - int p; - for (p = 0; p < 80; p++) - wavea[p] = AST_LIN2A (wave[p]); - } + { + int p; + for (p = 0; p < 80; p++) + wavea[p] = AST_LIN2A (wave[p]); + } #endif - snprintf (log_file, sizeof (log_file), "%s/sms", ast_config_AST_LOG_DIR); - snprintf (spool_dir, sizeof (spool_dir), "%s/sms", ast_config_AST_SPOOL_DIR); - return ast_register_application (app, sms_exec, synopsis, descrip); + snprintf (log_file, sizeof (log_file), "%s/sms", ast_config_AST_LOG_DIR); + snprintf (spool_dir, sizeof (spool_dir), "%s/sms", ast_config_AST_SPOOL_DIR); + return ast_register_application (app, sms_exec, synopsis, descrip); } -char * -description (void) +char *description (void) { - return tdesc; + return tdesc; } -int -usecount (void) +int usecount (void) { - int res; - STANDARD_USECOUNT (res); - return res; + int res; + STANDARD_USECOUNT (res); + return res; } -char * -key () +char *key () { - return ASTERISK_GPL_KEY; + return ASTERISK_GPL_KEY; } |