Skip to content
Snippets Groups Projects
Commit 526befba authored by Paul-Winpenny's avatar Paul-Winpenny
Browse files

read and write works, issue is disconnecting doesn't discard properly, 

resulting in issues
parent d5a636f0
No related branches found
No related tags found
1 merge request!1App now has a basic structure and BLE support
Show whitespace changes
Inline Side-by-side
App/RobobinApp/ViewModels/ConnectionPageViewModel.cs
+ 154
− 55
View file @ 526befba
......@@ -154,6 +154,7 @@ namespace RobobinApp.ViewModels
if (SelectedWifiNetwork != null)
{
Debug.WriteLine("Wifi been selected");
Debug.WriteLine($"Selected Network {SelectedWifiNetwork.SSID}");
}
if (!_isConnected || _connectedDevice == null)
{
......@@ -315,7 +316,7 @@ namespace RobobinApp.ViewModels
try
{
Debug.WriteLine($"Attempt {attempt}: Connecting to device {deviceId}");
var cancellationTokenSource = new CancellationTokenSource(TimeSpan.FromSeconds(30));
var cancellationTokenSource = new CancellationTokenSource(); // No timeout specified
device = await _adapter.ConnectToKnownDeviceAsync(deviceId, new ConnectParameters(false, true), cancellationTokenSource.Token);
return device;
}
......@@ -330,7 +331,6 @@ namespace RobobinApp.ViewModels
}
return device;
}
private async void OnConnect()
{
if (SelectedDevice == null)
......@@ -340,17 +340,16 @@ namespace RobobinApp.ViewModels
}
Debug.WriteLine($"Attempting to connect to {SelectedDevice.Name}, MAC Address {SelectedDevice.MacAddress}");
await Application.Current.MainPage.DisplayAlert("Connection", $"Connecting to {SelectedDevice.Name}...", "OK");
try
{
await _adapter.StopScanningForDevicesAsync();
Debug.WriteLine("Stopped scanning for devices.");
IsConnected = true;
// Connect to the selected device
_connectedDevice = await TryConnectAsync(Guid.Parse(SelectedDevice.MacAddress));
if (_connectedDevice != null)
{
Debug.WriteLine($"Successfully connected to {SelectedDevice.Name}.");
var services = await _connectedDevice.GetServicesAsync();
IsWifiNetworkSelectionVisible = true;
......@@ -359,67 +358,120 @@ namespace RobobinApp.ViewModels
{
Debug.WriteLine($"Service: ID={service.Id}, Name={service.Name}");
}
var transmitService = services.FirstOrDefault(s => s.Id == Guid.Parse(SendReceiveServiceUUID));
Debug.WriteLine("Transmit service was accessed");
Debug.WriteLine($"{transmitService.Name} : {transmitService.Id}");
if (transmitService == null)
if (service.Id.Equals(Guid.Parse("00000001-710e-4a5b-8d75-3e5b444bc3cf")) )
{
Debug.WriteLine("Transmit service wasn't found");
}
var characteristics = await transmitService.GetCharacteristicsAsync();
var characteristics = await service.GetCharacteristicsAsync();
foreach (var characteristic in characteristics)
{
Debug.WriteLine($"{characteristic.Uuid} | {characteristic.Name}");
if (characteristic.Uuid.Equals(rxUUID))
{
Debug.WriteLine("Found Read");
var result = await ReadOperationAsync(characteristic);
// Read the value from the characteristic
var temperatureData = await characteristic.ReadAsync();
// Convert the byte array to a string
var temperatureValue = System.Text.Encoding.UTF8.GetString(temperatureData.data);
Debug.WriteLine($"Temperature Value: {temperatureValue}");
}
else if (characteristic.Uuid.Equals(wxUUID))
{
Debug.WriteLine("Found Write");
// Read the current value (if needed)
var writeValueData = await characteristic.ReadAsync();
var writeValue = System.Text.Encoding.UTF8.GetString(writeValueData.data);
Debug.WriteLine($"Current Write Value: {writeValue}");
const string data = "C";
await WriteOperationAsync(characteristic,data);
}
}
}
}
var transmissionService = services.FirstOrDefault(s => s.Id == Guid.Parse(SendReceiveServiceUUID));
var readCharacteristic = await transmissionService.GetCharacteristicAsync(Guid.Parse(rxUUID));
var result2 = await ReadOperationAsync(readCharacteristic);
}
else
{
Debug.WriteLine("Failed to connect to the device.");
IsConnected = false;
}
}
catch (DeviceConnectionException ex)
{
Debug.WriteLine($"Connection error: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", $"Failed to connect: {ex.Message}", "OK");
}
catch (TaskCanceledException ex)
catch (Exception ex)
{
Debug.WriteLine($"General connection error: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", $"An error occurred: {ex.Message}", "OK");
}
finally
{
// Ensure we reset connection state
if (_connectedDevice == null)
{
Debug.WriteLine($"TaskCanceledException: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", "Connection timed out.", "OK");
_connectedDevice = null;
IsConnected = false;
// Consider resetting any other related UI state
}
}
}
private async Task<string> ReadOperationAsync(ICharacteristic characteristic, int retryCount = 3)
{
for (int attempt = 1; attempt <= retryCount; attempt++)
{
try
{
Debug.WriteLine($"Attempt {attempt}: Reading from characteristic {characteristic.Uuid}");
var temperatureData = await characteristic.ReadAsync();
var temperatureValue = System.Text.Encoding.UTF8.GetString(temperatureData.data);
Debug.WriteLine($"Temperature Value: {temperatureValue}");
return temperatureValue;
}
catch (Exception ex)
{
Debug.WriteLine($"General connection error: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", $"An error occurred: {ex.Message}", "OK");
Debug.WriteLine($"Read attempt {attempt} failed: {ex.Message}");
if (attempt == retryCount)
{
Debug.WriteLine("Max retry attempts reached for reading.");
throw;
} else
{
await Task.Delay(1000);
}
}
}
return null;
}
private async Task WriteOperationAsync(ICharacteristic characteristic,string sendData, int retryCount = 3)
{
byte[] data = System.Text.Encoding.UTF8.GetBytes(sendData);
for (int attempt = 1; attempt <= retryCount; attempt++)
{
try
{
Debug.WriteLine($"Attempt {attempt}: Writing to characteristic {characteristic.Uuid}");
await characteristic.WriteAsync(data);
Debug.WriteLine("Write operation succeeded.");
return;
}
catch (Exception ex)
{
Debug.WriteLine($"Write attempt {attempt} failed: {ex.Message}");
if (attempt == retryCount)
{
Debug.WriteLine("Max retry attempts reached for writing.");
throw;
} else
{
await Task.Delay(1000);
}
}
}
}
private async void OnDisconnect()
{
if (_connectedDevice != null)
......@@ -435,6 +487,7 @@ namespace RobobinApp.ViewModels
_connectedDevice.Dispose();
_connectedDevice = null;
IsConnected = false;
ScanDevices();
await Application.Current.MainPage.DisplayAlert("Disconnected", "Device disconnected successfully.", "OK");
}
catch (Exception ex)
......@@ -452,4 +505,50 @@ namespace RobobinApp.ViewModels
}
/**
*
var transmitService = services.FirstOrDefault(s => s.Id == Guid.Parse(SendReceiveServiceUUID));
Debug.WriteLine("Transmit service was accessed");
Debug.WriteLine($"{transmitService.Name} : {transmitService.Id}");
if (transmitService == null)
{
Debug.WriteLine("Transmit service wasn't found");
}
var characteristics = await transmitService.GetCharacteristicsAsync();
foreach (var characteristic in characteristics)
{
Debug.WriteLine($"{characteristic.Uuid} | {characteristic.Name}");
if (characteristic.Uuid.Equals(rxUUID))
{
var result = await ReadOperationAsync(characteristic);
}
else if (characteristic.Uuid.Equals(wxUUID))
{
//await WriteOperationAsync(characteristic);
}
}
}
catch (DeviceConnectionException ex)
{
Debug.WriteLine($"Connection error: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", $"Failed to connect: {ex.Message}", "OK");
}
catch (TaskCanceledException ex)
{
Debug.WriteLine($"TaskCanceledException: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", "Connection timed out.", "OK");
_connectedDevice = null;
IsConnected = false;
}
catch (Exception ex)
{
Debug.WriteLine($"General connection error: {ex.Message}");
await Application.Current.MainPage.DisplayAlert("Connection Error", $"An error occurred: {ex.Message}", "OK");
}
} **/
}
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment