Loop.h

Go to the documentation of this file.

#pragma once

#include <string>
#include <mutex>
#include <replxx.hxx>
#include <swarmio/tool/Command.h>
#include <swarmio/tool/LogBuffer.h>
#include <swarmio/profiles/ClientProfile.h>
#include <swarmio/transport/zyre/ZyreEndpoint.h>
#include <swarmio/services/telemetry/UpdateAwaiter.h>
#include <swarmio/data/Variant.pb.h>

namespace swarmio::tool 
{
    class Loop final : private profiles::ClientProfile
    {
        private:

            replxx::Replxx _repl;

            const Node* _selectedNode = nullptr;

            LogBuffer* _logBuffer = nullptr;

            std::string GetPrompt();

            std::vector<const Node*> _nodes;

            std::list<services::telemetry::UpdateAwaiter> _subscriptions;

            std::mutex _mutex;

            virtual void NodeWasDiscovered(const Node* node) noexcept override;

            data::Variant ConvertToVariant(const std::string& value);

            bool ExecuteCommand(const std::string& command);

            void ExecuteMembersCommand(const Command& command);

            void ExecuteSelectCommand(const Command& command);

            void ExecutePingCommand(const Command& command);

            void ExecuteInfoCommand(const Command& command);

            void ExecuteEventCommand(const Command& command);

            void ExecuteSetCommand(const Command& command);

            void ExecuteGetCommand(const Command& command);

            void ExecuteRediscoverCommand(const Command& command);

            void ExecuteSubscriptionsCommand(const Command& command);

            void ExecuteSubscribeCommand(const Command& command);

            void ExecuteUnsubscribeCommand(const Command& command);

            void ExecuteLogCommand(const Command& command);

        public:

            Loop(Endpoint* endpoint, LogBuffer* logBuffer);

            void Run();
    };

}