Radiusю (#12)

[stg.git] / projects / stargazer / plugins / other / radius / radius.h

diff --git a/projects/stargazer/plugins/other/radius/radius.h b/projects/stargazer/plugins/other/radius/radius.h
index 8eedace11e83cdb822674b4564b9416f920b1c1f..80e032a8c90b09c5a64715729744ec2ceb310c51 100644 (file)
--- a/projects/stargazer/plugins/other/radius/radius.h
+++ b/projects/stargazer/plugins/other/radius/radius.h
@@ -5,8 +5,11 @@
 #include "stg/module_settings.h"
 #include "stg/subscriptions.h"
 #include "stg/logger.h"
 #include "stg/module_settings.h"
 #include "stg/subscriptions.h"
 #include "stg/logger.h"

+#include "server.h"

 
 

+#include <boost/asio.hpp>

 #include <string>
 #include <string>

+#include <memory>

 #include <mutex>
 #include <jthread.hpp>
 #include <cstdint> //uint8_t, uint32_t
 #include <mutex>
 #include <jthread.hpp>
 #include <cstdint> //uint8_t, uint32_t


@@ -15,23 +18,54 @@ namespace STG
 {
     struct Settings;
 
 {
     struct Settings;
 

+    class Users;
+

     class RAD_SETTINGS
     {
         public:
             RAD_SETTINGS();
             virtual ~RAD_SETTINGS() {}
     class RAD_SETTINGS
     {
         public:
             RAD_SETTINGS();
             virtual ~RAD_SETTINGS() {}

-            const std::string & GetStrError() const { return m_errorStr; }
-            int ParseSettings(const ModuleSettings & s);
+
+            struct AttrValue
+            {
+                enum class Type
+                {
+                    PARAM_NAME,
+                    VALUE
+                };
+                std::string value;
+                Type type;
+            };
+
+            struct ASection
+            {
+                using Pairs = std::vector<std::pair<std::string, AttrValue>>;
+                Pairs match;
+                Pairs send;
+            };
+
+            const std::string& GetStrError() const { return m_errorStr; }
+            int ParseSettings(const ModuleSettings& s);

 
             uint16_t GetPort() const { return m_port; }
 
             uint16_t GetPort() const { return m_port; }

-            const std::string & GetDictionaries() const { return m_dictionaries; }
-            const std::string & GetSecret() const { return m_secret; }
+            const std::string& GetDictionaries() const { return m_dictionaries; }
+            const std::string& GetSecret() const { return m_secret; }
+            const ASection& getAuth() const { return m_auth; }
+            const ASection& getAutz() const { return m_autz; }

 
         private:
 
         private:

+            std::vector<std::pair<std::string, AttrValue>> ParseRules(const std::string& value, const std::string& paramName);
+            ASection parseASection(const std::vector<ParamValue>& conf);
+

             std::string m_errorStr;
             uint16_t m_port;
             std::string m_dictionaries;
             std::string m_secret;
             std::string m_errorStr;
             uint16_t m_port;
             std::string m_dictionaries;
             std::string m_secret;

+
+            ASection m_auth;
+            ASection m_autz;
+
+            PluginLogger m_logger;

     };
 
     class RADIUS : public Auth
     };
 
     class RADIUS : public Auth


@@ -41,26 +75,28 @@ namespace STG
             RADIUS(const RADIUS&) = delete;
             RADIUS& operator=(const RADIUS&) = delete;
 
             RADIUS(const RADIUS&) = delete;
             RADIUS& operator=(const RADIUS&) = delete;
 

-            void SetSettings(const ModuleSettings & s) override { m_settings = s; }
+            void SetUsers(Users* u) override { m_users = u; }
+            void SetSettings(const ModuleSettings& s) override { m_settings = s; }

             int ParseSettings() override;
 
             int Start() override;
             int Stop() override;
             int ParseSettings() override;
 
             int Start() override;
             int Stop() override;

-            int Reload(const ModuleSettings & /*ms*/) override { return 0; }
+            int Reload(const ModuleSettings& /*ms*/) override { return 0; }

             bool IsRunning() override;
             void SetRunning(bool val);
 
             bool IsRunning() override;
             void SetRunning(bool val);
 

-            const std::string & GetStrError() const override { return m_errorStr; }
+            const std::string& GetStrError() const override { return m_errorStr; }

             std::string GetVersion() const override;
 
             uint16_t GetStartPosition() const override { return 0; }
             uint16_t GetStopPosition() const override { return 0; }
 
             std::string GetVersion() const override;
 
             uint16_t GetStartPosition() const override { return 0; }
             uint16_t GetStopPosition() const override { return 0; }
 

-            int SendMessage(const Message & msg, uint32_t ip) const override { return 0; }
+            int SendMessage(const Message& /*msg*/, uint32_t /*ip*/) const override { return 0; }

 
         private:
             std::mutex m_mutex;
 
 
         private:
             std::mutex m_mutex;
 

+            boost::asio::io_context m_ioContext;

             int Run(std::stop_token token);
 
             mutable std::string m_errorStr;
             int Run(std::stop_token token);
 
             mutable std::string m_errorStr;


@@ -70,7 +106,9 @@ namespace STG
             bool m_running;
 
             std::jthread m_thread;
             bool m_running;
 
             std::jthread m_thread;

-
+            Users* m_users;

             PluginLogger m_logger;
             PluginLogger m_logger;

+
+            std::unique_ptr<Server> m_server;

     };
 }
     };
 }