Proof of concept - add API to patch config

build.sbt

@@ -14,6 +14,7 @@ val circeGenericExtrasVersion = "0.14.3"
 val circeVersion = "0.14.6"
 val fs2Version = "3.7.0"
 val http4sVersion = "0.23.23"
+val ip4sVersion = "3.3.0"
 val logbackVersion = "1.4.11"
 val scalamockVersion = "5.2.0"
 val scalatestVersion = "3.2.17"
@@ -26,10 +27,14 @@ libraryDependencies ++= Seq(
   "org.scala-lang" % "scala-library" % scalaVersion.value % "provided",
   "ch.qos.logback" % "logback-classic" % logbackVersion % Runtime,
   "org.slf4j" % "slf4j-api" % slf4jVersion,
+  "com.comcast" %% "ip4s-core" % ip4sVersion,
   "org.http4s" %% "http4s-ember-client" % http4sVersion,
+  "org.http4s" %% "http4s-ember-server" % http4sVersion,
+  "org.http4s" %% "http4s-dsl" % http4sVersion,
   "org.http4s" %% "http4s-circe" % http4sVersion,
   "org.http4s" %% "http4s-client" % http4sVersion,
   "org.http4s" %% "http4s-core" % http4sVersion,
+  "org.http4s" %% "http4s-server" % http4sVersion,
   "co.fs2" %% "fs2-core" % fs2Version,
   "co.fs2" %% "fs2-io" % fs2Version,
   "com.chuusai" %% "shapeless" % shapelessVersion,

src/main/scala/Routes.scala

@@ -0,0 +1,28 @@
+import cats.effect._
+import configuration.{Configuration, ConfigurationRedactor, ConfigurationUtils, MapAndFileAndSystemPropertyReader}
+import http.HttpClient
+import org.http4s._
+import org.http4s.circe.CirceEntityCodec.circeEntityDecoder
+import org.http4s.dsl.io._
+import org.slf4j.LoggerFactory
+
+object Routes {
+
+  private val logger = LoggerFactory.getLogger(getClass)
+  private def routes(configRef: Ref[IO, Configuration], client: HttpClient): HttpRoutes[IO] = HttpRoutes.of[IO] {
+
+    case req @ PATCH -> Root / "config" =>
+      logger.info(s"Received request: $req")
+      val result = for {
+        rawConfiguration <- req.as[Map[String, String]]
+        _ = logger.info(s"Parsed into $rawConfiguration")
+        newConfiguration <- ConfigurationUtils.create(new MapAndFileAndSystemPropertyReader(rawConfiguration), client)
+        _ = logger.info(s"New configuration: $newConfiguration")
+        _ <- configRef.set(newConfiguration)
+      } yield newConfiguration
+
+      Ok(result.map(ConfigurationRedactor.redactToString))
+  }
+
+  def service(configRef: Ref[IO, Configuration], client: HttpClient): HttpRoutes[IO] = routes(configRef, client)
+}

src/main/scala/Server.scala

@@ -1,8 +1,11 @@
 
 import cats.effect._
-import cats.implicits.catsSyntaxTuple3Parallel
-import configuration.{Configuration, ConfigurationUtils, FileAndSystemPropertyReader, SystemPropertyReader}
+import cats.implicits.catsSyntaxTuple4Parallel
+import com.comcast.ip4s.IpLiteralSyntax
+import configuration.{Configuration, ConfigurationUtils, FileAndSystemPropertyReader}
 import http.HttpClient
+import org.http4s.ember.server.EmberServerBuilder
+import org.http4s.server.middleware.CORS
 import org.slf4j.LoggerFactory
 
 import java.nio.channels.ClosedChannelException
@@ -25,13 +28,22 @@ object Server extends IOApp {
       initialConfig <- ConfigurationUtils.create(configReader, httpClient)
       configRef <- Ref.of[IO, Configuration](initialConfig)
       result <- (
+        server(configRef, httpClient),
         pingTokenSync(configRef, httpClient),
         plexTokenSync(configRef, httpClient),
         plexTokenDeleteSync(configRef, httpClient)
       ).parTupled.as(ExitCode.Success)
     } yield result
   }
 
+  private def server(configRef: Ref[IO, Configuration], client: HttpClient) = EmberServerBuilder
+    .default[IO]
+    .withHost(ipv4"0.0.0.0")
+    .withPort(port"3434")
+    .withHttpApp(CORS(Routes.service(configRef, client).orNotFound))
+    .build
+    .use(_ => IO.never)
+
   private def fetchLatestConfig(configRef: Ref[IO, Configuration]): IO[Configuration] =
     configRef.get
 

src/main/scala/configuration/MapReader.scala

@@ -0,0 +1,8 @@
+package configuration
+
+class MapAndFileAndSystemPropertyReader(map: Map[String, String]) extends ConfigurationReader {
+  override def getConfigOption(key: String): Option[String] = map.get(key) match {
+    case r@Some(_) => r
+    case None => FileAndSystemPropertyReader.getConfigOption(key)
+  }
+}