开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 手机WAP编程 > 查看源码
urltrans.c
资源名称：gateway-1.2.1　[点击查看]
上传用户：gzpyjq
上传日期：2013-01-31
资源大小：1852k
文件大小：30k
源码类别：

手机WAP编程

开发平台：

WINDOWS

urltrans.c：源码内容
  1. /*
  2.  * urltrans.c - URL translations
  3.  *
  4.  * Lars Wirzenius
  5.  */
  8. #include <ctype.h>
  9. #include <errno.h>
  10. #include <limits.h>
  11. #include <stdlib.h>
  12. #include <string.h>
  13. #include <time.h>
  15. #include "urltrans.h"
  16. #include "gwlib/gwlib.h"
  17. #include "gw/sms.h"
  20. /***********************************************************************
  21.  * Definitions of data structures. These are not visible to the external
  22.  * world -- they may be accessed only via the functions declared in
  23.  * urltrans.h.
  24.  */
  27. /*
  28.  * Hold one keyword/options entity
  29.  */
  30. struct URLTranslation {
  31.     Octstr *keyword; /* keyword in SMS (similar) query */
  32.     List *aliases; /* keyword aliases, List of Octstr */
  33.     int type; /* see enumeration in header file */
  34.     Octstr *pattern; /* url, text or file-name pattern */
  35.     Octstr *prefix; /* for prefix-cut */
  36.     Octstr *suffix; /* for suffix-cut */
  37.     Octstr *faked_sender;/* works only with certain services */
  38.     Octstr *default_sender;/* Default sender to sendsms-user */
  39.     long max_messages; /* absolute limit of reply messages */
  40.     int concatenation; /* send long messages as concatenated SMS's if true */
  41.     Octstr *split_chars;/* allowed chars to be used to split message */
  42.     Octstr *split_suffix;/* chars added to end after each split (not last) */
  43.     int omit_empty; /* if the reply is empty, is notification send */
  44.     Octstr *header; /* string to be inserted to each SMS */
  45.     Octstr *footer; /* string to be appended to each SMS */
  46.     List *accepted_smsc; /* smsc id's allowed to use this service. If not set,
  47.     all messages can use this service */
  48.     
  49.     Octstr *name; /* Translation name */
  50.     Octstr *username; /* send sms username */
  51.     Octstr *password; /* password associated */
  52.     Octstr *forced_smsc;/* if smsc id is forcet to certain for this user */
  53.     Octstr *default_smsc; /* smsc id if none given in http send-sms request */
  54.     Octstr *allow_ip; /* allowed IPs to request send-sms with this 
  55.                   account */
  56.     Octstr *deny_ip; /* denied IPs to request send-sms with this account */
  57.     Octstr *allowed_prefix; /* Prefixes (of sender) allowed in this translation, or... */
  58.     Octstr *denied_prefix; /* ...denied prefixes */
  59.     Octstr *allowed_recv_prefix; /* Prefixes (of receiver) allowed in this translation, or... */
  60.     Octstr *denied_recv_prefix; /* ...denied prefixes */
  61.     Numhash *white_list; /* To numbers allowed, or ... */
  62.     Numhash *black_list; /* ...denied numbers */
  64.     int assume_plain_text; /* for type: octet-stream */
  65.     int accept_x_kannel_headers; /* do we accept special headers in reply */
  66.     int strip_keyword; /* POST body */
  67.     int send_sender; /* POST headers */
  68.     
  69.     int args;
  70.     int has_catchall_arg;
  71.     int catch_all;
  72.     Octstr *dlr_url; /* Url to call for delivery reports */
  73. };
  76. /*
  77.  * Hold the list of all translations.
  78.  */
  79. struct URLTranslationList {
  80.     List *list;
  81.     Dict *dict; /* Dict of lowercase Octstr keywords*/
  82.     Dict *names; /* Dict of lowercase Octstr names */
  83. };
  86. /***********************************************************************
  87.  * Declarations of internal functions. These are defined at the end of
  88.  * the file.
  89.  */
  91. static long count_occurences(Octstr *str, Octstr *pat);
  92. static URLTranslation *create_onetrans(CfgGroup *grp);
  93. static void destroy_onetrans(void *ot);
  94. static URLTranslation *find_translation(URLTranslationList *trans, 
  95. List *words, Octstr *smsc,
  96. Octstr *sender, Octstr *receiver, int *reject);
  97. static URLTranslation *find_default_translation(URLTranslationList *trans,
  98. Octstr *smsc, Octstr *sender, Octstr *receiver,
  99. int *reject);
  100. static URLTranslation *find_black_list_translation(URLTranslationList *trans,
  101. Octstr *smsc);
  104. /***********************************************************************
  105.  * Implementations of the functions declared in urltrans.h. See the
  106.  * header for explanations of what they should do.
  107.  */
  110. static void destroy_keyword_list(void *list)
  111. {
  112.     list_destroy(list, NULL);
  113. }
  116. URLTranslationList *urltrans_create(void) 
  117. {
  118.     URLTranslationList *trans;
  119.     
  120.     trans = gw_malloc(sizeof(URLTranslationList));
  121.     trans->list = list_create();
  122.     trans->dict = dict_create(1024, destroy_keyword_list);
  123.     trans->names = dict_create(1024, destroy_keyword_list);
  124.     return trans;
  125. }
  128. void urltrans_destroy(URLTranslationList *trans) 
  129. {
  130.     list_destroy(trans->list, destroy_onetrans);
  131.     dict_destroy(trans->names);
  132.     dict_destroy(trans->dict);
  133.     gw_free(trans);
  134. }
  137. int urltrans_add_one(URLTranslationList *trans, CfgGroup *grp)
  138. {
  139.     URLTranslation *ot;
  140.     long i;
  141.     List *list, *list2;
  142.     Octstr *alias;
  143.     
  144.     ot = create_onetrans(grp);
  145.     if (ot == NULL)
  146. return -1;
  148.     list_append(trans->list, ot);
  149.     
  150.     list2 = dict_get(trans->names, ot->name);
  151.     if (list2 == NULL) {
  152.      list2 = list_create();
  153. dict_put(trans->names, ot->name, list2);
  154.     }
  155.     list_append(list2, ot);
  157.     if (ot->keyword == NULL || ot->type == TRANSTYPE_SENDSMS)
  158.      return 0;
  160.     list = dict_get(trans->dict, ot->keyword);
  161.     if (list == NULL) {
  162.      list = list_create();
  163. dict_put(trans->dict, ot->keyword, list);
  164.     }
  165.     list_append(list, ot);
  167.     for (i = 0; i < list_len(ot->aliases); ++i) {
  168. alias = list_get(ot->aliases, i);
  169. list = dict_get(trans->dict, alias);
  170. if (list == NULL) {
  171.     list = list_create();
  172.     dict_put(trans->dict, alias, list);
  173. }
  174. list_append(list, ot);
  175.     }
  178.     return 0;
  179. }
  182. int urltrans_add_cfg(URLTranslationList *trans, Cfg *cfg) 
  183. {
  184.     CfgGroup *grp;
  185.     List *list;
  186.     
  187.     list = cfg_get_multi_group(cfg, octstr_imm("sms-service"));
  188.     while (list && (grp = list_extract_first(list)) != NULL) {
  189. if (urltrans_add_one(trans, grp) == -1) {
  190.     list_destroy(list, NULL);
  191.     return -1;
  192. }
  193.     }
  194.     list_destroy(list, NULL);
  195.     
  196.     list = cfg_get_multi_group(cfg, octstr_imm("sendsms-user"));
  197.     while (list && (grp = list_extract_first(list)) != NULL) {
  198. if (urltrans_add_one(trans, grp) == -1) {
  199.     list_destroy(list, NULL);
  200.     return -1;
  201. }
  202.     }
  203.     list_destroy(list, NULL);
  205.     return 0;
  206. }
  209. URLTranslation *urltrans_find(URLTranslationList *trans, Octstr *text,
  210.       Octstr *smsc, Octstr *sender, Octstr *receiver) 
  211. {
  212.     List *words;
  213.     URLTranslation *t;
  214.     int reject = 0;
  215.     
  216.     words = octstr_split_words(text);
  217.     
  218.     t = find_translation(trans, words, smsc, sender, receiver, &reject);
  219.     list_destroy(words, octstr_destroy_item);
  220.     if (reject)
  221. t = find_black_list_translation(trans, smsc);
  222.     if (t == NULL) {
  223. t = find_default_translation(trans, smsc, sender, receiver, &reject);
  224. if (reject)
  225.     t = find_black_list_translation(trans, smsc);
  226.     }
  227.     return t;
  228. }
  231. URLTranslation *urltrans_find_service(URLTranslationList *trans, Msg *msg)
  232. {
  233.     URLTranslation *t;
  234.     List *list;
  235.     
  236.     list = dict_get(trans->names, msg->sms.service);
  237.     if (list != NULL) {
  238.        t = list_get(list, 0);
  239.     } else  {
  240.        t = NULL;
  241.     }
  242.     return t;
  243. }
  247. URLTranslation *urltrans_find_username(URLTranslationList *trans, 
  248.        Octstr *name)
  249. {
  250.     URLTranslation *t;
  251.     int i;
  253.     gw_assert(name != NULL);
  254.     for (i = 0; i < list_len(trans->list); ++i) {
  255. t = list_get(trans->list, i);
  256. if (t->type == TRANSTYPE_SENDSMS) {
  257.     if (octstr_compare(name, t->username) == 0)
  258. return t;
  259. }
  260.     }
  261.     return NULL;
  262. }
  264. /*
  265.  * Remove the first word and the whitespace that follows it from
  266.  * the start of the message data.
  267.  */
  268. static void strip_keyword(Msg *request)
  269. {          
  270.     int ch;
  271.     long pos;
  273.     pos = 0;
  275.     for (; (ch = octstr_get_char(request->sms.msgdata, pos)) >= 0; pos++)
  276.         if (isspace(ch))
  277.             break;
  279.     for (; (ch = octstr_get_char(request->sms.msgdata, pos)) >= 0; pos++)
  280.         if (!isspace(ch))
  281.             break;
  283.     octstr_delete(request->sms.msgdata, 0, pos);
  284. }
  288. Octstr *urltrans_get_pattern(URLTranslation *t, Msg *request)
  289. {
  290.     Octstr *enc;
  291.     int nextarg, j;
  292.     struct tm tm;
  293.     int num_words;
  294.     List *word_list;
  295.     Octstr *result, *pattern;
  296.     long pattern_len;
  297.     long pos;
  298.     int c;
  299.     long i;
  300.     Octstr *temp;
  301.     Octstr *url, *reply; /* For and If delivery report */
  303.     url = reply = NULL;
  304.     
  305.     if (request->sms.sms_type != report && t->type == TRANSTYPE_SENDSMS)
  306.         return octstr_create("");
  308.     word_list = octstr_split_words(request->sms.msgdata);
  309.     num_words = list_len(word_list);
  311.     result = octstr_create("");
  313.     /* check if this is a delivery report message or not */
  314.     if (request->sms.sms_type != report) {
  315.         pattern = t->pattern;
  316.     } else {
  318.         /* this is a DLR message */
  319.         reply = octstr_duplicate(request->sms.msgdata);
  320.         url = octstr_duplicate(request->sms.dlr_url);
  322.         pattern = url;
  323.         if (octstr_len(pattern) == 0) {
  324.             if (octstr_len(t->dlr_url)) {
  325.                 pattern = t->dlr_url;
  326.             } else {
  327.                 list_destroy(word_list, octstr_destroy_item);
  328.                 return octstr_create("");
  329.             }
  330.         }
  331.     }
  333.     pattern_len = octstr_len(pattern);
  334.     nextarg = 1;
  335.     pos = 0;
  336.     for (;;) {
  337.         while (pos < pattern_len) {
  338.             c = octstr_get_char(pattern, pos);
  339.             if (c == '%' && pos + 1 < pattern_len)
  340.                 break;
  341.             octstr_append_char(result, c);
  342.             ++pos;
  343.         }
  345.         if (pos == pattern_len)
  346.             break;
  348.     switch (octstr_get_char(pattern, pos + 1)) {
  349.     case 'k':
  350.     if (num_words <= 0)
  351. break;
  352.     enc = octstr_duplicate(list_get(word_list, 0));
  353.     octstr_url_encode(enc);
  354.     octstr_append(result, enc);
  355.     octstr_destroy(enc);
  356.     break;
  358. case 's':
  359.     if (nextarg >= num_words)
  360. break;
  361.     enc = octstr_duplicate(list_get(word_list, nextarg));
  362.     octstr_url_encode(enc);
  363.     octstr_append(result, enc);
  364.     octstr_destroy(enc);
  365.     ++nextarg;
  366.     break;
  368. case 'S':
  369.     if (nextarg >= num_words)
  370. break;
  371.     temp = list_get(word_list, nextarg);
  372.     for (i = 0; i < octstr_len(temp); ++i) {
  373. if (octstr_get_char(temp, i) == '*')
  374.     octstr_append_char(result, '~');
  375. else
  376.     octstr_append_char(result, octstr_get_char(temp, i));
  377.     }
  378.     ++nextarg;
  379.     break;
  381. case 'r':
  382.     for (j = nextarg; j < num_words; ++j) {
  383. enc = octstr_duplicate(list_get(word_list, j));
  384. octstr_url_encode(enc);
  385. if (j != nextarg)
  386.     octstr_append_char(result, '+');
  387. octstr_append(result, enc);
  388. octstr_destroy(enc);
  389.     }
  390.     break;
  391.     
  392. /* NOTE: the sender and receiver is already switched in
  393.  *    message, so that's why we must use 'sender' when
  394.  *    we want original receiver and vice versa
  395.  */
  396. case 'P':
  397.     enc = octstr_duplicate(request->sms.sender);
  398.          octstr_url_encode(enc);
  399.     octstr_append(result, enc);
  400.     octstr_destroy(enc);
  401.     break;
  403. case 'p':
  404.     enc = octstr_duplicate(request->sms.receiver);
  405.     octstr_url_encode(enc);
  406.     octstr_append(result, enc);
  407.     octstr_destroy(enc);
  408.     break;
  410. case 'Q':
  411.     if (strncmp(octstr_get_cstr(request->sms.sender), "00", 2) == 0) {
  412. enc = octstr_copy(request->sms.sender, 2, 
  413.             octstr_len(request->sms.sender));
  414. octstr_url_encode(enc);
  415. octstr_format_append(result, "%%2B%S", enc);
  416. octstr_destroy(enc);
  417.     } else {
  418. enc = octstr_duplicate(request->sms.sender);
  419.           octstr_url_encode(enc);
  420. octstr_append(result, enc);
  421. octstr_destroy(enc);
  422.     }
  423.     break;
  425. case 'q':
  426.     if (strncmp(octstr_get_cstr(request->sms.receiver),"00",2)==0) {
  427. enc = octstr_copy(request->sms.receiver, 2, 
  428.             octstr_len(request->sms.receiver));
  429. octstr_url_encode(enc);
  430. octstr_format_append(result, "%%2B%S", enc);
  431. octstr_destroy(enc);
  432.     } else {
  433. enc = octstr_duplicate(request->sms.receiver);
  434. octstr_url_encode(enc);
  435. octstr_append(result, enc);
  436. octstr_destroy(enc);
  437.     }
  438.     break;
  440. case 'a':
  441.     for (j = 0; j < num_words; ++j) {
  442. enc = octstr_duplicate(list_get(word_list, j));
  443. octstr_url_encode(enc);
  444. if (j > 0)
  445.     octstr_append_char(result, '+');
  446. octstr_append(result, enc);
  447. octstr_destroy(enc);
  448.     }
  449.     break;
  451. case 'b':
  452.     enc = octstr_duplicate(request->sms.msgdata);
  453.     octstr_url_encode(enc);
  454.     octstr_append(result, enc);
  455.     octstr_destroy(enc);
  456.     break;
  458. case 't':
  459.     tm = gw_gmtime(request->sms.time);
  460.     octstr_format_append(result, "%04d-%02d-%02d+%02d:%02d:%02d",
  461.  tm.tm_year + 1900,
  462.  tm.tm_mon + 1,
  463.  tm.tm_mday,
  464.  tm.tm_hour,
  465.  tm.tm_min,
  466.  tm.tm_sec);
  467.     break;
  469. case 'i':
  470.     if (request->sms.smsc_id == NULL)
  471. break;
  472.     enc = octstr_duplicate(request->sms.smsc_id);
  473.     octstr_url_encode(enc);
  474.     octstr_append(result, enc);
  475.     octstr_destroy(enc);
  476.     break;
  478. case 'n':
  479.     if (request->sms.service == NULL)
  480. break;
  481.     enc = octstr_duplicate(request->sms.service);
  482.     octstr_url_encode(enc);
  483.     octstr_append(result, enc);
  484.     octstr_destroy(enc);
  485.     break;
  487. case 'd':
  488.     enc = octstr_create("");
  489.     octstr_append_decimal(enc, request->sms.dlr_mask);
  490.     octstr_url_encode(enc);
  491.     octstr_append(result, enc);
  492.     octstr_destroy(enc);
  493.     break;
  495. case 'A':
  496.     enc = octstr_duplicate(reply);
  497.     octstr_url_encode(enc);
  498.     octstr_append(result, enc);
  499.     octstr_destroy(enc);
  500.     break;
  502. case 'c':
  503.     octstr_append_decimal(result, request->sms.coding);
  504.     break;
  506. case 'C':
  507.     if(octstr_len(request->sms.charset)) {
  508. octstr_append(result, request->sms.charset);
  509.     } else {
  510. switch (request->sms.coding) {
  511.     case DC_UNDEF:
  512.     case DC_7BIT:
  513. octstr_append(result, octstr_imm("gsm"));
  514. break;
  515.     case DC_8BIT:
  516. octstr_append(result, octstr_imm("binary"));
  517. break;
  518.     case DC_UCS2:
  519. octstr_append(result, octstr_imm("UTF16-BE"));
  520. break;
  521. }
  522.     }
  523.     break;
  525. case 'u':
  526.     if(octstr_len(request->sms.udhdata)) {
  527. enc = octstr_duplicate(request->sms.udhdata);
  528. octstr_url_encode(enc);
  529. octstr_append(result, enc);
  530. octstr_destroy(enc);
  531.     }
  532.     break;
  534. case '%':
  535.     octstr_format_append(result, "%%");
  536.     break;
  538. default:
  539.     octstr_format_append(result, "%%%c",
  540.                 octstr_get_char(pattern, pos + 1));
  541.     break;
  542. }
  544. pos += 2;
  545.     }
  546.     /*
  547.      * this SHOULD be done in smsbox, not here, but well,
  548.      * much easier to do here
  549.      */
  550.     if ( (t->type == TRANSTYPE_POST_URL || t->type == TRANSTYPE_POST_XML)
  551.     && t->strip_keyword)
  552. strip_keyword(request);
  554.     octstr_destroy(url);
  555.     octstr_destroy(reply);
  557.     list_destroy(word_list, octstr_destroy_item);
  558.     return result;
  559. }
  562. int urltrans_type(URLTranslation *t) 
  563. {
  564.     return t->type;
  565. }
  567. Octstr *urltrans_prefix(URLTranslation *t) 
  568. {
  569.     return t->prefix;
  570. }
  572. Octstr *urltrans_suffix(URLTranslation *t) 
  573. {
  574.     return t->suffix;
  575. }
  577. Octstr *urltrans_default_sender(URLTranslation *t) 
  578. {
  579.     return t->default_sender;
  580. }
  582. Octstr *urltrans_faked_sender(URLTranslation *t) 
  583. {
  584.     return t->faked_sender;
  585. }
  587. int urltrans_max_messages(URLTranslation *t) 
  588. {
  589.     return t->max_messages;
  590. }
  592. int urltrans_concatenation(URLTranslation *t) 
  593. {
  594.     return t->concatenation;
  595. }
  597. Octstr *urltrans_split_chars(URLTranslation *t) 
  598. {
  599.     return t->split_chars;
  600. }
  602. Octstr *urltrans_split_suffix(URLTranslation *t) 
  603. {
  604.     return t->split_suffix;
  605. }
  607. int urltrans_omit_empty(URLTranslation *t) 
  608. {
  609.     return t->omit_empty;
  610. }
  612. Octstr *urltrans_header(URLTranslation *t) 
  613. {
  614.     return t->header;
  615. }
  617. Octstr *urltrans_footer(URLTranslation *t) 
  618. {
  619.     return t->footer;
  620. }
  622. Octstr *urltrans_name(URLTranslation *t) 
  623. {
  624.     return t->name;
  625. }
  627. Octstr *urltrans_username(URLTranslation *t) 
  628. {
  629.     return t->username;
  630. }
  632. Octstr *urltrans_password(URLTranslation *t) 
  633. {
  634.     return t->password;
  635. }
  637. Octstr *urltrans_forced_smsc(URLTranslation *t) 
  638. {
  639.     return t->forced_smsc;
  640. }
  642. Octstr *urltrans_default_smsc(URLTranslation *t) 
  643. {
  644.     return t->default_smsc;
  645. }
  647. Octstr *urltrans_allow_ip(URLTranslation *t) 
  648. {
  649.     return t->allow_ip;
  650. }
  652. Octstr *urltrans_deny_ip(URLTranslation *t) 
  653. {
  654.     return t->deny_ip;
  655. }
  657. Octstr *urltrans_allowed_prefix(URLTranslation *t) 
  658. {
  659.     return t->allowed_prefix;
  660. }
  662. Octstr *urltrans_denied_prefix(URLTranslation *t) 
  663. {
  664.     return t->denied_prefix;
  665. }
  667. Octstr *urltrans_allowed_recv_prefix(URLTranslation *t) 
  668. {
  669.     return t->allowed_recv_prefix;
  670. }
  672. Octstr *urltrans_denied_recv_prefix(URLTranslation *t) 
  673. {
  674.     return t->denied_recv_prefix;
  675. }
  677. Numhash *urltrans_white_list(URLTranslation *t)
  678. {
  679.     return t->white_list;
  680. }
  682. Numhash *urltrans_black_list(URLTranslation *t)
  683. {
  684.     return t->black_list;
  685. }
  687. int urltrans_assume_plain_text(URLTranslation *t) 
  688. {
  689.     return t->assume_plain_text;
  690. }
  692. int urltrans_accept_x_kannel_headers(URLTranslation *t) 
  693. {
  694.     return t->accept_x_kannel_headers;
  695. }
  697. int urltrans_strip_keyword(URLTranslation *t) 
  698. {
  699.     return t->strip_keyword;
  700. }
  702. int urltrans_send_sender(URLTranslation *t) 
  703. {
  704.     return t->send_sender;
  705. }
  709. /***********************************************************************
  710.  * Internal functions.
  711.  */
  714. /*
  715.  * Create one URLTranslation. Return NULL for failure, pointer to it for OK.
  716.  */
  717. static URLTranslation *create_onetrans(CfgGroup *grp)
  718. {
  719.     URLTranslation *ot;
  720.     Octstr *aliases, *url, *post_url, *post_xml, *text, *file, *exec;
  721.     Octstr *accepted_smsc, *forced_smsc, *default_smsc;
  722.     Octstr *grpname, *sendsms_user, *sms_service;
  723.     int is_sms_service;
  724.     
  725.     grpname = cfg_get_group_name(grp);
  726.     if (grpname == NULL)
  727.      return NULL;
  729.     sms_service = octstr_imm("sms-service");
  730.     sendsms_user = octstr_imm("sendsms-user");
  731.     if (octstr_compare(grpname, sms_service) == 0)
  732.      is_sms_service = 1;
  733.     else if (octstr_compare(grpname, sendsms_user) == 0)
  734.      is_sms_service = 0;
  735.     else {
  736. octstr_destroy(grpname);
  737. return NULL;
  738.     }
  739.     octstr_destroy(grpname);
  741.     ot = gw_malloc(sizeof(URLTranslation));
  743.     ot->keyword = NULL;
  744.     ot->aliases = NULL;
  745.     ot->pattern = NULL;
  746.     ot->prefix = NULL;
  747.     ot->suffix = NULL;
  748.     ot->faked_sender = NULL;
  749.     ot->default_sender = NULL;
  750.     ot->split_chars = NULL;
  751.     ot->split_suffix = NULL;
  752.     ot->footer = NULL;
  753.     ot->header = NULL;
  754.     ot->name = NULL;
  755.     ot->username = NULL;
  756.     ot->password = NULL;
  757.     ot->omit_empty = 0;
  758.     ot->accepted_smsc = NULL;
  759.     ot->forced_smsc = NULL;
  760.     ot->default_smsc = NULL;
  761.     ot->allow_ip = NULL;
  762.     ot->deny_ip = NULL;
  763.     ot->allowed_prefix = NULL;
  764.     ot->denied_prefix = NULL;
  765.     ot->allowed_recv_prefix = NULL;
  766.     ot->denied_recv_prefix = NULL;
  767.     ot->white_list = NULL;
  768.     ot->black_list = NULL;
  769.     
  770.     if (is_sms_service) {
  771. cfg_get_bool(&ot->catch_all, grp, octstr_imm("catch-all"));
  773. ot->dlr_url = cfg_get(grp, octstr_imm("dlr-url"));
  774.     
  775. url = cfg_get(grp, octstr_imm("get-url"));
  776. if (url == NULL)
  777.     url = cfg_get(grp, octstr_imm("url"));
  778.     
  779. post_url = cfg_get(grp, octstr_imm("post-url"));
  780. post_xml = cfg_get(grp, octstr_imm("post-xml"));
  781. file = cfg_get(grp, octstr_imm("file"));
  782. text = cfg_get(grp, octstr_imm("text"));
  783. exec = cfg_get(grp, octstr_imm("exec"));
  784. if (url != NULL) {
  785.     ot->type = TRANSTYPE_GET_URL;
  786.     ot->pattern = url;
  787. } else if (post_url != NULL) {
  788.     ot->type = TRANSTYPE_POST_URL;
  789.     ot->pattern = post_url;
  790.     ot->catch_all = 1;
  791. } else if (post_xml != NULL) {
  792.     ot->type = TRANSTYPE_POST_XML;
  793.     ot->pattern = post_xml;
  794.     ot->catch_all = 1;
  795. } else if (file != NULL) {
  796.     ot->type = TRANSTYPE_FILE;
  797.     ot->pattern = file;
  798. } else if (text != NULL) {
  799.     ot->type = TRANSTYPE_TEXT;
  800.     ot->pattern = text;
  801. } else if (exec != NULL) {
  802.     ot->type = TRANSTYPE_EXECUTE;
  803.     ot->pattern = exec;
  804. } else {
  805.     error(0, "Configuration group `sms-service' "
  806.           "did not specify get-url, post-url, post-xml, file or text.");
  807.          goto error;
  808. }
  810. ot->keyword = cfg_get(grp, octstr_imm("keyword"));
  811. if (ot->keyword == NULL) {
  812.     error(0, "Group 'sms-service' must include 'keyword'.");
  813.     goto error;
  814. }
  815. octstr_convert_range(ot->keyword, 0, octstr_len(ot->keyword), 
  816.                tolower);
  818. ot->name = cfg_get(grp, octstr_imm("name"));
  819. if (ot->name == NULL)
  820.     ot->name = octstr_duplicate(ot->keyword);
  822. aliases = cfg_get(grp, octstr_imm("aliases"));
  823. if (aliases == NULL)
  824.     ot->aliases = list_create();
  825. else {
  826.     long i;
  827.     Octstr *os;
  829.     ot->aliases = octstr_split(aliases, octstr_imm(";"));
  830.     octstr_destroy(aliases);
  831.     for (i = 0; i < list_len(ot->aliases); ++i) {
  832. os = list_get(ot->aliases, i);
  833.      octstr_convert_range(os, 0, octstr_len(os), tolower);
  834.     }
  835. }
  837. accepted_smsc = cfg_get(grp, octstr_imm("accepted-smsc"));
  838. if (accepted_smsc != NULL) {
  839.     ot->accepted_smsc = octstr_split(accepted_smsc, octstr_imm(";"));
  840.     octstr_destroy(accepted_smsc);
  841. }
  843. cfg_get_bool(&ot->assume_plain_text, grp, 
  844.      octstr_imm("assume-plain-text"));
  845. cfg_get_bool(&ot->accept_x_kannel_headers, grp, 
  846.      octstr_imm("accept-x-kannel-headers"));
  847. cfg_get_bool(&ot->strip_keyword, grp, octstr_imm("strip-keyword"));
  848. cfg_get_bool(&ot->send_sender, grp, octstr_imm("send-sender"));
  850. ot->prefix = cfg_get(grp, octstr_imm("prefix"));
  851. ot->suffix = cfg_get(grp, octstr_imm("suffix"));
  853. ot->allowed_recv_prefix = cfg_get(grp, octstr_imm("allowed-receiver-prefix"));
  854.     ot->denied_recv_prefix = cfg_get(grp, octstr_imm("denied-receiver-prefix"));
  856. ot->args = count_occurences(ot->pattern, octstr_imm("%s"));
  857. ot->args += count_occurences(ot->pattern, octstr_imm("%S"));
  858. ot->has_catchall_arg = 
  859.     (count_occurences(ot->pattern, octstr_imm("%r")) > 0) ||
  860.     (count_occurences(ot->pattern, octstr_imm("%a")) > 0);
  862.     } else {
  863. ot->type = TRANSTYPE_SENDSMS;
  864. ot->pattern = octstr_create("");
  865. ot->args = 0;
  866. ot->has_catchall_arg = 0;
  867. ot->catch_all = 1;
  868. ot->username = cfg_get(grp, octstr_imm("username"));
  869. ot->password = cfg_get(grp, octstr_imm("password"));
  870. ot->dlr_url = cfg_get(grp, octstr_imm("dlr-url"));
  871. if (ot->password == NULL) {
  872.     error(0, "Password required for send-sms user");
  873.     goto error;
  874. }
  875. ot->name = cfg_get(grp, octstr_imm("name"));
  876. if (ot->name == NULL)
  877.     ot->name = octstr_duplicate(ot->username);
  879. forced_smsc = cfg_get(grp, octstr_imm("forced-smsc"));
  880. default_smsc = cfg_get(grp, octstr_imm("default-smsc"));
  881. if (forced_smsc != NULL) {
  882.     if (default_smsc != NULL) {
  883. info(0, "Redundant default-smsc for send-sms user %s", 
  884.      octstr_get_cstr(ot->username));
  885.     }
  886.     ot->forced_smsc = forced_smsc;
  887.     octstr_destroy(default_smsc);
  888. } else  if (default_smsc != NULL)
  889.     ot->default_smsc = default_smsc;
  891. ot->deny_ip = cfg_get(grp, octstr_imm("user-deny-ip"));
  892. ot->allow_ip = cfg_get(grp, octstr_imm("user-allow-ip"));
  893. ot->default_sender = cfg_get(grp, octstr_imm("default-sender"));
  895.     }
  896.     ot->allowed_prefix = cfg_get(grp, octstr_imm("allowed-prefix"));
  897.     ot->denied_prefix = cfg_get(grp, octstr_imm("denied-prefix"));
  898.     {
  899. Octstr *os;
  900. os = cfg_get(grp, octstr_imm("white-list"));
  901. if (os != NULL) {
  902.     ot->white_list = numhash_create(octstr_get_cstr(os));
  903.     octstr_destroy(os);
  904. }
  905. os = cfg_get(grp, octstr_imm("black-list"));
  906. if (os != NULL) {
  907.     ot->black_list = numhash_create(octstr_get_cstr(os));
  908.     octstr_destroy(os);
  909. }
  910.     }
  912.     if (cfg_get_integer(&ot->max_messages, grp, 
  913.                octstr_imm("max-messages")) == -1)
  914. ot->max_messages = 1;
  915.     cfg_get_bool(&ot->concatenation, grp, 
  916.  octstr_imm("concatenation"));
  917.     cfg_get_bool(&ot->omit_empty, grp, 
  918.  octstr_imm("omit-empty"));
  919.     
  920.     ot->header = cfg_get(grp, octstr_imm("header"));
  921.     ot->footer = cfg_get(grp, octstr_imm("footer"));
  922.     ot->faked_sender = cfg_get(grp, octstr_imm("faked-sender"));
  923.     ot->split_chars = cfg_get(grp, octstr_imm("split-chars"));
  924.     ot->split_suffix = cfg_get(grp, octstr_imm("split-suffix"));
  926.     if ( (ot->prefix == NULL && ot->suffix != NULL) ||
  927.  (ot->prefix != NULL && ot->suffix == NULL) ) {
  928. warning(0, "Service <%s>: suffix and prefix are only used"
  929.    " if both are set.", octstr_get_cstr(ot->keyword));
  930.     }
  931.     if ((ot->prefix != NULL || ot->suffix != NULL) &&
  932.         ot->type != TRANSTYPE_GET_URL) {
  933. warning(0, "Service <%s>: suffix and prefix are only used"
  934.                    " if type is 'get-url'.", octstr_get_cstr(ot->keyword));
  935.     }
  936.     
  937.     return ot;
  939. error:
  940.     error(0, "Couldn't create a URLTranslation.");
  941.     destroy_onetrans(ot);
  942.     return NULL;
  943. }
  946. /*
  947.  * Free one URLTranslation.
  948.  */
  949. static void destroy_onetrans(void *p) 
  950. {
  951.     URLTranslation *ot;
  952.     
  953.     ot = p;
  954.     if (ot != NULL) {
  955. octstr_destroy(ot->keyword);
  956. list_destroy(ot->aliases, octstr_destroy_item);
  957. octstr_destroy(ot->dlr_url);
  958. octstr_destroy(ot->pattern);
  959. octstr_destroy(ot->prefix);
  960. octstr_destroy(ot->suffix);
  961. octstr_destroy(ot->default_sender);
  962. octstr_destroy(ot->faked_sender);
  963. octstr_destroy(ot->split_chars);
  964. octstr_destroy(ot->split_suffix);
  965. octstr_destroy(ot->header);
  966. octstr_destroy(ot->footer);
  967. list_destroy(ot->accepted_smsc, octstr_destroy_item);
  968. octstr_destroy(ot->name);
  969. octstr_destroy(ot->username);
  970. octstr_destroy(ot->password);
  971. octstr_destroy(ot->forced_smsc);
  972. octstr_destroy(ot->default_smsc);
  973. octstr_destroy(ot->allow_ip);
  974. octstr_destroy(ot->deny_ip);
  975. octstr_destroy(ot->allowed_prefix);
  976. octstr_destroy(ot->denied_prefix);
  977. octstr_destroy(ot->allowed_recv_prefix);
  978. octstr_destroy(ot->denied_recv_prefix);
  979. numhash_destroy(ot->white_list);
  980. numhash_destroy(ot->black_list);
  981. gw_free(ot);
  982.     }
  983. }
  986. /*
  987.  * Find the appropriate translation 
  988.  */
  989. static URLTranslation *find_translation(URLTranslationList *trans, 
  990. List *words, Octstr *smsc, Octstr *sender, Octstr *receiver, int *reject)
  991. {
  992.     Octstr *keyword;
  993.     int i, n;
  994.     URLTranslation *t;
  995.     List *list;
  996.     
  997.     n = list_len(words);
  998.     if (n == 0)
  999. return NULL;
  1000.     keyword = list_get(words, 0);
  1001.     keyword = octstr_duplicate(keyword);
  1002.     octstr_convert_range(keyword, 0, octstr_len(keyword), tolower);
  1003.     
  1004.     list = dict_get(trans->dict, keyword);
  1005.     t = NULL;
  1006.     for (i = 0; i < list_len(list); ++i) {
  1007. t = list_get(list, i);
  1009. /* if smsc_id set and accepted_smsc exist, accept
  1010.  * translation only if smsc id is in accept string
  1011.  */
  1012. if (smsc && t->accepted_smsc) {
  1013.     if (!list_search(t->accepted_smsc, smsc, octstr_item_match)) {
  1014. t = NULL;
  1015. continue;
  1016.     }
  1017. }
  1019. /* Have allowed for sender */
  1020. if (t->allowed_prefix && ! t->denied_prefix &&
  1021.    (does_prefix_match(t->allowed_prefix, sender) != 1)) {
  1022.     t = NULL;
  1023.     continue;
  1024. }
  1026. /* Have denied for sender */
  1027. if (t->denied_prefix && ! t->allowed_prefix &&
  1028.    (does_prefix_match(t->denied_prefix, sender) == 1)) {
  1029.     t = NULL;
  1030.     continue;
  1031. }
  1033. /* Have allowed for receiver */
  1034. if (t->allowed_recv_prefix && ! t->denied_recv_prefix &&
  1035.    (does_prefix_match(t->allowed_recv_prefix, receiver) != 1)) {
  1036.     t = NULL;
  1037.     continue;
  1038. }
  1040. /* Have denied for receiver */
  1041. if (t->denied_recv_prefix && ! t->allowed_recv_prefix &&
  1042.    (does_prefix_match(t->denied_recv_prefix, receiver) == 1)) {
  1043.     t = NULL;
  1044.     continue;
  1045. }
  1047. if (t->white_list &&
  1048.     numhash_find_number(t->white_list, sender) < 1) {
  1049.     t = NULL; *reject = 1;
  1050.     continue;
  1051. }   
  1052. if (t->black_list &&
  1053.     numhash_find_number(t->black_list, sender) == 1) {
  1054.     t = NULL; *reject = 1;
  1055.     continue;
  1056. }   
  1058. /* Have allowed and denied */
  1059. if (t->denied_prefix && t->allowed_prefix &&
  1060.    (does_prefix_match(t->allowed_prefix, sender) != 1) &&
  1061.    (does_prefix_match(t->denied_prefix, sender) == 1) ) {
  1062.     t = NULL;
  1063.     continue;
  1064. }
  1066. if (t->catch_all)
  1067.     break;
  1069. if (n - 1 == t->args)
  1070.     break;
  1071. if (t->has_catchall_arg && n - 1 >= t->args)
  1072.     break;
  1073. t = NULL;
  1074.     }
  1076.     /* Only return reject if there's only blacklisted smsc's */
  1077.     if(t != NULL)
  1078. *reject = 0;
  1080.     octstr_destroy(keyword);    
  1081.     return t;
  1082. }
  1085. static URLTranslation *find_default_translation(URLTranslationList *trans,
  1086. Octstr *smsc, Octstr *sender, Octstr *receiver,
  1087. int *reject)
  1088. {
  1089.     URLTranslation *t;
  1090.     int i;
  1091.     List *list;
  1093.     *reject = 0;
  1095.     list = dict_get(trans->dict, octstr_imm("default"));
  1096.     t = NULL;
  1097.     for (i = 0; i < list_len(list); ++i) {
  1098. t = list_get(list, i);
  1099. if (smsc && t->accepted_smsc) {
  1100.     if (!list_search(t->accepted_smsc, smsc, octstr_item_match)) {
  1101. t = NULL;
  1102. continue;
  1103.     }
  1104. }
  1106. /* Have allowed sender */
  1107. if (t->allowed_prefix && ! t->denied_prefix &&
  1108.         (does_prefix_match(t->allowed_prefix, sender) != 1)) {
  1109.     t = NULL;
  1110.     continue;
  1111. }
  1113. /* Have denied sender */
  1114. if (t->denied_prefix && ! t->allowed_prefix &&
  1115.         (does_prefix_match(t->denied_prefix, sender) == 1)) {
  1116.     t = NULL;
  1117.     continue;
  1118. }
  1120. /* Have allowed receiver */
  1121. if (t->allowed_recv_prefix && ! t->denied_recv_prefix &&
  1122.         (does_prefix_match(t->allowed_recv_prefix, receiver) != 1)) {
  1123.     t = NULL;
  1124.     continue;
  1125. }
  1127. /* Have denied receiver */
  1128. if (t->denied_recv_prefix && ! t->allowed_recv_prefix &&
  1129.         (does_prefix_match(t->denied_recv_prefix, receiver) == 1)) {
  1130.     t = NULL;
  1131.     continue;
  1132. }
  1134. if (t->white_list && numhash_find_number(t->white_list, sender) < 1) {
  1135.     t = NULL; *reject = 1;
  1136.     continue;
  1137. }
  1138. if (t->black_list && numhash_find_number(t->black_list, sender) == 1) {
  1139.     t = NULL; *reject = 1;
  1140.     continue;
  1141.         }
  1143. /* Have allowed and denied */
  1144. if (t->denied_prefix && t->allowed_prefix &&
  1145.         (does_prefix_match(t->allowed_prefix, sender) != 1) &&
  1146.         (does_prefix_match(t->denied_prefix, sender) == 1) ) {
  1147.     t = NULL;
  1148.     continue;
  1149. }
  1150. break;
  1151.     }
  1153.     /* Only return reject if there's only blacklisted smsc's */
  1154.     if(t != NULL)
  1155. *reject = 0;
  1156.     return t;
  1157. }
  1159. static URLTranslation *find_black_list_translation(URLTranslationList *trans,
  1160. Octstr *smsc)
  1161. {
  1162.     URLTranslation *t;
  1163.     int i;
  1164.     List *list;
  1166.     list = dict_get(trans->dict, octstr_imm("black-list"));
  1167.     t = NULL;
  1168.     for (i = 0; i < list_len(list); ++i) {
  1169. t = list_get(list, i);
  1170. if (smsc && t->accepted_smsc) {
  1171.     if (!list_search(t->accepted_smsc, smsc, octstr_item_match)) {
  1172. t = NULL;
  1173. continue;
  1174.     }
  1175. }
  1176. break;
  1177.     }
  1178.     return t;
  1179. }
  1182. /*
  1183.  * Count the number of times `pat' occurs in `str'.
  1184.  */
  1185. static long count_occurences(Octstr *str, Octstr *pat)
  1186. {
  1187.     long count;
  1188.     long pos;
  1189.     long len;
  1190.     
  1191.     count = 0;
  1192.     pos = 0;
  1193.     len = octstr_len(pat);
  1194.     while ((pos = octstr_search(str, pat, pos)) != -1) {
  1195.      ++count;
  1196. pos += len;
  1197.     }
  1198.     return count;
  1199. }