feat: stop servers started after specific Timestamp

Author: Kaseax

controller-runtime/src/main/kotlin/app/simplecloud/controller/runtime/server/ServerService.kt

@@ -17,6 +17,7 @@ import io.grpc.Status
 import io.grpc.StatusException
 import org.apache.logging.log4j.LogManager
 import java.time.LocalDateTime
+import java.time.ZoneOffset
 import java.util.*
 
 class ServerService(
@@ -331,6 +332,14 @@ class ServerService(
     override suspend fun stopServer(request: StopServerRequest): ServerDefinition {
         val server = serverRepository.find(request.serverId)
             ?: throw StatusException(Status.NOT_FOUND.withDescription("No server was found matching this id."))
+
+        request.since?.let { sinceTimestamp ->
+            val sinceLocalDateTime = LocalDateTime.ofEpochSecond(sinceTimestamp.seconds, sinceTimestamp.nanos, ZoneOffset.UTC)
+            if (server.createdAt.isBefore(sinceLocalDateTime)) {
+                return server.toDefinition()
+            }
+        }
+
         try {
             val stopped = stopServer(server.toDefinition(), request.stopCause)
             return stopped
@@ -340,21 +349,30 @@ class ServerService(
     }
 
     override suspend fun stopServersByGroupWithTimeout(request: StopServersByGroupWithTimeoutRequest): StopServersByGroupResponse {
-        return stopServersByGroup(request.groupName, request.timeoutSeconds, request.stopCause)
+        val sinceLocalDateTime = request.since?.let {
+            LocalDateTime.ofEpochSecond(it.seconds, it.nanos, ZoneOffset.UTC)
+        }
+        return stopServersByGroup(request.groupName, request.timeoutSeconds, request.stopCause, sinceLocalDateTime)
     }
 
     override suspend fun stopServersByGroup(request: StopServersByGroupRequest): StopServersByGroupResponse {
-        return stopServersByGroup(request.groupName, null, request.stopCause)
+        val sinceLocalDateTime = request.since?.let {
+            LocalDateTime.ofEpochSecond(it.seconds, it.nanos, ZoneOffset.UTC)
+        }
+        return stopServersByGroup(request.groupName, null, request.stopCause, sinceLocalDateTime)
     }
 
     private suspend fun stopServersByGroup(
         groupName: String,
         timeout: Int?,
-        cause: ServerStopCause = ServerStopCause.NATURAL_STOP
+        cause: ServerStopCause = ServerStopCause.NATURAL_STOP,
+        since: LocalDateTime? = null
     ): StopServersByGroupResponse {
         val group = groupRepository.find(groupName)
             ?: throw StatusException(Status.NOT_FOUND.withDescription("No group was found matching this name. $groupName"))
         val groupServers = serverRepository.findServersByGroup(group.name)
+            .filter { since == null || it.createdAt.isAfter(since) }
+
         if (groupServers.isEmpty()) {
             throw StatusException(Status.NOT_FOUND.withDescription("No server was found matching this group name. ${group.name}"))
         }

gradle/libs.versions.toml

@@ -3,7 +3,7 @@ kotlin = "2.0.20"
 kotlin-coroutines = "1.9.0"
 shadow = "8.3.3"
 log4j = "2.20.0"
-droplet-api = "0.0.1-dev.4d43f53"
+droplet-api = "0.0.1-dev.16b322c"
 simplecloud-pubsub = "1.0.5"
 simplecloud-metrics = "1.0.0"
 jooq = "3.19.3"