core-takserver/org.meshtastic.core.takserver/TAKServer

TAKServer

Platform-agnostic contract for the Meshtastic TAK server.

The production implementation on Android / JVM runs a TLS (mTLS) listener on port DEFAULT_TAK_PORT (8089) using the bundled server identity. This matches the Meshtastic-Apple (iOS) implementation so that a single exported .zip data package is valid for ATAK on Android AND iTAK on iOS without re-configuration.

The interface deliberately hides the platform socket / TLS primitives so that commonMain code (TAKServerManagerImpl, DI, tests) can depend on it without pulling javax.net.ssl.* into the common source set.

Properties

connectionCount

abstract val connectionCount: StateFlow<Int>

Observable count of currently-connected TAK clients (ATAK/iTAK).

onClientConnected

abstract var onClientConnected: () -> Unit?

Callback invoked when a TAK client connects. Use to drain queued messages.

onMessage

abstract var onMessage: (CoTMessage, TAKClientInfo?) -> Unit?

Callback invoked on the IO dispatcher for every inbound CoT message from a client.

Functions

broadcast

abstract suspend fun broadcast(cotMessage: CoTMessage)

Broadcast a CoT message to every currently-connected client.

broadcastRawXml

abstract suspend fun broadcastRawXml(xml: String)

Broadcast raw CoT XML to every currently-connected client. Used for mesh-originated messages that should be forwarded verbatim without re-parsing through the app's CoTXmlParser (which strips shape detail elements like strokeColor, fillColor, vertices, etc.).

hasConnections

abstract suspend fun hasConnections(): Boolean

Returns true if at least one TAK client is currently connected.

start

abstract suspend fun start(scope: CoroutineScope): Result<Unit>

Bind the listener and begin accepting connections. Idempotent if already running.

stop

abstract fun stop()

Stop the listener, close all client sockets, and release OS resources.