fritz/tv-controller-android
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: add listening and sending data to bt service

Browse Source
This commit is contained in:
Fritz Heiden 2025-03-27 13:34:34 +01:00
parent a74d0ddef5
commit 4f40490fee
1 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
app/src/main/java/com/example/tvcontroller/services/BluetoothService.kt
View File

@ -11,7 +11,6 @@ import android.content.IntentFilter
import android.content.pm.PackageManager import android.content.pm.PackageManager
import android.os.Build import android.os.Build
import android.util.Log import android.util.Log
import androidx.compose.ui.Modifier
import androidx.core.content.ContextCompat.getSystemService import androidx.core.content.ContextCompat.getSystemService
import com.example.tvcontroller.data.BluetoothDevice import com.example.tvcontroller.data.BluetoothDevice
import kotlinx.coroutines.flow.MutableStateFlow import kotlinx.coroutines.flow.MutableStateFlow
@ -120,6 +119,7 @@ class BluetoothService(private val context: Context) {
currentDevice = device currentDevice = device
state = STATE_CONNECTED state = STATE_CONNECTED
Log.i(TAG, "Connected to device: $device") Log.i(TAG, "Connected to device: $device")
listenForIncomingData()
} catch (e: IOException) { } catch (e: IOException) {
state = STATE_DISCONNECTED state = STATE_DISCONNECTED
Log.e(TAG, "Error connecting to device: $e") Log.e(TAG, "Error connecting to device: $e")
@ -139,6 +139,35 @@ class BluetoothService(private val context: Context) {
state = STATE_DISCONNECTED 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 { companion object {
const val STATE_OFF = "off" const val STATE_OFF = "off"
const val STATE_DISCONNECTED = "disconnected" const val STATE_DISCONNECTED = "disconnected"