core-service/org.meshtastic.core.service/SharedRadioInterfaceService

SharedRadioInterfaceService

class SharedRadioInterfaceService(dispatchers: CoroutineDispatchers, bluetoothRepository: BluetoothRepository, networkRepository: NetworkRepository, serialDevicePresence: SerialDevicePresence, processLifecycle: Lifecycle, radioPrefs: RadioPrefs, transportFactory: RadioTransportFactory, analytics: PlatformAnalytics, firmwareMaintenanceLock: FirmwareMaintenanceLock) : RadioInterfaceService(source)

Shared multiplatform connection orchestrator for Meshtastic radios.

Manages the connection lifecycle (connect, active, disconnect, reconnect loop), device address state flows, and hardware state observability (BLE/Network toggles). Delegates the actual raw byte transport mapping to a platform-specific RadioTransportFactory.

Constructors

SharedRadioInterfaceService

constructor(dispatchers: CoroutineDispatchers, bluetoothRepository: BluetoothRepository, networkRepository: NetworkRepository, serialDevicePresence: SerialDevicePresence, processLifecycle: Lifecycle, radioPrefs: RadioPrefs, transportFactory: RadioTransportFactory, analytics: PlatformAnalytics, firmwareMaintenanceLock: FirmwareMaintenanceLock)

Types

object Companion

Properties

open override val activeSession: StateFlow<RadioSessionContext?>

connectionError

open override val connectionError: Flow<String>

connectionState

open override val connectionState: StateFlow<ConnectionState>

currentDeviceAddressFlow

open override val currentDeviceAddressFlow: StateFlow<String?>

isReplayTransportAvailable

open override val isReplayTransportAvailable: Boolean

open override val meshActivity: Flow<MeshActivity>

mockTransportEnabled

open override val mockTransportEnabled: StateFlow<Boolean>

open override val receivedData: Flow<ReceivedRadioFrame>

open override val serviceScope: CoroutineScope

sessionGeneration

open override val sessionGeneration: StateFlow<Long>

supportedDeviceTypes

open override val supportedDeviceTypes: List<DeviceType>

Functions

open override fun connect()

consumeGattCacheInvalidationRequest

open override fun consumeGattCacheInvalidationRequest(): Boolean

open suspend override fun disconnect()

getDeviceAddress

open override fun getDeviceAddress(): String?

handleFromRadio

open override fun handleFromRadio(bytes: ByteArray)

isSessionActive

open override fun isSessionActive(session: RadioSessionContext): Boolean

fun keepAlive(now: Long = now())

open override fun onConnect()

open override fun onDisconnect(isPermanent: Boolean, errorMessage: String?, reason: TransportDisconnectReason?)

requestGattCacheInvalidationOnNextConnect

open override fun requestGattCacheInvalidationOnNextConnect()

resetReceivedBuffer

open override fun resetReceivedBuffer()

restartTransport

open suspend override fun restartTransport()

runIfSessionActive

open override fun runIfSessionActive(session: RadioSessionContext, block: () -> Unit): Boolean

runWhileSessionActive

open suspend override fun runWhileSessionActive(session: RadioSessionContext, block: suspend () -> Unit): Boolean

runWithSessionLease

open suspend override fun runWithSessionLease(session: RadioSessionContext, block: suspend (RadioSessionLease) -> Unit): Boolean

open fun sendToRadio(bytes: ByteArray)

setDeviceAddress

open override fun setDeviceAddress(deviceAddr: String?): Boolean

toInterfaceAddress

open override fun toInterfaceAddress(interfaceId: InterfaceId, rest: String): String

open override fun trySendToRadio(bytes: ByteArray): Boolean