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: 2009/06/19 12:50:32 $
37 #include "stg/notifer.h"
38 #include "stg/user_ips.h"
39 #include "stg/users.h"
40 #include "stg/module_settings.h"
42 extern "C" PLUGIN * GetPlugin();
45 //-----------------------------------------------------------------------------
46 template <typename varParamType>
47 class CHG_BEFORE_NOTIFIER: public PROPERTY_NOTIFIER_BASE<varParamType> {
49 void Notify(const varParamType & oldValue, const varParamType & newValue);
50 void SetUser(USER_PTR u) { user = u; }
51 USER_PTR GetUser() {return user; }
52 void SetAuthorizator(const AUTH_STRESS * a) { auth = a; }
56 const AUTH_STRESS * auth;
58 //-----------------------------------------------------------------------------
59 template <typename varParamType>
60 class CHG_AFTER_NOTIFIER: public PROPERTY_NOTIFIER_BASE<varParamType> {
62 void Notify(const varParamType & oldValue, const varParamType & newValue);
63 void SetUser(USER_PTR u) { user = u; }
64 USER_PTR GetUser() {return user; }
65 void SetAuthorizator(const AUTH_STRESS * a) { auth = a; }
69 const AUTH_STRESS * auth;
71 //-----------------------------------------------------------------------------
72 class AUTH_STRESS_SETTINGS {
74 AUTH_STRESS_SETTINGS();
75 const std::string & GetStrError() const { return errorStr; }
76 int ParseSettings(const MODULE_SETTINGS & s);
77 int GetAverageOnlineTime() const;
79 int ParseIntInRange(const std::string & str, int min, int max, int * val);
80 int averageOnlineTime;
83 //-----------------------------------------------------------------------------
84 class AUTH_STRESS :public AUTH {
85 friend class CHG_BEFORE_NOTIFIER<USER_IPS>;
86 friend class CHG_AFTER_NOTIFIER<USER_IPS>;
89 virtual ~AUTH_STRESS() {}
91 void SetUsers(USERS * u);
92 void SetTariffs(TARIFFS *) {}
93 void SetAdmins(ADMINS *) {}
94 void SetTraffcounter(TRAFFCOUNTER *) {}
95 void SetStore(STORE *) {}
96 void SetStgSettings(const SETTINGS *) {}
100 int Reload() { return 0; }
102 void SetSettings(const MODULE_SETTINGS & s);
104 const std::string & GetStrError() const;
105 const std::string GetVersion() const;
106 uint16_t GetStartPosition() const;
107 uint16_t GetStopPosition() const;
109 int SendMessage(const STG_MSG & msg, uint32_t ip) const;
113 void SetUserNotifiers(USER_PTR u);
114 void UnSetUserNotifiers(USER_PTR u);
116 void AddUser(USER_PTR u);
117 void DelUser(USER_PTR u);
119 void Authorize(USER_PTR u) const;
120 void Unauthorize(USER_PTR u) const;
122 static void * Run(void *);
126 mutable std::string errorStr;
127 AUTH_STRESS_SETTINGS stressSettings;
129 std::list<USER_PTR> usersList;
131 MODULE_SETTINGS settings;
134 pthread_mutex_t mutex;
136 std::list<CHG_BEFORE_NOTIFIER<USER_IPS> > BeforeChgIPNotifierList;
137 std::list<CHG_AFTER_NOTIFIER<USER_IPS> > AfterChgIPNotifierList;
139 class ADD_USER_NONIFIER: public NOTIFIER_BASE<USER_PTR> {
141 ADD_USER_NONIFIER() {}
142 virtual ~ADD_USER_NONIFIER() {}
144 void SetAuthorizator(AUTH_STRESS * a) { auth = a; }
145 void Notify(const USER_PTR & user)
154 class DEL_USER_NONIFIER: public NOTIFIER_BASE<USER_PTR> {
156 DEL_USER_NONIFIER() {}
157 virtual ~DEL_USER_NONIFIER() {}
159 void SetAuthorizator(AUTH_STRESS * a) { auth = a; }
160 void Notify(const USER_PTR & user)
170 //-----------------------------------------------------------------------------