onMessageReceived.kt

onMessageReceived.kt

    override fun onMessageReceived(event: MessageEvent) {
        when (event.path) {
            WearPaths.REQUEST_CONTROL -> {
                val requester = DeviceType.fromName(event.data.decodeToString())
                publishControl(
                    ControlStatus(
                        holder = requester,
                        emergency = false,
                        timestamp = System.currentTimeMillis(),
                    )
                )
            }
            WearPaths.PING -> sendDirectMessage(event.sourceNodeId, WearPaths.PONG, ByteArray(0))
            WearPaths.PONG -> refreshNodes()
        }
    }