NotifierInstance.hpp

Go to the documentation of this file.

/*
    Copyright (C) 2014-2016 Leosac
 
    This file is part of Leosac.
 
    Leosac is free software: you can redistribute it and/or modify
    it under the terms of the GNU Affero General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.
 
    Leosac is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
    GNU Affero General Public License for more details.
 
    You should have received a copy of the GNU Affero General Public License
    along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
 
#pragma once
 
#include "LeosacFwd.hpp"
#include "ProtocolHandler.hpp"
#include "core/auth/AuthFwd.hpp"
#include "core/credentials/CredentialFwd.hpp"
#include <zmqpp/reactor.hpp>
#include <zmqpp/socket.hpp>
 
namespace Leosac
{
namespace Module
{
namespace TCPNotifier
{
class NotifierInstance;
using NotifierInstanceUPtr = std::unique_ptr<NotifierInstance>;
 
class NotifierInstance
{
  public:
    NotifierInstance(zmqpp::context &ctx, zmqpp::reactor &reactor,
                     std::vector<std::string> auth_sources,
                     std::vector<std::string> connect_to,
                     std::vector<std::string> bind_to,
                     ProtocolHandlerUPtr protocol_handler);
 
    ~NotifierInstance() = default;
 
    NotifierInstance(const NotifierInstance &) = delete;
    NotifierInstance &operator=(const NotifierInstance &) = delete;
    NotifierInstance(NotifierInstance &&o)                = delete;
    NotifierInstance &operator=(NotifierInstance &&o) = delete;
 
  private:
    void handle_credential(Cred::RFIDCard &card);
 
    void handle_one(zmqpp::message &msg);
 
    void handle_msg_bus();
 
    void handle_tcp_msg();
 
    void configure_tcp_socket(const std::vector<std::string> &endpoints);
 
    struct TargetInfo
    {
        TargetInfo()
            : status_(false)
        {
        }
        TargetInfo(const TargetInfo &) = default;
        TargetInfo(TargetInfo &&o)     = default;
        TargetInfo &operator=(const TargetInfo &o) = default;
        TargetInfo &operator=(TargetInfo &&o) = default;
 
        // Url is IP:PORT
        // Maybe be empty is peer is connecting to us.
        std::string url_;
 
        // The ZMQ routing-id for this target.
        std::string zmq_identity_;
 
        // ZMQ provide auto reconnection
        // This tracks the status.
        bool status_;
    };
 
    zmqpp::socket bus_sub_;
 
    zmqpp::socket tcp_;
 
    std::list<TargetInfo> targets_;
 
    ProtocolHandlerUPtr protocol_;
 
    bool act_as_server_;
 
    TargetInfo *find_target(const std::string &routing_id);
};
}
}
}