keyvalue/Service.h

Go to the documentation of this file.

#pragma once

#include <swarmio/Mailbox.h>
#include <swarmio/services/ErrorAwaiter.h>
#include <swarmio/services/keyvalue/Target.h>
#include <swarmio/services/keyvalue/ValueAwaiter.h>
#include <swarmio/services/discovery/Discoverable.h>
#include <string>
#include <memory>
#include <mutex>
#include <map>

namespace swarmio::services::keyvalue 
{
    class SWARMIO_API Service final : public Mailbox, public discovery::Discoverable
    {
        private:

            std::map<std::string, Target*> _targets;

            std::mutex _mutex;

            bool HandleGetRequest(const Node* sender, const data::Message* message);

            bool HandleSetRequest(const Node* sender, const data::Message* message);

        public:

            static ValueAwaiter Get(Endpoint* endpoint, const Node* node, const std::string& path);

            static ErrorAwaiter Set(Endpoint* endpoint, const Node* node, const std::string& path, const data::Variant& value);

            Service(Endpoint* endpoint)
                : Mailbox(endpoint)
            { 
                FinishConstruction();
            }

            virtual bool ReceiveMessage(const Node* sender, const data::Message* message) override;

            void RegisterTarget(const std::string& path, Target* target);

            void UnregisterTarget(const std::string& path);

            virtual void DescribeService(data::discovery::Response& descriptor) override;
    };
}