WebSocket client for connecting to yaze-server. More...

#include <websocket_client.h>

Collaboration diagram for yaze::net::WebSocketClient:

Classes
class	Impl

Public Types
using	MessageCallback = std::function< void(const nlohmann::json &)>

using	ErrorCallback = std::function< void(const std::string &)>

using	StateCallback = std::function< void(ConnectionState)>

Public Member Functions
	WebSocketClient ()

	~WebSocketClient ()

absl::Status	Connect (const std::string &host, int port=8765)

void	Disconnect ()

absl::StatusOr< SessionInfo >	HostSession (const std::string &session_name, const std::string &username, const std::string &rom_hash, bool ai_enabled=true)

absl::StatusOr< SessionInfo >	JoinSession (const std::string &session_code, const std::string &username)

absl::Status	LeaveSession ()

absl::Status	SendChatMessage (const std::string &message, const std::string &sender)

absl::Status	SendRomSync (const std::string &diff_data, const std::string &rom_hash, const std::string &sender)

absl::Status	ShareSnapshot (const std::string &snapshot_data, const std::string &snapshot_type, const std::string &sender)

absl::Status	ShareProposal (const nlohmann::json &proposal_data, const std::string &sender)

absl::Status	VoteOnProposal (const std::string &proposal_id, bool approved, const std::string &username)

absl::Status	UpdateProposalStatus (const std::string &proposal_id, const std::string &status)

absl::Status	SendAIQuery (const std::string &query, const std::string &username)

void	OnMessage (const std::string &type, MessageCallback callback)

void	OnError (ErrorCallback callback)

void	OnStateChange (StateCallback callback)

ConnectionState	GetState () const

absl::StatusOr< SessionInfo >	GetSessionInfo () const

bool	IsConnected () const

bool	InSession () const

Private Member Functions
void	HandleMessage (const std::string &message)

void	HandleError (const std::string &error)

void	SetState (ConnectionState state)

absl::Status	SendRaw (const nlohmann::json &message)

Private Attributes
std::unique_ptr< Impl >	impl_

ConnectionState	state_

SessionInfo	current_session_

std::map< std::string, std::vector< MessageCallback > >	message_callbacks_

std::vector< ErrorCallback >	error_callbacks_

std::vector< StateCallback >	state_callbacks_

Detailed Description

WebSocket client for connecting to yaze-server.

Provides:

Connection management with auto-reconnect
Session hosting and joining
Message sending/receiving
Event callbacks for different message types

Definition at line 58 of file websocket_client.h.

Member Typedef Documentation

◆ MessageCallback

using yaze::net::WebSocketClient::MessageCallback = std::function<void(const nlohmann::json&)>

Definition at line 61 of file websocket_client.h.

◆ ErrorCallback

using yaze::net::WebSocketClient::ErrorCallback = std::function<void(const std::string&)>

Definition at line 62 of file websocket_client.h.

◆ StateCallback

using yaze::net::WebSocketClient::StateCallback = std::function<void(ConnectionState)>

Definition at line 63 of file websocket_client.h.

Constructor & Destructor Documentation

◆ WebSocketClient()

yaze::net::WebSocketClient::WebSocketClient ( )

Definition at line 176 of file websocket_client.cc.

◆ ~WebSocketClient()

yaze::net::WebSocketClient::~WebSocketClient ( )

Definition at line 181 of file websocket_client.cc.

References Disconnect().

Here is the call graph for this function:

Member Function Documentation

◆ Connect()

absl::Status yaze::net::WebSocketClient::Connect	(	const std::string &	host,
		int	port = `8765`
	)

Connect to yaze-server

Parameters

host	Server hostname/IP
port	Server port (default: 8765)

Definition at line 185 of file websocket_client.cc.

References impl_, yaze::net::kConnected, yaze::net::kError, and SetState().

Here is the call graph for this function:

◆ Disconnect()

void yaze::net::WebSocketClient::Disconnect ( )

Disconnect from server

Definition at line 197 of file websocket_client.cc.

References current_session_, impl_, yaze::net::kDisconnected, and SetState().

Referenced by ~WebSocketClient().

Here is the call graph for this function:

◆ HostSession()

absl::StatusOr< SessionInfo > yaze::net::WebSocketClient::HostSession	(	const std::string &	session_name,
		const std::string &	username,
		const std::string &	rom_hash,
		bool	ai_enabled = `true`
	)

Host a new collaboration session

Definition at line 203 of file websocket_client.cc.

References yaze::net::SessionInfo::ai_enabled, current_session_, yaze::net::SessionInfo::host, IsConnected(), yaze::net::SessionInfo::rom_hash, SendRaw(), and yaze::net::SessionInfo::session_name.

Here is the call graph for this function:

◆ JoinSession()

absl::StatusOr< SessionInfo > yaze::net::WebSocketClient::JoinSession	(	const std::string &	session_code,
		const std::string &	username
	)

Join an existing session

Definition at line 244 of file websocket_client.cc.

References current_session_, IsConnected(), SendRaw(), and yaze::net::SessionInfo::session_code.

Here is the call graph for this function:

◆ LeaveSession()

absl::Status yaze::net::WebSocketClient::LeaveSession ( )

Leave current session

Definition at line 277 of file websocket_client.cc.

References current_session_, InSession(), and SendRaw().

Here is the call graph for this function:

◆ SendChatMessage()

absl::Status yaze::net::WebSocketClient::SendChatMessage	(	const std::string &	message,
		const std::string &	sender
	)

Send chat message

Definition at line 296 of file websocket_client.cc.

References SendRaw().

Here is the call graph for this function:

◆ SendRomSync()

absl::Status yaze::net::WebSocketClient::SendRomSync	(	const std::string &	diff_data,
		const std::string &	rom_hash,
		const std::string &	sender
	)

Send ROM sync

Definition at line 315 of file websocket_client.cc.

References SendRaw().

Here is the call graph for this function:

◆ ShareSnapshot()

absl::Status yaze::net::WebSocketClient::ShareSnapshot	(	const std::string &	snapshot_data,
		const std::string &	snapshot_type,
		const std::string &	sender
	)