connector/com.midnight.kuira.core.connector/ConnectorWebSocketServer

ConnectorWebSocketServer

class ConnectorWebSocketServer(router: JsonRpcRouter, scope: CoroutineScope, port: Int = DEFAULT_PORT) : WebSocketServer

WebSocket server for the DApp Connector.

Listens on localhost:port for JSON-RPC 2.0 messages from dApps. Each incoming text message is routed through JsonRpcRouter, and the JSON-RPC response is sent back on the same connection.

Binds to 127.0.0.1 only — no remote connections accepted.

Parameters

router

Routes JSON-RPC messages to ConnectedAPIHandler methods

scope

Coroutine scope for launching suspend handler calls

port

TCP port to listen on (default: 9932, matches CLI's mn serve)

Constructors

ConnectorWebSocketServer

constructor(router: JsonRpcRouter, scope: CoroutineScope, port: Int = DEFAULT_PORT)

Types

Companion

object Companion

Properties

address

val address: InetSocketAddress

connections

val connections: MutableCollection<WebSocket>

daemon

var daemon: Boolean

maxPendingConnections

var maxPendingConnections: Int

receiveBufferSize

var receiveBufferSize: Int

reuseAddr

var reuseAddr: Boolean

tcpNoDelay

var tcpNoDelay: Boolean

Functions

broadcast

open fun broadcast(p0: ByteBuffer)

open fun broadcast(p0: ByteArray)

open fun broadcast(p0: String)

open fun broadcast(p0: ByteBuffer, p1: MutableCollection<WebSocket>)

open fun broadcast(p0: ByteArray, p1: MutableCollection<WebSocket>)

open fun broadcast(p0: String, p1: MutableCollection<WebSocket>)

createBuffer

open fun createBuffer(): ByteBuffer

getConnectionLostTimeout

open fun getConnectionLostTimeout(): Int

getDraft

open fun getDraft(): MutableList<Draft>

getLocalSocketAddress

open override fun getLocalSocketAddress(p0: WebSocket): InetSocketAddress

getPort

open fun getPort(): Int

getRemoteSocketAddress

open override fun getRemoteSocketAddress(p0: WebSocket): InetSocketAddress

getWebSocketFactory

fun getWebSocketFactory(): WebSocketFactory

onClose

open override fun onClose(conn: WebSocket, code: Int, reason: String, remote: Boolean)

onCloseInitiated

open fun onCloseInitiated(p0: WebSocket, p1: Int, p2: String)

onClosing

open fun onClosing(p0: WebSocket, p1: Int, p2: String, p3: Boolean)

onError

open override fun onError(conn: WebSocket?, ex: Exception)

onMessage

open override fun onMessage(conn: WebSocket, message: String)

open fun onMessage(p0: WebSocket, p1: ByteBuffer)

onOpen

open override fun onOpen(conn: WebSocket, handshake: ClientHandshake)

onPreparePing

open override fun onPreparePing(p0: WebSocket): PingFrame

onStart

open override fun onStart()

onWebsocketClose

override fun onWebsocketClose(p0: WebSocket, p1: Int, p2: String, p3: Boolean)

onWebsocketCloseInitiated

open override fun onWebsocketCloseInitiated(p0: WebSocket, p1: Int, p2: String)

onWebsocketClosing

open override fun onWebsocketClosing(p0: WebSocket, p1: Int, p2: String, p3: Boolean)

onWebsocketError

override fun onWebsocketError(p0: WebSocket, p1: Exception)

onWebsocketHandshakeReceivedAsClient

open override fun onWebsocketHandshakeReceivedAsClient(p0: WebSocket, p1: ClientHandshake, p2: ServerHandshake)

onWebsocketHandshakeReceivedAsServer

open override fun onWebsocketHandshakeReceivedAsServer(p0: WebSocket, p1: Draft, p2: ClientHandshake): ServerHandshakeBuilder

onWebsocketHandshakeSentAsClient

open override fun onWebsocketHandshakeSentAsClient(p0: WebSocket, p1: ClientHandshake)

onWebsocketMessage

override fun onWebsocketMessage(p0: WebSocket, p1: ByteBuffer)

override fun onWebsocketMessage(p0: WebSocket, p1: String)

onWebsocketOpen

override fun onWebsocketOpen(p0: WebSocket, p1: Handshakedata)

onWebsocketPing

open override fun onWebsocketPing(p0: WebSocket, p1: Framedata)

onWebsocketPong

open override fun onWebsocketPong(p0: WebSocket, p1: Framedata)

onWriteDemand

override fun onWriteDemand(p0: WebSocket)

run

open override fun run()

setConnectionLostTimeout

open fun setConnectionLostTimeout(p0: Int)

setWebSocketFactory

fun setWebSocketFactory(p0: WebSocketServerFactory)

start

open fun start()

stop

open fun stop()

open fun stop(p0: Int)

open fun stop(p0: Int, p1: String)