upgrade dependencies

Author: fupelaqu

build.sbt

@@ -31,7 +31,7 @@ ThisBuild / organization := "app.softnetwork"
 
 name := "scheduler"
 
-ThisBuild / version := "0.2.5.3"
+ThisBuild / version := "0.2.6"
 
 ThisBuild / scalaVersion := "2.12.15"
 

common/build.sbt

@@ -11,7 +11,7 @@ libraryDependencies ++= Seq(
   // session
   "app.softnetwork.session" %% "session-core" % Versions.session,
   "app.softnetwork.api" %% "generic-server-api" % Versions.server,
-  "app.softnetwork.protobuf" %% "scalapb-extensions" % "0.1.5"
+  "app.softnetwork.protobuf" %% "scalapb-extensions" % "0.1.6"
 )
 
 Compile / unmanagedResourceDirectories += baseDirectory.value / "src/main/protobuf"

core/src/main/scala/app/softnetwork/scheduler/service/SchedulerService.scala

@@ -119,6 +119,17 @@ trait SchedulerService
           case _ => complete(HttpResponse(StatusCodes.BadRequest))
         }
       }
+    } ~ get {
+      loadScheduler() completeWith {
+        case Some(s) =>
+          complete(
+            HttpResponse(
+              StatusCodes.OK,
+              entity = s.cronTabs.toList
+            )
+          )
+        case _ => complete(HttpResponse(StatusCodes.NotFound))
+      }
     }
   }
 

project/src/main/scala/app/softnetwork/sbt/build/Versions.scala

@@ -2,7 +2,7 @@ package app.softnetwork.sbt.build
 
 object Versions {
 
-  val genericPersistence = "0.2.6.1"
+  val genericPersistence = "0.2.6.2"
 
   val akkaPersistenceJdbc = "5.0.4"
 

testkit/src/test/scala/app/softnetwork/scheduler/service/SchedulerServiceSpec.scala

@@ -1,18 +1,44 @@
 package app.softnetwork.scheduler.service
 
+import akka.actor.typed.ActorSystem
 import app.softnetwork.scheduler.model.{CronTab, Schedule}
 import app.softnetwork.scheduler.scalatest.SchedulerRouteTestKit
+import app.softnetwork.serialization
 import org.scalatest.wordspec.AnyWordSpecLike
 
+import scala.concurrent.ExecutionContextExecutor
+import scala.util.{Failure, Success, Try}
+
 class SchedulerServiceSpec extends AnyWordSpecLike with SchedulerRouteTestKit {
 
+  implicit lazy val asystem: ActorSystem[Nothing] = typedSystem()
+
+  implicit lazy val ec: ExecutionContextExecutor = asystem.executionContext
+
   val schedule: Schedule = Schedule("s", "0", "add", 1, Some(true), None, None)
 
   val cronTab: CronTab = CronTab("c", "*", "cron", "* * * * *")
 
+  val json: String =
+    """
+      |{
+      |  "persistenceId": "Order",
+      |  "entityId": "de72dc88-b333-4ff0-a8a1-29aef0ec9810",
+      |  "key": "CancelNonValidatedOrderTimerKey",
+      |  "delay": 1,
+      |  "scheduledDate": "2023-02-03T17:10:09.149Z"
+      |}""".stripMargin
+
   "scheduler service" must {
     "add schedule" in {
       createSession("admin", admin = Some(true))
+      Try(serialization.serialization.read[Schedule](json)) match {
+        case Success(value) =>
+          assert(value.triggerable)
+          assert(!value.removable)
+        case Failure(f) =>
+          fail(f.getMessage)
+      }
       addSchedule(schedule)
     }
     "add cron tab" in {