[AstarteDeviceSDKCSharp] Fix: automatic reconnect when device lost co…

…nnection to Astarte Signed-off-by: Osman Hadzic <osman.hadzic@secomind.com>
astarte-platform · Dec 13, 2023 · 1eb6d95 · 1eb6d95
1 parent 3af1296
commit 1eb6d95
Show file tree

Hide file tree

Showing 4 changed files with 31 additions and 17 deletions.
diff --git a/AstarteDeviceSDKCSharp/AstartePairingHandler.cs b/AstarteDeviceSDKCSharp/AstartePairingHandler.cs
@@ -52,15 +52,15 @@ public AstartePairingHandler(string pairingUrl, string astarteRealm, string devi
 
         }
 
-        public void Init()
+        public async Task Init()
         {
-            ReloadTransports();
+            await ReloadTransports();
         }
 
-        private void ReloadTransports()
+        private async Task ReloadTransports()
         {
-            _transports = _AstartePairingService.ReloadTransports(_credentialSecret,
-            _cryptoStore, _deviceId).Result;
+            _transports = await _AstartePairingService.ReloadTransports(_credentialSecret,
+            _cryptoStore, _deviceId);
         }
 
         public List<AstarteTransport> GetTransports()

diff --git a/AstarteDeviceSDKCSharp/Crypto/AstarteCryptoStore.cs b/AstarteDeviceSDKCSharp/Crypto/AstarteCryptoStore.cs
@@ -175,10 +175,8 @@ public string GenerateCSR(string commonName)
 
         public MqttClientOptionsBuilderTlsParameters GetMqttClientOptionsBuilderTlsParameters()
         {
-            if (_parametersFactory == null)
-            {
-                _parametersFactory = new AstarteMutualTLSParametersFactory(this);
-            }
+            _parametersFactory = new AstarteMutualTLSParametersFactory(this);
+
             return _parametersFactory.Get();
         }
 

diff --git a/AstarteDeviceSDKCSharp/Device/AstarteDevice.cs b/AstarteDeviceSDKCSharp/Device/AstarteDevice.cs
@@ -37,7 +37,7 @@ public class AstarteDevice : IAstarteTransportEventListener
         private IAstarteMessageListener? _astarteMessagelistener;
         private IAstartePropertyStorage astartePropertyStorage;
         private AstarteFailedMessageStorage _astarteFailedMessageStorage;
-        private bool _initialized;
+        private bool _initialized = false;
         private const string _cryptoSubDir = "crypto";
         private bool _alwaysReconnect = false;
         private bool _explicitDisconnectionRequest;
@@ -117,9 +117,9 @@ public AstarteDevice(
             _astarteFailedMessageStorage = new(fullCryptoDirPath);
         }
 
-        private void Init()
+        private async Task Init()
         {
-            _pairingHandler.Init();
+            await _pairingHandler.Init();
 
             // Get and configure the first available transport
             SetFirstTransportFromPairingHandler();
@@ -221,10 +221,16 @@ public void SetAlwaysReconnect(bool alwaysReconnect)
         public async Task Connect()
         {
 
+            if (!_pairingHandler.IsCertificateAvailable())
+            {
+                await _pairingHandler.RequestNewCertificate();
+                _initialized = false;
+            }
+
             if (!_initialized)
             {
 
-                Init();
+                await Init();
                 _initialized = true;
             }
 

diff --git a/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttV1Transport.cs b/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttV1Transport.cs
@@ -79,13 +79,23 @@ private async Task DoSendMqttMessage(string topic, byte[] payload, int qos)
                                 .WithRetainFlag(false)
                                 .Build();
 
-            MqttClientPublishResult result = await _client.PublishAsync(applicationMessage);
+            try
+            {
+
+                MqttClientPublishResult result = await _client.PublishAsync(applicationMessage);
+
+                if (result.ReasonCode != MqttClientPublishReasonCode.Success)
+                {
+                    throw new AstarteTransportException
+                    ($"Error publishing on MQTT. Code: {result.ReasonCode}");
+                }
 
-            if (result.ReasonCode != MqttClientPublishReasonCode.Success)
+            }
+            catch (MqttCommunicationException)
             {
-                throw new AstarteTransportException
-                ($"Error publishing on MQTT. Code: {result.ReasonCode}");
+                _astarteTransportEventListener?.OnTransportDisconnected();
             }
+
         }
 
         public override async Task SendIntrospection()