reaktiv-devtools/io.github.syrou.reaktiv.devtools.server/ClientManager

ClientManager

class ClientManager(source)

Manages connected clients and their WebSocket sessions.

Constructors

constructor()

Functions

suspend fun assignRole(clientId: String, role: ClientRole, publisherClientId: String?)

Assigns a role to a client.

broadcastClientList

suspend fun broadcastClientList()

Broadcasts the current client list to all connected clients. Includes both real clients and ghost devices.

broadcastGhostEvent

suspend fun broadcastGhostEvent(ghostId: String, message: DevToolsMessage)

Broadcasts a ghost device's events to all listeners.

broadcastToListeners

suspend fun broadcastToListeners(publisherId: String, message: DevToolsMessage)

Broadcasts a message to all listeners of a publisher.

suspend fun getAllClients(): List<ClientInfo>

Gets all connected clients including ghost devices.

suspend fun getClient(clientId: String): ClientInfo?

Gets information about a specific client.

getCurrentPublisher

suspend fun getCurrentPublisher(): String?

Gets the current publisher ID.

suspend fun getGhostDevice(ghostId: String): GhostDevice?

Gets a ghost device by ID.

suspend fun isGhostDevice(clientId: String): Boolean

Checks if a client ID belongs to a ghost device.

suspend fun registerClient(session: WebSocketSession, registration: DevToolsMessage.ClientRegistration)

Registers a new client connection.

registerGhostDevice

suspend fun registerGhostDevice(registration: DevToolsMessage.GhostDeviceRegistration): String

Registers a ghost device from an imported session. Ghost devices can be played back and will broadcast events to listeners.

removeGhostDevice

suspend fun removeGhostDevice(ghostId: String)

Removes a ghost device.

sendToPublisher

suspend fun sendToPublisher(publisherId: String, message: DevToolsMessage)

Sends a message to the publisher client.

suspend fun setPublisher(clientId: String, reason: String)

Sets the current publisher. Only one publisher is allowed at a time. If the new publisher is a real device and there's a ghost publisher, the ghost is removed.

unregisterClient

suspend fun unregisterClient(clientId: String)

Unregisters a client and removes all subscriptions.