* Author : Boris Mikhailenko <stg34@stargazer.dp.ua>
*/
-/*
- $Revision: 1.48 $
- $Date: 2010/11/03 10:50:03 $
- $Author: faust $
- */
-
-#ifndef USER_IMPL_H
-#define USER_IMPL_H
+#pragma once
#include "stg/user.h"
#include "stg/user_stat.h"
#include "stg/auth.h"
#include "stg/message.h"
#include "stg/noncopyable.h"
-#include "stg/os_int.h"
#include "stg/const.h"
-#include <list>
#include <vector>
#include <string>
#include <set>
+#include <mutex>
#include <ctime>
+#include <cstdint>
+
+namespace STG
+{
//-----------------------------------------------------------------------------
-class TARIFF;
-class TARIFFS;
-class ADMIN;
-class USER_IMPL;
+struct Tariff;
+class Tariffs;
+class Admin;
+class UserImpl;
#ifdef USE_ABSTRACT_SETTINGS
-class SETTINGS;
+struct Settings;
#else
-class SETTINGS_IMPL;
+class SettingsImpl;
#endif
//-----------------------------------------------------------------------------
-class USER_ID_GENERATOR {
-friend class USER_IMPL;
-private:
- USER_ID_GENERATOR() {}
- int GetNextID() { static int id = 0; return id++; }
-};
-//-----------------------------------------------------------------------------
-class CHG_PASSIVE_NOTIFIER : public PROPERTY_NOTIFIER_BASE<int>,
- private NONCOPYABLE {
-public:
- CHG_PASSIVE_NOTIFIER(USER_IMPL * u) : user(u) {}
- void Notify(const int & oldPassive, const int & newPassive);
-
-private:
- USER_IMPL * user;
-};
-//-----------------------------------------------------------------------------
-class CHG_DISABLED_NOTIFIER : public PROPERTY_NOTIFIER_BASE<int>,
- private NONCOPYABLE {
-public:
- CHG_DISABLED_NOTIFIER(USER_IMPL * u) : user(u) {}
- void Notify(const int & oldValue, const int & newValue);
-
-private:
- USER_IMPL * user;
-};
-//-----------------------------------------------------------------------------
-class CHG_TARIFF_NOTIFIER : public PROPERTY_NOTIFIER_BASE<std::string>,
- private NONCOPYABLE {
-public:
- CHG_TARIFF_NOTIFIER(USER_IMPL * u) : user(u) {}
- void Notify(const std::string & oldTariff, const std::string & newTariff);
-
-private:
- USER_IMPL * user;
-};
-//-----------------------------------------------------------------------------
-class CHG_CASH_NOTIFIER : public PROPERTY_NOTIFIER_BASE<double>,
- private NONCOPYABLE {
-public:
- CHG_CASH_NOTIFIER(USER_IMPL * u) : user(u) {}
- void Notify(const double & oldCash, const double & newCash);
-
-private:
- USER_IMPL * user;
-};
-//-----------------------------------------------------------------------------
-class CHG_IPS_NOTIFIER : public PROPERTY_NOTIFIER_BASE<USER_IPS>,
- private NONCOPYABLE {
-public:
- CHG_IPS_NOTIFIER(USER_IMPL * u) : user(u) {}
- void Notify(const USER_IPS & oldIPs, const USER_IPS & newIPs);
-
-private:
- USER_IMPL * user;
-};
-//-----------------------------------------------------------------------------
-class USER_IMPL : public USER {
-friend class CHG_PASSIVE_NOTIFIER;
-friend class CHG_DISABLED_NOTIFIER;
-friend class CHG_TARIFF_NOTIFIER;
-friend class CHG_CASH_NOTIFIER;
-friend class CHG_IPS_NOTIFIER;
-public:
+class UserImpl : public User
+{
+ public:
#ifdef USE_ABSTRACT_SETTINGS
- USER_IMPL(const SETTINGS * settings,
- const STORE * store,
- const TARIFFS * tariffs,
- const ADMIN * sysAdmin,
- const USERS * u,
- const SERVICES & svcs);
+ using Settings = STG::Settings;
#else
- USER_IMPL(const SETTINGS_IMPL * settings,
- const STORE * store,
- const TARIFFS * tariffs,
- const ADMIN * sysAdmin,
- const USERS * u,
- const SERVICES & svcs);
+ using Settings = STG::SettingsImpl;
#endif
- USER_IMPL(const USER_IMPL & u);
- virtual ~USER_IMPL();
+ UserImpl(const Settings * settings,
+ const Store * store,
+ const Tariffs * tariffs,
+ const Admin * sysAdmin,
+ const Users * u,
+ const Services & svcs);
+ UserImpl(const UserImpl & u);
- int ReadConf();
- int ReadStat();
- int WriteConf();
- int WriteStat();
- int WriteMonthStat();
+ int ReadConf();
+ int ReadStat();
+ int WriteConf() override;
+ int WriteStat() override;
+ int WriteMonthStat();
- const std::string & GetLogin() const { return login; }
- void SetLogin(std::string const & l);
+ const std::string & GetLogin() const override { return login; }
+ void SetLogin(std::string const & l);
- uint32_t GetCurrIP() const { return currIP; }
- time_t GetCurrIPModificationTime() const { return currIP.ModificationTime(); }
+ int GetID() const override { return id; }
- void AddCurrIPBeforeNotifier(CURR_IP_NOTIFIER * notifier);
- void DelCurrIPBeforeNotifier(const CURR_IP_NOTIFIER * notifier);
+ double GetPassiveTimePart() const override;
+ void ResetPassiveTime() { passiveTime = 0; }
+ void SetPassiveTimeAsNewUser();
- void AddCurrIPAfterNotifier(CURR_IP_NOTIFIER * notifier);
- void DelCurrIPAfterNotifier(const CURR_IP_NOTIFIER * notifier);
+ int WriteDetailStat(bool hard = false);
- void AddConnectedBeforeNotifier(CONNECTED_NOTIFIER * notifier);
- void DelConnectedBeforeNotifier(const CONNECTED_NOTIFIER * notifier);
+ const Tariff * GetTariff() const override { return tariff; }
+ void ResetNextTariff() override { nextTariff = ""; }
- void AddConnectedAfterNotifier(CONNECTED_NOTIFIER * notifier);
- void DelConnectedAfterNotifier(const CONNECTED_NOTIFIER * notifier);
+ #ifdef TRAFF_STAT_WITH_PORTS
+ void AddTraffStatU(int dir, uint32_t ip, uint16_t port, uint32_t len);
+ void AddTraffStatD(int dir, uint32_t ip, uint16_t port, uint32_t len);
+ #else
+ void AddTraffStatU(int dir, uint32_t ip, uint32_t len);
+ void AddTraffStatD(int dir, uint32_t ip, uint32_t len);
+ #endif
- int GetID() const { return id; }
+ const DirTraff & GetSessionUpload() const override { return sessionUpload; }
+ const DirTraff & GetSessionDownload() const override { return sessionDownload; }
+ time_t GetSessionUploadModificationTime() const override { return sessionUploadModTime; }
+ time_t GetSessionDownloadModificationTime() const override { return sessionDownloadModTime; }
- double GetPassiveTimePart() const;
- void ResetPassiveTime() { passiveTime = 0; }
- void SetPassiveTimeAsNewUser();
+ const std::string & GetLastDisconnectReason() const override { return lastDisconnectReason; }
+ int GetAuthorized() const override { return static_cast<int>(authorizedBy.size()); }
+ time_t GetAuthorizedModificationTime() const override { return authorizedModificationTime; }
+ int Authorize(uint32_t ip, uint32_t enabledDirs, const Auth * auth);
+ void Unauthorize(const Auth * auth,
+ const std::string & reason = std::string());
+ bool IsAuthorizedBy(const Auth * auth) const override;
+ std::vector<std::string> GetAuthorizers() const override;
- int WriteDetailStat(bool hard = false);
+ int AddMessage(Message * msg) override;
- const TARIFF * GetTariff() const { return tariff; }
- void ResetNextTariff() { nextTariff = ""; }
+ void UpdatePingTime(time_t t = 0) override;
+ time_t GetPingTime() const override { return pingTime; }
- #ifdef TRAFF_STAT_WITH_PORTS
- void AddTraffStatU(int dir, uint32_t ip, uint16_t port, uint32_t len);
- void AddTraffStatD(int dir, uint32_t ip, uint16_t port, uint32_t len);
- #else
- void AddTraffStatU(int dir, uint32_t ip, uint32_t len);
- void AddTraffStatD(int dir, uint32_t ip, uint32_t len);
- #endif
+ void Run() override;
- const DIR_TRAFF & GetSessionUpload() const { return sessionUpload; }
- const DIR_TRAFF & GetSessionDownload() const { return sessionDownload; }
- time_t GetSessionUploadModificationTime() const { return sessionUploadModTime; }
- time_t GetSessionDownloadModificationTime() const { return sessionDownloadModTime; }
+ const std::string & GetStrError() const override { return errorStr; }
- bool GetConnected() const { return connected; }
- time_t GetConnectedModificationTime() const { return connected.ModificationTime(); }
- const std::string & GetLastDisconnectReason() const { return lastDisconnectReason; }
- int GetAuthorized() const { return static_cast<int>(authorizedBy.size()); }
- time_t GetAuthorizedModificationTime() const { return authorizedModificationTime; }
- int Authorize(uint32_t ip, uint32_t enabledDirs, const AUTH * auth);
- void Unauthorize(const AUTH * auth,
- const std::string & reason = std::string());
- bool IsAuthorizedBy(const AUTH * auth) const;
- std::vector<std::string> GetAuthorizers() const;
+ UserProperties & GetProperties() override { return properties; }
+ const UserProperties & GetProperties() const override { return properties; }
- int AddMessage(STG_MSG * msg);
+ void SetDeleted() override { deleted = true; }
+ bool GetDeleted() const override { return deleted; }
- void UpdatePingTime(time_t t = 0);
- time_t GetPingTime() const { return pingTime; }
+ time_t GetLastWriteStatTime() const override { return lastWriteStat; }
- void Run();
+ void MidnightResetSessionStat();
+ void ProcessDayFee();
+ void ProcessDayFeeSpread();
+ void ProcessNewMonth();
+ void ProcessDailyFee();
+ void ProcessServices();
- const std::string & GetStrError() const { return errorStr; }
+ bool IsInetable() override;
+ std::string GetEnabledDirs() const override;
+
+ void OnAdd() override;
+ void OnDelete() override;
+
+ virtual std::string GetParamValue(const std::string & name) const override;
- USER_PROPERTIES & GetProperty() { return property; }
- const USER_PROPERTIES & GetProperty() const { return property; }
+ private:
+ UserImpl & operator=(const UserImpl & rvalue);
- void SetDeleted() { deleted = true; }
- bool GetDeleted() const { return deleted; }
+ void Init();
- time_t GetLastWriteStatTime() const { return lastWriteStat; }
+ const Users* users;
+ UserProperties properties;
+ STG::Logger& WriteServLog;
- void MidnightResetSessionStat();
- void ProcessDayFee();
- void ProcessDayFeeSpread();
- void ProcessNewMonth();
- void ProcessDailyFee();
- void ProcessServices();
+ void Connect(bool fakeConnect = false);
+ void Disconnect(bool fakeDisconnect, const std::string & reason);
+ int SaveMonthStat(int month, int year);
- bool IsInetable();
- std::string GetEnabledDirs() const;
+ void SetPrepaidTraff();
- void OnAdd();
- void OnDelete();
+ int SendMessage(Message & msg) const;
+ void ScanMessage();
- virtual std::string GetParamValue(const std::string & name) const;
+ time_t lastScanMessages;
-private:
- USER_IMPL & operator=(const USER_IMPL & rvalue);
+ std::string login;
+ int id;
- void Init();
+ bool enabledDirs[DIR_NUM];
- const USERS * users;
- USER_PROPERTIES property;
- STG_LOGGER & WriteServLog;
+ uint32_t lastIPForDisconnect; // User's ip after unauth but before disconnect
+ std::string lastDisconnectReason;
- void Connect(bool fakeConnect = false);
- void Disconnect(bool fakeDisconnect, const std::string & reason);
- int SaveMonthStat(int month, int year);
+ time_t pingTime;
- void SetPrepaidTraff();
+ const Admin * sysAdmin;
+ const Store * store;
- int SendMessage(STG_MSG & msg) const;
- void ScanMessage();
+ const Tariffs * tariffs;
+ const Tariff * tariff;
- time_t lastScanMessages;
+ const Services & m_services;
- std::string login;
- int id;
- bool __connected;
- USER_PROPERTY<bool> connected;
+ TraffStat traffStat;
+ std::pair<time_t, TraffStat> traffStatSaved;
- bool enabledDirs[DIR_NUM];
+ const Settings * settings;
- USER_ID_GENERATOR userIDGenerator;
+ std::set<const Auth *> authorizedBy;
+ time_t authorizedModificationTime;
- uint32_t __currIP; // Current user's ip
- USER_PROPERTY<uint32_t> currIP;
+ std::vector<Message> messages;
- uint32_t lastIPForDisconnect; // User's ip after unauth but before disconnect
- std::string lastDisconnectReason;
+ bool deleted;
- time_t pingTime;
+ time_t lastWriteStat;
+ time_t lastWriteDetailedStat;
- const ADMIN * sysAdmin;
- const STORE * store;
+ // Properties
+ UserProperty<double> & cash;
+ UserProperty<DirTraff> & up;
+ UserProperty<DirTraff> & down;
+ UserProperty<double> & lastCashAdd;
+ UserProperty<time_t> & passiveTime;
+ UserProperty<time_t> & lastCashAddTime;
+ UserProperty<double> & freeMb;
+ UserProperty<time_t> & lastActivityTime;
+ UserProperty<std::string> & password;
+ UserProperty<int> & passive;
+ UserProperty<int> & disabled;
+ UserProperty<int> & disabledDetailStat;
+ UserProperty<int> & alwaysOnline;
+ UserProperty<std::string> & tariffName;
+ UserProperty<std::string> & nextTariff;
+ UserProperty<std::string> & address;
+ UserProperty<std::string> & note;
+ UserProperty<std::string> & group;
+ UserProperty<std::string> & email;
+ UserProperty<std::string> & phone;
+ UserProperty<std::string> & realName;
+ UserProperty<double> & credit;
+ UserProperty<time_t> & creditExpire;
+ UserProperty<UserIPs> & ips;
+ UserProperty<std::string> & userdata0;
+ UserProperty<std::string> & userdata1;
+ UserProperty<std::string> & userdata2;
+ UserProperty<std::string> & userdata3;
+ UserProperty<std::string> & userdata4;
+ UserProperty<std::string> & userdata5;
+ UserProperty<std::string> & userdata6;
+ UserProperty<std::string> & userdata7;
+ UserProperty<std::string> & userdata8;
+ UserProperty<std::string> & userdata9;
- const TARIFFS * tariffs;
- const TARIFF * tariff;
+ // End properties
- const SERVICES & m_services;
+ DirTraff sessionUpload;
+ DirTraff sessionDownload;
+ time_t sessionUploadModTime;
+ time_t sessionDownloadModTime;
- TRAFF_STAT traffStat;
- std::pair<time_t, TRAFF_STAT> traffStatSaved;
+ ScopedConnection m_beforePassiveConn;
+ void onPassiveChange(int oldVal, int newVal);
-#ifdef USE_ABSTRACT_SETTINGS
- const SETTINGS * settings;
-#else
- const SETTINGS_IMPL * settings;
-#endif
+ ScopedConnection m_afterDisabledConn;
+ void onDisabledChange(int oldVal, int newVal);
- std::set<const AUTH *> authorizedBy;
- time_t authorizedModificationTime;
-
- std::list<STG_MSG> messages;
-
- bool deleted;
-
- time_t lastWriteStat;
- time_t lastWriteDetailedStat;
-
- // Properties
- USER_PROPERTY<double> & cash;
- USER_PROPERTY<DIR_TRAFF> & up;
- USER_PROPERTY<DIR_TRAFF> & down;
- USER_PROPERTY<double> & lastCashAdd;
- USER_PROPERTY<time_t> & passiveTime;
- USER_PROPERTY<time_t> & lastCashAddTime;
- USER_PROPERTY<double> & freeMb;
- USER_PROPERTY<time_t> & lastActivityTime;
- USER_PROPERTY<std::string> & password;
- USER_PROPERTY<int> & passive;
- USER_PROPERTY<int> & disabled;
- USER_PROPERTY<int> & disabledDetailStat;
- USER_PROPERTY<int> & alwaysOnline;
- USER_PROPERTY<std::string> & tariffName;
- USER_PROPERTY<std::string> & nextTariff;
- USER_PROPERTY<std::string> & address;
- USER_PROPERTY<std::string> & note;
- USER_PROPERTY<std::string> & group;
- USER_PROPERTY<std::string> & email;
- USER_PROPERTY<std::string> & phone;
- USER_PROPERTY<std::string> & realName;
- USER_PROPERTY<double> & credit;
- USER_PROPERTY<time_t> & creditExpire;
- USER_PROPERTY<USER_IPS> & ips;
- USER_PROPERTY<std::string> & userdata0;
- USER_PROPERTY<std::string> & userdata1;
- USER_PROPERTY<std::string> & userdata2;
- USER_PROPERTY<std::string> & userdata3;
- USER_PROPERTY<std::string> & userdata4;
- USER_PROPERTY<std::string> & userdata5;
- USER_PROPERTY<std::string> & userdata6;
- USER_PROPERTY<std::string> & userdata7;
- USER_PROPERTY<std::string> & userdata8;
- USER_PROPERTY<std::string> & userdata9;
-
- // End properties
-
- DIR_TRAFF sessionUpload;
- DIR_TRAFF sessionDownload;
- time_t sessionUploadModTime;
- time_t sessionDownloadModTime;
-
- CHG_PASSIVE_NOTIFIER passiveNotifier;
- CHG_DISABLED_NOTIFIER disabledNotifier;
- CHG_TARIFF_NOTIFIER tariffNotifier;
- CHG_CASH_NOTIFIER cashNotifier;
- CHG_IPS_NOTIFIER ipNotifier;
-
- mutable pthread_mutex_t mutex;
-
- std::string errorStr;
+ ScopedConnection m_beforeTariffConn;
+ void onTariffChange(const std::string& oldVal, const std::string& newVal);
+
+ ScopedConnection m_beforeCashConn;
+ void onCashChange(double oldVal, double newVal);
+
+ ScopedConnection m_afterIPConn;
+ void onIPChange(const UserIPs& oldVal, const UserIPs& newVal);
+
+ mutable std::mutex m_mutex;
+
+ std::string errorStr;
+
+ double getPassiveTimePart() const;
};
//-----------------------------------------------------------------------------
-typedef USER_IMPL * USER_IMPL_PTR;
-
-#endif //USER_H
+}
git.stg.codes / stg.git / blobdiff