- changed sip_msg (new rcv member containing all the ips, ports, protocol)
[sip-router] / parser / msg_parser.h
1 /*
2  * $Id$
3  *
4  * Copyright (C) 2001-2003 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
29 #ifndef msg_parser_h
30 #define msg_parser_h
31
32 #include "../str.h"
33 #include "../data_lump.h"
34 #include "../flags.h"
35 #include "../ip_addr.h"
36 #include "../md5utils.h"
37 #include "../config.h"
38 #include "parse_def.h"
39 #include "parse_cseq.h"
40 #include "parse_to.h"
41 #include "parse_via.h"
42 #include "parse_fline.h"
43 #include "hf.h"
44
45
46 /* convenience short-cut macros */
47 #define REQ_LINE(_msg) ((_msg)->first_line.u.request)
48 #define REQ_METHOD first_line.u.request.method_value
49 #define REPLY_STATUS first_line.u.reply.statuscode
50 #define REPLY_CLASS(_reply) ((_reply)->REPLY_STATUS/100)
51
52 /* number methods as power of two to allow bitmap matching */
53 enum request_method { METHOD_INVITE=1, METHOD_CANCEL=2, METHOD_ACK=4, 
54         METHOD_BYE=8, METHOD_OTHER=16 };
55
56
57 #define IFISMETHOD(methodname,firstchar)                                  \
58 if (  (*tmp==(firstchar) || *tmp==((firstchar) | 32)) &&                  \
59         strncasecmp( tmp+1, #methodname +1, methodname##_LEN-1)==0 &&     \
60         *(tmp+methodname##_LEN)==' ') {                                   \
61                 fl->type=SIP_REQUEST;                                     \
62                 fl->u.request.method.len=methodname##_LEN;                \
63                 fl->u.request.method_value=METHOD_##methodname;           \
64                 tmp=buffer+methodname##_LEN;                              \
65 }
66
67
68
69 struct sip_uri {
70         str user;     /* Username */
71         str passwd;   /* Password */
72         str host;     /* Host name */
73         str port;     /* Port number */
74         str params;   /* Parameters */
75         str headers;  
76         unsigned short port_no;
77 };
78
79
80
81 struct sip_msg {
82         unsigned int id;               /* message id, unique/process*/
83         struct msg_start first_line;   /* Message first line */
84         struct via_body* via1;         /* The first via */
85         struct via_body* via2;         /* The second via */
86         struct hdr_field* headers;     /* All the parsed headers*/
87         struct hdr_field* last_header; /* Pointer to the last parsed header*/
88         int parsed_flag;               /* Already parsed header field types */
89
90              /* Via, To, CSeq, Call-Id, From, end of header*/
91              /* pointers to the first occurances of these headers;
92                   * everything is also saved in 'headers'
93                   * (WARNING: do not deallocate them twice!)*/
94
95         struct hdr_field* h_via1;
96         struct hdr_field* h_via2;
97         struct hdr_field* callid;
98         struct hdr_field* to;
99         struct hdr_field* cseq;
100         struct hdr_field* from;
101         struct hdr_field* contact;
102         struct hdr_field* maxforwards;
103         struct hdr_field* route;
104         struct hdr_field* record_route;
105         struct hdr_field* content_type;
106         struct hdr_field* content_length;
107         struct hdr_field* authorization;
108         struct hdr_field* expires;
109         struct hdr_field* proxy_auth;
110         struct hdr_field* www_auth;
111         struct hdr_field* supported;
112         struct hdr_field* require;
113         struct hdr_field* proxy_require;
114         struct hdr_field* unsupported;
115         struct hdr_field* allow;
116         struct hdr_field* event;
117
118         char* eoh;        /* pointer to the end of header (if found) or null */
119         char* unparsed;   /* here we stopped parsing*/
120         
121         struct receive_info rcv; /* source & dest ip, ports, proto a.s.o*/
122         
123         char* orig;       /* original message copy */
124         char* buf;        /* scratch pad, holds a modfied message,
125                                            *  via, etc. point into it */
126         unsigned int len; /* message len (orig) */
127
128              /* modifications */
129         
130         str new_uri; /* changed first line uri*/
131
132         str dst_uri; /* Destination URI, must be forwarded to this URI if len != 0 */
133
134         int parsed_uri_ok; /* 1 if parsed_uri is valid, 0 if not */
135         struct sip_uri parsed_uri; /* speed-up > keep here the parsed uri*/
136         
137         struct lump* add_rm;         /* used for all the forwarded requests */
138         struct lump* repl_add_rm;    /* used for all the forwarded replies */
139         struct lump_rpl *reply_lump; /* only for localy generated replies !!!*/
140
141         /* str add_to_branch; 
142            whatever whoever want to append to branch comes here 
143         */
144         char add_to_branch_s[MAX_BRANCH_PARAM_LEN];
145         int add_to_branch_len;
146         
147              /* index to TM hash table; stored in core to avoid unnecessary calcs */
148         unsigned int  hash_index;
149         
150              /* allows to set various flags on the message; may be used for 
151               * simple inter-module communication or remembering processing state
152               * reached 
153               */
154         flag_t flags;   
155 };
156
157 /* pointer to a fakes message which was never received ;
158    (when this message is "relayed", it is generated out
159     of the original request)
160 */
161 #define FAKED_REPLY     ((struct sip_msg *) -1)
162
163 extern int via_cnt;
164
165 int parse_msg(char* buf, unsigned int len, struct sip_msg* msg);
166
167 int parse_headers(struct sip_msg* msg, int flags, int next);
168
169 void free_sip_msg(struct sip_msg* msg);
170
171 /* make sure all HFs needed for transaction identification have been
172    parsed; return 0 if those HFs can't be found
173  */
174
175 int check_transaction_quadruple( struct sip_msg* msg );
176
177 /* calculate characteristic value of a message -- this value
178    is used to identify a transaction during the process of
179    reply matching
180  */
181 inline static int char_msg_val( struct sip_msg *msg, char *cv )
182 {
183         str src[8];
184
185         if (!check_transaction_quadruple(msg)) {
186                 LOG(L_ERR, "ERROR: can't calculate char_value due "
187                         "to a parsing error\n");
188                 memset( cv, '0', MD5_LEN );
189                 return 0;
190         }
191
192         src[0]= msg->from->body;
193         src[1]= msg->to->body;
194         src[2]= msg->callid->body;
195         src[3]= msg->first_line.u.request.uri;
196         src[4]= get_cseq( msg )->number;
197         
198         /* topmost Via is part of transaction key as well ! */
199         src[5]= msg->via1->host;
200         src[6]= msg->via1->port_str;
201         if (msg->via1->branch) {
202                 src[7]= msg->via1->branch->value;
203                 MDStringArray ( cv, src, 8 );
204         } else {
205                 MDStringArray( cv, src, 7 );
206         }
207         return 1;
208 }
209
210
211 /* returns a pointer to the begining of the msg's body
212  */
213 inline static char* get_body(struct sip_msg *msg)
214 {
215         int offset;
216         int len;
217
218         if ( parse_headers(msg,HDR_EOH, 0)==-1 )
219                 return 0;
220
221         if (msg->unparsed){
222                 len=(int)(msg->unparsed-msg->buf);
223         }else return 0;
224         if ((len+2<=msg->len) && (strncmp(CRLF,msg->unparsed,CRLF_LEN)==0) )
225                 offset = CRLF_LEN;
226         else if ( (len+1<=msg->len) &&
227                                 (*(msg->unparsed)=='\n' || *(msg->unparsed)=='\r' ) )
228                 offset = 1;
229         else
230                 return 0;
231
232         return msg->unparsed + offset;
233 }
234
235 #endif