Kannel: Open Source WAP and SMS gateway  $Revision: 5037 $
generic.c File Reference
#include "gwlib/gwlib.h"

Go to the source code of this file.

Data Structures

struct  fieldmap
 
struct  generic_values
 

Functions

static void fieldmap_destroy (struct fieldmap *fieldmap)
 
static struct fieldmapgeneric_get_field_map (CfgGroup *grp)
 
static void generic_receive_sms (SMSCConn *conn, HTTPClient *client, List *headers, Octstr *body, List *cgivars)
 
static int generic_send_sms (SMSCConn *conn, Msg *sms)
 
static void generic_parse_reply (SMSCConn *conn, Msg *msg, int status, List *headers, Octstr *body)
 
static int generic_init (SMSCConn *conn, CfgGroup *cfg)
 
static void generic_destroy (SMSCConn *conn)
 

Variables

struct smsc_http_fn_callbacks smsc_http_generic_callback
 

Function Documentation

◆ fieldmap_destroy()

static void fieldmap_destroy ( struct fieldmap fieldmap)
static

Definition at line 142 of file generic.c.

References fieldmap::account, fieldmap::binfo, fieldmap::coding, fieldmap::deferred, fieldmap::dlr_err, fieldmap::dlr_mask, fieldmap::dlr_mid, fieldmap::dlr_url, fieldmap::flash, fieldmap::foreign_id, fieldmap::from, fieldmap::mclass, fieldmap::message_sent, fieldmap::meta_data, fieldmap::mwi, octstr_destroy(), fieldmap::password, fieldmap::service, fieldmap::text, fieldmap::to, fieldmap::udh, fieldmap::username, and fieldmap::validity.

Referenced by generic_destroy().

143 {
144  if (fieldmap == NULL)
145  return;
146  octstr_destroy(fieldmap->username);
147  octstr_destroy(fieldmap->password);
148  octstr_destroy(fieldmap->from);
149  octstr_destroy(fieldmap->to);
150  octstr_destroy(fieldmap->text);
151  octstr_destroy(fieldmap->udh);
152  octstr_destroy(fieldmap->service);
153  octstr_destroy(fieldmap->account);
154  octstr_destroy(fieldmap->binfo);
155  octstr_destroy(fieldmap->meta_data);
156  octstr_destroy(fieldmap->dlr_mask);
157  octstr_destroy(fieldmap->dlr_err);
158  octstr_destroy(fieldmap->dlr_url);
159  octstr_destroy(fieldmap->dlr_mid);
160  octstr_destroy(fieldmap->flash);
161  octstr_destroy(fieldmap->mclass);
162  octstr_destroy(fieldmap->mwi);
163  octstr_destroy(fieldmap->coding);
164  octstr_destroy(fieldmap->validity);
165  octstr_destroy(fieldmap->deferred);
166  octstr_destroy(fieldmap->foreign_id);
167  octstr_destroy(fieldmap->message_sent);
168  gw_free(fieldmap);
169 }
Octstr * to
Definition: generic.c:100
Octstr * text
Definition: generic.c:101
Octstr * validity
Definition: generic.c:115
Octstr * account
Definition: generic.c:104
Octstr * message_sent
Definition: generic.c:118
Octstr * deferred
Definition: generic.c:116
Octstr * dlr_mask
Definition: generic.c:107
Octstr * flash
Definition: generic.c:111
Octstr * binfo
Definition: generic.c:105
Octstr * dlr_mid
Definition: generic.c:110
Octstr * dlr_url
Definition: generic.c:109
Octstr * foreign_id
Definition: generic.c:117
Octstr * mclass
Definition: generic.c:112
Octstr * service
Definition: generic.c:103
void octstr_destroy(Octstr *ostr)
Definition: octstr.c:322
Octstr * meta_data
Definition: generic.c:106
Octstr * coding
Definition: generic.c:114
Octstr * from
Definition: generic.c:99
Octstr * udh
Definition: generic.c:102
Octstr * username
Definition: generic.c:97
Octstr * dlr_err
Definition: generic.c:108
Octstr * mwi
Definition: generic.c:113
Octstr * password
Definition: generic.c:98

◆ generic_destroy()

static void generic_destroy ( SMSCConn conn)
static

Definition at line 582 of file generic.c.

References conndata::data, smscconn::data, debug(), fieldmap_destroy(), generic_values::generic_foreign_id_regex, generic_values::map, generic_values::permfail_regex, generic_values::success_regex, and generic_values::tempfail_regex.

583 {
585  struct generic_values *values;
586 
587  if (conn == NULL || conn->data == NULL)
588  return;
589 
590  conndata = conn->data;
591  values = conndata->data;
592 
593  fieldmap_destroy(values->map);
594  if (values->success_regex)
595  gw_regex_destroy(values->success_regex);
596  if (values->permfail_regex)
597  gw_regex_destroy(values->permfail_regex);
598  if (values->tempfail_regex)
599  gw_regex_destroy(values->tempfail_regex);
600  if (values->generic_foreign_id_regex)
601  gw_regex_destroy(values->generic_foreign_id_regex);
602 
603  gw_free(values);
604  conndata->data = NULL;
605 
606  debug("", 0, "generic destroy completed");
607 }
void * data
Definition: smsc_http.c:171
void * data
Definition: smscconn_p.h:249
regex_t * success_regex
Definition: generic.c:130
regex_t * permfail_regex
Definition: generic.c:131
void debug(const char *place, int err, const char *fmt,...)
Definition: log.c:726
static void fieldmap_destroy(struct fieldmap *fieldmap)
Definition: generic.c:142
regex_t * generic_foreign_id_regex
Definition: generic.c:136
struct fieldmap * map
Definition: generic.c:124
regex_t * tempfail_regex
Definition: generic.c:132

◆ generic_get_field_map()

static struct fieldmap* generic_get_field_map ( CfgGroup grp)
static

Definition at line 175 of file generic.c.

References fieldmap::account, fieldmap::binfo, cfg_get, cfg_get_integer(), fieldmap::coding, fieldmap::deferred, fieldmap::dlr_err, fieldmap::dlr_mask, fieldmap::dlr_mid, fieldmap::dlr_url, fieldmap::flash, fieldmap::foreign_id, fieldmap::from, gw_assert(), HTTP_ACCEPTED, fieldmap::mclass, fieldmap::message_sent, fieldmap::meta_data, fieldmap::mwi, octstr_create, octstr_imm(), fieldmap::password, fieldmap::service, fieldmap::status_error, fieldmap::status_sent, fieldmap::text, fieldmap::to, fieldmap::udh, fieldmap::username, and fieldmap::validity.

Referenced by generic_init().

176 {
177  struct fieldmap *fm = NULL;
178 
179  fm = gw_malloc(sizeof(*fm));
180  gw_assert(fm != NULL);
181 
182  fm->username = cfg_get(grp, octstr_imm("generic-param-username"));
183  if (fm->username == NULL)
184  fm->username = octstr_create("username");
185  fm->password = cfg_get(grp, octstr_imm("generic-param-password"));
186  if (fm->password == NULL)
187  fm->password = octstr_create("password");
188  fm->from = cfg_get(grp, octstr_imm("generic-param-from"));
189  if (fm->from == NULL)
190  fm->from = octstr_create("from");
191  fm->to = cfg_get(grp, octstr_imm("generic-param-to"));
192  if (fm->to == NULL)
193  fm->to = octstr_create("to");
194  fm->text = cfg_get(grp, octstr_imm("generic-param-text"));
195  if (fm->text == NULL)
196  fm->text = octstr_create("text");
197  fm->udh = cfg_get(grp, octstr_imm("generic-param-udh"));
198  if (fm->udh == NULL)
199  fm->udh = octstr_create("udh");
200  /* "service" preloads the "username" parameter to mimic former behaviour */
201  fm->service = cfg_get(grp, octstr_imm("generic-param-service"));
202  if (fm->service == NULL)
203  fm->service = octstr_create("username");
204  fm->account = cfg_get(grp, octstr_imm("generic-param-account"));
205  if (fm->account == NULL)
206  fm->account = octstr_create("account");
207  fm->binfo = cfg_get(grp, octstr_imm("generic-param-binfo"));
208  if (fm->binfo == NULL)
209  fm->binfo = octstr_create("binfo");
210  fm->dlr_mask = cfg_get(grp, octstr_imm("generic-param-dlr-mask"));
211  if (fm->dlr_mask == NULL)
212  fm->dlr_mask = octstr_create("dlr-mask");
213  fm->dlr_err = cfg_get(grp, octstr_imm("generic-param-dlr-err"));
214  if (fm->dlr_err == NULL)
215  fm->dlr_err = octstr_create("dlr-err");
216  fm->dlr_url = cfg_get(grp, octstr_imm("generic-param-dlr-url"));
217  if (fm->dlr_url == NULL)
218  fm->dlr_url = octstr_create("dlr-url");
219  fm->dlr_mid = cfg_get(grp, octstr_imm("generic-param-dlr-mid"));
220  if (fm->dlr_mid == NULL)
221  fm->dlr_mid = octstr_create("dlr-mid");
222  fm->flash = cfg_get(grp, octstr_imm("generic-param-flash"));
223  if (fm->flash == NULL)
224  fm->flash = octstr_create("flash");
225  fm->mclass = cfg_get(grp, octstr_imm("generic-param-mclass"));
226  if (fm->mclass == NULL)
227  fm->mclass = octstr_create("mclass");
228  fm->mwi = cfg_get(grp, octstr_imm("generic-param-mwi"));
229  if (fm->mwi == NULL)
230  fm->mwi = octstr_create("mwi");
231  fm->coding = cfg_get(grp, octstr_imm("generic-param-coding"));
232  if (fm->coding == NULL)
233  fm->coding = octstr_create("coding");
234  fm->validity = cfg_get(grp, octstr_imm("generic-param-validity"));
235  if (fm->validity == NULL)
236  fm->validity = octstr_create("validity");
237  fm->deferred = cfg_get(grp, octstr_imm("generic-param-deferred"));
238  if (fm->deferred == NULL)
239  fm->deferred = octstr_create("deferred");
240  fm->foreign_id = cfg_get(grp, octstr_imm("generic-param-foreign-id"));
241  if (fm->foreign_id == NULL)
242  fm->foreign_id = octstr_create("foreign-id");
243  fm->meta_data = cfg_get(grp, octstr_imm("generic-param-meta-data"));
244  if (fm->meta_data == NULL)
245  fm->meta_data = octstr_create("meta-data");
246  fm->message_sent = cfg_get(grp, octstr_imm("generic-message-sent"));
247  if (fm->message_sent == NULL)
248  fm->message_sent = octstr_create("Sent");
249  /* both success and error uses HTTP_ACCEPTED to mimic former behaviour */
250  if (cfg_get_integer(&fm->status_sent, grp, octstr_imm("generic-status-sent")) == -1) {
252  }
253  if (cfg_get_integer(&fm->status_error, grp, octstr_imm("generic-status-error")) == -1) {
255  }
256 
257  return fm;
258 }
Octstr * to
Definition: generic.c:100
Octstr * text
Definition: generic.c:101
Octstr * validity
Definition: generic.c:115
Octstr * account
Definition: generic.c:104
gw_assert(wtls_machine->packet_to_send !=NULL)
Octstr * message_sent
Definition: generic.c:118
Octstr * deferred
Definition: generic.c:116
#define cfg_get(grp, varname)
Definition: cfg.h:86
Octstr * dlr_mask
Definition: generic.c:107
Octstr * flash
Definition: generic.c:111
Octstr * binfo
Definition: generic.c:105
Octstr * dlr_mid
Definition: generic.c:110
Octstr * octstr_imm(const char *cstr)
Definition: octstr.c:281
Octstr * dlr_url
Definition: generic.c:109
Octstr * foreign_id
Definition: generic.c:117
Octstr * mclass
Definition: generic.c:112
Octstr * service
Definition: generic.c:103
#define octstr_create(cstr)
Definition: octstr.h:125
Octstr * meta_data
Definition: generic.c:106
Octstr * coding
Definition: generic.c:114
Octstr * from
Definition: generic.c:99
Octstr * udh
Definition: generic.c:102
Octstr * username
Definition: generic.c:97
Octstr * dlr_err
Definition: generic.c:108
Octstr * mwi
Definition: generic.c:113
int cfg_get_integer(long *n, CfgGroup *grp, Octstr *varname)
Definition: cfg.c:739
Octstr * password
Definition: generic.c:98
long status_error
Definition: generic.c:120
long status_sent
Definition: generic.c:119

◆ generic_init()

static int generic_init ( SMSCConn conn,
CfgGroup cfg 
)
static

Definition at line 529 of file generic.c.

References cfg_get, conndata::data, smscconn::data, debug(), error(), generic_values::generic_foreign_id_regex, generic_get_field_map(), smscconn::id, generic_values::map, octstr_destroy(), octstr_get_cstr, octstr_imm(), octstr_search_char(), panic, generic_values::permfail_regex, generic_values::success_regex, generic_values::tempfail_regex, and warning().

530 {
531  Octstr *os;
532  ConnData *conndata = conn->data;
533  struct generic_values *values;
534 
535  conndata->data = values = gw_malloc(sizeof(*values));
536  /* reset */
537  memset(conndata->data, 0, sizeof(*values));
538 
539  values->success_regex = values->permfail_regex = values->tempfail_regex = NULL;
540  values->generic_foreign_id_regex = NULL;
541 
542  values->map = generic_get_field_map(cfg);
543 
544  /* pre-compile regex expressions */
545  if ((os = cfg_get(cfg, octstr_imm("status-success-regex"))) != NULL) {
546  if ((values->success_regex = gw_regex_comp(os, REG_EXTENDED|REG_NOSUB)) == NULL)
547  error(0, "HTTP[%s]: Could not compile pattern '%s' defined for variable 'status-success-regex'",
548  octstr_get_cstr(conn->id), octstr_get_cstr(os));
549  octstr_destroy(os);
550  } else {
551  /* we need at least the criteria for a successful sent */
552  error(0, "HTTP[%s]: 'status-success-regex' required for generic http smsc",
553  octstr_get_cstr(conn->id));
554  return -1;
555  }
556  if ((os = cfg_get(cfg, octstr_imm("status-permfail-regex"))) != NULL) {
557  if ((values->permfail_regex = gw_regex_comp(os, REG_EXTENDED|REG_NOSUB)) == NULL)
558  panic(0, "Could not compile pattern '%s' defined for variable 'status-permfail-regex'", octstr_get_cstr(os));
559  octstr_destroy(os);
560  }
561  if ((os = cfg_get(cfg, octstr_imm("status-tempfail-regex"))) != NULL) {
562  if ((values->tempfail_regex = gw_regex_comp(os, REG_EXTENDED|REG_NOSUB)) == NULL)
563  panic(0, "Could not compile pattern '%s' defined for variable 'status-tempfail-regex'", octstr_get_cstr(os));
564  octstr_destroy(os);
565  }
566  if ((os = cfg_get(cfg, octstr_imm("generic-foreign-id-regex"))) != NULL) {
567  if ((values->generic_foreign_id_regex = gw_regex_comp(os, REG_EXTENDED)) == NULL)
568  panic(0, "Could not compile pattern '%s' defined for variable 'generic-foreign-id-regex'", octstr_get_cstr(os));
569  else {
570  /* check quickly that at least 1 group seems to be defined in the regex */
571  if (octstr_search_char(os, '(', 0) == -1 || octstr_search_char(os, ')', 0) == -1)
572  warning(0, "HTTP[%s]: No group defined in pattern '%s' for variable 'generic-foreign-id-regex'", octstr_get_cstr(conn->id), octstr_get_cstr(os));
573  }
574  octstr_destroy(os);
575  }
576 
577  debug("", 0, "generic init completed");
578 
579  return 0;
580 }
void error(int err, const char *fmt,...)
Definition: log.c:648
void * data
Definition: smsc_http.c:171
Octstr * id
Definition: smscconn_p.h:174
void * data
Definition: smscconn_p.h:249
#define cfg_get(grp, varname)
Definition: cfg.h:86
regex_t * success_regex
Definition: generic.c:130
#define octstr_get_cstr(ostr)
Definition: octstr.h:233
long octstr_search_char(const Octstr *ostr, int ch, long pos)
Definition: octstr.c:1010
regex_t * permfail_regex
Definition: generic.c:131
Octstr * octstr_imm(const char *cstr)
Definition: octstr.c:281
static struct fieldmap * generic_get_field_map(CfgGroup *grp)
Definition: generic.c:175
void warning(int err, const char *fmt,...)
Definition: log.c:660
void octstr_destroy(Octstr *ostr)
Definition: octstr.c:322
Definition: octstr.c:118
void debug(const char *place, int err, const char *fmt,...)
Definition: log.c:726
#define panic
Definition: log.h:87
regex_t * generic_foreign_id_regex
Definition: generic.c:136
struct fieldmap * map
Definition: generic.c:124
regex_t * tempfail_regex
Definition: generic.c:132

◆ generic_parse_reply()

static void generic_parse_reply ( SMSCConn conn,
Msg msg,
int  status,
List headers,
Octstr body 
)
static

Definition at line 463 of file generic.c.

References bb_smscconn_send_failed(), bb_smscconn_sent(), conndata::data, smscconn::data, debug(), dlr_add(), DLR_IS_ENABLED_DEVICE, error(), generic_values::generic_foreign_id_regex, smscconn::id, octstr_copy, octstr_create, octstr_destroy(), octstr_dump, octstr_duplicate, octstr_get_cstr, generic_values::permfail_regex, SMSCCONN_FAILED_MALFORMED, SMSCCONN_FAILED_REJECTED, SMSCCONN_FAILED_TEMPORARILY, generic_values::success_regex, generic_values::tempfail_regex, UUID_STR_LEN, uuid_unparse(), and warning().

465 {
466  ConnData *conndata = conn->data;
467  struct generic_values *values = conndata->data;
468  regmatch_t pmatch[2];
469  Octstr *msgid = NULL;
470 
471  /*
472  * Our generic type checks only content on the HTTP response body.
473  * We use the pre-compiled regex to match against the states.
474  * This is the most generic criteria (at the moment).
475  */
476  if ((values->success_regex != NULL) &&
477  (gw_regex_exec(values->success_regex, body, 0, NULL, 0) == 0)) {
478  /* SMSC ACK... the message id should be in the body */
479 
480  /* add to our own DLR storage */
481  if (DLR_IS_ENABLED_DEVICE(msg->sms.dlr_mask)) {
482  /* directive 'generic-foreign-id-regex' is present, fetch the foreign ID */
483  if ((values->generic_foreign_id_regex != NULL)) {
484  if (gw_regex_exec(values->generic_foreign_id_regex, body, sizeof(pmatch) / sizeof(regmatch_t), pmatch, 0) == 0) {
485  if (pmatch[1].rm_so != -1 && pmatch[1].rm_eo != -1) {
486  msgid = octstr_copy(body, pmatch[1].rm_so, pmatch[1].rm_eo - pmatch[1].rm_so);
487  debug("smsc.http.generic", 0, "HTTP[%s]: Found foreign message id <%s> in body.",
488  octstr_get_cstr(conn->id), octstr_get_cstr(msgid));
489  dlr_add(conn->id, msgid, msg, 0);
490  octstr_destroy(msgid);
491  }
492  }
493  if (msgid == NULL)
494  warning(0, "HTTP[%s]: Can't get the foreign message id from the HTTP body.",
495  octstr_get_cstr(conn->id));
496  } else {
497  char id[UUID_STR_LEN + 1];
498  /* use own own UUID as msg ID in the DLR storage */
499  uuid_unparse(msg->sms.id, id);
500  msgid = octstr_create(id);
501  dlr_add(conn->id, msgid, msg, 0);
502  octstr_destroy(msgid);
503  }
504  }
505  bb_smscconn_sent(conn, msg, NULL);
506  }
507  else if ((values->permfail_regex != NULL) &&
508  (gw_regex_exec(values->permfail_regex, body, 0, NULL, 0) == 0)) {
509  error(0, "HTTP[%s]: Message not accepted.", octstr_get_cstr(conn->id));
510  bb_smscconn_send_failed(conn, msg,
512  }
513  else if ((values->tempfail_regex != NULL) &&
514  (gw_regex_exec(values->tempfail_regex, body, 0, NULL, 0) == 0)) {
515  warning(0, "HTTP[%s]: Message temporary not accepted, will retry.",
516  octstr_get_cstr(conn->id));
517  bb_smscconn_send_failed(conn, msg,
519  }
520  else {
521  error(0, "HTTP[%s]: Message was rejected. SMSC response was:",
522  octstr_get_cstr(conn->id));
523  octstr_dump(body, 0);
524  bb_smscconn_send_failed(conn, msg,
526  }
527 }
void error(int err, const char *fmt,...)
Definition: log.c:648
void * data
Definition: smsc_http.c:171
Octstr * id
Definition: smscconn_p.h:174
void * data
Definition: smscconn_p.h:249
void uuid_unparse(const uuid_t uu, char *out)
Definition: gw_uuid.c:562
regex_t * success_regex
Definition: generic.c:130
void dlr_add(const Octstr *smsc, const Octstr *ts, Msg *msg, int use_dst)
Definition: dlr.c:330
#define octstr_get_cstr(ostr)
Definition: octstr.h:233
#define octstr_copy(ostr, from, len)
Definition: octstr.h:178
regex_t * permfail_regex
Definition: generic.c:131
#define octstr_duplicate(ostr)
Definition: octstr.h:187
#define octstr_dump(ostr, level,...)
Definition: octstr.h:564
void warning(int err, const char *fmt,...)
Definition: log.c:660
void octstr_destroy(Octstr *ostr)
Definition: octstr.c:322
#define octstr_create(cstr)
Definition: octstr.h:125
#define UUID_STR_LEN
Definition: gw_uuid.h:19
Definition: octstr.c:118
void bb_smscconn_sent(SMSCConn *conn, Msg *sms, Octstr *reply)
Definition: bb_smscconn.c:279
void debug(const char *place, int err, const char *fmt,...)
Definition: log.c:726
void bb_smscconn_send_failed(SMSCConn *conn, Msg *sms, int reason, Octstr *reply)
Definition: bb_smscconn.c:328
regex_t * generic_foreign_id_regex
Definition: generic.c:136
regex_t * tempfail_regex
Definition: generic.c:132
#define DLR_IS_ENABLED_DEVICE(dlr)
Definition: dlr.h:82

◆ generic_receive_sms()

static void generic_receive_sms ( SMSCConn conn,
HTTPClient client,
List headers,
Octstr body,
List cgivars 
)
static

Definition at line 260 of file generic.c.

References fieldmap::account, conndata::alt_charset, bb_smscconn_receive(), fieldmap::binfo, fieldmap::coding, conndata::data, smscconn::data, debug(), fieldmap::deferred, fieldmap::dlr_err, dlr_find(), fieldmap::dlr_mask, fieldmap::dlr_mid, DLR_UNDEFINED, error(), fieldmap::flash, fieldmap::from, gwlist_create, http_cgi_variable(), http_destroy_headers(), http_header_add(), http_send_reply(), smscconn::id, generic_values::map, MAX_SMS_OCTETS, fieldmap::mclass, fieldmap::message_sent, fieldmap::meta_data, meta_data_set_value(), METADATA_DLR_GROUP, METADATA_DLR_GROUP_ERRORCODE, msg, msg_create, msg_destroy(), msg_duplicate(), fieldmap::mwi, octstr_compare(), octstr_create, octstr_destroy(), octstr_duplicate, octstr_get_char(), octstr_get_cstr, octstr_imm(), octstr_len(), fieldmap::password, conndata::password, report_mo, sms_charset_processing(), SMS_PARAM_UNDEFINED, fieldmap::status_error, fieldmap::status_sent, fieldmap::text, fieldmap::to, fieldmap::udh, urltrans_fill_escape_codes(), fieldmap::username, conndata::username, and fieldmap::validity.

262 {
263  ConnData *conndata = conn->data;
264  struct generic_values *values = conndata->data;
265  struct fieldmap *fm = values->map;
266  Octstr *user, *pass, *from, *to, *text, *udh, *account, *binfo, *meta_data;
267  Octstr *dlrmid, *dlrerr;
268  Octstr *tmp_string, *retmsg;
269  int dlrmask;
270  List *reply_headers;
271  int ret, retstatus;
272 
273  dlrmask = SMS_PARAM_UNDEFINED;
274 
275  /* Parse enough parameters to validate the request */
276  user = http_cgi_variable(cgivars, octstr_get_cstr(fm->username));
277  pass = http_cgi_variable(cgivars, octstr_get_cstr(fm->password));
278  from = http_cgi_variable(cgivars, octstr_get_cstr(fm->from));
279  to = http_cgi_variable(cgivars, octstr_get_cstr(fm->to));
280  text = http_cgi_variable(cgivars, octstr_get_cstr(fm->text));
281  udh = http_cgi_variable(cgivars, octstr_get_cstr(fm->udh));
282  dlrmid = http_cgi_variable(cgivars, octstr_get_cstr(fm->dlr_mid));
283  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->dlr_mask));
284  if (tmp_string) {
285  sscanf(octstr_get_cstr(tmp_string),"%d", &dlrmask);
286  }
287  dlrerr = http_cgi_variable(cgivars, octstr_get_cstr(fm->dlr_err));
288 
289  debug("smsc.http.generic", 0, "HTTP[%s]: Received an HTTP request",
290  octstr_get_cstr(conn->id));
291 
292  if ((conndata->username != NULL && conndata->password != NULL) &&
293  (user == NULL || pass == NULL ||
294  octstr_compare(user, conndata->username) != 0 ||
295  octstr_compare(pass, conndata->password) != 0)) {
296  error(0, "HTTP[%s]: Authorization failure",
297  octstr_get_cstr(conn->id));
298  retmsg = octstr_create("Authorization failed for sendsms");
299  retstatus = fm->status_error;
300  } else if (dlrmask != DLR_UNDEFINED && dlrmid != NULL) {
301  /* we got a DLR, and we don't require additional values */
302  Msg *dlrmsg;
303 
304  dlrmsg = dlr_find(conn->id,
305  dlrmid, /* message id */
306  to, /* destination */
307  dlrmask, 0);
308 
309  if (dlrmsg != NULL) {
310  dlrmsg->sms.sms_type = report_mo;
311  dlrmsg->sms.msgdata = octstr_duplicate(text);
312  dlrmsg->sms.account = octstr_duplicate(conndata->username);
313 
314  debug("smsc.http.generic", 0, "HTTP[%s]: Received DLR for DLR-URL <%s>",
315  octstr_get_cstr(conn->id), octstr_get_cstr(dlrmsg->sms.dlr_url));
316 
317  if (dlrerr != NULL) {
318  /* pass errorcode as is */
319  if (dlrmsg->sms.meta_data == NULL)
320  dlrmsg->sms.meta_data = octstr_create("");
321 
322  meta_data_set_value(dlrmsg->sms.meta_data, METADATA_DLR_GROUP,
324  }
325 
326  Msg *resp = msg_duplicate(dlrmsg);
327  ret = bb_smscconn_receive(conn, dlrmsg);
328  if (ret == -1) {
329  retmsg = octstr_create("Not accepted");
330  retstatus = fm->status_error;
331  } else {
332  retmsg = urltrans_fill_escape_codes(fm->message_sent, resp);
333  retstatus = fm->status_sent;
334  }
335  msg_destroy(resp);
336  } else {
337  error(0,"HTTP[%s]: Got DLR but could not find message or was not interested "
338  "in it id<%s> dst<%s>, type<%d>",
339  octstr_get_cstr(conn->id), octstr_get_cstr(dlrmid),
340  octstr_get_cstr(to), dlrmask);
341  retmsg = octstr_create("Unknown DLR, not accepted");
342  retstatus = fm->status_error;
343  }
344  } else if (from == NULL || to == NULL || text == NULL) {
345  error(0, "HTTP[%s]: Insufficient args",
346  octstr_get_cstr(conn->id));
347  retmsg = octstr_create("Insufficient args, rejected");
348  retstatus = fm->status_error;
349  } else if (udh != NULL && (octstr_len(udh) != octstr_get_char(udh, 0) + 1)) {
350  error(0, "HTTP[%s]: UDH field misformed, rejected",
351  octstr_get_cstr(conn->id));
352  retmsg = octstr_create("UDH field misformed, rejected");
353  retstatus = fm->status_error;
354  } else if (udh != NULL && octstr_len(udh) > MAX_SMS_OCTETS) {
355  error(0, "HTTP[%s]: UDH field is too long, rejected",
356  octstr_get_cstr(conn->id));
357  retmsg = octstr_create("UDH field is too long, rejected");
358  retstatus = fm->status_error;
359  }
360  else {
361  /* we got a normal MO SMS */
362  Msg *msg;
363  msg = msg_create(sms);
364 
365  /* Parse the rest of the parameters */
366  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->flash));
367  if (tmp_string) {
368  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.mclass);
369  }
370  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->mclass));
371  if (tmp_string) {
372  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.mclass);
373  }
374  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->mwi));
375  if (tmp_string) {
376  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.mwi);
377  }
378  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->coding));
379  if (tmp_string) {
380  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.coding);
381  }
382  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->validity));
383  if (tmp_string) {
384  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.validity);
385  msg->sms.validity = time(NULL) + msg->sms.validity * 60;
386  }
387  tmp_string = http_cgi_variable(cgivars, octstr_get_cstr(fm->deferred));
388  if (tmp_string) {
389  sscanf(octstr_get_cstr(tmp_string),"%ld", &msg->sms.deferred);
390  msg->sms.deferred = time(NULL) + msg->sms.deferred * 60;
391  }
392  account = http_cgi_variable(cgivars, octstr_get_cstr(fm->account));
393  binfo = http_cgi_variable(cgivars, octstr_get_cstr(fm->binfo));
394  meta_data = http_cgi_variable(cgivars, octstr_get_cstr(fm->meta_data));
395 
396  debug("smsc.http.generic", 0, "HTTP[%s]: Constructing new SMS",
397  octstr_get_cstr(conn->id));
398 
399  msg->sms.msgdata = octstr_duplicate(text);
400 
401  /* re-encode content if necessary */
402  if (conndata->alt_charset &&
403  sms_charset_processing(conndata->alt_charset, msg->sms.msgdata, msg->sms.coding) == -1) {
404  error(0, "HTTP[%s]: Charset or body misformed, will leave it as it is.",
405  octstr_get_cstr(conn->id));
406  }
407 
408  msg->sms.service = octstr_duplicate(user);
409  msg->sms.sender = octstr_duplicate(from);
410  msg->sms.receiver = octstr_duplicate(to);
411  msg->sms.udhdata = octstr_duplicate(udh);
412  msg->sms.smsc_id = octstr_duplicate(conn->id);
413  msg->sms.time = time(NULL);
414  msg->sms.account = octstr_duplicate(account);
415  msg->sms.binfo = octstr_duplicate(binfo);
416  msg->sms.meta_data = octstr_duplicate(meta_data);
417  Msg *resp = msg_duplicate(msg);
418  ret = bb_smscconn_receive(conn, msg);
419  if (ret == -1) {
420  retmsg = octstr_create("Not accepted");
421  retstatus = fm->status_error;
422  } else {
423  retmsg = urltrans_fill_escape_codes(fm->message_sent, resp);
424  retstatus = fm->status_sent;
425  }
426  msg_destroy(resp);
427  }
428 
429  reply_headers = gwlist_create();
430  http_header_add(reply_headers, "Content-Type", "text/plain");
431  debug("smsc.http.generic", 0, "HTTP[%s]: Sending reply",
432  octstr_get_cstr(conn->id));
433  http_send_reply(client, retstatus, reply_headers, retmsg);
434 
435  octstr_destroy(retmsg);
436  http_destroy_headers(reply_headers);
437 }
Octstr * to
Definition: generic.c:100
void error(int err, const char *fmt,...)
Definition: log.c:648
#define MAX_SMS_OCTETS
Definition: sms.h:129
void * data
Definition: smsc_http.c:171
Msg * msg_duplicate(Msg *msg)
Definition: msg.c:111
Octstr * text
Definition: generic.c:101
Octstr * alt_charset
Definition: smsc_http.c:162
Octstr * validity
Definition: generic.c:115
void http_header_add(List *headers, char *name, char *contents)
Definition: http.c:2863
Octstr * account
Definition: generic.c:104
Octstr * message_sent
Definition: generic.c:118
Definition: msg.h:109
Octstr * id
Definition: smscconn_p.h:174
void * data
Definition: smscconn_p.h:249
#define METADATA_DLR_GROUP_ERRORCODE
Definition: meta_data.h:71
int meta_data_set_value(Octstr *data, const char *group, const Octstr *key, const Octstr *value, int replace)
Definition: meta_data.c:324
Octstr * deferred
Definition: generic.c:116
#define msg_create(type)
Definition: msg.h:136
Msg * dlr_find(const Octstr *smsc, const Octstr *ts, const Octstr *dst, int typ, int use_dst)
Definition: dlr.c:387
#define octstr_get_cstr(ostr)
Definition: octstr.h:233
Octstr * dlr_mask
Definition: generic.c:107
Octstr * http_cgi_variable(List *list, char *name)
Definition: http.c:2813
Octstr * flash
Definition: generic.c:111
void http_destroy_headers(List *headers)
Definition: http.c:2856
static Octstr * from
Definition: mtbatch.c:95
Octstr * binfo
Definition: generic.c:105
Octstr * dlr_mid
Definition: generic.c:110
void http_send_reply(HTTPClient *client, int status, List *headers, Octstr *body)
Definition: http.c:2672
Octstr * octstr_imm(const char *cstr)
Definition: octstr.c:281
Definition: msg.h:79
long bb_smscconn_receive(SMSCConn *conn, Msg *sms)
Definition: bb_smscconn.c:478
char * text
Definition: smsc_cimd2.c:921
Octstr * urltrans_fill_escape_codes(Octstr *pattern, Msg *request)
Definition: urltrans.c:323
#define METADATA_DLR_GROUP
Definition: meta_data.h:68
#define octstr_duplicate(ostr)
Definition: octstr.h:187
void msg_destroy(Msg *msg)
Definition: msg.c:132
Octstr * mclass
Definition: generic.c:112
void octstr_destroy(Octstr *ostr)
Definition: octstr.c:322
int sms_charset_processing(Octstr *charset, Octstr *body, int coding)
Definition: sms.c:419
#define octstr_create(cstr)
Definition: octstr.h:125
Octstr * meta_data
Definition: generic.c:106
#define SMS_PARAM_UNDEFINED
Definition: sms.h:91
Octstr * coding
Definition: generic.c:114
Octstr * from
Definition: generic.c:99
Octstr * udh
Definition: generic.c:102
Octstr * username
Definition: generic.c:97
Octstr * dlr_err
Definition: generic.c:108
Octstr * mwi
Definition: generic.c:113
#define DLR_UNDEFINED
Definition: dlr.h:70
long octstr_len(const Octstr *ostr)
Definition: octstr.c:340
Definition: octstr.c:118
Octstr * password
Definition: smsc_http.c:156
void debug(const char *place, int err, const char *fmt,...)
Definition: log.c:726
#define gwlist_create()
Definition: list.h:136
Octstr * username
Definition: smsc_http.c:155
Octstr * password
Definition: generic.c:98
struct fieldmap * map
Definition: generic.c:124
long status_error
Definition: generic.c:120
int octstr_get_char(const Octstr *ostr, long pos)
Definition: octstr.c:404
long status_sent
Definition: generic.c:119
Definition: list.c:102
static Octstr * account
Definition: mtbatch.c:94
static XMLRPCDocument * msg
Definition: test_xmlrpc.c:86
int octstr_compare(const Octstr *ostr1, const Octstr *ostr2)
Definition: octstr.c:869

◆ generic_send_sms()

static int generic_send_sms ( SMSCConn conn,
Msg sms 
)
static

Definition at line 440 of file generic.c.

References smscconn::data, debug(), gwlist_create, http_destroy_headers(), HTTP_METHOD_GET, conndata::http_ref, http_start_request(), smscconn::id, octstr_destroy(), octstr_get_cstr, conndata::send_url, url, and urltrans_fill_escape_codes().

441 {
442  ConnData *conndata = conn->data;
443  Octstr *url = NULL;
444  List *headers;
445 
446  /* We use the escape code population function from our
447  * URLTranslation module to fill in the appropriate values
448  * into the URL scheme. */
449  url = urltrans_fill_escape_codes(conndata->send_url, sms);
450 
451  headers = gwlist_create();
452  debug("smsc.http.generic", 0, "HTTP[%s]: Sending request <%s>",
453  octstr_get_cstr(conn->id), octstr_get_cstr(url));
454  http_start_request(conndata->http_ref, HTTP_METHOD_GET, url, headers,
455  NULL, 0, sms, NULL);
456 
457  octstr_destroy(url);
458  http_destroy_headers(headers);
459 
460  return 0;
461 }
Octstr * id
Definition: smscconn_p.h:174
void * data
Definition: smscconn_p.h:249
HTTPCaller * http_ref
Definition: smsc_http.c:144
#define octstr_get_cstr(ostr)
Definition: octstr.h:233
void http_destroy_headers(List *headers)
Definition: http.c:2856
void http_start_request(HTTPCaller *caller, int method, Octstr *url, List *headers, Octstr *body, int follow, void *id, Octstr *certkeyfile)
Definition: http.c:1745
Octstr * urltrans_fill_escape_codes(Octstr *pattern, Msg *request)
Definition: urltrans.c:323
void octstr_destroy(Octstr *ostr)
Definition: octstr.c:322
Definition: octstr.c:118
void debug(const char *place, int err, const char *fmt,...)
Definition: log.c:726
#define gwlist_create()
Definition: list.h:136
Octstr * send_url
Definition: smsc_http.c:151
static Octstr * url
Definition: test_xmlrpc.c:84
Definition: list.c:102

Variable Documentation

◆ smsc_http_generic_callback

struct smsc_http_fn_callbacks smsc_http_generic_callback
Initial value:
= {
.init = generic_init,
.destroy = generic_destroy,
.send_sms = generic_send_sms,
.parse_reply = generic_parse_reply,
.receive_sms = generic_receive_sms,
}
static int generic_send_sms(SMSCConn *conn, Msg *sms)
Definition: generic.c:440
static void generic_destroy(SMSCConn *conn)
Definition: generic.c:582
static void generic_receive_sms(SMSCConn *conn, HTTPClient *client, List *headers, Octstr *body, List *cgivars)
Definition: generic.c:260
static void generic_parse_reply(SMSCConn *conn, Msg *msg, int status, List *headers, Octstr *body)
Definition: generic.c:463
static int generic_init(SMSCConn *conn, CfgGroup *cfg)
Definition: generic.c:529

Definition at line 609 of file generic.c.

Referenced by smsc_http_create().

See file LICENSE for details about the license agreement for using, modifying, copying or deriving work from this software.