*/
-#ifndef USERS_H
-#define USERS_H
+#ifndef USERS_IMPL_H
+#define USERS_IMPL_H
#include <pthread.h>
#include <list>
#include <set>
-#include "os_int.h"
-
-#include "settings.h"
-#include "user.h"
-#include "tariffs.h"
-#include "stg_logger.h"
-#include "notifer.h"
+#include "stg/os_int.h"
+#include "stg/store.h"
+#include "stg/users.h"
+#include "stg/user.h"
+#include "stg/tariffs.h"
+#include "stg/logger.h"
+#include "stg/notifer.h"
+#include "stg/noncopyable.h"
#include "actions.h"
-#include "noncopyable.h"
#include "eventloop.h"
+#include "settings_impl.h"
+#include "user_impl.h"
const int userDeleteDelayTime = 120;
-using namespace std;
-class USERS;
-//-----------------------------------------------------------------------------
-class PROPERTY_NOTIFER_IP_BEFORE: public PROPERTY_NOTIFIER_BASE<uint32_t>
-{
-public:
- PROPERTY_NOTIFER_IP_BEFORE(USERS & us, user_iter u) : users(us), user(u) {};
- void Notify(const uint32_t & oldValue, const uint32_t & newValue);
- user_iter GetUser() const { return user; };
-private:
- USERS & users;
- user_iter user;
-};
-//-----------------------------------------------------------------------------
-class PROPERTY_NOTIFER_IP_AFTER: public PROPERTY_NOTIFIER_BASE<uint32_t>
-{
-public:
- PROPERTY_NOTIFER_IP_AFTER(USERS & us, user_iter u) : users(us), user(u) {};
- void Notify(const uint32_t & oldValue, const uint32_t & newValue);
- user_iter GetUser() const { return user; };
-private:
- USERS & users;
- user_iter user;
-};
+typedef std::list<USER_IMPL>::iterator user_iter;
+typedef std::list<USER_IMPL>::const_iterator const_user_iter;
+
+class USERS_IMPL;
//-----------------------------------------------------------------------------
-struct USER_TO_DEL
-{
+struct USER_TO_DEL {
USER_TO_DEL()
: iter(),
delTime(0)
-{};
+{}
-list<USER>::iterator iter;
+std::list<USER_IMPL>::iterator iter;
time_t delTime;
};
//-----------------------------------------------------------------------------
-class USERS : private NONCOPYABLE
- {
+class USERS_IMPL : private NONCOPYABLE, public USERS {
friend class PROPERTY_NOTIFER_IP_BEFORE;
friend class PROPERTY_NOTIFER_IP_AFTER;
public:
- USERS(SETTINGS * s, BASE_STORE * store, TARIFFS * tariffs, const ADMIN & sysAdmin);
- ~USERS();
+ USERS_IMPL(SETTINGS_IMPL * s, STORE * store,
+ TARIFFS * tariffs, SERVICES & svcs,
+ const ADMIN * sysAdmin);
+ virtual ~USERS_IMPL();
+
+ int FindByName(const std::string & login, USER_PTR * user);
+ int FindByName(const std::string & login, CONST_USER_PTR * user) const;
+
+ bool Exists(const std::string & login) const;
- int FindByName(const string & login, user_iter * user) const;
- int FindByID(int id, user_iter * user);
+ bool TariffInUse(const std::string & tariffName) const;
- bool TariffInUse(const string & tariffName);
+ void AddNotifierUserAdd(NOTIFIER_BASE<USER_PTR> *);
+ void DelNotifierUserAdd(NOTIFIER_BASE<USER_PTR> *);
- void AddNotifierUserAdd(NOTIFIER_BASE<user_iter> *);
- void DelNotifierUserAdd(NOTIFIER_BASE<user_iter> *);
+ void AddNotifierUserDel(NOTIFIER_BASE<USER_PTR> *);
+ void DelNotifierUserDel(NOTIFIER_BASE<USER_PTR> *);
- void AddNotifierUserDel(NOTIFIER_BASE<user_iter> *);
- void DelNotifierUserDel(NOTIFIER_BASE<user_iter> *);
+ void AddNotifierUserAdd(NOTIFIER_BASE<USER_IMPL_PTR> *);
+ void DelNotifierUserAdd(NOTIFIER_BASE<USER_IMPL_PTR> *);
- int Add(const string & login, const ADMIN & admin);
- void Del(const string & login, const ADMIN & admin);
+ void AddNotifierUserDel(NOTIFIER_BASE<USER_IMPL_PTR> *);
+ void DelNotifierUserDel(NOTIFIER_BASE<USER_IMPL_PTR> *);
+
+ int Add(const std::string & login, const ADMIN * admin);
+ void Del(const std::string & login, const ADMIN * admin);
+
+ bool Authorize(const std::string & login, uint32_t ip,
+ uint32_t enabledDirs, const AUTH * auth);
+ bool Unauthorize(const std::string & login,
+ const AUTH * auth,
+ const std::string & reason = std::string());
int ReadUsers();
- int GetUserNum();
+ size_t Count() const { return users.size(); }
- int FindByIPIdx(uint32_t ip, user_iter * user);
+ int FindByIPIdx(uint32_t ip, USER_PTR * user) const;
+ int FindByIPIdx(uint32_t ip, USER_IMPL ** user) const;
+ bool IsIPInIndex(uint32_t ip) const;
+ bool IsIPInUse(uint32_t ip, const std::string & login, CONST_USER_PTR * user) const;
int OpenSearch();
- int SearchNext(int handler, user_iter * u);
+ int SearchNext(int handler, USER_PTR * user);
+ int SearchNext(int handler, USER_IMPL ** user);
int CloseSearch(int handler);
int Start();
int Stop();
private:
- void AddToIPIdx(user_iter);
+ USERS_IMPL(const USERS_IMPL & rvalue);
+ USERS_IMPL & operator=(const USERS_IMPL & rvalue);
+
+ void AddToIPIdx(user_iter user);
void DelFromIPIdx(uint32_t ip);
+ bool FindByIPIdx(uint32_t ip, user_iter & iter) const;
- int FindByNameNonLock(const string & login, user_iter * user) const;
- int FindByIDNonLock(int id, user_iter * user);
+ int FindByNameNonLock(const std::string & login, user_iter * user);
+ int FindByNameNonLock(const std::string & login, const_user_iter * user) const;
void RealDelUser();
void ProcessActions();
- void SetUserNotifiers(user_iter user);
- void UnSetUserNotifiers(user_iter user);
-
void AddUserIntoIndexes(user_iter user);
void DelUserFromIndexes(user_iter user);
bool TimeToWriteDetailStat(const struct tm & t);
- list<USER> users;
- list<USER_TO_DEL> usersToDelete;
- list<PROPERTY_NOTIFER_IP_BEFORE> userIPNotifiersBefore;
- list<PROPERTY_NOTIFER_IP_AFTER> userIPNotifiersAfter;
+ std::list<USER_IMPL> users;
+ std::list<USER_TO_DEL> usersToDelete;
- map<uint32_t, user_iter> ipIndex;
- map<string, user_iter> loginIndex;
+ std::map<uint32_t, user_iter> ipIndex;
+ std::map<std::string, user_iter> loginIndex;
- SETTINGS * settings;
+ SETTINGS_IMPL * settings;
TARIFFS * tariffs;
- BASE_STORE * store;
- const ADMIN sysAdmin;
+ SERVICES & m_services;
+ STORE * store;
+ const ADMIN * sysAdmin;
STG_LOGGER & WriteServLog;
bool nonstop;
pthread_t thread;
mutable unsigned int handle;
- mutable map<int, user_iter> searchDescriptors;
+ mutable std::map<int, user_iter> searchDescriptors;
- set <NOTIFIER_BASE<user_iter>*> onAddNotifiers;
- set <NOTIFIER_BASE<user_iter>*> onDelNotifiers;
- };
+ std::set<NOTIFIER_BASE<USER_PTR>*> onAddNotifiers;
+ std::set<NOTIFIER_BASE<USER_PTR>*> onDelNotifiers;
+ std::set<NOTIFIER_BASE<USER_IMPL_PTR>*> onAddNotifiersImpl;
+ std::set<NOTIFIER_BASE<USER_IMPL_PTR>*> onDelNotifiersImpl;
+};
//-----------------------------------------------------------------------------
-inline
+/*inline
void PROPERTY_NOTIFER_IP_BEFORE::Notify(const uint32_t & oldValue,
const uint32_t &)
{
//EVENT_LOOP_SINGLETON::GetInstance().Enqueue(users, &USERS::AddToIPIdx, user);
// Using explicit call to assure that index is valid, because fast reconnect with delayed call can result in authorization error
users.AddToIPIdx(user);
-}
+}*/
//-----------------------------------------------------------------------------
#endif
-
git.stg.codes / stg.git / blobdiff