feat: add CORS management

service-discovery-proxy/app/src/CorsHandler.scala

@@ -0,0 +1,62 @@
+package fr.inrae.metabohub.app
+
+import cask.main.Main
+import cask.internal.DispatchTrie
+import cask.util.Logger
+import cask.main.Routes
+import cask.router.EndpointMetadata
+import cask.router.Decorator
+import cask.model.Response
+import cask.router.Result
+import com.typesafe.config.ConfigFactory._
+//import com.typesafe.scalalogging.LazyLogging
+
+import io.undertow.Undertow
+import io.undertow.server.HttpServerExchange
+import io.undertow.server.handlers.BlockingHandler
+import io.undertow.util.Headers
+import io.undertow.util.HttpString
+
+import java.util.concurrent.TimeUnit
+
+import scala.concurrent.duration._
+import scala.io.StdIn
+import scala.jdk.CollectionConverters._
+
+object CorsHandler {
+  val accessControlAllowOrigin = new HttpString("Access-Control-Allow-Origin")
+  val accessControlAllowCredentials = new HttpString("Access-Control-Allow-Credentials")
+  val acccessControlAllowHeaders = new HttpString("Access-Control-Allow-Headers")
+  val accessControlAllowMethods = new HttpString("Access-Control-Allow-Methods")
+
+  val origin = "*"
+  val accepted = "true"
+  val headers = Set("Authorization", "Content-Type", "X-Requested-With").asJava
+  val methods = Set("POST", "GET", "PUT", "DELETE", "PATCH", "HEAD", "OPTIONS").asJava
+}
+
+case class CorsHandler(dispatchTrie: DispatchTrie[Map[String, (Routes, EndpointMetadata[_])]],
+                    mainDecorators: Seq[Decorator[_, _, _]],
+                    debugMode: Boolean,
+                    handleNotFound: () => Response.Raw,
+                    handleMethodNotAllowed: () => Response.Raw,
+                    handleError: (Routes, EndpointMetadata[_], Result.Error) => Response.Raw)
+    extends Main.DefaultHandler(dispatchTrie,
+      mainDecorators,
+      debugMode,
+      handleNotFound,
+      handleMethodNotAllowed,
+      handleError)(new Logger.Console()) {
+
+
+  override def handleRequest(exchange: HttpServerExchange): Unit = {
+    exchange.getResponseHeaders
+      .put(CorsHandler.accessControlAllowOrigin, CorsHandler.origin)
+      .put(CorsHandler.accessControlAllowCredentials, CorsHandler.accepted)
+      .putAll(CorsHandler.acccessControlAllowHeaders, CorsHandler.headers)
+      .putAll(CorsHandler.accessControlAllowMethods, CorsHandler.methods)
+    super.handleRequest(exchange)
+  }
+
+
+}

service-discovery-proxy/app/src/SWDiscoveryProxy.scala

@@ -3,6 +3,7 @@ package fr.inrae.metabohub.app
 import cask.main.Main
 import fr.inrae.metabohub.semantic_web.{SWDiscoveryVersionAtBuildTime, SWTransaction}
 import io.undertow.Undertow
+import io.undertow.server.handlers.BlockingHandler
 import ujson.Value
 import wvlet.log.Logger.rootLogger.info
 
@@ -13,6 +14,14 @@ object SWDiscoveryProxy extends cask.MainRoutes{
 
   var _server : Option[Undertow] = None
 
+  override def defaultHandler: BlockingHandler =
+    new BlockingHandler( CorsHandler(dispatchTrie,
+      mainDecorators,
+      debugMode = false,
+      handleNotFound,
+      handleMethodNotAllowed,
+      handleEndpointError) )
+
   import scopt.OParser
 
   case class Config(