ClientManager Class Reference

Manages the lifecycle of the network client and IO context. More...

#include <ClientManager.hpp>

Inherits QObject.

Collaboration diagram for ClientManager:

Signals
void	connected ()
void	disconnected ()
void	reconnecting ()
void	reconnected ()
void	connectionError (const QString &message)
void	notificationReceived (const QString &eventType, const QDateTime &timestamp)
	Emitted when a notification is received from the server.

Public Member Functions
	ClientManager (std::shared_ptr< eventing::service::event_bus > event_bus, QObject *parent=nullptr)
LoginResult	connectAndLogin (const std::string &host, std::uint16_t port, const std::string &username, const std::string &password)
	Connect to the server and perform login.
void	disconnect ()
	Logout the current user and disconnect from the server.
bool	logout ()
	Logout the current user without disconnecting.
bool	isConnected () const
	Check if currently connected.
bool	isAdmin () const
	Check if the logged-in user has admin privileges.
const std::string &	currentUsername () const
	Get the current logged-in user's username.
const std::string &	currentEmail () const
	Get the current logged-in user's email.
void	setCurrentEmail (const std::string &email)
	Set the current logged-in user's email.
std::expected< comms::messaging::frame, comms::messaging::error_code >	sendRequest (comms::messaging::frame request)
	Send a request if connected.
std::shared_ptr< comms::net::client >	getClient () const
	Get the current client (internal use only).
boost::asio::any_io_executor	getExecutor ()
	Get the IO context executor.
void	subscribeToEvent (const std::string &eventType)
	Subscribe to server-push notifications for an event type.
void	unsubscribeFromEvent (const std::string &eventType)
	Unsubscribe from server-push notifications for an event type.
void	setSupportedCompression (std::uint8_t compression)
	Set the supported compression bitmask for client connections.

Detailed Description

Manages the lifecycle of the network client and IO context.

Maintains a persistent IO context/thread while allowing the client connection to be established and torn down repeatedly. Signals changes in connection state to allow UI components to update accordingly without closing.

Member Function Documentation

connectAndLogin()

LoginResult connectAndLogin	(	const std::string &	host,
		std::uint16_t	port,
		const std::string &	username,
		const std::string &	password
	)

Connect to the server and perform login.

Parameters

host	Server hostname
port	Server port
username	Login username
password	Login password

Returns

LoginResult containing success status, error message, and password_reset_required flag

disconnect()

void disconnect

(

)

Logout the current user and disconnect from the server.

Sends a logout request to mark the user as offline before disconnecting.

logout()

bool logout

(

)

Logout the current user without disconnecting.

Sends a logout request to the server to mark the user as offline.

Returns

true if logout was successful, false otherwise

isAdmin()

bool isAdmin

(

)

const

Check if the logged-in user has admin privileges.

Returns

true if user is an admin, false otherwise or if not logged in.

currentUsername()

const std::string & currentUsername

(

)

const

Get the current logged-in user's username.

Returns

Username string, or empty if not logged in.

currentEmail()

const std::string & currentEmail

(

)

const

Get the current logged-in user's email.

Returns

Email string, or empty if not logged in or not set.

setCurrentEmail()

void setCurrentEmail

(

const std::string &

email

)

Set the current logged-in user's email.

Used after successful email update to keep local state in sync.

sendRequest()

std::expected< comms::messaging::frame, comms::messaging::error_code > sendRequest

(

comms::messaging::frame

request

)

Send a request if connected.

Parameters

request

The request frame to send

Returns

Response frame or error code

subscribeToEvent()

void subscribeToEvent

(

const std::string &

eventType

)

Subscribe to server-push notifications for an event type.

This method is non-blocking - the subscription request is sent asynchronously and any errors are logged.

Parameters

eventType

The event type to subscribe to (e.g., "ores.risk.currency_changed_event")

Here is the caller graph for this function:

unsubscribeFromEvent()

void unsubscribeFromEvent

(

const std::string &

eventType

)

Unsubscribe from server-push notifications for an event type.

This method is non-blocking - the unsubscription request is sent asynchronously and any errors are logged.

Parameters

eventType

The event type to unsubscribe from

Here is the caller graph for this function:

setSupportedCompression()

void setSupportedCompression

(

std::uint8_t

compression

)

Set the supported compression bitmask for client connections.

Should be called before connectAndLogin(). The value is used when creating client_options for the handshake negotiation.

Parameters

compression

Bitmask of supported compression types (0 = disabled)

notificationReceived

void notificationReceived ( const QString &  eventType, const QDateTime &  timestamp  )

signal

Emitted when a notification is received from the server.

Parameters

eventType	The event type name (e.g., "ores.risk.currency_changed_event")
timestamp	When the event occurred

Here is the caller graph for this function: