emimsg.c File Reference

#include "emimsg.h"

Go to the source code of this file.

Functions
static char *	emi_strerror (int errnum)
static int	field_count_op (int ot, Octstr *whoami)
static int	field_count_reply (int ot, int posit, Octstr *whoami)
static struct emimsg *	emimsg_create_withlen (int len)
struct emimsg *	emimsg_create_op (int ot, int trn, Octstr *whoami)
static struct emimsg *	emimsg_create_reply_s (int ot, int trn, int positive, Octstr *whoami)
struct emimsg *	emimsg_create_reply (int ot, int trn, int positive, Octstr *whoami)
void	emimsg_destroy (struct emimsg *emimsg)
struct emimsg *	emimsg_duplicate (struct emimsg *emimsg)
static int	calculate_checksum (Octstr *message)
static Octstr *	emimsg_tostring (struct emimsg *emimsg)
struct emimsg *	get_fields (Octstr *message, Octstr *whoami)
int	emimsg_send (Connection *conn, struct emimsg *emimsg, Octstr *whoami)

Function Documentation

calculate_checksum()

static int calculate_checksum ( Octstr *  message )

static

Definition at line 252 of file emimsg.c.

References octstr_get_char(), and octstr_len().

Referenced by emimsg_tostring(), and get_fields().

{
    int end, i, checksum;

    end = octstr_len(message);
    if (octstr_get_char(message, end - 1) == 3)  /* etx, whole message */
    end -= 3;
    checksum = 0;
    for (i = 1; i < end; i++)
    checksum += octstr_get_char(message, i);
    return checksum & 0xff;
}

emi_strerror()

static char* emi_strerror ( int  errnum )

static

Definition at line 67 of file emimsg.c.

Referenced by get_fields().

{
    switch (errnum) {
    case  1: return "Checksum error";
    case  2: return "Syntax error";
    case  3: return "Operation not supported by system";
    case  4: return "Operation not allowed";
    case  5: return "Call barring active";
    case  6: return "AdC invalid";
    case  7: return "Authentication failure";
    case  8: return "Legitimisation code for all calls, failure";
    case  9: return "GA not valid";
    case 10: return "Repetition not allowed";
    case 11: return "Legitimisation code for repetition, failure";
    case 12: return "Priority call not allowed";
    case 13: return "Legitimisation code for priority call, failure";
    case 14: return "Urgent message not allowed";
    case 15: return "Legitimisation code for urgent message, failure";
    case 16: return "Reverse charging not allowed";
    case 17: return "Legitimisation code for reverse charging, failure";
    case 18: return "Deferred delivery not allowed";
    case 19: return "New AC not valid";
    case 20: return "New legitimisation code not valid";
    case 21: return "Standard text not valid";
    case 22: return "Time period not valid";
    case 23: return "Message type not supported by system";
    case 24: return "Message too long";
    case 25: return "Requested standard text not valid";
    case 26: return "Message type not valid for the pager type";
    case 27: return "Message not found in smsc";
    case 30: return "Subscriber hang-up";
    case 31: return "Fax group not supported";
    case 32: return "Fax message type not supported";
    case 33: return "Address already in list (60 series)";
    case 34: return "Address not in list (60 series)";
    case 35: return "List full, cannot add address to list (60 series)";
    case 36: return "RPID already in use";
    case 37: return "Delivery in progress";
    case 38: return "Message forwarded";
    default: return "!UNRECOGNIZED ERROR CODE!";
    }
}

emimsg_create_op()

struct emimsg* emimsg_create_op	(	int	ot,
		int	trn,
		Octstr *	whoami
	)

Definition at line 166 of file emimsg.c.

References emimsg_create_withlen(), field_count_op(), emimsg::or, emimsg::ot, and emimsg::trn.

Referenced by get_fields(), make_emi31(), make_emi60(), and msg_to_emimsg().

{
    int len;
    struct emimsg *ret;

    len = field_count_op(ot, whoami);
    if (len < 0)
    return NULL;
    ret = emimsg_create_withlen(len);
    ret->ot = ot;
    ret->or = 'O';
    ret->trn = trn;
    return ret;
}

emimsg_create_reply()

struct emimsg* emimsg_create_reply	(	int	ot,
		int	trn,
		int	positive,
		Octstr *	whoami
	)

Definition at line 199 of file emimsg.c.

References emimsg_create_reply_s(), emimsg::fields, octstr_create, emimsg::ot, and emimsg::trn.

Referenced by handle_operation().

{
    struct emimsg *ret;

    ret = emimsg_create_reply_s(ot, trn, positive, whoami);
    if (ret) {
    if (positive)
        ret->fields[0] = octstr_create("A");
    else
        ret->fields[0] = octstr_create("N");
    }
    return ret;
}

emimsg_create_reply_s()

static struct emimsg* emimsg_create_reply_s ( int  ot, int  trn, int  positive, Octstr *  whoami  )

static

Definition at line 182 of file emimsg.c.

References emimsg_create_withlen(), field_count_reply(), emimsg::or, emimsg::ot, and emimsg::trn.

Referenced by emimsg_create_reply(), and get_fields().

{
    int len;
    struct emimsg *ret;

    len = field_count_reply(ot, positive, whoami);
    if (len < 0)
    return NULL;
    ret = emimsg_create_withlen(len);
    ret->ot = ot;
    ret->or = 'R';
    ret->trn = trn;
    return ret;
}

emimsg_create_withlen()

static struct emimsg* emimsg_create_withlen ( int  len )

static

Definition at line 153 of file emimsg.c.

References emimsg::fields, and emimsg::num_fields.

Referenced by emimsg_create_op(), and emimsg_create_reply_s().

{
    struct emimsg *ret;

    ret = gw_malloc(sizeof(struct emimsg));
    ret->fields = gw_malloc(len * sizeof(Octstr *));
    ret->num_fields = len;
    while (--len >= 0)
    ret->fields[len] = NULL;
    return ret;
}

emimsg_destroy()

void emimsg_destroy

(

struct emimsg *

emimsg

)

Definition at line 215 of file emimsg.c.

References emimsg::fields, emimsg::num_fields, and octstr_destroy().

Referenced by emi2_do_send(), emi2_handle_smscreq(), emi2_keepalive_handling(), emi2_receiver(), get_fields(), handle_operation(), open_send_connection(), and wait_for_ack().

{
    int len;

    len = emimsg->num_fields;
    while (--len >= 0) {
        octstr_destroy(emimsg->fields[len]);  /* octstr_destroy(NULL) is ok */
        emimsg->fields[len] = NULL;
    }
    gw_free(emimsg->fields);
    gw_free(emimsg);
}

emimsg_duplicate()

struct emimsg* emimsg_duplicate

(

struct emimsg *

emimsg

)

Definition at line 229 of file emimsg.c.

References emimsg::fields, emimsg::num_fields, octstr_duplicate, emimsg::or, emimsg::ot, and emimsg::trn.

{
    int len;
    struct emimsg *ret;

    len = emimsg->num_fields;
    if (len < 0)
        return NULL;
    ret = gw_malloc(sizeof(struct emimsg));
    ret->fields = gw_malloc(len * sizeof(Octstr *));
    ret->num_fields = len;
    while (--len >= 0)
        ret->fields[len] = octstr_duplicate(emimsg->fields[len]);
    ret->ot = emimsg->ot;
    ret->or = emimsg->or;
    ret->trn = emimsg->trn;

    return ret;
}

emimsg_send()

int emimsg_send	(	Connection *	conn,
		struct emimsg *	emimsg,
		Octstr *	whoami
	)

Definition at line 368 of file emimsg.c.

References conn_write(), debug(), emimsg_tostring(), error(), octstr_destroy(), octstr_get_cstr, and emimsg::ot.

Referenced by emi2_emimsg_send().

{
    Octstr *string;

    string = emimsg_tostring(emimsg);
    if (!string) {
    error(0, "EMI2[%s]: emimsg_send: conversion to string failed",
          octstr_get_cstr(whoami));
    return -1;
    }
    if (emimsg->ot == 60)
    debug("smsc.emi2", 0, "EMI2[%s]: Sending operation type 60, message with "
          "password not shown in log file.", octstr_get_cstr(whoami));
    else
    debug("smsc.emi2", 0, "EMI2[%s]: emi2 sending packet: <%s>",
          octstr_get_cstr(whoami), octstr_get_cstr(string));
    if (conn_write(conn, string) == -1) {
    octstr_destroy(string);
    error(0, "EMI2[%s]: emimsg_send: write failed",
          octstr_get_cstr(whoami));
    return -1;
    }
    octstr_destroy(string);
    return 1;
}

emimsg_tostring()

static Octstr* emimsg_tostring ( struct emimsg *  emimsg )

static

Definition at line 266 of file emimsg.c.

References calculate_checksum(), emimsg::fields, emimsg::num_fields, octstr_append(), octstr_append_char(), octstr_create, octstr_destroy(), octstr_format(), octstr_len(), emimsg::or, emimsg::ot, and emimsg::trn.

Referenced by emimsg_send().

{
    int i, checksum;
    Octstr *result, *data;
    char *hexits = "0123456789ABCDEF";

    data = octstr_create("");
    for (i = 0; i < emimsg->num_fields; i++) {
    if (emimsg->fields[i])
        octstr_append(data, emimsg->fields[i]);
    octstr_append_char(data, '/');
    }
    result = octstr_format("\02%02d/%05d/%c/%02d/%S", emimsg->trn,
        octstr_len(data) + 16, emimsg->or, emimsg->ot, data);
    checksum = calculate_checksum(result);
    octstr_append_char(result, hexits[checksum >> 4 & 15]);
    octstr_append_char(result, hexits[checksum & 15]);
    octstr_append_char(result, 3);
    octstr_destroy(data);
    return result;
}

field_count_op()

static int field_count_op ( int  ot, Octstr *  whoami  )

static

Definition at line 111 of file emimsg.c.

References error(), octstr_get_cstr, SZ01, SZ50, and SZ60.

Referenced by emimsg_create_op().

{
    switch (ot) {
    case 01:
    return SZ01;
    case 31:
    return 2;
    case 51:
    case 52:
    case 53:
    return SZ50;
    case 60:
    return SZ60;
    default:
    error(0, "EMI2[%s]: Unsupported EMI operation request type %d", 
          octstr_get_cstr(whoami), ot);
    return -1;
    }
}

field_count_reply()

static int field_count_reply ( int  ot, int  posit, Octstr *  whoami  )

static

Definition at line 132 of file emimsg.c.

References error(), and octstr_get_cstr.

Referenced by emimsg_create_reply_s().

{
    switch(ot) {
    case 01:
    return posit ? 2 : 3;
    case 31:
    return posit ? 2 : 3;
    case 51:
    case 52:
    case 53:
    return 3;
    case 60:
    return posit ? 2 : 3;
    default:
    error(0, "EMI2[%s]: Unsupported EMI operation reply type %d", 
          octstr_get_cstr(whoami), ot);
    return -1;
    }
}

get_fields()

struct emimsg* get_fields	(	Octstr *	message,
		Octstr *	whoami
	)

Definition at line 290 of file emimsg.c.

References calculate_checksum(), debug(), emi_strerror(), emimsg_create_op(), emimsg_create_reply_s(), emimsg_destroy(), error(), emimsg::fields, emimsg::num_fields, octstr_copy, octstr_get_char(), octstr_get_cstr, octstr_len(), octstr_parse_long(), octstr_search_char(), emimsg::or, emimsg::ot, emimsg::trn, and warning().

Referenced by emi2_handle_smscreq(), emi2_receiver(), main(), and wait_for_ack().

{
    long trn, len, ot, checksum; /* because of Octstr_parse_long... */
    char or, posit;
    long fieldno, pos, pos2;
    struct emimsg *result = NULL;

    debug("smsc.emi2", 0, "EMI2[%s]: emi2 parsing packet: <%s>",
      octstr_get_cstr(whoami), octstr_get_cstr(message));
    if (octstr_get_char(message, 0) != 2 ||
    octstr_get_char(message, octstr_len(message) - 1) != 3)
    goto error;
    if (octstr_parse_long(&trn, message, 1, 10) != 3)
    goto error;
    if (octstr_parse_long(&len, message, 4, 10) != 9)
    goto error;
    if (octstr_len(message) != len + 2)     /* +2 for start/end markers */
    goto error;
    if ( (or = octstr_get_char(message, 10)) != 'O' && or != 'R')
    goto error;
    if (octstr_parse_long(&ot, message, 12, 10) != 14)
    goto error;
    if (or == 'O')
    result = emimsg_create_op(ot, trn, whoami);
    else {
    posit = octstr_get_char(message, 15);
    if (posit == 'A')
        result = emimsg_create_reply_s(ot, trn, 1, whoami);
    else if (posit == 'N')
        result = emimsg_create_reply_s(ot, trn, 0, whoami);
    else
        goto error;
    }
    if (result == NULL)
    goto error;
    pos2 = 14;
    for (fieldno = 0; fieldno < result->num_fields; fieldno++) {
    pos = pos2 + 1;
    if ( (pos2 = octstr_search_char(message, '/', pos)) == -1)
        goto error;
    if (pos2 > pos)
        result->fields[fieldno] = octstr_copy(message, pos, pos2 - pos);
    }
    if (octstr_search_char(message, '/', pos2 + 1) != -1) {
    int extrafields = 0;

    pos = pos2;
    while ((pos = octstr_search_char(message, '/', pos + 1)) != -1) {
        extrafields++;
        pos2 = pos;
    }
    /* The extra fields are ignored */
    warning(0, "get_fields: EMI message of type %d/%c has %d more fields "
        "than expected.", result->ot, result->or, extrafields);
    }
    if (octstr_parse_long(&checksum, message, pos2 + 1, 16) !=
    octstr_len(message) - 1 || checksum != calculate_checksum(message))
    goto error;
    if (result->or == 'R' && octstr_get_char(result->fields[0], 0) == 'N') {
    long errcode;
    if (!result->fields[1] ||
        octstr_parse_long(&errcode, result->fields[1], 0, 10) != 2)
        goto error;
    error(0, "EMI2[%s]: Got negative ack. op:%d, trn:%d, error:%ld (%s), message:%s",
          octstr_get_cstr(whoami),
          result->ot, result->trn, errcode, emi_strerror(errcode),
          result->fields[2] ? octstr_get_cstr(result->fields[2]) : "");
    }
    return result;
error:
    error(0, "EMI2[%s]: Invalid EMI packet: %s", octstr_get_cstr(whoami),
      octstr_get_cstr(message));
    if (result)
    emimsg_destroy(result);
    return NULL;
}