From d40161530364511bd5f88ec367f513e405b5fe89 Mon Sep 17 00:00:00 2001
From: jem <michael.jerger@meissa-gmbh.de>
Date: Tue, 1 Feb 2022 20:42:39 +0100
Subject: [PATCH] introduce k3sServerConfig

---
 .run/provs-server statistics.prod.run.xml     |  2 +-
 .run/provs-server.run.xml                     |  2 +-
 .../server/application/CliArgumentsParser.kt  | 17 +++++--
 .../provs/server/domain/ConfigFileName.kt     |  3 ++
 .../provs/server/domain/ServerCliCommand.kt   |  3 +-
 .../provs/server/domain/ServerService.kt      |  2 +-
 .../provs/server/domain/k3s/Fqdn.kt           |  6 +++
 .../provs/server/domain/k3s/Ipv4.kt           |  6 +++
 .../provs/server/domain/k3s/Ipv6.kt           |  6 +++
 .../provs/server/domain/k3s/K3sConfig.kt      | 12 +++++
 .../provs/server/domain/k3s/K3sService.kt     | 20 ++++----
 .../provs/server/domain/k3s/Reprovision.kt    |  6 +++
 .../infrastructure/k3s/ConfigRepository.kt    | 30 ++++++++++++
 .../server/infrastructure/k3s/K3sSerial.kt    | 15 ++++++
 .../k3s/ConfigRepositoryTest.kt               | 46 +++++++++++++++++++
 src/test/resources/myK3sServerConfig.yaml     |  4 ++
 16 files changed, 162 insertions(+), 18 deletions(-)
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ConfigFileName.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Fqdn.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv4.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv6.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sConfig.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Reprovision.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepository.kt
 create mode 100644 src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/K3sSerial.kt
 create mode 100644 src/test/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepositoryTest.kt
 create mode 100644 src/test/resources/myK3sServerConfig.yaml

diff --git a/.run/provs-server statistics.prod.run.xml b/.run/provs-server statistics.prod.run.xml
index 3c80f82..4c49865 100644
--- a/.run/provs-server statistics.prod.run.xml	
+++ b/.run/provs-server statistics.prod.run.xml	
@@ -2,7 +2,7 @@
   <configuration default="false" name="provs-server statistics.prod" type="JetRunConfigurationType">
     <option name="MAIN_CLASS_NAME" value="org.domaindrivenarchitecture.provs.server.application.ApplicationKt" />
     <module name="provs.main" />
-    <option name="PROGRAM_PARAMETERS" value="k3s -r statistics.prod.meissa-gmbh.de -u root -k" />
+    <option name="PROGRAM_PARAMETERS" value="k3s -r statistics.prod.meissa-gmbh.de -u root -k myServerKonfig.yaml" />
     <shortenClasspath name="NONE" />
     <method v="2">
       <option name="Make" enabled="true" />
diff --git a/.run/provs-server.run.xml b/.run/provs-server.run.xml
index 4b45005..e541262 100644
--- a/.run/provs-server.run.xml
+++ b/.run/provs-server.run.xml
@@ -2,7 +2,7 @@
   <configuration default="false" name="provs-server statistics.dev" type="JetRunConfigurationType">
     <option name="MAIN_CLASS_NAME" value="org.domaindrivenarchitecture.provs.server.application.ApplicationKt" />
     <module name="provs.main" />
-    <option name="PROGRAM_PARAMETERS" value="k3s -r statistics.test.meissa-gmbh.de -u root -k" />
+    <option name="PROGRAM_PARAMETERS" value="k3s -r statistics.test.meissa-gmbh.de -u root -k myServerKonfig.yaml" />
     <shortenClasspath name="NONE" />
     <method v="2">
       <option name="Make" enabled="true" />
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/application/CliArgumentsParser.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/application/CliArgumentsParser.kt
index f8a0917..1102ca6 100644
--- a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/application/CliArgumentsParser.kt
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/application/CliArgumentsParser.kt
@@ -1,8 +1,10 @@
 package org.domaindrivenarchitecture.provs.server.application
 
+import kotlinx.cli.ArgType
 import kotlinx.cli.Subcommand
 import org.domaindrivenarchitecture.provs.framework.core.cli.CliTargetParser
 import org.domaindrivenarchitecture.provs.framework.core.cli.TargetCliCommand
+import org.domaindrivenarchitecture.provs.server.domain.ConfigFileName
 import org.domaindrivenarchitecture.provs.server.domain.ServerCliCommand
 import org.domaindrivenarchitecture.provs.server.domain.ServerType
 
@@ -29,17 +31,26 @@ class CliArgumentsParser(
                 sshWithPasswordPrompt,
                 sshWithGopassPath,
                 sshWithKey
-            )
+            ),
+            module.configFileName
         )
     }
 
     abstract class ServerSubcommand(name: String, description: String): Subcommand(name, description) {
-        var parsed = false
+        var parsed: Boolean = false
+        var configFileName: ConfigFileName? = null
     }
 
     class K3s: ServerSubcommand("k3s", "the k3s module") {
+        val cliConfigFileName by argument(
+            ArgType.String,
+            "configFilename",
+            "the filename containing the yaml config for k3s"
+        )
+
         override fun execute() {
-            parsed = true
+            super.configFileName = ConfigFileName(cliConfigFileName)
+            super.parsed = true
         }
     }
 
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ConfigFileName.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ConfigFileName.kt
new file mode 100644
index 0000000..a581807
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ConfigFileName.kt
@@ -0,0 +1,3 @@
+package org.domaindrivenarchitecture.provs.server.domain
+
+data class ConfigFileName(val fileName: String)
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerCliCommand.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerCliCommand.kt
index a5305a8..339096a 100644
--- a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerCliCommand.kt
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerCliCommand.kt
@@ -8,7 +8,8 @@ enum class ServerType {
 
 class ServerCliCommand(
     val serverType: ServerType,
-    val target: TargetCliCommand)
+    val target: TargetCliCommand,
+    val configFileName: ConfigFileName?,)
 {
     fun isValid(): Boolean {
         return target.isValid()
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerService.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerService.kt
index 0bd753d..a87f98e 100644
--- a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerService.kt
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/ServerService.kt
@@ -5,6 +5,6 @@ import org.domaindrivenarchitecture.provs.server.domain.k3s.provisionK3s
 
 fun provisionServer(prov: Prov,  cmd: ServerCliCommand) {
     when(cmd.serverType) {
-        ServerType.K3S -> prov.provisionK3s()
+        ServerType.K3S -> prov.provisionK3s(cmd.configFileName)
     }
 }
\ No newline at end of file
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Fqdn.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Fqdn.kt
new file mode 100644
index 0000000..18c5c57
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Fqdn.kt
@@ -0,0 +1,6 @@
+package org.domaindrivenarchitecture.provs.server.domain.k3s
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class Fqdn(val it: String)
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv4.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv4.kt
new file mode 100644
index 0000000..268886b
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv4.kt
@@ -0,0 +1,6 @@
+package org.domaindrivenarchitecture.provs.server.domain.k3s
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class Ipv4(val ip: String)
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv6.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv6.kt
new file mode 100644
index 0000000..6a960ad
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Ipv6.kt
@@ -0,0 +1,6 @@
+package org.domaindrivenarchitecture.provs.server.domain.k3s
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class Ipv6(val ip: String)
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sConfig.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sConfig.kt
new file mode 100644
index 0000000..5c3ea75
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sConfig.kt
@@ -0,0 +1,12 @@
+package org.domaindrivenarchitecture.provs.server.domain.k3s
+
+data class K3sConfig(
+    val fqdn: Fqdn,
+    val nodeIpv4: Ipv4,
+    val nodeIpv6: Ipv6?,
+    val loopbackIpv4: Ipv4? = Ipv4("192.168.5.1"),
+    val loopbackIpv6: Ipv6? = Ipv6("fc00::5:1"),
+    val reprovision: Reprovision? = Reprovision(false)
+) {
+
+}
\ No newline at end of file
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sService.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sService.kt
index 7e98ddc..e6c84ea 100644
--- a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sService.kt
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/K3sService.kt
@@ -1,26 +1,24 @@
 package org.domaindrivenarchitecture.provs.server.domain.k3s
 
 import org.domaindrivenarchitecture.provs.framework.core.Prov
+import org.domaindrivenarchitecture.provs.server.domain.ConfigFileName
 import org.domaindrivenarchitecture.provs.server.infrastructure.*
+import org.domaindrivenarchitecture.provs.server.infrastructure.k3s.getK3sConfig
 
 /**
  * Installs a k3s server.
  * If docker is true, then docker will be installed (may conflict if docker is already existing) and k3s will be installed with docker option.
  * If tlsHost is specified, then tls (if configured) also applies to the specified host.
  */
-fun Prov.provisionK3s() = task {
-    val loopbackIpv4 = "192.168.5.1"
-    val loopbackIpv6 = "fc00::5:1"
-    val nodeIpv4 = "159.69.176.151"
-    val nodeIpv6 = "2a01:4f8:c010:672f::1"
-    val fqdn = "statistics.test.meissa-gmbh.de"
+fun Prov.provisionK3s(configFileName: ConfigFileName?) = task {
+    val k3sConfig: K3sConfig = getK3sConfig(configFileName!!)
 
-    provisionNetwork(loopbackIpv4 = loopbackIpv4, loopbackIpv6 = loopbackIpv6)
-    if (testConfigExists()) {
+    provisionNetwork(loopbackIpv4 = k3sConfig.loopbackIpv4!!.ip, loopbackIpv6 = k3sConfig.loopbackIpv6!!.ip)
+    if (k3sConfig.reprovision!!.it && testConfigExists()) {
         deprovisionK3sInfra()
     }
-    provisionK3sInfra(tlsName = fqdn, nodeIpv4 = nodeIpv4, nodeIpv6 = nodeIpv6,
-        loopbackIpv4 = loopbackIpv4, loopbackIpv6 = loopbackIpv6)
+    provisionK3sInfra(tlsName = k3sConfig.fqdn.it, nodeIpv4 = k3sConfig.nodeIpv4.ip, nodeIpv6 = k3sConfig.nodeIpv6?.ip,
+        loopbackIpv4 = k3sConfig.loopbackIpv4!!.ip, loopbackIpv6 = k3sConfig.loopbackIpv6.ip)
     provisionK3sCertManager(CertManagerEndPoint.STAGING)
-    provisionK3sApple(fqdn, CertManagerEndPoint.STAGING)
+    provisionK3sApple(k3sConfig.fqdn.it, CertManagerEndPoint.STAGING)
 }
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Reprovision.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Reprovision.kt
new file mode 100644
index 0000000..50ea8c0
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/domain/k3s/Reprovision.kt
@@ -0,0 +1,6 @@
+package org.domaindrivenarchitecture.provs.server.domain.k3s
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class Reprovision(val it: Boolean)
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepository.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepository.kt
new file mode 100644
index 0000000..eb535b2
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepository.kt
@@ -0,0 +1,30 @@
+package org.domaindrivenarchitecture.provs.server.infrastructure.k3s
+
+import com.charleskorn.kaml.Yaml
+import kotlinx.serialization.json.Json
+import org.domaindrivenarchitecture.provs.server.domain.ConfigFileName
+import org.domaindrivenarchitecture.provs.server.domain.k3s.*
+import java.io.BufferedReader
+import java.io.FileReader
+
+
+public fun getK3sConfig(configFileName: ConfigFileName): K3sConfig {
+    // read file
+    val inputAsString = BufferedReader(FileReader(configFileName.fileName)).use { it.readText() }
+
+    // deserializing
+    val config =
+        if (configFileName.fileName.lowercase().endsWith(".yaml")) {
+            Yaml.default.decodeFromString(K3sSerial.serializer(), inputAsString)
+        } else {
+            Json.decodeFromString(K3sSerial.serializer(), inputAsString)
+        }
+    return K3sConfig(
+        Fqdn(config.fqdn),
+        Ipv4(config.nodeIpv4),
+        config.nodeIpv6?.let { Ipv6(it) },
+        config.loopbackIpv4?.let { Ipv4(it) },
+        config.loopbackIpv6?.let { Ipv6(it) },
+        config.reprovision?.let { Reprovision(it) }
+    )
+}
\ No newline at end of file
diff --git a/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/K3sSerial.kt b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/K3sSerial.kt
new file mode 100644
index 0000000..b425a27
--- /dev/null
+++ b/src/main/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/K3sSerial.kt
@@ -0,0 +1,15 @@
+package org.domaindrivenarchitecture.provs.server.infrastructure.k3s
+
+import kotlinx.serialization.Serializable
+
+@Serializable
+data class K3sSerial(
+    val fqdn: String,
+    val nodeIpv4: String,
+    val nodeIpv6: String? = null,
+    val loopbackIpv4: String? = null,
+    val loopbackIpv6: String? = null,
+    val reprovision: Boolean? = null
+) {
+
+}
\ No newline at end of file
diff --git a/src/test/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepositoryTest.kt b/src/test/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepositoryTest.kt
new file mode 100644
index 0000000..0131e86
--- /dev/null
+++ b/src/test/kotlin/org/domaindrivenarchitecture/provs/server/infrastructure/k3s/ConfigRepositoryTest.kt
@@ -0,0 +1,46 @@
+package org.domaindrivenarchitecture.provs.server.infrastructure.k3s
+
+import com.charleskorn.kaml.InvalidPropertyValueException
+import com.charleskorn.kaml.UnknownPropertyException
+import org.domaindrivenarchitecture.provs.server.domain.ConfigFileName
+import org.domaindrivenarchitecture.provs.server.domain.k3s.Fqdn
+import org.domaindrivenarchitecture.provs.server.domain.k3s.Ipv4
+import org.domaindrivenarchitecture.provs.server.domain.k3s.Ipv6
+import org.domaindrivenarchitecture.provs.server.domain.k3s.Reprovision
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.Test
+import org.junit.jupiter.api.assertThrows
+import java.io.FileNotFoundException
+
+internal class ConfigRepositoryTest {
+
+    @Test
+    fun getConfig_successful() {
+        // when
+        val config = getK3sConfig(ConfigFileName("src/test/resources/myK3sServerConfig.yaml"))
+
+        // then
+        assertEquals(Ipv4("159.69.176.151"), config.nodeIpv4)
+        assertEquals(Ipv6("2a01:4f8:c010:672f::1"), config.nodeIpv6)
+        assertEquals(Ipv4("192.168.5.1"), config.loopbackIpv4)
+        assertEquals(Ipv6("fc00::5:1"), config.loopbackIpv6)
+        assertEquals(Fqdn("statistics.test.meissa-gmbh.de"), config.fqdn)
+        assertEquals(Reprovision(true), config.reprovision)
+    }
+
+    @Test
+    fun getConfig_fails_due_to_invalidProperty() {
+        assertThrows<UnknownPropertyException> {
+            getK3sConfig(ConfigFileName("src/test/resources/InvalidWorkplaceConfig.yaml"))
+        }
+
+    }
+
+    @Test
+    fun getConfig_fails_due_to_non_existing_file() {
+        assertThrows<FileNotFoundException> {
+            getK3sConfig(ConfigFileName("src/test/resources/Idonotexist.yaml"))
+        }
+
+    }
+}
\ No newline at end of file
diff --git a/src/test/resources/myK3sServerConfig.yaml b/src/test/resources/myK3sServerConfig.yaml
new file mode 100644
index 0000000..d8ffc37
--- /dev/null
+++ b/src/test/resources/myK3sServerConfig.yaml
@@ -0,0 +1,4 @@
+nodeIpv4: 159.69.176.151
+nodeIpv6: 2a01:4f8:c010:672f::1
+fqdn: statistics.test.meissa-gmbh.de
+reprovision: true
\ No newline at end of file