bridge/com.lastlock.bridge.proxy

Package-level declarations

Types

class AdvertisementTelemetryEntry(val deviceId: UInt, val rssi: Int, val advertisingPacket: ByteArray)

One BLE advertisement sample for structured bridge telemetry (see plane.proto).

class BLEProxy(messageStreamManager: IOSMessageStreamManager?, val blueLink: BlueLink, networkConnectivityMonitor: NetworkConnectivityMonitor, persistenceManager: PersistenceManager, iOSTrueTimeManager: ITrueTimeManager?) : ConnectivityListener

DeviceTaskExecutor

class DeviceTaskExecutor

InstallOOBResult

sealed class InstallOOBResult

Result of deliverInstallOOBAndWaitForMode. Success: device entered install/DFU mode; device is the peripheral to use for DFU if needed. Timeout: did not see install/DFU mode within the timeout. Failure: OOB delivery or other error.

IOSMessageStreamManager

interface IOSMessageStreamManager

MessageStreamManager

interface MessageStreamManager

OOBWrapper

interface OOBWrapper

ProxyDevice

class ProxyDevice(var peripheral: BluetoothDevice, var deviceId: UInt, var proxyTaskQueue: TaskQueue = TaskQueue(), var internalCache: BridgeCache = BridgeCache(), val taskExecutor: DeviceTaskExecutor = DeviceTaskExecutor(), var batteryStatusLow: Boolean = false, cachedDevicePayloadChunks: MutableList<ByteArray> = mutableListOf(), var lastSuccessfulOOBTimestamp: Long? = null, var lastDiscoveryTime: Instant? = null, var isBlacklisted: Boolean = false, var inInstallMode: Boolean = false, var inDFUMode: Boolean = false, var lastHeartbeatSentTime: Long? = null, var lastHeartbeatAdvData: ByteArray? = null, var lastRssi: Int? = null)

Represents a BLE Device and its associated properties and operations.

ProxyPayloadOffloadStatus

sealed class ProxyPayloadOffloadStatus

ProxyProvider

class ProxyProvider(messageStreamManager: IOSMessageStreamManager? = null, heartbeatParser: IHeartbeatParser? = null, iOSTrueTimeManager: ITrueTimeManager? = null) : KoinComponent

ServerResponse

@Serializable

data class ServerResponse(val stateUpdates: MutableList<ServerResponseStateUpdate>)

Represents the full server response.

ServerResponseStateUpdate

@Serializable

data class ServerResponseStateUpdate(val psc: Int, val payload: ByteArray, var dsc: Int? = null, var isAck: Boolean)

Represents an update within the server response.

StreamInactiveForPushException

class StreamInactiveForPushException(message: String = "Plane stream is not connected") : Exception

Raised when encrypted device payloads or heartbeats must not be sent because the plane stream is not connected.

Properties

proxyModule

val proxyModule: Module

Functions

provideMessageStreamManager

actual fun provideMessageStreamManager(persistenceManager: PersistenceManager, messageStreamManager: IOSMessageStreamManager?, oobStateFlow: MutableSharedFlow<OOBWrapper?>, proxyUpdateFlow: MutableSharedFlow<UInt>): MessageStreamManager

expect fun provideMessageStreamManager(persistenceManager: PersistenceManager, messageStreamManager: IOSMessageStreamManager?, oobStateFlow: MutableSharedFlow<OOBWrapper?>, proxyUpdateFlow: MutableSharedFlow<UInt>): MessageStreamManager