clean up / fix sms user data header parsing
[project/uqmi.git] / commands-wms.c
index 16c2a3b..9e28f65 100644 (file)
@@ -28,34 +28,14 @@ cmd_wms_list_messages_prepare(struct qmi_dev *qmi, struct qmi_request *req, stru
        return QMI_CMD_REQUEST;
 }
 
-static void decode_7bit(char *name, const unsigned char *data, int data_len)
+static int
+pdu_decode_7bit_str(char *dest, const unsigned char *data, int data_len, int bit_offset)
 {
-       bool multipart = false;
-       char *dest;
-       int part = 0, n_parts = 0;
-       int len, pos_offset = 0;
+       char *orig_dest = dest;
        int i;
 
-       if (data[0] == 5 && data[1] == 0 && data[2] == 3) {
-               multipart = true;
-               n_parts = data[4];
-               part = data[5];
-       } else if (data[0] == 6 && data[1] == 8 && data[2] == 4) {
-               multipart = true;
-               n_parts = data[5];
-               part = data[6];
-       }
-
-       if (multipart) {
-               len = data[0] + 1;
-               data += len;
-               data_len -= len;
-               pos_offset = 6;
-       }
-
-       dest = blobmsg_alloc_string_buffer(&status, name, data_len * 8 / 7 + 2);
        for (i = 0; i < data_len; i++) {
-               int pos = (i + pos_offset) % 7;
+               int pos = (i + bit_offset) % 7;
 
                if (pos == 0) {
                        *(dest++) = data[i] & 0x7f;
@@ -69,15 +49,64 @@ static void decode_7bit(char *name, const unsigned char *data, int data_len)
                }
        }
        *dest = 0;
-       blobmsg_add_string_buffer(&status);
+       return dest - orig_dest;
+}
+
+static void decode_udh(const unsigned char *data)
+{
+       const unsigned char *start = data;
+       const unsigned char *end;
+       unsigned int type, len;
+
+       len = *(data++);
+       end = data + len;
+       while (data < end) {
+               const unsigned char *val;
+
+               type = data[0];
+               len = data[1];
+               val = &data[2];
+               data += 2 + len;
+               if (data > end)
+                       break;
 
-       if (multipart) {
-               blobmsg_add_u32(&status, "part", part + 1);
-               blobmsg_add_u32(&status, "parts", n_parts);
+               switch (type) {
+               case 0:
+                       blobmsg_add_u32(&status, "concat_ref", (uint32_t) val[0]);
+                       blobmsg_add_u32(&status, "concat_part", (uint32_t) val[2] + 1);
+                       blobmsg_add_u32(&status, "concat_parts", (uint32_t) val[1]);
+                       break;
+               default:
+                       break;
+               }
        }
 }
 
-static char *add_semioctet(char *str, char val)
+static void decode_7bit_field(char *name, const unsigned char *data, int data_len, bool udh)
+{
+       bool multipart = false;
+       const unsigned char *udh_start;
+       char *dest;
+       int pos_offset = 0;
+
+       if (udh) {
+               int len = data[0] + 1;
+
+               udh_start = data;
+               data += len;
+               data_len -= len;
+               pos_offset = len % 7;
+       }
+
+       dest = blobmsg_alloc_string_buffer(&status, name, data_len * 8 / 7 + 2);
+       pdu_decode_7bit_str(dest, data, data_len, pos_offset);
+       blobmsg_add_string_buffer(&status);
+
+       if (udh)
+               decode_udh(udh_start);
+}
+
+static char *pdu_add_semioctet(char *str, char val)
 {
        *str = '0' + (val & 0xf);
        if (*str <= '9')
@@ -90,25 +119,34 @@ static char *add_semioctet(char *str, char val)
        return str;
 }
 
-static unsigned char *
-decode_semioctet_number(char *str, char *name, unsigned char *data, int len)
+static void
+pdu_decode_address(char *str, unsigned char *data, int len)
 {
-       str = blobmsg_alloc_string_buffer(&status, name, len * 2 + 2);
-       if (*data == 0x91) {
-               len--;
+       unsigned char toa;
+
+       toa = *(data++);
+       switch (toa & 0x70) {
+       case 0x50:
+               pdu_decode_7bit_str(str, data, len, 0);
+               return;
+       case 0x10:
                *(str++) = '+';
-       }
-       data++;
-       while (len) {
-               str = add_semioctet(str, *data);
-               data++;
-               len--;
+               /* fall through */
+       default:
+               while (len--) {
+                       str = pdu_add_semioctet(str, *data);
+                       data++;
+               }
        }
 
        *str = 0;
-       blobmsg_add_string_buffer(&status);
+}
 
-       return data;
+static void wms_decode_address(char *str, char *name, unsigned char *data, int len)
+{
+       str = blobmsg_alloc_string_buffer(&status, name, len * 2 + 2);
+       pdu_decode_address(str, data, len);
+       blobmsg_add_string_buffer(&status);
 }
 
 static void cmd_wms_get_message_cb(struct qmi_dev *qmi, struct qmi_request *req, struct qmi_msg *msg)
@@ -118,84 +156,88 @@ static void cmd_wms_get_message_cb(struct qmi_dev *qmi, struct qmi_request *req,
        char *str;
        int i, cur_len;
        bool sent;
+       unsigned char first;
 
        qmi_parse_wms_raw_read_response(msg, &res);
        data = (unsigned char *) res.data.raw_message_data.raw_data;
        end = data + res.data.raw_message_data.raw_data_n;
 
-       do {
-               cur_len = *(data++);
-               if (data + cur_len >= end)
-                       break;
+       cur_len = *(data++);
+       if (data + cur_len >= end)
+               return;
 
-               if (cur_len)
-                       data = decode_semioctet_number(str, "smsc", data, cur_len);
+       if (cur_len) {
+               wms_decode_address(str, "smsc", data, cur_len - 1);
+               data += cur_len;
+       }
 
-               if (data + 3 >= end)
-                       break;
+       if (data + 3 >= end)
+               return;
 
-               sent = (*data & 0x3) == 1;
+       first = *(data++);
+       sent = (first & 0x3) == 1;
+       if (sent)
                data++;
-               if (sent)
-                       data++;
 
-               cur_len = *(data++);
-               if (data + cur_len >= end)
-                       break;
+       cur_len = *(data++);
+       if (data + cur_len >= end)
+               return;
 
-               if (cur_len)
-                       data = decode_semioctet_number(str, sent ? "receiver" : "sender", data, (cur_len + 1) / 2);
+       if (cur_len) {
+               cur_len = (cur_len + 1) / 2;
+               wms_decode_address(str, sent ? "receiver" : "sender", data, cur_len);
+               data += cur_len + 1;
+       }
 
-               if (data + 3 >= end)
-                       break;
+       if (data + 3 >= end)
+               return;
 
-               /* Protocol ID */
-               if (*(data++) != 0)
-                       break;
+       /* Protocol ID */
+       if (*(data++) != 0)
+               return;
 
-               /* Data Encoding */
-               if (*(data++) != 0)
-                       break;
+       /* Data Encoding */
+       if (*(data++) != 0)
+               return;
 
-               if (sent) {
-                       /* Message validity */
-                       data++;
-               } else {
-                       if (data + 6 >= end)
-                               break;
-
-                       str = blobmsg_alloc_string_buffer(&status, "timestamp", 32);
-
-                       /* year */
-                       *(str++) = '2';
-                       *(str++) = '0';
-                       str = add_semioctet(str, data[0]);
-                       /* month */
-                       *(str++) = '-';
-                       str = add_semioctet(str, data[1]);
-                       /* day */
-                       *(str++) = '-';
-                       str = add_semioctet(str, data[2]);
-
-                       /* hour */
-                       *(str++) = ' ';
-                       str = add_semioctet(str, data[3]);
-                       /* minute */
-                       *(str++) = ':';
-                       str = add_semioctet(str, data[4]);
-                       /* second */
-                       *(str++) = ':';
-                       str = add_semioctet(str, data[5]);
-                       *str = 0;
-
-                       blobmsg_add_string_buffer(&status);
-
-                       data += 7;
-               }
+       if (sent) {
+               /* Message validity */
+               data++;
+       } else {
+               if (data + 6 >= end)
+                       return;
+
+               str = blobmsg_alloc_string_buffer(&status, "timestamp", 32);
+
+               /* year */
+               *(str++) = '2';
+               *(str++) = '0';
+               str = pdu_add_semioctet(str, data[0]);
+               /* month */
+               *(str++) = '-';
+               str = pdu_add_semioctet(str, data[1]);
+               /* day */
+               *(str++) = '-';
+               str = pdu_add_semioctet(str, data[2]);
+
+               /* hour */
+               *(str++) = ' ';
+               str = pdu_add_semioctet(str, data[3]);
+               /* minute */
+               *(str++) = ':';
+               str = pdu_add_semioctet(str, data[4]);
+               /* second */
+               *(str++) = ':';
+               str = pdu_add_semioctet(str, data[5]);
+               *str = 0;
+
+               blobmsg_add_string_buffer(&status);
+
+               data += 7;
+       }
 
-               cur_len = *(data++);
-               decode_7bit("text", data, end - data);
-       } while (0);
+       cur_len = *(data++);
+       decode_7bit_field("text", data, end - data, !!(first & 0x40));
 }
 
 static enum qmi_cmd_result