@@ -17,7 +17,6 @@ import io.grpc.Status
1717import io.grpc.StatusException
1818import org.apache.logging.log4j.LogManager
1919import java.time.LocalDateTime
20- import java.time.ZoneOffset
2120import java.util.*
2221
2322class ServerService (
@@ -334,7 +333,7 @@ class ServerService(
334333 ? : throw StatusException (Status .NOT_FOUND .withDescription(" No server was found matching this id." ))
335334
336335 request.since?.let { sinceTimestamp ->
337- val sinceLocalDateTime = LocalDateTime .ofEpochSecond (sinceTimestamp.seconds, sinceTimestamp.nanos, ZoneOffset . UTC )
336+ val sinceLocalDateTime = ProtobufTimestamp .toLocalDateTime (sinceTimestamp)
338337 if (server.createdAt.isBefore(sinceLocalDateTime)) {
339338 return server.toDefinition()
340339 }
@@ -350,14 +349,14 @@ class ServerService(
350349
351350 override suspend fun stopServersByGroupWithTimeout (request : StopServersByGroupWithTimeoutRequest ): StopServersByGroupResponse {
352351 val sinceLocalDateTime = request.since?.let {
353- LocalDateTime .ofEpochSecond (it.seconds, it.nanos, ZoneOffset . UTC )
352+ ProtobufTimestamp .toLocalDateTime (it)
354353 }
355354 return stopServersByGroup(request.groupName, request.timeoutSeconds, request.stopCause, sinceLocalDateTime)
356355 }
357356
358357 override suspend fun stopServersByGroup (request : StopServersByGroupRequest ): StopServersByGroupResponse {
359358 val sinceLocalDateTime = request.since?.let {
360- LocalDateTime .ofEpochSecond (it.seconds, it.nanos, ZoneOffset . UTC )
359+ ProtobufTimestamp .toLocalDateTime (it)
361360 }
362361 return stopServersByGroup(request.groupName, null , request.stopCause, sinceLocalDateTime)
363362 }
0 commit comments