feat: get specific device types for channel

Author: JMolenkamp

src/Atc.Kepware.Configuration/Services/Connectivity/KepwareConfigurationClientConnectivity.cs

@@ -1,5 +1,8 @@
 // ReSharper disable ParameterTypeCanBeEnumerable.Local
 // ReSharper disable CheckNamespace
+using System.Reflection;
+using System.Text.Json.Nodes;
+
 namespace Atc.Kepware.Configuration.Services;
 
 /// <summary>
@@ -206,6 +209,67 @@ public async Task<HttpClientRequestResult<bool>> IsTagGroupDefined(
         return response.Adapt<HttpClientRequestResult<IList<DeviceBase>?>>();
     }
 
+    public async Task<HttpClientRequestResult<IList<TDevice>?>> GetDevicesByChannelName<TDevice>(
+        string channelName,
+        CancellationToken cancellationToken)
+        where TDevice : DeviceBase
+    {
+        ArgumentNullException.ThrowIfNull(channelName);
+
+        if (!IsValidConnectivityName(
+                channelName,
+                deviceName: null,
+                tagGroupNameOrTagName: null,
+                tagGroupStructure: null,
+                out var errorMessage))
+        {
+            return await Task.FromResult(HttpClientRequestResultFactory<IList<TDevice>?>.CreateBadRequest(errorMessage!));
+        }
+
+        var response = await Get<IList<JsonObject>>(
+            $"{EndpointPathTemplateConstants.Channels}/{channelName}/{EndpointPathTemplateConstants.Devices}",
+            cancellationToken);
+
+        // TODO: Handle properly and return HttpClientRequestResult<...>
+        if (!response.HasData)
+        {
+            throw new Exception("No data returned!");
+        }
+
+        // Get the implemented interfaces that derive from IDeviceBase, but are not IDeviceBase
+        // TODO: Cache
+        ISet<Type> implementedInterfaces = typeof(TDevice)
+            .GetInterfaces()
+            .Where(x
+                => typeof(IDeviceBase).IsAssignableFrom(x)
+                && x != typeof(IDeviceBase))
+            .ToHashSet();
+
+        // Find the first type in this assembly that share an interface
+        // TODO: Cache
+        Type mappingType = Assembly
+            .GetExecutingAssembly()
+            .GetTypes()
+            .First(x => x
+                .GetInterfaces()
+                .Any(y => implementedInterfaces.Contains(y)));
+
+        // Serialize JSON to internal type and adapt to destination type
+        IList<object?> internalDeviceTypes = response
+            .Data
+            .Select(x => JsonSerializer.Deserialize(x.ToString(), mappingType))
+            .ToList();
+        Type deviceTypeListType = typeof(IList<>).MakeGenericType(typeof(TDevice));
+        IList<TDevice>? deviceTypes = (IList<TDevice>?)internalDeviceTypes.Adapt(typeof(IList<object?>), deviceTypeListType);
+
+        return new HttpClientRequestResult<IList<TDevice>?>(deviceTypes)
+        {
+            CommunicationSucceeded = response.CommunicationSucceeded,
+            StatusCode = response.StatusCode,
+            Message = response.Message,
+        };
+    }
+
     public async Task<HttpClientRequestResult<TagRoot>> GetTags(
         string channelName,
         string deviceName,