First draft of kubernetes file browser

2026-04-11 21:08:22 +02:00 · 2023-07-30 04:52:53 +02:00
commit 9fd5f5cbd8
20 changed files with 765 additions and 0 deletions
--- a/K8sFileBrowser/Services/KubernetesService.cs
+++ b/K8sFileBrowser/Services/KubernetesService.cs
@@ -0,0 +1,100 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using k8s;
+using k8s.KubeConfigModels;
+using K8sFileBrowser.Models;
+using Serilog;
+
+namespace K8sFileBrowser.Services;
+
+public class KubernetesService
+{
+    private readonly K8SConfiguration _k8SConfiguration;
+    private IKubernetes _kubernetesClient = null!;
+
+    public KubernetesService()
+    {
+        _k8SConfiguration = KubernetesClientConfiguration.LoadKubeConfig();
+        CreateKubernetesClient();
+    }
+
+    public IEnumerable<ClusterContext> GetClusterContexts()
+    {
+        return _k8SConfiguration.Contexts.Select(c => new ClusterContext { Name = c.Name }).ToList();
+    }
+
+    public string GetCurrentContext()
+    {
+        return _k8SConfiguration.CurrentContext;
+    }
+
+    public void SwitchClusterContext(ClusterContext clusterContext)
+    {
+        CreateKubernetesClient(clusterContext);
+    }
+
+    public IEnumerable<Namespace> GetNamespaces()
+    {
+        var namespaces = _kubernetesClient.CoreV1.ListNamespace();
+        var namespaceList = namespaces != null
+            ? namespaces.Items.Select(n => new Namespace { Name = n.Metadata.Name }).ToList()
+            : new List<Namespace>();
+        return namespaceList;
+    }
+
+    public IEnumerable<Pod> GetPods(string namespaceName)
+    {
+        var pods = _kubernetesClient.CoreV1.ListNamespacedPod(namespaceName);
+        var podList = pods != null
+            ? pods.Items.Select(n => 
+                new Pod
+                {
+                    Name = n.Metadata.Name,
+                    Containers = n.Spec.Containers.Select(c => c.Name).ToList()
+                }).ToList()
+            : new List<Pod>();
+        return podList;
+    }
+    
+    public IList<FileInformation> GetFiles(string namespaceName, string podName, string containerName, string path)
+    {
+        try
+        {
+            var execResult = new KubernetesFileInformationResult(path);
+            var resultCode = _kubernetesClient
+                .NamespacedPodExecAsync(
+                    podName, namespaceName, containerName, 
+                    new[] { "find", path, "-maxdepth", "1", "-exec", "stat", "-c", "%F|%n|%s|%Y", "{}", ";" }, 
+                    true,
+                    execResult.ParseFileInformationCallback, CancellationToken.None)
+                .ConfigureAwait(false)
+                .GetAwaiter()
+                .GetResult();
+            return execResult.FileInformations;
+        }
+        catch (Exception e)
+        {
+            Log.Error(e, "exception while getting files");
+            return new List<FileInformation>();
+        }
+    }
+
+    private void CreateKubernetesClient(ClusterContext? clusterContext = null)
+    {
+        var clusterContextName = clusterContext == null ? _k8SConfiguration.CurrentContext : clusterContext.Name;
+        var kubernetesClientConfiguration =
+            KubernetesClientConfiguration.BuildConfigFromConfigFile(currentContext: clusterContextName);
+        var kubernetesClient = new Kubernetes(kubernetesClientConfiguration);
+        _kubernetesClient = kubernetesClient;
+    }
+
+
+    public void DownloadFile(Namespace? selectedNamespace, Pod? selectedPod, FileInformation selectedFile, string? saveFileName)
+    {
+        Log.Information($"{selectedNamespace} - {selectedPod} - {selectedFile} - {saveFileName}");
+        
+        // TODO: this is done with Tar 
+    }
+}