Mercurial > hg > freeDiameter

comparison extensions/app_sip/app_sip.h @ 433:0d08a9ab2212

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Corrected name mistakes on app_sip
author Alexandre Westfahl <awestfahl@freediameter.net>
date Wed, 28 Jul 2010 14:34:48 +0900
parents
children a94ecaaf15ec
comparison
equal deleted inserted replaced
432:533188d2e6cc 433:0d08a9ab2212
1 /*********************************************************************************************************
2 * Software License Agreement (BSD License) *
3 * Author: Alexandre Westfahl <awestfahl@freesipserver.net> *
4 * *
5 * Copyright (c) 2010, Alexandre Westfahl, Teraoka Laboratory (Keio University), and the WIDE Project. *
6 * *
7 * All rights reserved. *
8 * *
9 * Redistribution and use of this software in source and binary forms, with or without modification, are *
10 * permitted provided that the following conditions are met: *
11 * *
12 * * Redistributions of source code must retain the above *
13 * copyright notice, this list of conditions and the *
14 * following disclaimer. *
15 * *
16 * * Redistributions in binary form must reproduce the above *
17 * copyright notice, this list of conditions and the *
18 * following disclaimer in the documentation and/or other *
19 * materials provided with the distribution. *
20 * *
21 * * Neither the name of the Teraoka Laboratory nor the *
22 * names of its contributors may be used to endorse or *
23 * promote products derived from this software without *
24 * specific prior written permission of Teraoka Laboratory *
25 * *
26 * *
27 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS OR IMPLIED *
28 * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A *
29 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR *
30 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT *
31 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS *
32 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR *
33 * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF *
34 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. *
35 *********************************************************************************************************/
36 #include <freeDiameter/extension.h>
37 #include <sys/time.h>
38 #include <stdint.h>
39 #include <stdlib.h>
40 #include <stdio.h>
41 #include <gcrypt.h>
42 #include <string.h>
43 #include <mysql.h>
44 #include "md5.h"
45
46
47 #define NONCE_SIZE 16
48 #define DIGEST_LEN 16
49
50
51 /* Mode for the extension */
52 #define MODE_DSSERVER 0x1
53 #define MODE_SL 0x2
54
55 //Redirect_Host_Usage
56 #define ALL_USER 6
57
58 /* The module configuration */
59 struct as_conf {
60 int mode; /* default MODE_DSSERVER | MODE_SL */
61 enum {ASMYSQL} datasource;
62 char * mysql_login;
63 char * mysql_password;
64 char * mysql_database;
65 char * mysql_server;
66 char mysql_prefix[10]; //default: as_
67 uint16_t mysql_port; //if 0, default port will be used
68
69 };
70 extern struct as_conf * as_conf;
71
72 /* Parse the configuration file */
73 int as_conf_handle(char * conffile);
74
75
76 extern MYSQL *conn;
77
78
79
80 void calc_md5(char *buffer, char * data);
81 void clear_digest(uint8_t * digest, char * readable_digest, int digestlength);
82 struct avp_hdr * walk_digest(struct avp *avp, int avp_code);
83
84
85 //MySQL part
86 int start_mysql_connection();
87 void request_mysql(char *query);
88 void close_mysql_connection();
89 int get_sipserver_uri(const unsigned char *sip_aor, const size_t sipaorlen, unsigned char ** sipserver_uri, size_t *sipserverurilen);
90 int exist_username(const unsigned char *sip_aor, const size_t sipaorlen);
91 int get_sipserver_cap(const unsigned char *sip_aor, const size_t sipaorlen, struct avp **capabilities);
92 int get_password(const unsigned char *username, const size_t usernamelen, char *password);
93 int check_sipaor(const unsigned char *username, const size_t usernamelen, const char * sip_aor,const size_t sipaorlen);
94 int add_user_datatype(const unsigned char *sip_aor, const size_t sipaorlen,struct msg *message);
95 int set_pending_flag(const unsigned char *username, const size_t usernamelen);
96 int clear_pending_flag(const unsigned char *username, const size_t usernamelen);
97 int set_real_sipserver_uri(const unsigned char *username, const size_t usernamelen, const unsigned char *sipserver_uri,const size_t sipserverurilen);
98 int set_sipserver_uri(const unsigned char *username, const size_t usernamelen, const unsigned char *sipserver_uri,const size_t sipserverurilen);
99 //int get_sipserver_uri(const unsigned char *sip_aor, const size_t sipaorlen, unsigned char ** sipserver_uri, size_t *sipserverurilen);
100 int allow_roaming(const unsigned char *username, const size_t usernamelen, const char * network,const size_t networklen);
101 int get_diameter_uri(const unsigned char *sip_aor, const size_t sipaorlen, char ** diameter_uri, size_t *diameterurilen);
102 //count functions
103 int count_avp(struct msg * message, int code, int vendor);
104
105
106 void DigestCalcHA1(char * pszAlg,char * pszUserName,char * pszRealm,char * pszPassword,char * pszNonce,char * pszCNonce,HASHHEX SessionKey);
107 void DigestCalcResponse(HASHHEX HA1,char * pszNonce,char * pszNonceCount,char * pszCNonce,char * pszQop,char * pszMethod,char * pszDigestUri,HASHHEX HEntity,HASHHEX Response);
108 void DigestCalcResponseAuth(HASHHEX HA1,char * pszNonce,char * pszNonceCount,char * pszCNonce,char * pszQop,char * pszMethod,char * pszDigestUri,HASHHEX HEntity,HASHHEX Response);
109
110 int fd_avp_search_avp ( struct avp * groupedavp, struct dict_object * what, struct avp ** avp );
111
112 //thread procedure
113 void *rtr_socket(void *);
114 void *ppr_socket(void *);
115
116 struct rtrsipaor
117 {
118 char username[200];
119 char sip_aor1[200];
120 char sip_aor2[200];
121 char sip_aor3[200];
122 char strreason[200];
123 char desthost[200];
124 int reason;
125 };
126 struct pprsipaor
127 {
128 char username[200];
129 char label1[200];
130 char value1[200];
131 char label2[200];
132 char value2[200];
133 char desthost[200];
134 };
135 int app_sip_RTR_cb(struct rtrsipaor structure);
136 int app_sip_PPR_cb(struct pprsipaor structure);
137 #define PORT 666 //TODO:put in conf file
138
139 int ds_entry();
140 void fd_ext_fini(void);
141 int app_sip_default_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
142 int app_sip_MAR_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
143 int app_sip_RTA_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
144 int app_sip_PPA_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
145 int app_sip_LIR_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
146 int app_sip_UAR_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
147 int app_sip_SAR_cb( struct msg ** msg, struct avp * avp, struct session * sess, enum disp_action * act);
148
149 //Suscriber Locator
150 int app_sip_SL_LIR_cb( struct msg ** msg, struct avp * paramavp, struct session * sess, enum disp_action * act);
151 //int app_sip_SL_SAR_cb( struct msg ** msg, struct avp * paramavp, struct session * sess, enum disp_action * act);
152
153 #define SQL_GETPASSWORD "SELECT `password` FROM ds_users WHERE `username` ='%s'"
154 #define SQL_GETPASSWORD_LEN 52
155
156 //username by SIP-AOR
157 #define SQL_GETUSERNAME "SELECT `username` FROM ds_users, ds_sip_aor WHERE `sip_aor` ='%s' AND `ds_sip_aor`.`id_user` = `ds_users`.`id_user`"
158 #define SQL_GETUSERNAME_LEN 113
159
160 //sip server uri by username
161 #define SQL_GETSIPURI "SELECT `sip_server_uri` FROM ds_users WHERE `username` ='%s'"
162 #define SQL_GETSIPURI_LEN 60
163
164 //sip server uri by SIP-AOR
165 #define SQL_GETSIPSERURI "SELECT `ds_sip_aor`.`sip_server_uri` FROM ds_users, ds_sip_aor WHERE `sip_aor` ='%s' AND `ds_sip_aor`.`id_user` = `ds_users`.`id_user`"
166 #define SQL_GETSIPSERURI_LEN 132
167
168 //sip capabilities for a SIP-AOR
169 #define SQL_GETSIPSERCAP "SELECT `compulsory`,`id_service` FROM ds_user_services, ds_sip_aor WHERE `sip_aor` ='%s' AND `ds_sip_aor`.`id_user` = `ds_user_services`.`id_user`"
170 #define SQL_GETSIPSERCAP_LEN 144
171
172 //user data for a user data supported
173 #define SQL_GETSIPDATA "SELECT `label_type`,`data` FROM ds_sip_aor, ds_user_data, ds_data_types WHERE `sip_aor` ='%s' AND `ds_sip_aor`.`id_sip_aor` = `ds_user_data`.`id_sip_aor` AND `ds_data_types`.`id_data_type`=`ds_user_data`.`id_data_type`"
174 #define SQL_GETSIPDATA_LEN 216
175
176 #define SQL_GETDIAMURI "SELECT `sipserver_uri` FROM ds_sip_aor_map WHERE `sip_aor` ='%s'"
177 #define SQL_GETDIAMURI_LEN 61
178
179 //networks for this user
180 #define SQL_GETUSERNET "SELECT `label_network` FROM ds_users, ds_user_networks, ds_networks WHERE `ds_users`.`username` ='%s' AND `ds_user_networks`.`id_user` = `ds_users`.`id_user` AND `ds_user_networks`.`id_network` = `ds_networks`.`id_network`"
181 #define SQL_GETUSERNET_LEN 220
182
183 #define SQL_SETSIPURI "UPDATE ds_users SET `temp_sip_server_uri`='%s' WHERE `username` ='%s'"
184 #define SQL_SETSIPURI_LEN 65
185
186 //TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO
187 #define SQL_RMSIPURI "UPDATE ds_users SET `temp_sip_server_uri`='', `sip_server_uri`='' WHERE `id_user` ='%s'"
188 #define SQL_RMSIPURI_LEN 65
189 //TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO TODO
190
191 #define SQL_SETREALSIPURI "UPDATE ds_users SET `sip_server_uri`='%s' WHERE `username` ='%s'"
192 #define SQL_SETREALSIPURI_LEN 65
193
194 #define SQL_SETFLAG "UPDATE ds_users SET `authentication_pending`=1 WHERE `username` ='%s'"
195 #define SQL_SETFLAG_LEN 67
196
197 #define SQL_CLEARFLAG "UPDATE ds_users SET `authentication_pending`=0, `registrated`=1 WHERE `username` ='%s'"
198 #define SQL_CLEARFLAG_LEN 84
199
200 #define SQL_GETSIPAOR "SELECT `sip_aor` FROM `ds_sip_aor`, `ds_users` WHERE `ds_sip_aor`.`id_user` = `ds_users`.`id_user` AND `ds_users`.`username` = '%s'"
201 #define SQL_GETSIPAOR_LEN 131
202
203 //#define SQL_CLEARFLAG "UPDATE ds_users SET `authentication_pending`=0 WHERE `username` ='%s'"
204 //#define SQL_CLEARFLAG_LEN 67
205
206 extern struct session_handler * ds_sess_hdl;
207
208 //AVP code
209 #define CODE_SIP_USER_DATA_TYPE 388
210 #define CODE_SIP_AOR 122
211
212 struct ds_nonce
213 {
214 char *nonce;
215 };
216
217 //Storage for some usefull AVPs
218 struct app_sip_dict{
219 struct dict_object * Auth_Session_State;
220 struct dict_object * Auth_Application_Id;
221 struct dict_object * Destination_Host;
222 struct dict_object * Destination_Realm;
223 struct dict_object * User_Name;
224 struct dict_object * Session_Id;
225 struct dict_object * Redirect_Host;
226 struct dict_object * Redirect_Host_Usage;
227 struct dict_object * SIP_Auth_Data_Item;
228 struct dict_object * SIP_Accounting_Information;
229 struct dict_object * SIP_Accounting_Server_URI;
230 struct dict_object * SIP_Credit_Control_Server_URI;
231 struct dict_object * SIP_Server_Assignment_Type;
232 struct dict_object * SIP_Item_Number;
233 struct dict_object * SIP_User_Authorization_Type;
234 struct dict_object * SIP_Supported_User_Data_Type;
235 struct dict_object * SIP_User_Data;
236 struct dict_object * SIP_User_Data_Type;
237 struct dict_object * SIP_User_Data_Contents;
238 struct dict_object * SIP_User_Data_Already_Available;
239 struct dict_object * SIP_Visited_Network_Id;
240 struct dict_object * SIP_Authorization;
241 struct dict_object * SIP_Authenticate;
242 struct dict_object * SIP_Number_Auth_Items;
243 struct dict_object * SIP_Authentication_Scheme;
244 struct dict_object * SIP_Authentication_Info;
245 struct dict_object * SIP_Server_URI;
246 struct dict_object * SIP_Server_Capabilities;
247 struct dict_object * SIP_Mandatory_Capability;
248 struct dict_object * SIP_Optional_Capability;
249 struct dict_object * SIP_Method;
250 struct dict_object * SIP_AOR;
251 struct dict_object * SIP_Deregistration_Reason;
252 struct dict_object * SIP_Reason_Code;
253 struct dict_object * SIP_Reason_Info;
254 struct dict_object * Digest_URI;
255 struct dict_object * Digest_Nonce;
256 struct dict_object * Digest_Nonce_Count;
257 struct dict_object * Digest_CNonce;
258 struct dict_object * Digest_Realm;
259 struct dict_object * Digest_Response;
260 struct dict_object * Digest_Response_Auth;
261 struct dict_object * Digest_Username;
262 struct dict_object * Digest_Method;
263 struct dict_object * Digest_QOP;
264 struct dict_object * Digest_Algorithm;
265 struct dict_object * Digest_HA1;
266 };
267
268 extern struct app_sip_dict sip_dict;
"Welcome to our mercurial repository"