AuthFileInstance.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 "FileAuthSourceMapper.hpp"
#include "LeosacFwd.hpp"
#include "core/auth/AuthFwd.hpp"
#include "core/tasks/Task.hpp"
#include <fstream>
#include <zmqpp/zmqpp.hpp>

namespace Leosac
{
namespace Module
{
namespace Auth
{

class AuthFileInstance;
using AuthFileInstancePtr = std::shared_ptr<AuthFileInstance>;

struct AuthResult
{
    AuthResult(bool s, ::Leosac::Auth::IAccessProfilePtr p,
               ::Leosac::Auth::UserPtr u)
        : success(s)
        , profile(p)
        , user(u)
    {
    }

    bool success;
    ::Leosac::Auth::IAccessProfilePtr profile;

    ::Leosac::Auth::UserPtr user;
};

class AuthFileInstance : public std::enable_shared_from_this<AuthFileInstance>
{
  public:
    AuthFileInstance(zmqpp::context &ctx, const std::string &auth_ctx_name,
                     const std::list<std::string> &auth_sources_names,
                     const std::string &auth_target_name,
                     const std::string &input_file, CoreUtilsPtr core_utils);

    ~AuthFileInstance();

    AuthFileInstance(const AuthFileInstance &) = delete;

    AuthFileInstance &operator=(const AuthFileInstance &) = delete;

    void handle_bus_msg();

    zmqpp::socket &bus_sub();

    const std::string &auth_file_name() const;

    std::string auth_file_content() const;

  private:
    bool handle_kernel_message(const zmqpp::message &msg);

    void reload_auth_config();

    AuthResult handle_auth(zmqpp::message *msg) noexcept;

    std::mutex mutex_;

    FileAuthSourceMapperPtr mapper_;

    zmqpp::socket bus_push_;

    zmqpp::socket bus_sub_;

    std::string name_;

    std::string target_name_;

    std::string file_path_;

    CoreUtilsPtr core_utils_;
};
}
}
}