UniSetUno.h

/*
 * Copyright (c) 2026 Pavel Vainerman.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, version 2.1.
 */
// -------------------------------------------------------------------------
#ifndef UniSetUno_H_
#define UniSetUno_H_
// -------------------------------------------------------------------------
#include <memory>
#include <string>
#include <vector>
#include <unordered_map>
#include "UniSetTypes.h"
#include "UniSetObject.h"
#include "SharedMemory.h"
#include "UniXML.h"
#include "Debug.h"
// -------------------------------------------------------------------------
namespace uniset
{
    class UniSetUno
    {
        public:
            UniSetUno();
            ~UniSetUno();
 
            bool init(int argc, const char* const* argv, const std::string& appName = "");
 
            void run();
 
            void stop();
 
            std::shared_ptr<SharedMemory> getSharedMemory() const;
 
            std::shared_ptr<UniSetObject> getExtension(const std::string& name) const;
 
            std::vector<std::string> getExtensionNames() const;
 
            bool isRunning() const;
 
            std::shared_ptr<DebugStream> log();
 
            static void help_print(int argc, const char* const* argv, const std::string& extName = "");
 
            static bool help_extension(int argc, const char* const* argv, const std::string& extType);
 
            static std::vector<std::string> parseArgsString(const std::string& argsStr);
 
            static std::vector<std::string> collectExtensionArgs(
                const std::shared_ptr<UniXML>& xml,
                const std::string& appName);
 
            // Supported extension types
            static constexpr const char* EXT_SHARED_MEMORY = "SharedMemory";
            static constexpr const char* EXT_UNET_EXCHANGE = "UNetExchange";
            static constexpr const char* EXT_MBTCP_MASTER = "MBTCPMaster";
            static constexpr const char* EXT_MBTCP_MULTIMASTER = "MBTCPMultiMaster";
            static constexpr const char* EXT_MB_SLAVE = "MBSlave";
            static constexpr const char* EXT_RTU_EXCHANGE = "RTUExchange";
            static constexpr const char* EXT_OPCUA_SERVER = "OPCUAServer";
            static constexpr const char* EXT_OPCUA_EXCHANGE = "OPCUAExchange";
            static constexpr const char* EXT_IO_CONTROL = "IOControl";
            static constexpr const char* EXT_LOGIC_PROCESSOR = "LogicProcessor";
            static constexpr const char* EXT_MQTT_PUBLISHER = "MQTTPublisher";
            static constexpr const char* EXT_WEBSOCKET_GATE = "UWebSocketGate";
            static constexpr const char* EXT_BACKEND_CLICKHOUSE = "BackendClickHouse";
            static constexpr const char* EXT_DBSERVER_POSTGRESQL = "DBServerPostgreSQL";
 
        private:
            struct ExtensionInfo
            {
                std::string type;
                std::string name;
                std::string prefix;
                std::string args;  
                std::shared_ptr<UniSetObject> object;
            };
 
            bool loadConfig(const std::string& appName);
            bool validateExtensions();
            static std::string getDefaultPrefix(const std::string& type);
            bool createExtensions(int argc, const char* const* argv);
 
            std::shared_ptr<UniSetObject> createExtension(
                int argc, const char* const* argv,
                const ExtensionInfo& info);
 
            std::shared_ptr<DebugStream> applog;
            std::shared_ptr<SharedMemory> shm_;
            std::vector<ExtensionInfo> extensions_;
            std::unordered_map<std::string, std::shared_ptr<UniSetObject>> extByName_;
 
            bool running_ = false;
            std::string logfile_;
    };
 
} // end of namespace uniset
// -------------------------------------------------------------------------
#endif // UniSetUno_H_
// -------------------------------------------------------------------------