k8s api

kubernetes-client/csharp#78

Author: RouR

ExampleTDTB.sln

@@ -1,7 +1,7 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
 # Visual Studio 15
-VisualStudioVersion = 15.0.27130.2010
+VisualStudioVersion = 15.0.27130.2020
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Web", "src\Web\Web.csproj", "{B27DD2E5-C587-444A-A535-CA8AC3605AE2}"
 EndProject
@@ -13,7 +13,9 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "tests", "tests", "{BD7B76F7
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Tools", "Tools", "{261F76A5-DF6B-4B25-9A88-8BDA0D797C34}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "DockerHubChecker", "src\DockerHubChecker\DockerHubChecker.csproj", "{E2D0FEB8-70BF-409B-85C5-4A58420F7A19}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "DockerHubChecker", "src\DockerHubChecker\DockerHubChecker.csproj", "{E2D0FEB8-70BF-409B-85C5-4A58420F7A19}"
+EndProject
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "KubernetesClient", "src\k8sApi\KubernetesClient.csproj", "{BA08576C-3F8F-44E8-B335-C71CD353D211}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -29,6 +31,10 @@ Global
 		{E2D0FEB8-70BF-409B-85C5-4A58420F7A19}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{E2D0FEB8-70BF-409B-85C5-4A58420F7A19}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{E2D0FEB8-70BF-409B-85C5-4A58420F7A19}.Release|Any CPU.Build.0 = Release|Any CPU
+		{BA08576C-3F8F-44E8-B335-C71CD353D211}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{BA08576C-3F8F-44E8-B335-C71CD353D211}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{BA08576C-3F8F-44E8-B335-C71CD353D211}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{BA08576C-3F8F-44E8-B335-C71CD353D211}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -38,6 +44,7 @@ Global
 		{92641CE6-1981-4B33-B778-7A23A4E68FCA} = {BD6146CB-DDB4-42C1-934A-102E5D5DC104}
 		{261F76A5-DF6B-4B25-9A88-8BDA0D797C34} = {BD6146CB-DDB4-42C1-934A-102E5D5DC104}
 		{E2D0FEB8-70BF-409B-85C5-4A58420F7A19} = {261F76A5-DF6B-4B25-9A88-8BDA0D797C34}
+		{BA08576C-3F8F-44E8-B335-C71CD353D211} = {261F76A5-DF6B-4B25-9A88-8BDA0D797C34}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {60475545-BB2D-4640-BE30-0A4289C1C368}

src/DockerHubChecker/DockerHubChecker.csproj

@@ -6,9 +6,12 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="KubernetesClient" Version="0.3.0-beta" />
-    <PackageReference Include="Newtonsoft.Json" Version="10.0.3" />
+    <PackageReference Include="Microsoft.AspNetCore.JsonPatch" Version="2.0.0" />
     <PackageReference Include="RestSharp" Version="106.2.1" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\k8sApi\KubernetesClient.csproj" />
+  </ItemGroup>
+
 </Project>

src/DockerHubChecker/Program.cs

@@ -1,11 +1,17 @@
 using System;
+using System.Collections.Generic;
 using System.IO;
 using System.Linq;
 using System.Runtime.InteropServices;
 using System.Text.RegularExpressions;
 using System.Threading;
 using k8s;
+using k8s.Models;
+using Microsoft.AspNetCore.JsonPatch;
 
+//using Marvin.JsonPatch;
+
+//Install-Package KubernetesClient -Version 0.3.0-beta
 
 namespace DockerHubChecker
 {
@@ -18,14 +24,21 @@ private static string DetectNamespace()
         {
 
             var envHost = Environment.GetEnvironmentVariable(EnvName);
+            if(string.IsNullOrWhiteSpace(envHost))
+                throw new ArgumentNullException(nameof(envHost));
             return envHost;
             //return new Regex("kubernetes.(?<name>.*).svc.cluster.local").Match(envHost).Groups["name"].Value;
         }
 
 
         private static void CheckNamespace(string k8Namespace)
         {
+#if DEBUG
+            var config = KubernetesClientConfiguration.BuildConfigFromConfigFile();
+#else
             var config = KubernetesClientConfiguration.InClusterConfig();
+#endif
+
             IKubernetes client = new Kubernetes(config);
             Console.WriteLine("Starting Request to Kubernetes!");
 
@@ -55,6 +68,22 @@ private static void CheckNamespace(string k8Namespace)
                     Console.WriteLine($"\t\t\tFound!");
                     var images = item.Spec.Template.Spec.Containers.Select(x => x.Image);
                     Console.WriteLine($"\t\t\tImages = {string.Join("; ", images)}");
+
+                    //client.PatchNamespacedDeployment(new
+                    //{
+                    //    op = "replace",
+                    //    path = "/spec/template/metadata/labels/" + ciLabel.Key,
+                    //    value = DateTime.UtcNow.ToString("O")
+                    //}, item.Metadata.Name, "default"); //fail!
+
+                    var newlables = new Dictionary<string, string>(item.Spec.Template.Metadata.Labels)
+                    {
+                        //todo: get time from docker
+                        [ciLabel.Key] = DateTime.UtcNow.ToString("O").Replace(".","").Replace(":","").Replace("-","") //some symbols is not allowed
+                    };
+                    var patch = new JsonPatchDocument<Appsv1beta1Deployment>();
+                    patch.Replace(e => e.Spec.Template.Metadata.Labels, newlables);
+                    client.PatchNamespacedDeployment(patch, item.Metadata.Name, k8Namespace);
                 }
 
                 foreach (var container in item.Spec.Template.Spec.Containers)

src/Marvin.JsonPatch/Adapters/IObjectAdapter.cs

@@ -0,0 +1,20 @@
+// Any comments, input: @KevinDockx
+// Any issues, requests: https://github.com/KevinDockx/JsonPatch
+//
+// Enjoy :-)
+
+using Marvin.JsonPatch.Operations;
+
+namespace Marvin.JsonPatch.Adapters
+{
+    public interface IObjectAdapter
+    {
+        void Add(Operation operation, object objectToApplyTo);
+        void Copy(Operation operation, object objectToApplyTo);
+        void Move(Operation operation, object objectToApplyTo);
+        void Remove(Operation operation, object objectToApplyTo);
+        void Replace(Operation operation, object objectToApplyTo);
+    }
+
+   
+}