Release 0.12.1

.gitignore

@@ -75,6 +75,7 @@ lib_managed/
 src_managed/
 project/boot/
 project/plugins/project/
+.bsp/
 
 # Scala-IDE specific
 .scala_dependencies

build.sbt

@@ -1,3 +1,5 @@
+organization := "me.arcanis"
+
 name := "ffxivbis"
 
 scalaVersion := "2.13.6"
@@ -5,12 +7,3 @@ scalaVersion := "2.13.6"
 scalacOptions ++= Seq("-deprecation", "-feature")
 
 enablePlugins(JavaAppPackaging)
-
-assemblyMergeStrategy in assembly := {
-  case PathList("META-INF", xs @ _*) => MergeStrategy.discard
-  case "application.conf" => MergeStrategy.concat
-  case "module-info.class" => MergeStrategy.first
-  case x =>
-    val oldStrategy = (assemblyMergeStrategy in assembly).value
-    oldStrategy(x)
-}

project/build.properties

@@ -1 +1 @@
-sbt.version = 1.3.3
+sbt.version = 1.5.8

project/plugins.sbt

@@ -1,4 +1,4 @@
-addSbtPlugin("com.eed3si9n" % "sbt-assembly" % "0.14.6")
 addSbtPlugin("org.scalameta" % "sbt-scalafmt" % "2.4.3")
+addSbtPlugin("org.scoverage" % "sbt-scoverage" % "1.9.3")
 addSbtPlugin("com.typesafe.sbt" % "sbt-native-packager" % "1.3.4")
-addSbtPlugin("net.virtual-void" % "sbt-dependency-graph" % "0.10.0-RC1")
+addDependencyTreePlugin

src/main/resources/logback.xml

@@ -11,6 +11,6 @@
         <appender-ref ref="http" />
     </logger>
     <logger name="org.flywaydb.core.internal" level="INFO" />
-    <logger name="com.zaxxer.hikari.pool.HikariPool" level="INFO" />
+    <logger name="com.zaxxer.hikari.pool" level="INFO" />
 
 </configuration>

src/main/scala/me/arcanis/ffxivbis/http/HttpLog.scala

@@ -13,8 +13,8 @@ import akka.http.scaladsl.server.Directive0
 import akka.http.scaladsl.server.Directives.{extractClientIP, extractRequestContext, mapResponse, optionalHeaderValueByType}
 import com.typesafe.scalalogging.Logger
 
-import java.time.{Instant, ZoneId}
 import java.time.format.DateTimeFormatter
+import java.time.{Instant, ZoneId}
 import java.util.Locale
 
 trait HttpLog {
@@ -68,7 +68,7 @@ object HttpLog {
 
   val httpLogDatetimeFormatter: DateTimeFormatter =
     DateTimeFormatter
-      .ofPattern("dd/MMM/uuuu:HH:mm:ss xx  ")
+      .ofPattern("dd/MMM/uuuu:HH:mm:ss xx")
       .withLocale(Locale.UK)
       .withZone(ZoneId.systemDefault())
 }

src/main/scala/me/arcanis/ffxivbis/http/RootEndpoint.scala

@@ -25,7 +25,7 @@ class RootEndpoint(system: ActorSystem[Nothing], storage: ActorRef[Message], pro
   private val config = system.settings.config
 
   implicit val scheduler: Scheduler = system.scheduler
-  implicit val timeout: Timeout = config.getDuration("me.arcanis.ffxivbis.settings.request-timeout")
+  implicit val timeout: Timeout = config.getTimeout("me.arcanis.ffxivbis.settings.request-timeout")
 
   private val auth = AuthorizationProvider(config, storage, timeout, scheduler)
 

src/main/scala/me/arcanis/ffxivbis/http/Swagger.scala

@@ -22,6 +22,7 @@ class Swagger(config: Config) extends SwaggerHttpService {
     classOf[api.v1.LootEndpoint],
     classOf[api.v1.PartyEndpoint],
     classOf[api.v1.PlayerEndpoint],
+    classOf[api.v1.StatusEndpoint],
     classOf[api.v1.TypesEndpoint],
     classOf[api.v1.UserEndpoint]
   )
@@ -35,7 +36,7 @@ class Swagger(config: Config) extends SwaggerHttpService {
 
   override val host: String =
     if (config.hasPath("me.arcanis.ffxivbis.web.hostname")) config.getString("me.arcanis.ffxivbis.web.hostname")
-    else s"${config.getString("me.arcanis.ffxivbis.web.host")}:${config.getString("me.arcanis.ffxivbis.web.port")}"
+    else s"${config.getString("me.arcanis.ffxivbis.web.host")}:${config.getInt("me.arcanis.ffxivbis.web.port")}"
 
   private val basicAuth = new SecurityScheme()
     .description("basic http auth")

src/main/scala/me/arcanis/ffxivbis/http/api/v1/RootApiV1Endpoint.scala

@@ -32,14 +32,15 @@ class RootApiV1Endpoint(
   private val lootEndpoint = new LootEndpoint(storage, auth)
   private val partyEndpoint = new PartyEndpoint(storage, provider, auth)
   private val playerEndpoint = new PlayerEndpoint(storage, provider, auth)
+  private val statusEndpoint = new StatusEndpoint
   private val typesEndpoint = new TypesEndpoint(config)
   private val userEndpoint = new UserEndpoint(storage, auth)
 
   def route: Route =
     handleExceptions(exceptionHandler) {
       handleRejections(rejectionHandler) {
-        biSEndpoint.route ~ lootEndpoint.route ~ partyEndpoint.route ~
+        biSEndpoint.route ~ lootEndpoint.route ~ partyEndpoint.route ~ playerEndpoint.route ~
-          playerEndpoint.route ~ typesEndpoint.route ~ userEndpoint.route
+          statusEndpoint.route ~ typesEndpoint.route ~ userEndpoint.route
       }
     }
 }

src/main/scala/me/arcanis/ffxivbis/http/api/v1/StatusEndpoint.scala

@@ -0,0 +1,54 @@
+/*
+ * Copyright (c) 2019-2022 Evgeniy Alekseev.
+ *
+ * This file is part of ffxivbis
+ * (see https://github.com/arcan1s/ffxivbis).
+ *
+ * License: 3-clause BSD, see https://opensource.org/licenses/BSD-3-Clause
+ */
+package me.arcanis.ffxivbis.http.api.v1
+
+import akka.http.scaladsl.server.Directives._
+import akka.http.scaladsl.server._
+import io.swagger.v3.oas.annotations.Operation
+import io.swagger.v3.oas.annotations.media.{Content, Schema}
+import io.swagger.v3.oas.annotations.responses.ApiResponse
+import jakarta.ws.rs._
+import me.arcanis.ffxivbis.http.api.v1.json._
+
+@Path("/api/v1")
+class StatusEndpoint extends JsonSupport {
+
+  def route: Route = getServerStatus
+
+  @GET
+  @Path("status")
+  @Produces(value = Array("application/json"))
+  @Operation(
+    summary = "server status",
+    description = "Returns the server status descriptor",
+    responses = Array(
+      new ApiResponse(
+        responseCode = "200",
+        description = "Service status descriptor",
+        content = Array(new Content(schema = new Schema(implementation = classOf[StatusModel])))
+      ),
+      new ApiResponse(
+        responseCode = "500",
+        description = "Internal server error",
+        content = Array(new Content(schema = new Schema(implementation = classOf[ErrorModel])))
+      ),
+    ),
+    tags = Array("status"),
+  )
+  def getServerStatus: Route =
+    path("status") {
+      get {
+        complete {
+          StatusModel(
+            version = Option(getClass.getPackage.getImplementationVersion),
+          )
+        }
+      }
+    }
+}

src/main/scala/me/arcanis/ffxivbis/http/api/v1/json/JsonSupport.scala

@@ -52,5 +52,6 @@ trait JsonSupport extends SprayJsonSupport with DefaultJsonProtocol {
   implicit val playerBiSLinkFormat: RootJsonFormat[PlayerBiSLinkModel] = jsonFormat2(PlayerBiSLinkModel.apply)
   implicit val playerIdWithCountersFormat: RootJsonFormat[PlayerIdWithCountersModel] =
     jsonFormat9(PlayerIdWithCountersModel.apply)
+  implicit val statusFormat: RootJsonFormat[StatusModel] = jsonFormat1(StatusModel.apply)
   implicit val userFormat: RootJsonFormat[UserModel] = jsonFormat4(UserModel.apply)
 }

src/main/scala/me/arcanis/ffxivbis/http/api/v1/json/StatusModel.scala

@@ -0,0 +1,13 @@
+/*
+ * Copyright (c) 2019-2022 Evgeniy Alekseev.
+ *
+ * This file is part of ffxivbis
+ * (see https://github.com/arcan1s/ffxivbis).
+ *
+ * License: 3-clause BSD, see https://opensource.org/licenses/BSD-3-Clause
+ */
+package me.arcanis.ffxivbis.http.api.v1.json
+
+import io.swagger.v3.oas.annotations.media.Schema
+
+case class StatusModel(@Schema(description = "server version") version: Option[String])

src/main/scala/me/arcanis/ffxivbis/service/PartyService.scala

@@ -24,14 +24,14 @@ class PartyService(context: ActorContext[Message], storage: ActorRef[DatabaseMes
   with StrictLogging {
   import me.arcanis.ffxivbis.utils.Implicits._
 
-  private val cacheTimeout: FiniteDuration =
+  private val cacheTimeout =
-    context.system.settings.config.getDuration("me.arcanis.ffxivbis.settings.cache-timeout")
+    context.system.settings.config.getFiniteDuration("me.arcanis.ffxivbis.settings.cache-timeout")
   implicit private val executionContext: ExecutionContext = {
     val selector = DispatcherSelector.fromConfig("me.arcanis.ffxivbis.default-dispatcher")
     context.system.dispatchers.lookup(selector)
   }
   implicit private val timeout: Timeout =
-    context.system.settings.config.getDuration("me.arcanis.ffxivbis.settings.request-timeout")
+    context.system.settings.config.getTimeout("me.arcanis.ffxivbis.settings.request-timeout")
   implicit private val scheduler: Scheduler = context.system.scheduler
 
   override def onMessage(msg: Message): Behavior[Message] = handle(Map.empty)(msg)

src/main/scala/me/arcanis/ffxivbis/utils/Implicits.scala

@@ -11,7 +11,6 @@ package me.arcanis.ffxivbis.utils
 import akka.util.Timeout
 import com.typesafe.config.Config
 
-import java.time.Duration
 import java.util.concurrent.TimeUnit
 import scala.concurrent.duration.FiniteDuration
 import scala.language.implicitConversions
@@ -19,20 +18,14 @@ import scala.util.Try
 
 object Implicits {
 
-  implicit def getBooleanFromOptionString(maybeYes: Option[String]): Boolean = maybeYes.map(_.toLowerCase) match {
-    case Some("yes" | "on") => true
-    case _ => false
-  }
-
-  implicit def getFiniteDuration(duration: Duration): FiniteDuration =
-    FiniteDuration(duration.toNanos, TimeUnit.NANOSECONDS)
-
-  implicit def getTimeout(duration: Duration): Timeout =
-    FiniteDuration(duration.toNanos, TimeUnit.NANOSECONDS)
-
   implicit class ConfigExtension(config: Config) {
 
+    def getFiniteDuration(path: String): FiniteDuration =
+      FiniteDuration(config.getDuration(path, TimeUnit.MILLISECONDS), TimeUnit.MILLISECONDS)
+
     def getOptString(path: String): Option[String] =
       Try(config.getString(path)).toOption.filter(_.nonEmpty)
+
+    def getTimeout(path: String): Timeout = getFiniteDuration(path)
   }
 }

src/test/scala/me/arcanis/ffxivbis/http/api/v1/StatusEndpointTest.scala

@@ -0,0 +1,29 @@
+package me.arcanis.ffxivbis.http.api.v1
+
+import akka.http.scaladsl.model.StatusCodes
+import akka.http.scaladsl.testkit.ScalatestRouteTest
+import com.typesafe.config.Config
+import me.arcanis.ffxivbis.Settings
+import me.arcanis.ffxivbis.http.api.v1.json._
+import org.scalatest.matchers.should.Matchers
+import org.scalatest.wordspec.AnyWordSpecLike
+
+import scala.language.postfixOps
+
+class StatusEndpointTest extends AnyWordSpecLike
+  with Matchers with ScalatestRouteTest with JsonSupport {
+
+  override val testConfig: Config = Settings.withRandomDatabase
+
+  private val route = new StatusEndpoint().route
+
+  "api v1 status endpoint" must {
+
+    "return server status" in {
+      Get("/status") ~> route ~> check {
+        status shouldEqual StatusCodes.OK
+      }
+    }
+
+  }
+}

version.sbt

@@ -1 +1 @@
-version := "0.11.1"
+version := "0.12.1"