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);
};
}
}
}