event/Service.h

Go to the documentation of this file.

#pragma once

#include <swarmio/Mailbox.h>
#include <swarmio/services/ErrorAwaiter.h>
#include <swarmio/services/event/Handler.h>
#include <swarmio/services/discovery/Discoverable.h>
#include <string>
#include <memory>
#include <map>

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

            std::map<std::string, Handler*> _handlers;

            std::mutex _mutex;

        public:

            static void Trigger(Endpoint* endpoint, const data::event::Notification& event);

            static ErrorAwaiter Trigger(Endpoint* endpoint, const data::event::Notification& event, const Node* node);

            Service(Endpoint* endpoint)
                : Mailbox(endpoint)
            { 
                FinishConstruction();
            }
            
            virtual bool ReceiveMessage(const Node* sender, const data::Message* message) override;

            void RegisterHandler(const std::string& name, Handler* handler);

            void UnregisterHandler(const std::string& name);

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