Renew Certificate After Expiration

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()

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();
         }
 

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;
             }
 

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 (Exception)
             {
-                throw new AstarteTransportException
-                ($"Error publishing on MQTT. Code: {result.ReasonCode}");
+                _astarteTransportEventListener?.OnTransportDisconnected();
             }
+
         }
 
         public override async Task SendIntrospection()

CHANGELOG.md

@@ -11,6 +11,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Add option to ignore SSL errors in the AstarteDevice constructor.
 - Add a method to remove interface from device.
 
+### Fixed
+- Fix Connect method to handle certificate expiration.
+
 ## [0.5.4] - 2023-06-23
 ### Added
 - Expose an interface path from Astarte aggregate datastream event.