/****************************************************************************** smsc_cimd.c - Nokia SMS Center (CIMD 1.3).* Mikael Gueck for WapIT Ltd.*/#include <errno.h>#include <string.h>#include <stdio.h>#include <unistd.h>#include <stdlib.h>#include <time.h>#include <sys/time.h>#include <sys/types.h>#include <sys/socket.h>#include "smsc.h"#include "smsc_p.h"#include "gwlib/gwlib.h"#include "alt_charsets.h"/******************************************************************************* Static functions*//* do the handshake baby */static int cimd_open_connection(SMSCenter *smsc);/* waits for an ACK message, returns the ACK command number or -1 for error */static int expect_acknowledge(SMSCenter *smsc, int *cmd, int *err);/* sends a general ACK */static int send_acknowledge(SMSCenter *smsc);/* Reconnect to a CIMD server, use an existing structure */static int connect_tcpip(SMSCenter *smsc);static int parse_cimd_to_iso88591(char *from, char *to, int length);static int parse_iso88591_to_cimd(    char *from, char *to, int length, int alt_charset);/******************************************************************************* Open the connection and log in** return 0 if ok, -1 on failure*/static int cimd_open_connection(SMSCenter *smsc){    char *tmpbuff = NULL;    int ret = 0;    int cmd = 0, err = 0;    /* allocate some spare space */    tmpbuff = gw_malloc(10 * 1024);    memset(tmpbuff, 0, 10*1024);    /* connect */    smsc->socket = tcpip_connect_to_server(smsc->cimd_hostname, smsc->cimd_port,	NULL);	/* XXX add interface_name if required */    if (smsc->socket == -1)        goto error;    /* receive protocol string "CIMD rel 1.37\n" */    for (;;) {        ret = smscenter_read_into_buffer(smsc);        if (strstr(smsc->buffer, "CIMD rel 1.37\n") != NULL)            break;        if (ret < 0) goto logout;    }    debug("bb.sms.cimd", 0, "got the server identification tag");    smscenter_remove_from_buffer(smsc, smsc->buflen);    /* send login string */    sprintf(tmpbuff, "%c%s%c%s%c%s%c%s%c%c",            0x02,            "01", 0x09,            smsc->cimd_username, 0x09,            smsc->cimd_password, 0x09,            "11",            0x03, 0x0A);    ret = write_to_socket(smsc->socket, tmpbuff);    if (ret < 0) goto logout;    /* get an acknowledge message */    smsc->cimd_last_spoke = 0;    if (expect_acknowledge(smsc, &cmd, &err) < 1)        goto logout;    debug("bb.sms.cimd", 0, "logged in");    gw_free(tmpbuff);    return 0;logout:    cimd_close(smsc);error:    error(0, "cimd_open: could not open/handshake");    gw_free(tmpbuff);    return -1;}/******************************************************************************* Open the smscenter*/SMSCenter *cimd_open(char *hostname, int port, char *username, char *password){    SMSCenter *smsc = NULL;    int ret = 0;    /* create a SMSCenter structure */    smsc = smscenter_construct();    if (smsc == NULL) goto error;    smsc->type = SMSC_TYPE_CIMD;    smsc->cimd_hostname = gw_strdup(hostname);    smsc->hostname = gw_strdup(hostname); /* Needed by read_into_buffer() */    smsc->cimd_port = port;    smsc->cimd_username = gw_strdup(username);    smsc->cimd_password = gw_strdup(password);    ret = cimd_open_connection(smsc);    if (ret < 0)        goto error;    sprintf(smsc->name, "CIMD:%s:%d:%s", smsc->cimd_hostname,            smsc->cimd_port, smsc->cimd_username);    return smsc;error:    error(0, "cimd_open: could not open!");    smscenter_destruct(smsc);    return NULL;}/******************************************************************************* Re-open the connection and log in** return -1 if failed*/int cimd_reopen(SMSCenter *smsc){    cimd_close(smsc);    if (cimd_open_connection(smsc) < 0) {        error(0, "Failed to re-open the connection!");        return -1;    }    return 0;}/******************************************************************************* Log out and close the socket**/int cimd_close(SMSCenter *smsc){    char *cbuff = NULL;    int sum;    int ret;    if (smsc->socket == -1) {        debug("bb.sms.cimd", 0, "Trying to close cimd while already closed!");        return 0;    }    cbuff = gw_malloc(2 * 1024);    sprintf(cbuff, "%c%s%c%s%c%c", 0x02, "02", 0x09, "11", 0x03, 0x0A);    sum = write_to_socket(smsc->socket, cbuff);    if (sum < 0) goto error;    /* this time we don't block waiting for acknowledge */    recv(smsc->socket, cbuff, 2*1024, 0);    gw_free(cbuff);    ret = close(smsc->socket);    smsc->socket = -1;    return ret;error:    gw_free(cbuff);    return -1;}/******************************************************************************* Check for MO messages, returns as in smsc_submit_smsmessage in smsc.h*/int cimd_pending_smsmessage(SMSCenter *smsc){    char *tmpbuff = NULL, *newline = NULL;    int ret = 0;    time_t thetime = 0;    /* check for input sanity */    if (smsc == NULL)        goto error;    /* we can only query every 5 seconds */    thetime = time(NULL);    if ((smsc->cimd_last_spoke + 5) > thetime) goto no_messages;    smsc->cimd_last_spoke = thetime;    /* allocate some spare space */    tmpbuff = gw_malloc(10 * 1024);    memset(tmpbuff, 0, 10*1024);    sprintf(tmpbuff, "%c%s%c%s%c%c",            0x02,         /* stx */            "05", 0x09,   /* request for message, tab */            "11",         /* dummy chksum */            0x03, 0x0A);  /* etx, lf */    /* send the poll message to determine if we have messages in queue */    ret = write_to_socket(smsc->socket, tmpbuff);    if (ret < 0) {        debug("bb.sms.cimd", 0, "sending poll message failed");        goto error;    }    /* block while waiting for answer that dataset ends to a 0x0A */    for (;;) {        newline = memchr(smsc->buffer, 0x0A, smsc->buflen);        if (newline != NULL) break;        newline = memchr(smsc->buffer, 0x03, smsc->buflen);        if (newline != NULL) break;        ret = smscenter_read_into_buffer(smsc);        if (ret <= 0) {            debug("bb.sms.cimd", 0, "read_into_buffer failed!, ret=%d", ret);            goto error;        }        usleep(500);        /* Reconnect if no results in 30 seconds */        if (time(NULL) > (thetime + 30)) {            error(0, "timeout occurred, maybe the connection was broken?");            /* Reconnect if neccessary, this catches most of them */            /* XXX this is an ugly kludge, but then again,               CIMD 1.3 is an ugly kludge. */            connect_tcpip(smsc);            goto no_messages;        }    }    /* if we got an nck, cut the message out and return 0 */    newline = memchr(smsc->buffer, 0x15, smsc->buflen);    if (newline != NULL) {        newline = memchr(smsc->buffer, 0x0A, smsc->buflen);        if (newline == NULL)            newline = memchr(smsc->buffer, 0x03, smsc->buflen);        smscenter_remove_from_buffer(smsc, newline - smsc->buffer + 1);        goto no_messages;    }    /* miracle of miracles, we got a message */    gw_free(tmpbuff);    return 1;no_messages:    gw_free(tmpbuff);    return 0;error:    debug("bb.sms.cimd", 0, "smscenter_pending_smsmessage: returning error");    gw_free(tmpbuff);    return -1;}/******************************************************************************* Send a MT message, returns as in smsc_submit_smsmessage in smsc.h*/int cimd_submit_msg(SMSCenter *smsc, Msg *msg){    char *tmpbuff = NULL, *tmptext = NULL;    char msgtext[1024];    int ret;    int cmd = 0, err = 0;    /* Fix these by implementing a could-not-send-because-       protocol-does-not-allow in smsc.c or smsgateway.c */    if (octstr_len(msg->sms.msgdata) + octstr_len(msg->sms.udhdata) < 1) {	if (msg->sms.msgdata == NULL)	    msg->sms.msgdata = octstr_create("");	octstr_append_from_hex(msg->sms.msgdata, "20");    }    if (octstr_len(msg->sms.sender) < 1) {        warning(0, "cimd_submit_smsmessage: ignoring message with 0-length field");        goto okay;  /* THIS IS NOT OKAY!!!! XXX */    }    if (octstr_len(msg->sms.receiver) < 1) {        warning(0, "cimd_submit_smsmessage: ignoring message with 0-length field");        goto okay;  /* THIS IS NOT OKAY!!!! XXX */    }    tmpbuff = gw_malloc(10 * 1024);    tmptext = gw_malloc(10 * 1024);    memset(tmpbuff, 0, 10*1024);    memset(tmptext, 0, 10*1024);    memset(msgtext, 0, sizeof(msgtext));    if (octstr_len(msg->sms.udhdata)) {        octstr_get_many_chars(msgtext, msg->sms.udhdata, 0, octstr_len(msg->sms.udhdata));        octstr_get_many_chars(msgtext + octstr_len(msg->sms.udhdata),                              msg->sms.msgdata, 0,                              140 - octstr_len(msg->sms.udhdata));    } else {        octstr_get_many_chars(msgtext, msg->sms.msgdata, 0,                              octstr_len(msg->sms.msgdata));    }    /* XXX parse_iso88591_to_cimd should use Octstr     * directly, or get a char* and a length, instead of using NUL     * terminated strings.     */    parse_iso88591_to_cimd(msgtext, tmptext, 10*1024, smsc->alt_charset);    /* If messages has UDHs, add the magic number 31 to the right spot */    sprintf(tmpbuff, "%c%s%c%s%c%s%c%s%c%s%c%s%c%s%c%c",            0x02,            "03", 0x09,            octstr_get_cstr(msg->sms.receiver), 0x09,            tmptext, 0x09,            "", 0x09,            "", 0x09,            (octstr_len(msg->sms.udhdata)) ? "31" : "", 0x09,            "11", 0x03, 0x0A);    ret = write_to_socket(smsc->socket, tmpbuff);    if (ret < 0) {        debug("bb.sms.cimd", 0, "cimd_submit_smsmessage: socket write error");        goto error;    }