feat(json): ♻️ centralize JSON merge logic

Refactored JSON merging to use a new extension method, improving code organization and reusability. JSON merge operations are now handled via a dedicated method, replacing previous inline implementations.

Author: caunt

src/EcoFlow.Mqtt.Api/Extensions/JsonExtensions.cs

@@ -40,6 +40,30 @@ public void Sort()
             }
         }
 
+        public void MergeWith(JsonNode nextNode)
+        {
+            if (node is not JsonObject previousObject || nextNode is not JsonObject nextObject)
+                return;
+
+            foreach (var nextProperty in nextObject)
+            {
+                var previousProperty = previousObject[nextProperty.Key];
+
+                if (previousProperty is JsonObject && nextProperty.Value is JsonObject)
+                {
+                    node.MergeWith(nextProperty.Value);
+                }
+                else
+                {
+                    var clonedNode = nextProperty.Value?.DeepClone();
+                    clonedNode.Sort();
+
+                    previousObject[nextProperty.Key] = clonedNode;
+                    previousObject.Sort();
+                }
+            }
+        }
+
         public IEnumerable<string> Flatten(string keySeparator = ".", string arrayFormat = "[{0}]")
         {
             foreach (var flattenedLine in Walk(node, string.Empty))

src/EcoFlow.Mqtt.Api/Services/InternalMqttApi.cs

@@ -152,13 +152,13 @@ private Task OnApplicationMessageReceived(MqttApplicationMessageReceivedEventArg
 
             foreach (var state in _states.Values)
             {
-                if (!state.Devices.TryGetValue(serialNumber, out var device))
+                if (!state.Devices.TryGetValue(serialNumber, out var deviceNode))
                     continue;
 
                 lock (_states)
                 {
                     foreach (var node in nodes)
-                        MergeJsonNodes(device, node);
+                        deviceNode.MergeWith(node);
                 }
 
                 updated = true;
@@ -186,30 +186,6 @@ static bool TryParse(ReadOnlySequence<byte> bytes, [MaybeNullWhen(false)] out st
                 return false;
             }
         }
-
-        static void MergeJsonNodes(JsonNode previousNode, JsonNode nextNode)
-        {
-            if (previousNode is not JsonObject previousObject || nextNode is not JsonObject nextObject)
-                return;
-
-            foreach (var nextProperty in nextObject)
-            {
-                var previousProperty = previousObject[nextProperty.Key];
-
-                if (previousProperty is JsonObject && nextProperty.Value is JsonObject)
-                {
-                    MergeJsonNodes(previousProperty, nextProperty.Value);
-                }
-                else
-                {
-                    var clonedNode = nextProperty.Value?.DeepClone();
-                    clonedNode.Sort();
-
-                    previousObject[nextProperty.Key] = clonedNode;
-                    previousObject.Sort();
-                }
-            }
-        }
     }
 
     private record MqttState(IMqttClient Client, ConcurrentDictionary<string, JsonNode> Devices);