everything: shotgun attempt to put PROTO_WS and PROTO_WSS across core and in modules...
[sip-router] / modules_k / presence / utils_func.h
1 /*
2  * $Id$
3  *
4  * presence module - presence server implementation
5  *
6  * Copyright (C) 2006 Voice Sistem S.R.L.
7  *
8  * This file is part of Kamailio, a free SIP server.
9  *
10  * Kamailio is free software; you can redistribute it and/or modify
11  * it under the terms of the GNU General Public License as published by
12  * the Free Software Foundation; either version 2 of the License, or
13  * (at your option) any later version
14  *
15  * Kamailio is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  * GNU General Public License for more details.
19  *
20  * You should have received a copy of the GNU General Public License
21  * along with this program; if not, write to the Free Software
22  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
23  *
24  * History:
25  * --------
26  *  2006-08-15  initial version (Anca Vamanu)
27  */
28
29 /*! \file
30  * \brief Kamailio presence module :: Utility functions
31  * \ref utils_func.c
32  * \ingroup presence 
33  */
34
35
36
37 #ifndef UTILS_FUNC_H
38 #define UTILS_FUNC_H
39 #include <stdio.h>
40 #include <stdlib.h>
41 #include <string.h>
42 #include "../../mem/mem.h"
43 #include "../../dprint.h"
44 #include "../../str.h"
45 #include "../../parser/msg_parser.h"
46 #include "../../parser/parse_event.h"
47
48 #define LCONTACT_BUF_SIZE 1024
49 #define BAD_EVENT_CODE 489
50
51
52 #define EVENT_DIALOG_SLA(ev) \
53         ((ev)->type == EVENT_DIALOG \
54                 && ((ev)->params.hooks.event_dialog.sla \
55                         || (ev)->params.hooks.event_dialog.ma))
56
57
58 static inline int uandd_to_uri(str user,  str domain, str *out)
59 {
60         int size;
61
62         if(out==0)
63                 return -1;
64
65         size = user.len + domain.len+7;
66         out->s = (char*)pkg_malloc(size);
67
68         if(out->s == NULL)
69         {
70                 LM_ERR("no more memory\n");
71                 return -1;
72         }
73         strcpy(out->s,"sip:");
74         out->len = 4;
75         if(user.s!=NULL && user.len>0)
76         {
77                 memcpy(out->s+out->len, user.s, user.len);
78                 out->len += user.len;
79                 out->s[out->len++] = '@';
80         }
81         memcpy(out->s + out->len, domain.s, domain.len);
82         out->len += domain.len;
83         out->s[out->len] = '\0';
84         
85         return 0;
86 }
87
88 static inline int ps_fill_local_contact(struct sip_msg* msg, str *contact)
89 {
90         str ip;
91         char* proto;
92         int port;
93         int len;
94         int plen;
95
96         contact->s= (char*)pkg_malloc(LCONTACT_BUF_SIZE);
97         if(contact->s== NULL)
98         {
99                 LM_ERR("No more memory\n");
100                 goto error;
101         }
102
103         memset(contact->s, 0, LCONTACT_BUF_SIZE);
104         contact->len= 0;
105         
106         plen = 3;
107         if(msg->rcv.proto== PROTO_NONE || msg->rcv.proto==PROTO_UDP)
108                 proto= "udp";
109         else
110         if(msg->rcv.proto== PROTO_TLS )
111                         proto= "tls";
112         else    
113         if(msg->rcv.proto== PROTO_TCP)
114                 proto= "tcp";
115         else    
116         if(msg->rcv.proto== PROTO_SCTP) {
117                 proto= "sctp";
118                 plen = 4;
119         }
120         else    
121         if(msg->rcv.proto== PROTO_WS || msg->rcv.proto== PROTO_WSS) {
122                 proto= "ws";
123                 plen = 2;
124         }
125         else
126         {
127                 LM_ERR("unsupported proto\n");
128                 goto error;
129         }       
130         
131         ip.s= ip_addr2a(&msg->rcv.dst_ip);
132         if(ip.s== NULL)
133         {
134                 LM_ERR("transforming ip_addr to ascii\n");
135                 goto error;
136         }
137         ip.len= strlen(ip.s);
138         port = msg->rcv.dst_port;
139
140         if(strncmp(ip.s, "sip:", 4)!=0)
141         {
142                 strncpy(contact->s, "sip:", 4);
143                 contact->len+= 4;
144         }       
145         strncpy(contact->s+contact->len, ip.s, ip.len);
146         contact->len += ip.len;
147         if(contact->len> LCONTACT_BUF_SIZE - 21)
148         {
149                 LM_ERR("buffer overflow\n");
150                 goto error;
151
152         }       
153         len= sprintf(contact->s+contact->len, ":%d;transport=" , port);
154         if(len< 0)
155         {
156                 LM_ERR("unsuccessful sprintf\n");
157                 goto error;
158         }       
159         contact->len+= len;
160         strncpy(contact->s+ contact->len, proto, plen);
161         contact->len += plen;
162         
163         return 0;
164 error:
165         if(contact->s!=NULL)
166                 pkg_free(contact->s);
167         contact->s = 0;
168         contact->len = 0;
169         return -1;
170 }
171
172 //str* int_to_str(long int n);
173
174 int a_to_i (char *s,int len);
175
176 void to64frombits(unsigned char *out, const unsigned char *in, int inlen);
177
178 int send_error_reply(struct sip_msg* msg, int reply_code, str reply_str);
179
180 #endif
181