to fix scheduler endpoints signature

Author: fupelaqu

build.sbt

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

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

@@ -18,6 +18,8 @@ import com.softwaremill.session.{
 }
 import org.slf4j.{Logger, LoggerFactory}
 import org.softnetwork.session.model.Session
+import sttp.capabilities
+import sttp.capabilities.akka.AkkaStreams
 import sttp.model.headers.CookieValueWithMeta
 import sttp.model.Method
 import sttp.monad.FutureMonad
@@ -182,15 +184,16 @@ trait SchedulerServiceEndpoints
         }
       }
 
-  override def endpoints: List[ServerEndpoint[Any, Future]] = List(
-    addScheduleEndpoint,
-    removeScheduleEndpoint,
-    listSchedulesEndpoint,
-    addCronTabEndpoint,
-    removeCronTabEndpoint,
-    listCronTabsEndpoint,
-    loadSchedulerEndpoint
-  )
+  override def endpoints: List[ServerEndpoint[AkkaStreams with capabilities.WebSockets, Future]] =
+    List(
+      addScheduleEndpoint,
+      removeScheduleEndpoint,
+      listSchedulesEndpoint,
+      addCronTabEndpoint,
+      removeCronTabEndpoint,
+      listCronTabsEndpoint,
+      loadSchedulerEndpoint
+    )
 
   lazy val route: Route = apiRoute
 }

testkit/src/main/scala/app/softnetwork/scheduler/scalatest/SchedulerEndpointsTestKit.scala

@@ -4,6 +4,8 @@ import akka.actor.typed.ActorSystem
 import app.softnetwork.scheduler.service.SchedulerServiceEndpoints
 import app.softnetwork.session.scalatest.SessionEndpointsRoutes
 import com.softwaremill.session.CsrfCheck
+import sttp.capabilities
+import sttp.capabilities.akka.AkkaStreams
 import sttp.tapir.server.ServerEndpoint
 
 import scala.concurrent.Future
@@ -13,7 +15,8 @@ trait SchedulerEndpointsTestKit extends SessionEndpointsRoutes { _: CsrfCheck =>
   def schedulerEndpoints: ActorSystem[_] => SchedulerServiceEndpoints = system =>
     SchedulerServiceEndpoints.apply(system, sessionEndpoints(system))
 
-  override def endpoints: ActorSystem[_] => List[ServerEndpoint[Any, Future]] = system =>
-    sessionServiceEndpoints(system).endpoints ++ schedulerEndpoints(system).endpoints
+  override def endpoints
+    : ActorSystem[_] => List[ServerEndpoint[AkkaStreams with capabilities.WebSockets, Future]] =
+    system => sessionServiceEndpoints(system).endpoints ++ schedulerEndpoints(system).endpoints
 
 }