feat: update extensions

Author: IvanJosipovic

src/Function.SDK.CSharp/Extensions/RequestExtensions.cs

@@ -42,11 +42,19 @@ public static RunFunctionResponse To(this RunFunctionRequest request, Duration t
             },
             Desired = request.Desired,
             Context = request.Context,
+            Requirements = new()
         };
 
         return resp;
     }
 
+    public static T GetKubeResource<T>(this Resource resource)
+    {
+        var json = JsonFormatter.Default.Format(resource.Resource_);
+
+        return KubernetesJson.Deserialize<T>(json);
+    }
+
     /// <summary>
     /// Get Observed Composite Resource from the supplied request.
     /// </summary>
@@ -55,9 +63,7 @@ public static RunFunctionResponse To(this RunFunctionRequest request, Duration t
     /// <returns></returns>
     public static T? GetObservedCompositeResource<T>(this RunFunctionRequest request)
     {
-        var json = JsonFormatter.Default.Format(request.Observed.Composite.Resource_);
-
-        return KubernetesJson.Deserialize<T>(json);
+        return request.Observed.Composite.GetKubeResource<T>();
     }
 
     /// <summary>
@@ -92,9 +98,7 @@ public static IDictionary<string, Resource> GetDesiredComposedResources(this Run
     {
         if (request.Desired.Resources.TryGetValue(key, out var resource))
         {
-            var json = JsonFormatter.Default.Format(resource.Resource_);
-
-            return KubernetesJson.Deserialize<T>(json);
+            return resource.GetKubeResource<T>();
         }
 
         return default;
@@ -110,9 +114,7 @@ public static IDictionary<string, Resource> GetDesiredComposedResources(this Run
     {
         if (request.Observed.Resources.TryGetValue(key, out var resource))
         {
-            var json = JsonFormatter.Default.Format(resource.Resource_);
-
-            return KubernetesJson.Deserialize<T>(json);
+            return resource.GetKubeResource<T>();
         }
 
         return default;
@@ -124,13 +126,19 @@ public static IDictionary<string, Resource> GetDesiredComposedResources(this Run
     /// <param name="request">The RunFunctionRequest.</param>
     /// <param name="key">The Resource Key</param>
     /// <returns>A Required resource</returns>
-    public static T? GetRequiredResource<T>(this RunFunctionRequest request, string key)
+    public static List<T>? GetRequiredResource<T>(this RunFunctionRequest request, string key)
     {
         if (request.RequiredResources.TryGetValue(key, out var resource))
         {
-            var json = JsonFormatter.Default.Format(resource);
+            var list = new List<T>();
+
+            foreach (var item in resource.Items)
+            {
+                var obj = item.GetKubeResource<T>();
+                list.Add(obj);
+            }
 
-            return KubernetesJson.Deserialize<T>(json);
+            return list;
         }
 
         return default;

tests/Function.SDK.CSharp.Sample.Tests/UnitTest1.cs

@@ -252,7 +252,7 @@ public static void SetCompositeResource(this RunFunctionRequest request, IKubern
 
     public static T GetResource<T>(this State state, string key)
     {
-        string json = JsonFormatter.Default.Format(state.Resources[key].Resource_);
+        var json = JsonFormatter.Default.Format(state.Resources[key].Resource_);
 
         return KubernetesJson.Deserialize<T>(json);
     }