bridge/com.lastlock.bridge.proxy/MessageStreamManager

MessageStreamManager

interface MessageStreamManager

Properties

abstract val oobStateFlow: MutableSharedFlow<OOBWrapper?>

persistenceManager

abstract val persistenceManager: PersistenceManager

proxyUpdateFlow

abstract val proxyUpdateFlow: SharedFlow<UInt>

Emits deviceId when the stream has an update for that device (new payloads or device added to stream). Proxy should queue DEVICE_INFORMATION.

Functions

addDeviceToStream

abstract fun addDeviceToStream(deviceId: UInt)

getActiveDevices

abstract suspend fun getActiveDevices(): List<UInt>

abstract suspend fun isStreamActive(): Boolean

processStreamResponse

abstract fun processStreamResponse(response: Any)

pushEncryptedHeartbeatAndCiphertext

abstract suspend fun pushEncryptedHeartbeatAndCiphertext(deviceId: UInt, heartbeats: List<ByteArray>, ciphertexts: List<ByteArray>, heartbeatBridgeReceiveEpochSeconds: List<Long?> = emptyList())

pushEncryptedMessages

abstract suspend fun pushEncryptedMessages(deviceId: UInt, payloads: List<ByteArray>, isHeartbeat: Boolean, heartbeatBridgeReceiveEpochSeconds: List<Long?> = emptyList())

removeDeviceFromStream

abstract suspend fun removeDeviceFromStream(deviceId: UInt)

sendAdvertisementTelemetry

abstract suspend fun sendAdvertisementTelemetry(entries: List<AdvertisementTelemetryEntry>)

abstract suspend fun sendTelemetry(data: ByteArray)

setStreamEstablishedListener

open fun setStreamEstablishedListener(listener: () -> Unit?)

Invoked on the plane stream UI thread / stream coroutine when the stream becomes connected; used to flush persisted device payloads.

abstract suspend fun shutdown()

streamMessagesFromServer

abstract fun streamMessagesFromServer()