2 * This program is free software; you can redistribute it and/or modify
3 * it under the terms of the GNU General Public License as published by
4 * the Free Software Foundation; either version 2 of the License, or
5 * (at your option) any later version.
7 * This program is distributed in the hope that it will be useful,
8 * but WITHOUT ANY WARRANTY; without even the implied warranty of
9 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
10 * GNU General Public License for more details.
12 * You should have received a copy of the GNU General Public License
13 * along with this program; if not, write to the Free Software
14 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
18 * Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
23 $Date: 2010/09/10 06:39:19 $
41 #include "stg/os_int.h"
43 #include "stg/store.h"
44 #include "stg/notifer.h"
45 #include "stg/user_ips.h"
47 #include "stg/users.h"
48 #include "stg/ia_packets.h"
49 #include "stg/blowfish.h"
50 #include "stg/logger.h"
51 #include "stg/utime.h"
53 extern "C" PLUGIN * GetPlugin();
55 #define IA_PROTO_VER (6)
57 //#define IA_DEBUG (1)
58 //#define IA_PHASE_DEBUG (1)
61 //-----------------------------------------------------------------------------
86 //-----------------------------------------------------------------------------
100 const UTIME & GetTime() const;
102 #ifdef IA_PHASE_DEBUG
103 void SetUserLogin(const std::string & login);
104 void SetLogFileName(const std::string & logFileName);
111 #ifdef IA_PHASE_DEBUG
112 void WritePhaseChange(int newPhase);
118 //-----------------------------------------------------------------------------
127 password("NO PASSWORD")
129 unsigned char keyL[PASSWD_LEN];
130 memset(keyL, 0, PASSWD_LEN);
131 strncpy((char *)keyL, password.c_str(), PASSWD_LEN);
132 Blowfish_Init(&ctx, keyL, PASSWD_LEN);
139 IA_USER(const IA_USER & u)
143 lastSendAlive(u.lastSendAlive),
146 messagesToSend(u.messagesToSend),
147 protoVer(u.protoVer),
151 aliveSent = u.aliveSent;
153 memcpy(&ctx, &u.ctx, sizeof(BLOWFISH_CTX));
156 IA_USER(const std::string & l,
169 password(user->GetProperty().password.Get())
171 unsigned char keyL[PASSWD_LEN];
172 memset(keyL, 0, PASSWD_LEN);
173 strncpy((char *)keyL, password.c_str(), PASSWD_LEN);
174 Blowfish_Init(&ctx, keyL, PASSWD_LEN);
188 std::list<STG_MSG> messagesToSend;
190 std::string password;
195 //-----------------------------------------------------------------------------
196 class AUTH_IA_SETTINGS {
199 virtual ~AUTH_IA_SETTINGS() {};
200 const std::string & GetStrError() const { return errorStr; };
201 int ParseSettings(const MODULE_SETTINGS & s);
202 int GetUserDelay() const { return userDelay; };
203 int GetUserTimeout() const { return userTimeout; };
204 int GetUserPort() const { return port; };
205 FREEMB GetFreeMbShowType() const { return freeMbShowType; };
211 std::string errorStr;
212 FREEMB freeMbShowType;
214 //-----------------------------------------------------------------------------
216 //-----------------------------------------------------------------------------
217 class DEL_USER_NOTIFIER: public NOTIFIER_BASE<USER_PTR> {
219 DEL_USER_NOTIFIER(AUTH_IA & a) : auth(a) {}
220 virtual ~DEL_USER_NOTIFIER() {}
222 void Notify(const USER_PTR & user);
226 //-----------------------------------------------------------------------------
227 class AUTH_IA :public AUTH {
228 friend class DEL_USER_NOTIFIER;
233 void SetUsers(USERS * u) { users = u; }
234 void SetStgSettings(const SETTINGS * s) { stgSettings = s; }
235 void SetSettings(const MODULE_SETTINGS & s) { settings = s; }
240 int Reload() { return 0; }
241 bool IsRunning() { return isRunningRunTimeouter || isRunningRun; }
243 const std::string & GetStrError() const { return errorStr; }
244 const std::string GetVersion() const { return "InetAccess authorization plugin v.1.4"; }
245 uint16_t GetStartPosition() const { return 50; }
246 uint16_t GetStopPosition() const { return 50; }
248 int SendMessage(const STG_MSG & msg, uint32_t ip) const;
251 static void * Run(void *);
252 static void * RunTimeouter(void * d);
255 void DelUser(USER_PTR u);
256 int RecvData(char * buffer, int bufferSize);
257 int CheckHeader(const char * buffer, int * protoVer);
258 int PacketProcessor(char * buff, int dataLen, uint32_t sip, uint16_t sport, int protoVer, USER_PTR user);
260 int Process_CONN_SYN_6(CONN_SYN_6 * connSyn, IA_USER * iaUser, uint32_t sip);
261 int Process_CONN_SYN_7(CONN_SYN_7 * connSyn, IA_USER * iaUser, uint32_t sip);
262 int Process_CONN_SYN_8(CONN_SYN_8 * connSyn, IA_USER * iaUser, uint32_t sip);
264 int Process_CONN_ACK_6(CONN_ACK_6 * connAck, IA_USER * iaUser, uint32_t sip);
265 int Process_CONN_ACK_7(CONN_ACK_7 * connAck, IA_USER * iaUser, uint32_t sip);
266 int Process_CONN_ACK_8(CONN_ACK_8 * connAck, IA_USER * iaUser, uint32_t sip);
268 int Process_ALIVE_ACK_6(ALIVE_ACK_6 * aliveAck, IA_USER * iaUser, uint32_t sip);
269 int Process_ALIVE_ACK_7(ALIVE_ACK_7 * aliveAck, IA_USER * iaUser, uint32_t sip);
270 int Process_ALIVE_ACK_8(ALIVE_ACK_8 * aliveAck, IA_USER * iaUser, uint32_t sip);
272 int Process_DISCONN_SYN_6(DISCONN_SYN_6 * disconnSyn, IA_USER * iaUser, uint32_t sip);
273 int Process_DISCONN_SYN_7(DISCONN_SYN_7 * disconnSyn, IA_USER * iaUser, uint32_t sip);
274 int Process_DISCONN_SYN_8(DISCONN_SYN_8 * disconnSyn, IA_USER * iaUser, uint32_t sip);
276 int Process_DISCONN_ACK_6(DISCONN_ACK_6 * disconnSyn,
279 map<uint32_t, IA_USER>::iterator it);
280 int Process_DISCONN_ACK_7(DISCONN_ACK_7 * disconnSyn,
283 map<uint32_t, IA_USER>::iterator it);
284 int Process_DISCONN_ACK_8(DISCONN_ACK_8 * disconnSyn,
287 map<uint32_t, IA_USER>::iterator it);
289 int Send_CONN_SYN_ACK_6(IA_USER * iaUser, uint32_t sip);
290 int Send_CONN_SYN_ACK_7(IA_USER * iaUser, uint32_t sip);
291 int Send_CONN_SYN_ACK_8(IA_USER * iaUser, uint32_t sip);
293 int Send_ALIVE_SYN_6(IA_USER * iaUser, uint32_t sip);
294 int Send_ALIVE_SYN_7(IA_USER * iaUser, uint32_t sip);
295 int Send_ALIVE_SYN_8(IA_USER * iaUser, uint32_t sip);
297 int Send_DISCONN_SYN_ACK_6(IA_USER * iaUser, uint32_t sip);
298 int Send_DISCONN_SYN_ACK_7(IA_USER * iaUser, uint32_t sip);
299 int Send_DISCONN_SYN_ACK_8(IA_USER * iaUser, uint32_t sip);
301 int Send_FIN_6(IA_USER * iaUser, uint32_t sip, map<uint32_t, IA_USER>::iterator it);
302 int Send_FIN_7(IA_USER * iaUser, uint32_t sip, map<uint32_t, IA_USER>::iterator it);
303 int Send_FIN_8(IA_USER * iaUser, uint32_t sip, map<uint32_t, IA_USER>::iterator it);
307 int SendError(uint32_t ip, uint16_t port, int protoVer, const std::string & text);
308 int Send(uint32_t ip, uint16_t port, const char * buffer, int len);
309 int RealSendMessage6(const STG_MSG & msg, uint32_t ip, IA_USER & user);
310 int RealSendMessage7(const STG_MSG & msg, uint32_t ip, IA_USER & user);
311 int RealSendMessage8(const STG_MSG & msg, uint32_t ip, IA_USER & user);
313 BLOWFISH_CTX ctxS; //for loginS
315 mutable std::string errorStr;
316 AUTH_IA_SETTINGS iaSettings;
317 MODULE_SETTINGS settings;
322 bool isRunningRunTimeouter;
325 const SETTINGS * stgSettings;
327 mutable std::map<uint32_t, IA_USER> ip2user;
329 pthread_t recvThread;
330 pthread_t timeouterThread;
331 mutable pthread_mutex_t mutex;
335 CONN_SYN_ACK_6 connSynAck6;
336 CONN_SYN_ACK_8 connSynAck8;
338 DISCONN_SYN_ACK_6 disconnSynAck6;
339 DISCONN_SYN_ACK_8 disconnSynAck8;
341 ALIVE_SYN_6 aliveSyn6;
342 ALIVE_SYN_8 aliveSyn8;
346 std::map<std::string, int> packetTypes;
348 STG_LOGGER & WriteServLog;
350 uint32_t enabledDirs;
352 DEL_USER_NOTIFIER onDelUserNotifier;
354 class UnauthorizeUser : std::unary_function<const std::pair<uint32_t, IA_USER> &, void> {
356 UnauthorizeUser(AUTH_IA * a) : auth(a) {}
357 void operator()(const std::pair<uint32_t, IA_USER> & p)
359 auth->users->Unauthorize(p.second.user->GetLogin(), auth);
366 //-----------------------------------------------------------------------------
368 void DEL_USER_NOTIFIER::Notify(const USER_PTR & user)