bsc::ui::UIClient Class Reference

#include <UIClient.hpp>

Classes
class	Impl

Public Member Functions
	UIClient (std::string socket_uri)
	~UIClient ()
	UIClient (const UIClient &)=delete
UIClient &	operator= (const UIClient &)=delete
void	start ()
void	stop ()
bool	is_connected () const noexcept
std::optional< bsc::rule::Rule >	ask_rule (const bsc::model::Connection &conn)
bool	ping (const bsc::stats::Statistics &stats)
bool	post_alert (const std::string &text)
bool	post_connection_alert (const bsc::model::Connection &conn, const std::string &action, const std::string &rule_name={})
void	set_notification_handler (std::function< void(const NotificationEvent &)> cb)

Private Attributes
std::unique_ptr< Impl >	impl_

Detailed Description

Client Unix-socket verso il server della UI. Sostituisce la precedente implementazione gRPC. Gestisce:

• thread di lettura frame che smista pong / notification / ask_rule_reply
• scrittore serializzato via mutex
• reconnector che riprova finche' il socket non e' disponibile

Definition at line 35 of file UIClient.hpp.

Constructor & Destructor Documentation

UIClient() [1/2]

bsc::ui::UIClient::UIClient ( std::string socket_uri )

explicit

Definition at line 372 of file UIClient.cpp.

    : impl_(std::make_unique<Impl>(std::move(socket_uri))) {}

References impl_.

Referenced by operator=(), and UIClient().

~UIClient()

bsc::ui::UIClient::~UIClient ( )

default

UIClient() [2/2]

bsc::ui::UIClient::UIClient ( const UIClient & )

delete

References UIClient().

Member Function Documentation

ask_rule()

std::optional< bsc::rule::Rule > bsc::ui::UIClient::ask_rule

(

const bsc::model::Connection &

conn

)

Definition at line 389 of file UIClient.cpp.

                                                                          {
    if (!impl_->is_connected()) return std::nullopt;
 
    const auto id = impl_->next_id_++;
    auto pending = std::make_shared<Impl::PendingAsk>();
    {
        std::lock_guard<std::mutex> lk(impl_->pending_mutex_);
        impl_->pending_asks_[id] = pending;
    }
 
    // Costruisci la richiesta
    json j = {
        {"type", bsc::proto::msg::kAskRule},
        {"id",   id}
    };
    json cj;
    connection_to_json(conn, cj);
    j["connection"] = cj;
 
    if (!impl_->write_frame(j.dump())) {
        std::lock_guard<std::mutex> lk(impl_->pending_mutex_);
        impl_->pending_asks_.erase(id);
        return std::nullopt;
    }
 
    // Aspetta la risposta con timeout 30s (il popup ha countdown 15s,
    // 30 da margine per il jitter).
    std::unique_lock<std::mutex> lk(pending->mu);
    const bool ok = pending->cv.wait_for(lk, std::chrono::seconds(30),
                                         [&]() { return pending->ready; });
 
    {
        std::lock_guard<std::mutex> lk2(impl_->pending_mutex_);
        impl_->pending_asks_.erase(id);
    }
 
    if (!ok) return std::nullopt;  // timeout
 
    // Estrai la rule dalla risposta
    bsc::rule::Rule r;
    r.action   = pending->reply.value("action",   std::string{"deny"});
    r.duration = pending->reply.value("duration", std::string{"once"});
    r.name     = pending->reply.value("rule_name", std::string{});
    r.enabled  = true;
    return r;
}

References impl_, and bsc::proto::msg::kAskRule.

Referenced by operator=().

is_connected()

bool bsc::ui::UIClient::is_connected ( ) const

noexcept

Definition at line 380 of file UIClient.cpp.

                                           {
    return impl_->is_connected();
}

References impl_.

Referenced by operator=().

operator=()

UIClient & bsc::ui::UIClient::operator= ( const UIClient & )

delete

References ask_rule(), is_connected(), ping(), post_alert(), post_connection_alert(), start(), stop(), and UIClient().

ping()

bool bsc::ui::UIClient::ping

(

const bsc::stats::Statistics &

stats

)

Definition at line 436 of file UIClient.cpp.

                                                   {
    if (!impl_->is_connected()) return false;
    json j = {
        {"type", bsc::proto::msg::kPing},
        {"id",   impl_->next_id_++},
        {"stats", {
            {"daemon_version", "bsc-daemon-cpp"},
            {"rules",         stats.rules()},
            {"connections",   stats.connections()},
            {"dns_responses", stats.dns_responses()},
            {"ignored",       stats.ignored()},
            {"accepted",      stats.accepted()},
            {"dropped",       stats.dropped()},
            {"rule_hits",     stats.rule_hits()},
            {"rule_misses",   stats.rule_misses()},
        }}
    };
    return impl_->write_frame(j.dump());
}

References impl_, and bsc::proto::msg::kPing.

Referenced by operator=().

post_alert()

bool bsc::ui::UIClient::post_alert

(

const std::string &

text

)

Definition at line 456 of file UIClient.cpp.

                                               {
    json j = {
        {"type", bsc::proto::msg::kAlert},
        {"id",   impl_->next_id_++},
        {"level", "info"},
        {"what",  "generic"},
        {"text",  text}
    };
    return impl_->send_or_queue_alert(j);
}

References impl_, and bsc::proto::msg::kAlert.

Referenced by operator=(), and bsc::service::DaemonService::run().

post_connection_alert()

bool bsc::ui::UIClient::post_connection_alert	(	const bsc::model::Connection &	conn,
		const std::string &	action,
		const std::string &	rule_name = {} )

Definition at line 467 of file UIClient.cpp.

                                                                 {
    json j = {
        {"type", bsc::proto::msg::kAlert},
        {"id",   impl_->next_id_++},
        {"level", action == "deny" ? "warning" : "info"},
        {"what",  "connection"},
    };
    json cj;
    connection_to_json(conn, cj);
    j["connection"] = cj;
    if (!rule_name.empty()) {
        j["rule"] = {{"name", rule_name}, {"action", action}};
    }
    return impl_->send_or_queue_alert(j);
}

References impl_, and bsc::proto::msg::kAlert.

Referenced by operator=().

set_notification_handler()

void bsc::ui::UIClient::set_notification_handler

(

std::function< void(const NotificationEvent &)>

cb

)

Definition at line 384 of file UIClient.cpp.

                                                                                      {
    std::lock_guard<std::mutex> lk(impl_->handler_mutex_);
    impl_->notif_handler_ = std::move(cb);
}

References impl_.

Referenced by bsc::service::DaemonService::run().

start()

void bsc::ui::UIClient::start

(

)

Definition at line 377 of file UIClient.cpp.

{ impl_->start(); }

References impl_.

Referenced by operator=(), and bsc::service::DaemonService::run().

stop()

void bsc::ui::UIClient::stop

(

)

Definition at line 378 of file UIClient.cpp.

{ impl_->stop(); }

References impl_.

Referenced by operator=().

Member Data Documentation

impl_

std::unique_ptr<Impl> bsc::ui::UIClient::impl_

private

Definition at line 58 of file UIClient.hpp.

Referenced by ask_rule(), is_connected(), ping(), post_alert(), post_connection_alert(), set_notification_handler(), start(), stop(), and UIClient().

---

The documentation for this class was generated from the following files:

• BastionGuard/thirdparty/bastionguard-secure-connection/daemon/include/bsc/ui/UIClient.hpp
• BastionGuard/thirdparty/bastionguard-secure-connection/daemon/src/ui/UIClient.cpp