Replace Trace.WritteLine with AstarteLogger.LogLevel

Signed-off-by: Osman Hadzic <osman.hadzic@secomind.com>
astarte-platform · Nov 12, 2024 · 1a345e4 · 1a345e4
1 parent 79c4015
commit 1a345e4
Show file tree

Hide file tree

Showing 7 changed files with 22 additions and 21 deletions.
diff --git a/AstarteDeviceSDKCSharp/Device/AstarteDevice.cs b/AstarteDeviceSDKCSharp/Device/AstarteDevice.cs
@@ -226,7 +226,7 @@ public async Task Connect()
             }
             catch (AstarteCryptoException)
             {
-                Trace.WriteLine("Regenerating the cert");
+                AstarteLogger.Debug("Regenerating the cert", this.GetType().Name);
                 try
                 {
                     await _pairingHandler.RequestNewCertificate();
@@ -395,7 +395,7 @@ public void OnTransportConnectionError(Exception ex)
             {
                 if (ex is AstarteCryptoException)
                 {
-                    Trace.WriteLine("Regenerating the cert");
+                    AstarteLogger.Debug("Regenerating the cert", this.GetType().Name);
                     try
                     {
                         Task.Run(() => _pairingHandler.RequestNewCertificate());

diff --git a/AstarteDeviceSDKCSharp/Protocol/AstarteDeviceAggregateDatastreamInterface.cs b/AstarteDeviceSDKCSharp/Protocol/AstarteDeviceAggregateDatastreamInterface.cs
@@ -84,9 +84,9 @@ public void ValidatePayload(string path, Dictionary<string, object> payload, Dat
 
                 if (astarteInterfaceMapping.Path is null)
                 {
-                    Trace.WriteLine("Astarte mapping path " +
+                    AstarteLogger.Warn("Astarte mapping path " +
                     "{" + astarteInterfaceMapping.Path + " } "
-                    + " is null.");
+                    + " is null.", this.GetType().Name);
                     continue;
                 }
                 if (!payload.ContainsKey(

diff --git a/AstarteDeviceSDKCSharp/Protocol/AstarteDevicePropertyInterface.cs b/AstarteDeviceSDKCSharp/Protocol/AstarteDevicePropertyInterface.cs
@@ -55,7 +55,7 @@ public void SetProperty(string path, object payload)
             }
             catch (AstartePropertyStorageException e)
             {
-                Trace.WriteLine(e.Message);
+                AstarteLogger.Error(e.Message, this.GetType().Name);
             }
 
             if (!(storedValue?.PayloadEquality(payload) ?? false))

diff --git a/AstarteDeviceSDKCSharp/Protocol/AstarteServerAggregateDatastreamInterface.cs b/AstarteDeviceSDKCSharp/Protocol/AstarteServerAggregateDatastreamInterface.cs
@@ -51,7 +51,7 @@ public void RemoveListener(IAstarteAggregateDatastreamEventListener listener)
         {
             if (serverValue is null)
             {
-                Trace.WriteLine("Unable to build AstarteServerValue, serverValue was empty");
+                AstarteLogger.Error("Unable to build AstarteServerValue, serverValue was empty", this.GetType().Name);
                 return null;
             }
 
@@ -63,7 +63,7 @@ public void RemoveListener(IAstarteAggregateDatastreamEventListener listener)
 
             if (astartePayload is null)
             {
-                Trace.WriteLine("Unable to build AstarteServerValue, astartePayload was empty");
+                AstarteLogger.Error("Unable to build AstarteServerValue, astartePayload was empty", this.GetType().Name);
                 return null;
             }
 

diff --git a/AstarteDeviceSDKCSharp/Protocol/AstarteServerDatastreamInterface.cs b/AstarteDeviceSDKCSharp/Protocol/AstarteServerDatastreamInterface.cs
@@ -58,7 +58,7 @@ public void RemoveListener(IAstarteDatastreamEventListener listener)
             AstarteInterfaceMapping? targetMapping = null;
             if (serverValue is null)
             {
-                Trace.WriteLine($"Unable to build AstarteServerValue, astartePayload was empty");
+                AstarteLogger.Error("Unable to build AstarteServerValue, astartePayload was empty", this.GetType().Name);
                 return null;
             }
 
@@ -87,8 +87,9 @@ public void RemoveListener(IAstarteDatastreamEventListener listener)
             }
             else
             {
-                Trace.WriteLine($"Got an unexpected path {interfacePath}"
-                + "for interface {GetInterfaceName()}");
+                AstarteLogger.Warn($"Got an unexpected path {interfacePath}"
+                + "for interface {GetInterfaceName()}", this.GetType().Name);
+
             }
             return astarteServerValue;
         }

diff --git a/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttTransport.cs b/AstarteDeviceSDKCSharp/Transport/MQTT/AstarteMqttTransport.cs
@@ -128,7 +128,7 @@ async Task OnConnectedAsync(MqttClientConnectedEventArgs args)
             }
             else
             {
-                Trace.WriteLine("Transport Connected");
+                AstarteLogger.Info("Transport Connected", this.GetType().Name);
             }
 
         }
@@ -276,7 +276,7 @@ async Task OnDisconnectAsync(MqttClientDisconnectedEventArgs e)
             }
             else
             {
-                Trace.WriteLine("The Connection was lost.");
+                AstarteLogger.Error("The Connection was lost.", this.GetType().Name);
             }
 
         }
@@ -285,8 +285,8 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
         {
             object? payload = null;
 
-            Trace.WriteLine("Incoming message: "
-                + Encoding.UTF8.GetString(e.ApplicationMessage.Payload ?? new byte[0]));
+            AstarteLogger.Debug("Incoming message: "
+                + Encoding.UTF8.GetString(e.ApplicationMessage.Payload ?? new byte[0]), this.GetType().Name);
 
             if (!e.ApplicationMessage.Topic.Contains(_connectionInfo.GetClientId())
             || _messageListener == null)
@@ -313,7 +313,7 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
                 }
                 else
                 {
-                    Trace.WriteLine("Unhandled control message!" + path);
+                    AstarteLogger.Error("Unhandled control message!" + path, this.GetType().Name);
                 }
                 return;
             }
@@ -323,7 +323,7 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
 
             if (!astarteDevice.HasInterface(astarteInterface))
             {
-                Trace.WriteLine("Got an unexpected interface!" + astarteInterface);
+                AstarteLogger.Warn("Got an unexpected interface!" + astarteInterface, this.GetType().Name);
                 return;
             }
 
@@ -335,7 +335,7 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
                 decodedMessage = AstartePayload.Deserialize(e.ApplicationMessage.Payload);
                 if (decodedMessage is null)
                 {
-                    Trace.WriteLine("Unable to get payload, decodedMessage was null");
+                    AstarteLogger.Warn("Unable to get payload, decodedMessage was null ", this.GetType().Name);
                     return;
                 }
                 payload = decodedMessage.GetPayload();
@@ -362,7 +362,7 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
 
             if (astarteServerValue == null)
             {
-                Trace.WriteLine("Unable to get value, astarteServerValue was null");
+                AstarteLogger.Error("Unable to get value, astarteServerValue was null", this.GetType().Name);
                 return;
             }
 
@@ -389,7 +389,7 @@ private void OnMessageReceive(MqttApplicationMessageReceivedEventArgs e)
                 }
                 catch (AstartePropertyStorageException ex)
                 {
-                    Trace.WriteLine(ex.Message);
+                    AstarteLogger.Error(ex.Message, this.GetType().Name);
                 }
             }
 
@@ -434,7 +434,7 @@ private void HandlePurgeProperties(byte[] payload, AstarteDevice? astarteDevice)
             }
             catch (IOException e)
             {
-                Trace.WriteLine(e.Message);
+                AstarteLogger.Error(e.Message, this.GetType().Name);
             }
 
             string purgePropertiesPayload = result.ToString();

diff --git a/AstarteDeviceSDKCSharp/Utilities/Logger/AstarteLogger.cs b/AstarteDeviceSDKCSharp/Utilities/Logger/AstarteLogger.cs
@@ -1,7 +1,7 @@
 /*
  * This file is part of Astarte.
  *
- * Copyright 2023 SECO Mind Srl
+ * Copyright 2023-2024 SECO Mind Srl
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.