class MainActivity : AppCompatActivity(),
    OpWear.OnConnectionChangedListener,
    MessageClient.OnMessageReceivedListener {

    override fun onCreate(savedInstanceState: Bundle?) {
        // ***
        
        OpWear.install(this)
        
        // ONLY OBSERVER SHOULD CALL THIS
        lifecycleScope.launch { OpWear.connect() }
    }

    override fun onConnectionChange(status: OpWear.ConnectionStatus) {
        println(status.name)

        if (status == OpWear.ConnectionStatus.CONNECTED) {
            lifecycleScope.launch {
                OpWear.sendMessage(
                    "Hello",
                    "Hello ${OpWear.connectedNodeDisplayName}!".toByteArray()
                )
            }
        }
    }

    override fun onMessageReceived(msg: MessageEvent) {
        println("MESSAGE RECEIVED:")
        println(msg.path)
        println(String(msg.data))
    }
}

OpWear.acknowledgeListener = OpWear.OnAcknowledgeListener { nodeId, displayName ->
    println("$displayName:$nodeId WANTS TO CONNECT")
    true
}

OpWear.attachToLifecycle(owner)

override fun onResume() {
    super.onResume()
    OpWear.register()
}

override fun onPause() {
    super.onPause()
    OpWear.unregister()
}

OpWear.autoValidationStrategy = OpWear.AutoValidationStrategy.NONE
OpWear.autoValidationStrategy = OpWear.AutoValidationStrategy.RESPONSE
OpWear.autoValidationStrategy = OpWear.AutoValidationStrategy.ACKNOWLEDGE