Volt/dev.kingssack.volt.ai/AIServer

AIServer

class AIServer(port: Int = 8081) : NanoWSD

WebSocket server for AI client communication.

Provides a WebSocket interface for AI agents to execute robot actions and receive state updates. Supports request-response correlation via request IDs and provides heartbeat functionality for connection health monitoring.

Parameters

port

the port to listen on (default: 8081)

Constructors

AIServer

constructor(port: Int = 8081)

Types

ActionResult

data class ActionResult(val success: Boolean, val message: String, val data: Map<String, Any?>? = null, val actionId: String? = null)

Result of an action execution.

AIWebSocket

inner class AIWebSocket(handshake: NanoHTTPD.IHTTPSession?) : NanoWSD.WebSocket

Companion

object Companion

Properties

hostname

open val hostname: String?

isAlive

val isAlive: Boolean

listeningPort

val listeningPort: Int

serverSocketFactory

open var serverSocketFactory: NanoHTTPD.ServerSocketFactory?

tempFileManagerFactory

open var tempFileManagerFactory: NanoHTTPD.TempFileManagerFactory?

Functions

broadcastActionComplete

fun broadcastActionComplete(actionId: String, requestId: String?, success: Boolean, message: String, data: Map<String, Any?>? = null)

Broadcasts an action completion notification to the connected client.

broadcastState

fun broadcastState(state: Map<String, Any>)

Broadcasts the current robot state to the connected client.

closeAllConnections

open fun closeAllConnections()

hasActiveConnection

fun hasActiveConnection(): Boolean

Returns whether there is an active, healthy client connection.

makeSecure

open fun makeSecure(sslServerSocketFactory: SSLServerSocketFactory?, sslProtocols: Array<out String?>?)

sendPing

fun sendPing()

Sends a ping to the active client to check connection health.

serve

open fun serve(session: NanoHTTPD.IHTTPSession?): NanoHTTPD.Response?

open fun ~~serve~~(uri: String?, method: NanoHTTPD.Method?, headers: Map<String?, String?>?, parms: Map<String?, String?>?, files: Map<String?, String?>?): NanoHTTPD.Response?

setActionCallback

fun setActionCallback(callback: (String, Map<String, Any?>, String?) -> AIServer.ActionResult)

Sets the callback for handling action execution requests.

setAsyncRunner

open fun setAsyncRunner(asyncRunner: NanoHTTPD.AsyncRunner?)

setStateProvider

fun setStateProvider(provider: () -> Map<String, Any>)

Sets the provider for robot state data.

start

open fun start()

open fun start(timeout: Int)

open fun start(timeout: Int, daemon: Boolean)

stop

open fun stop()

wasStarted

fun wasStarted(): Boolean