From 4f40490fee073e5fe121214acbf500f36c5680de Mon Sep 17 00:00:00 2001
From: Fritz Heiden <fritz.heiden@mailbox.org>
Date: Thu, 27 Mar 2025 13:34:34 +0100
Subject: [PATCH] feat: add listening and sending data to bt service

---
 .../tvcontroller/services/BluetoothService.kt | 31 ++++++++++++++++++-
 1 file changed, 30 insertions(+), 1 deletion(-)

diff --git a/app/src/main/java/com/example/tvcontroller/services/BluetoothService.kt b/app/src/main/java/com/example/tvcontroller/services/BluetoothService.kt
index c8428a3..f41bff3 100644
--- a/app/src/main/java/com/example/tvcontroller/services/BluetoothService.kt
+++ b/app/src/main/java/com/example/tvcontroller/services/BluetoothService.kt
@@ -11,7 +11,6 @@ import android.content.IntentFilter
 import android.content.pm.PackageManager
 import android.os.Build
 import android.util.Log
-import androidx.compose.ui.Modifier
 import androidx.core.content.ContextCompat.getSystemService
 import com.example.tvcontroller.data.BluetoothDevice
 import kotlinx.coroutines.flow.MutableStateFlow
@@ -120,6 +119,7 @@ class BluetoothService(private val context: Context) {
             currentDevice = device
             state = STATE_CONNECTED
             Log.i(TAG, "Connected to device: $device")
+            listenForIncomingData()
         } catch (e: IOException) {
             state = STATE_DISCONNECTED
             Log.e(TAG, "Error connecting to device: $e")
@@ -139,6 +139,35 @@ class BluetoothService(private val context: Context) {
         state = STATE_DISCONNECTED
     }
 
+    private fun listenForIncomingData() {
+        if (clientSocket == null || !clientSocket!!.isConnected) return
+        Log.i(TAG, "Listening for incoming data")
+        val buffer = ByteArray(1024)
+        while (true) {
+            try {
+                val bytesRead = clientSocket?.inputStream?.read(buffer)
+                if (bytesRead != null && bytesRead != -1) {
+                    val data = buffer.decodeToString(endIndex = bytesRead)
+                    Log.i(TAG, "Received data: $data")
+                }
+            } catch (e: IOException) {
+                Log.e(TAG, "Error reading from socket: $e")
+            }
+        }
+    }
+
+    fun sendData(data: String) {
+        if (clientSocket == null || !clientSocket!!.isConnected) return
+        try {
+            val bytes = data.encodeToByteArray()
+            clientSocket?.outputStream?.write(bytes)
+            Log.i(TAG, "Sent data: $data")
+        } catch (e: IOException) {
+            Log.e(TAG, "Error writing to socket: $e")
+            closeBluetoothConnection()
+        }
+    }
+
     companion object {
         const val STATE_OFF = "off"
         const val STATE_DISCONNECTED = "disconnected"