EventPublish.cpp

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/>.
*/

#include "EventPublish.h"
#include <core/auth/Auth.hpp>

using namespace Leosac::Module::EventPublish;

EventPublish::EventPublish(zmqpp::context &ctx, zmqpp::socket *pipe,
                           const boost::property_tree::ptree &cfg,
                           CoreUtilsPtr utils)
    : BaseModule(ctx, pipe, cfg, utils)
    , bus_sub_(ctx, zmqpp::socket_type::sub)
    , network_pub_(ctx, zmqpp::socket_type::pub)
{
    bus_sub_.connect("inproc://zmq-bus-pub");
    process_config();
    reactor_.add(bus_sub_, std::bind(&EventPublish::handle_msg_bus, this));
}

void EventPublish::handle_msg_bus()
{
    zmqpp::message msg;
    std::string src;
    Leosac::Auth::SourceType type;
    std::string card;
    int bits;

    bus_sub_.receive(msg);

    if (msg.parts() < 4)
        return;
    msg >> src >> type >> card >> bits;
    INFO("Will publish card id {" << card << "}");

    if (type != Leosac::Auth::SourceType::SIMPLE_WIEGAND)
    {
        INFO("EventPublish cannot handle this type of credential yet.");
        return;
    }

    // Hack Alert! Hack Alert!
    // For this use case, we read 35bits wiegand frame CP1000 encoded.
    // We want to extract the identifier: the 20 second-to-last bits (14 first bit
    // ignored).
    // In case this is not a 35 bits tram, do nothing
    if (bits == 35)
    {
        std::stringstream ss;
        ss << std::hex << "0x";
        for (auto c : card)
        {
            if (c == ':')
                continue;
            ss << std::hex << c;
        }
        INFO("Bla: {" << ss.str() << "}");
        // n has 40 "meaningful" bits because the hex string was 5 bytes.
        uint64_t n;
        ss >> n;
        INFO(" n = " << n);
        n = (n >> 6); // remove last 6bits. parity bit + 5bits;
        n &= 0xFFFFF; // keep 20 bits.
        INFO(" n2 = " << n);
        std::stringstream ss2;
        ss2 << n;
        ss2 >> card;
    }
    else
        return;

    if (publish_source_)
        network_pub_.send(zmqpp::message() << card << src);
    else
        network_pub_.send(card);
}

void EventPublish::process_config()
{
    auto port = config_.get<int>("module_config.port");
    network_pub_.bind("tcp://*:" + std::to_string(port));
    publish_source_ = config_.get<bool>("module_config.publish_source", false);

    for (auto &&itr : config_.get_child("module_config.sources"))
    {
        auto name = itr.second.get<std::string>("");
        bus_sub_.subscribe("S_" + name);
    }
}