Xamarin / MAUI

using TeoTestBluetooth.Droid.Receivers;

using TeoTestBluetooth.Droid.Utils;

using TeoTestBluetooth.Models;

using TeoTestBluetooth.Services;

namespace TeoTestBluetooth.Droid.Services

        private readonly List<BluetoothDevice> discoveredDevices = new List<BluetoothDevice>();

        private readonly BluetoothReceiver bluetoothReceiver;

        private TaskCompletionSource<bool> scanCompletionSource;

        private Thread listeningThread;

        private BluetoothSocket socket;

        private readonly string sppUUID = "00001101-0000-1000-8000-00805f9b34fb";

            bluetoothReceiver = new BluetoothReceiver();

            bluetoothReceiver.OnBluetoothDeviceDiscovered += DeviceDiscovered;

            bluetoothReceiver.OnScanFinished += ScanFinished;

            // abonnements du BluetoothReceiver au intent ActionFound Et ActionDiscoveryFinished

            IntentFilter intentFilter = new IntentFilter();

            intentFilter.AddAction(BluetoothDevice.ActionFound);

            intentFilter.AddAction(BluetoothAdapter.ActionDiscoveryFinished);

            intentFilter.AddAction(BluetoothDevice.ActionBondStateChanged);

            Application.Context.RegisterReceiver(bluetoothReceiver, intentFilter);

        }

        public async Task<bool> Connect(Device btDevice)

        {

            try

            {

                // Si jamais on est en train de scanner

                // On annule le scan

                if (bluetoothAdapter.IsDiscovering)

                {

                    bluetoothAdapter.CancelDiscovery();

                }

                BluetoothDevice droidBtDevice = bluetoothAdapter.GetRemoteDevice(btDevice.MACAddress);

                //Android.Bluetooth.BluetoothDevice droidBtDevice = adapter.BondedDevices.FirstOrDefault(x => (x.Address == bluetoothDevice.Address));

                if (droidBtDevice != null)

                {

                    // Si le socket est occupé pour une autre connexion

                    // On ferme la connexion existante

                    if (socket != null)

                    {

                        await Disconnect(btDevice);

                    }

                    // Creation du canal RFCOMM (non sécurisé)

                    socket = droidBtDevice.CreateInsecureRfcommSocketToServiceRecord(UUID.FromString(sppUUID));

                    CancellationTokenSource cts = new CancellationTokenSource();

                    cts.CancelAfter(50000);

                    await socket.ConnectAsync().WithCancellation(cts.Token);

                    if (listeningThread != null) listeningThread.Abort();

                    listeningThread = new Thread(async delagate => await ListeningAsync(btDevice));

                    listeningThread.Start();

                    return true;

                }

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine(ex);

            }

            return false;

        }

        // Fonction d'écoute pour le Thread d'écoute

        private async Task ListeningAsync(Device btDevice)

        {

            try

            {

                byte[] buffer = new byte[1024];

                while (socket.IsConnected)

                {

                    int byteAvailable = await socket.InputStream.ReadAsync(buffer, 0, buffer.Length);

                    // Resize the byte array 

                    byte[] filledBuffer = buffer.Take(byteAvailable).ToArray();

                    Application.SynchronizationContext.Post(_ => { OnDataReceived(filledBuffer); }, null);

                }

            }

            catch (IOException ex)

            {

                System.Diagnostics.Debug.WriteLine(ex);

            }

            catch (ThreadAbortException taEx)

            {

                System.Diagnostics.Debug.WriteLine(taEx);

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine(ex);

            }

        }

        public EventHandler<string> DataReceivedEvent { get; set; }

        private string _bufferedData;

        /* 

         * Fonction appelée à la reception de données

         * Trigger l'evenement DataReceivedEvent

         * 

         * IMPORTANT: Les trames peuvent arriver découpées,

         * Donc les données sont gardées dans un buffer d'envoi

         * nommé _bufferedData

         */

        private void OnDataReceived(byte[] buffer)

        {

            // Si le premier character est 2 (ASCII: STX)

            // Alors c'est le début de la trame.

            if (buffer[0] == 2)

            {

                _bufferedData = "";

                // Si character seul on quitte

                if (buffer.Length == 1)

                {

                    return;

                }

                // On enlève STX

                buffer = buffer.Skip(1).ToArray();

                // On mets le début de la trame dans buffer d'envoi

                _bufferedData += Encoding.ASCII.GetString(buffer);

            }

            // Si le dernier character est 13 (ASCII: CR)

            // Alors la trame est terminée

            if (buffer[^1] == 13)

            {

                // On enlève CR

                buffer = buffer.SkipLast(1).ToArray();

                // Conversion en chaîne de caractères

                // Et on complète le buffer d'envoi

                _bufferedData += Encoding.ASCII.GetString(buffer);

                // Trigger evènement

                DataReceivedEvent.Invoke(this, _bufferedData);

            }

        }

        private void ScanFinished(object sender, string e)

        {

            scanCompletionSource?.SetResult(true);

        }

        private void DeviceDiscovered(object sender, BluetoothDevice e)

        {

            if (discoveredDevices.FirstOrDefault(x => x.Address == e.Address) is null)

            {

                discoveredDevices.Add(e);

                FoundDevices.Add(new Device() { Name = e.Name, MACAddress = e.Address });

            }

        }

        public ObservableCollection<Device> DeviceList { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }

        public Task StartScan()

        {

            if (bluetoothAdapter.IsDiscovering)

            {

                return scanCompletionSource.Task;

            }

            scanCompletionSource = new TaskCompletionSource<bool>();

            discoveredDevices.Clear();

            FoundDevices.Clear();

            // Lancement du scan

            bluetoothAdapter.StartDiscovery();

            return scanCompletionSource.Task;

        }

        public Task<bool> Pair(Device bluetoothDevice)

        {

            throw new NotImplementedException();

        }

        public Task<bool> Disconnect(Device bluetoothDevice)

        {

            while (socket.IsConnected) socket.Close();

            return Task.FromResult(true);

        }

        public Task<bool> SendHexValues(byte[] hexValues)

        {

            if (socket.IsConnected == false)

            {

                return Task.FromResult(false);

            } else

            {

                // Envoi de la commande

                socket.OutputStream.Write(hexValues, 0, hexValues.Length);

                socket.OutputStream.Flush();

            }

            return Task.FromResult(true);