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