added support for provisional responses while using t_uac_dlg.
[sip-router] / modules / tm / uac_unixsock.c
1 /*
2  * $Id$
3  *
4  * Copyright (C) 2001-2004 FhG Fokus
5  *
6  * This file is part of ser, a free SIP server.
7  *
8  * ser is free software; you can redistribute it and/or modify
9  * it under the terms of the GNU General Public License as published by
10  * the Free Software Foundation; either version 2 of the License, or
11  * (at your option) any later version
12  *
13  * For a license to use the ser software under conditions
14  * other than those described here, or to purchase support for this
15  * software, please contact iptel.org by e-mail at the following addresses:
16  *    info@iptel.org
17  *
18  * ser is distributed in the hope that it will be useful,
19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
21  * GNU General Public License for more details.
22  *
23  * You should have received a copy of the GNU General Public License 
24  * along with this program; if not, write to the Free Software 
25  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
26  */
27
28 #include <string.h>
29 #include "../../mem/mem.h"
30 #include "../../mem/shm_mem.h"
31 #include "../../parser/hf.h"
32 #include "../../dprint.h"
33 #include "../../parser/parse_uri.h"
34 #include "../../unixsock_server.h"
35 #include "../../parser/msg_parser.h"
36 #include "../../parser/parse_to.h"
37 #include "../../parser/parse_cseq.h"
38 #include "../../parser/parse_from.h"
39 #include "../../ut.h"
40 #include "uac_unixsock.h"
41 #include "config.h"
42 #include "ut.h"
43 #include "t_hooks.h"
44 #include "callid.h"
45 #include "uac.h"
46 #include "dlg.h"
47
48 struct str_list {
49         str s;
50         struct str_list *next;
51 };
52
53 struct uac_cb_param {
54     
55     str from;
56     str callid;
57     str cseq;
58     struct sockaddr_un addr;
59 };
60
61 #define skip_hf(_hf) (             \
62     ((_hf)->type == HDR_FROM_T)   || \
63     ((_hf)->type == HDR_TO_T)     || \
64     ((_hf)->type == HDR_CALLID_T) || \
65     ((_hf)->type == HDR_CSEQ_T)      \
66 )
67
68
69 /*
70  * Read the method from the request
71  */
72 static int get_method(str* method, str* msg)
73 {
74         if (unixsock_read_line(method, msg) != 0) {
75                 unixsock_reply_asciiz("400 Method expected");
76                 unixsock_reply_send();
77                 return -1;
78         }
79         DBG("get_method: method: '%.*s'\n", method->len, ZSW(method->s));
80         return 0;
81 }
82
83
84 /*
85  * Read the Request-URI and parse it
86  */
87 static int get_ruri(str* ruri, struct sip_uri* puri, str* msg)
88 {
89         if (unixsock_read_line(ruri, msg) != 0) {
90                 unixsock_reply_asciiz("400 Request-URI expected");
91                 unixsock_reply_send();
92                 return -1;
93         }
94         
95         if (parse_uri(ruri->s, ruri->len, puri) < 0 ) {
96                 unixsock_reply_asciiz("400 Request-URI is invalid\n");
97                 unixsock_reply_send();
98                 return -1;
99         }
100         DBG("get_ruri: '%.*s'\n", ruri->len, ZSW(ruri->s));
101         return 0;
102 }
103
104
105 /*
106  * Read and parse the next hop
107  */
108 static int get_nexthop(str* nexthop, struct sip_uri* pnexthop, str* msg)
109 {
110         if (unixsock_read_line(nexthop, msg) != 0) {
111                 unixsock_reply_asciiz("400 Next-hop URI expected\n");
112                 unixsock_reply_send();
113                 return -1;
114         }
115
116         if (nexthop->len == 1 && nexthop->s[0] == '.' ) {
117                 DBG("get_nexthop: next hop empty\n");
118                 nexthop->s = 0; 
119                 nexthop->len = 0;
120         } else if (parse_uri(nexthop->s, nexthop->len, pnexthop) < 0 ) {
121                 unixsock_reply_asciiz("400 Next-hop URI is invalid\n");
122                 unixsock_reply_send();
123                 return -1;
124         } else {
125                 DBG("get_nexthop: '%.*s'\n", nexthop->len, ZSW(nexthop->s));
126         }
127         return 0;
128 }
129
130
131 /*
132  * Read header into a static buffer (it is necessary because
133  * the unixsock_read_lineset performs CRLF recovery and thus
134  * the result may be longer than the original
135  */
136 static int get_headers(str* headers, str* msg)
137 {
138         static char headers_buf[MAX_HEADER];
139
140         headers->s = headers_buf;
141         headers->len = MAX_HEADER;
142
143              /* now read and parse header fields */
144         if (unixsock_read_lineset(headers, msg) < 0) {
145                 unixsock_reply_asciiz("400 Header fields expected\n");
146                 unixsock_reply_send();
147                 return -1;
148         }
149
150         DBG("get_headers: %.*s\n", headers->len, ZSW(headers->s));
151         return 0;
152 }
153
154
155 /*
156  * Read the message body
157  */
158 static int get_body_lines(str* body, str* msg)
159 {
160         if (unixsock_read_body(body, msg) < 0) {
161                 unixsock_reply_asciiz("400 Body expected\n");
162                 unixsock_reply_send();
163                 return -1;
164         }
165         DBG("get_body_lines: %.*s\n", body->len,  ZSW(body->s));
166         return 0;
167 }
168
169
170 /*
171  * Make sure that the FIFO user created the message
172  * correctly
173  */
174 static int check_msg(struct sip_msg* msg, str* method, str* body, 
175                      int* fromtag, int *cseq_is, int* cseq, str* callid)
176 {
177         struct to_body* parsed_from;
178         struct cseq_body *parsed_cseq;
179         int i;
180         char c;
181
182         if (body->len && !msg->content_type) {
183                 unixsock_reply_asciiz("400 Content-Type missing");
184                 goto err;
185         }
186
187         if (body->len && msg->content_length) {
188                 unixsock_reply_asciiz("400 Content-Length disallowed");
189                 goto err;
190         }
191
192         if (!msg->to) {
193                 unixsock_reply_asciiz("400 To missing");
194                 goto err;
195         }
196
197         if (!msg->from) {
198                 unixsock_reply_asciiz("400 From missing");
199                 goto err;
200         }
201
202              /* we also need to know if there is from-tag and add it otherwise */
203         if (parse_from_header(msg) < 0) {
204                 unixsock_reply_asciiz("400 Error in From");
205                 goto err;
206         }
207
208         parsed_from = (struct to_body*)msg->from->parsed;
209         *fromtag = parsed_from->tag_value.s && parsed_from->tag_value.len;
210
211         *cseq = 0;
212         if (msg->cseq && (parsed_cseq = get_cseq(msg))) {
213                 *cseq_is = 1;
214                 for (i = 0; i < parsed_cseq->number.len; i++) {
215                         c = parsed_cseq->number.s[i];
216                         if (c >= '0' && c <= '9' ) {
217                                 *cseq = (*cseq) * 10 + c - '0';
218                         } else {
219                                 DBG("check_msg: Found non-numerical in CSeq: <%i>='%c'\n", (unsigned int)c, c);
220                                 unixsock_reply_asciiz("400 Non-numerical CSeq");
221                                 goto err;
222                         }
223                 }
224                 
225                 if (parsed_cseq->method.len != method->len 
226                     || memcmp(parsed_cseq->method.s, method->s, method->len) !=0 ) {
227                         unixsock_reply_asciiz("400 CSeq method mismatch");
228                         goto err;
229                 }
230         } else {
231                 *cseq_is = 0;
232         }
233
234         if (msg->callid) {
235                 callid->s = msg->callid->body.s;
236                 callid->len = msg->callid->body.len;
237         } else {
238                 callid->s = 0;
239                 callid->len = 0;
240         }
241         return 0;
242
243  err:
244         unixsock_reply_send();
245         return -1;
246 }
247
248
249 static inline struct str_list *new_str(char *s, int len, struct str_list **last, int *total)
250 {
251         struct str_list *new;
252         new = pkg_malloc(sizeof(struct str_list));
253         if (!new) {
254                 LOG(L_ERR, "new_str: Not enough mem\n");
255                 return 0;
256         }
257         new->s.s = s;
258         new->s.len = len;
259         new->next = 0;
260
261         (*last)->next = new;
262         *last = new;
263         *total += len;
264         return new;
265 }
266
267
268 static char *get_hfblock(str *uri, struct hdr_field *hf, int *l, int proto) 
269 {
270         struct str_list sl, *last, *i, *foo;
271         int p, frag_len, total_len;
272         char *begin, *needle, *dst, *ret, *d;
273         str *sock_name, *portname;
274         union sockaddr_union to_su;
275         struct socket_info* send_sock;
276
277         ret = 0; /* pessimist: assume failure */
278         total_len = 0;
279         last = &sl;
280         last->next = 0;
281         portname = sock_name = 0;
282
283         for (; hf; hf = hf->next) {
284                 if (skip_hf(hf)) continue;
285
286                 begin = needle = hf->name.s; 
287                 p = hf->len;
288
289                      /* substitution loop */
290                 while(p) {
291                         d = q_memchr(needle, SUBST_CHAR, p);
292                         if (!d || d + 1 >= needle + p) { /* nothing to substitute */
293                                 if (!new_str(begin, p, &last, &total_len)) goto error;
294                                 break;
295                         } else {
296                                 frag_len = d - begin;
297                                 d++; /* d not at the second substitution char */
298                                 switch(*d) {
299                                 case SUBST_CHAR: /* double SUBST_CHAR: IP */
300                                              /* string before substitute */
301                                         if (!new_str(begin, frag_len, &last, &total_len)) goto error;
302                                              /* substitute */
303                                         if (!sock_name) {
304                                                 send_sock = uri2sock(0, uri, &to_su, proto);
305                                                 if (!send_sock) {
306                                                         LOG(L_ERR, "ERROR: get_hfblock: send_sock failed\n");
307                                                         goto error;
308                                                 }
309                                                 sock_name = &send_sock->address_str;
310                                                 portname = &send_sock->port_no_str;
311                                         }
312                                         if (!new_str(sock_name->s, sock_name->len, &last, &total_len)) goto error;
313                                              /* inefficient - FIXME --andrei*/
314                                         if (!new_str(":", 1, &last, &total_len)) goto error;
315                                         if (!new_str(portname->s, portname->len, &last, &total_len)) goto error;
316                                              /* keep going ... */
317                                         begin = needle = d + 1;
318                                         p -= frag_len + 2;
319                                         continue;
320                                 default:
321                                              /* no valid substitution char -- keep going */
322                                         p -= frag_len + 1;
323                                         needle = d;
324                                 }
325                         } /* possible substitute */
326                 } /* substitution loop */
327                 DBG("get_hfblock: one more hf processed\n");
328         } /* header loop */
329         
330              /* construct a single header block now */
331         ret = pkg_malloc(total_len);
332         if (!ret) {
333                 LOG(L_ERR, "get_hfblock: no pkg mem for hf block\n");
334                 goto error;
335         }
336         i = sl.next;
337         dst = ret;
338         while(i) {
339                 foo = i;
340                 i = i->next;
341                 memcpy(dst, foo->s.s, foo->s.len);
342                 dst += foo->s.len;
343                 pkg_free(foo);
344         }
345         *l = total_len;
346         return ret;
347         
348  error:
349         i = sl.next;
350         while(i) {
351                 foo = i;
352                 i = i->next;
353                 pkg_free(foo);
354         }
355         *l = 0;
356         return 0;
357 }
358
359
360 #define FIFO_ROUTE_PREFIX "Route: "
361 #define FIFO_ROUTE_SEPARATOR ", "
362
363 static void print_routes(dlg_t* _d)
364 {
365         rr_t* ptr;
366
367         ptr = _d->hooks.first_route;
368
369         if (ptr) {
370                 unixsock_reply_asciiz(FIFO_ROUTE_PREFIX);
371         } else {
372                 unixsock_reply_asciiz(".\n");
373                 return;
374         }
375
376         while(ptr) {
377                 unixsock_reply_printf("%.*s", ptr->len, ptr->nameaddr.name.s);
378
379                 ptr = ptr->next;
380                 if (ptr) {
381                         unixsock_reply_asciiz(FIFO_ROUTE_SEPARATOR);
382                 }
383         } 
384
385         if (_d->hooks.last_route) {
386                 unixsock_reply_asciiz(FIFO_ROUTE_SEPARATOR "<");
387                 unixsock_reply_printf("%.*s", _d->hooks.last_route->len, _d->hooks.last_route->s);
388                 unixsock_reply_asciiz(">");
389         }
390
391         if (_d->hooks.first_route) {
392                 unixsock_reply_asciiz(CRLF);
393         }
394 }
395
396
397
398 static int print_uris(struct sip_msg* reply)
399 {
400         dlg_t* dlg;
401         
402         dlg = (dlg_t*)shm_malloc(sizeof(dlg_t));
403         if (!dlg) {
404                 LOG(L_ERR, "print_uris: No memory left\n");
405                 return -1;
406         }
407
408         memset(dlg, 0, sizeof(dlg_t));
409         if (dlg_response_uac(dlg, reply) < 0) {
410                 LOG(L_ERR, "print_uris: Error while creating dialog structure\n");
411                 free_dlg(dlg);
412                 return -2;
413         }
414
415         if (dlg->state != DLG_CONFIRMED) {
416                 unixsock_reply_asciiz(".\n.\n.\n");
417                 free_dlg(dlg);
418                 return 0;
419         }
420
421         if (dlg->hooks.request_uri->s) {        
422                 unixsock_reply_printf("%.*s\n", dlg->hooks.request_uri->len, dlg->hooks.request_uri->s);
423         } else {
424                 unixsock_reply_asciiz(".\n");
425         }
426         if (dlg->hooks.next_hop->s) {
427                 unixsock_reply_printf("%.*s\n", dlg->hooks.next_hop->len, dlg->hooks.next_hop->s);
428         } else {
429                 unixsock_reply_asciiz(".\n");
430         }
431         print_routes(dlg);
432         free_dlg(dlg);
433         return 0;
434 }
435
436 static int new_uac_cb_param(struct uac_cb_param** param,
437                             struct sip_msg* msg, 
438                             struct sockaddr_un* addr)
439 {
440     int len=0;
441     struct uac_cb_param* p_param=0;
442
443     if(msg && addr) {
444
445         *param = shm_malloc(sizeof(struct uac_cb_param));
446         if (!*param) {
447             unixsock_reply_asciiz("500 No shared memory");
448             return -1;
449         }
450         
451         p_param = *param;
452
453         len += msg->from->len;
454         len += msg->callid->len;
455         len += msg->cseq->len;
456
457         p_param->from.s = shm_malloc(len);
458         if(!p_param->from.s){
459
460             shm_free(p_param);
461             *param = 0;
462
463             unixsock_reply_asciiz("500 No shared memory");
464             return -1;
465         }
466
467         memcpy(p_param->from.s,msg->from->name.s,msg->from->len);
468         p_param->from.len = msg->from->len;
469
470         p_param->callid.s = p_param->from.s + p_param->from.len;
471         memcpy(p_param->callid.s,msg->callid->name.s,msg->callid->len);
472         p_param->callid.len = msg->callid->len;
473
474         p_param->cseq.s = p_param->callid.s + p_param->callid.len;
475         memcpy(p_param->cseq.s,msg->cseq->name.s,msg->cseq->len);
476         p_param->cseq.len = msg->cseq->len;
477
478         memcpy(&(p_param->addr), addr, sizeof(struct sockaddr_un));
479
480     } else {
481         *param = 0;
482     }
483     return 0;
484 }
485
486 static void free_uac_cb_param(struct uac_cb_param* param)
487 {
488     shm_free(param->from.s);
489     shm_free(param);
490 }
491
492 static void callback(struct cell *t, int type, struct tmcb_params *ps)
493 {
494         struct sockaddr_un*  to;
495         struct uac_cb_param* param=0;
496
497         str text;
498
499         if (!*ps->param) {
500                 LOG(L_INFO, "INFO: fifo UAC completed with status %d\n", ps->code);
501                 return;
502         }
503         
504         param = (struct uac_cb_param*)(*ps->param);
505         to = &param->addr;
506         unixsock_reply_reset();
507
508         if (ps->rpl == FAKED_REPLY) {
509                 get_reply_status(&text, ps->rpl, ps->code);
510                 if (text.s == 0) {
511                         LOG(L_ERR, "callback: get_reply_status failed\n");
512                         unixsock_reply_asciiz("500 callback: get_reply_status failed\n");
513                         goto done;
514                 }
515
516                 unixsock_reply_printf("%.*s\n.\n.\n.\n", text.len, text.s);
517
518                 unixsock_reply_printf("%.*s", param->from.len, param->from.s);
519                 unixsock_reply_printf("%.*s", param->callid.len, param->callid.s);
520                 unixsock_reply_printf("%.*s\n", param->cseq.len, param->cseq.s);
521
522                 pkg_free(text.s);
523
524         } else {
525                 text.s = ps->rpl->first_line.u.reply.reason.s;
526                 text.len = ps->rpl->first_line.u.reply.reason.len;
527
528                      /* FIXME: check for return values here */
529                 unixsock_reply_printf("%d %.*s\n", ps->rpl->first_line.u.reply.statuscode, text.len, text.s);
530                 print_uris(ps->rpl);
531                 unixsock_reply_printf("%s\n", ps->rpl->headers->name.s);
532         }
533 done:
534         unixsock_reply_sendto(to);
535
536         if (ps->code >= 200) {
537
538             free_uac_cb_param(param);
539             *ps->param=0; /* 0 it so the callback won't do 
540                              anything if called for a retransmission */
541         }
542 }
543
544
545 /*
546  * Create shm_copy of filename
547  */
548 static int duplicate_addr(struct sockaddr_un** dest, struct sockaddr_un* addr)
549 {
550         if (addr) {
551                 *dest = shm_malloc(sizeof(*addr));
552                 if (!*dest) {
553                         unixsock_reply_asciiz("500 No shared memory");
554                         return -1;
555                 }
556                 memcpy(*dest, addr, sizeof(*addr));
557         } else {
558                 *dest = 0;
559         }
560         return 0;
561 }
562
563 int unixsock_uac(str* msg)
564 {
565         str method, ruri, nexthop, headers, body, hfb, callid;
566         struct sip_uri puri, pnexthop;
567         struct sip_msg faked_msg;
568         int ret, sip_error, err_ret, fromtag, cseq_is, cseq;
569         char err_buf[MAX_REASON_LEN];
570         struct sockaddr_un* shm_sockaddr;
571         struct uac_cb_param* shm_param;
572         dlg_t dlg;
573
574         if (get_method(&method, msg) < 0) return -1;
575         if (get_ruri(&ruri, &puri, msg) < 0) return -1;
576         if (get_nexthop(&nexthop, &pnexthop, msg) < 0) return -1;
577         if (get_headers(&headers, msg) < 0) return -1;
578
579              /* use SIP parser to look at what is in the FIFO request */
580         memset(&faked_msg, 0, sizeof(struct sip_msg));
581         faked_msg.len = headers.len; 
582         faked_msg.buf = faked_msg.unparsed = headers.s;
583         if (parse_headers(&faked_msg, HDR_EOH_F, 0) == -1 ) {
584                 unixsock_reply_asciiz("400 HFs unparsable\n");
585                 unixsock_reply_send();
586                 goto error;
587         }
588
589         if (get_body_lines(&body, msg) < 0) goto error;
590         
591              /* at this moment, we collected all the things we got, let's
592               * verify user has not forgotten something */
593         if (check_msg(&faked_msg, &method, &body, &fromtag, 
594                       &cseq_is, &cseq, &callid) < 0) goto error;
595
596         hfb.s = get_hfblock(nexthop.len ? &nexthop : &ruri, 
597                             faked_msg.headers, &hfb.len, PROTO_UDP);
598         if (!hfb.s) {
599                 unixsock_reply_asciiz("500 No memory for HF block");
600                 unixsock_reply_send();
601                 goto error;
602         }
603
604         memset(&dlg, 0, sizeof(dlg_t));
605              /* Fill in Call-ID, use given Call-ID if
606               * present and generate it if not present
607               */
608         if (callid.s && callid.len) dlg.id.call_id = callid;
609         else generate_callid(&dlg.id.call_id);
610         
611              /* We will not fill in dlg->id.rem_tag because
612               * if present it will be printed within To HF
613               */
614         
615              /* Generate fromtag if not present */
616         if (!fromtag) {
617                 generate_fromtag(&dlg.id.loc_tag, &dlg.id.call_id);
618         }
619         
620              /* Fill in CSeq */
621         if (cseq_is) dlg.loc_seq.value = cseq;
622         else dlg.loc_seq.value = DEFAULT_CSEQ;
623         dlg.loc_seq.is_set = 1;
624
625         dlg.loc_uri = faked_msg.from->body;
626         dlg.rem_uri = faked_msg.to->body;
627         dlg.hooks.request_uri = &ruri;
628         dlg.hooks.next_hop = (nexthop.len ? &nexthop : &ruri);
629         
630         if (new_uac_cb_param(&shm_param,&faked_msg,unixsock_sender_addr()) < 0) {
631             
632             unixsock_reply_send();
633             goto error01;
634         }
635
636              /* we got it all, initiate transaction now! */
637         ret = t_uac(&method, &hfb, &body, &dlg, callback, shm_param);
638         if (ret <= 0) {
639                 err_ret = err2reason_phrase(ret, &sip_error, err_buf, sizeof(err_buf), "FIFO/UAC");
640                 if (err_ret > 0) {
641                         unixsock_reply_printf("%d %s", sip_error, err_buf);
642                 } else {
643                         unixsock_reply_asciiz("500 UNIXSOCK/UAC error");
644                 }
645                 unixsock_reply_send();
646                 free_uac_cb_param(shm_param);
647                 goto error01;
648         }
649
650              /* Do not free shm_sockaddr here, it will be used
651               * by the callback
652               */
653         pkg_free(hfb.s);
654         if (faked_msg.headers) free_hdr_field_lst(faked_msg.headers);
655         return 0;
656         
657  error01:
658         pkg_free(hfb.s);
659  error:
660         if (faked_msg.headers) free_hdr_field_lst(faked_msg.headers);
661         return -1;
662 }