feat: add firstSeen method to player data handling and update related services

Author: twisti-dev

surf-cloud-api/surf-cloud-api-common/src/main/kotlin/dev/slne/surf/cloud/api/common/player/OfflineCloudPlayer.kt

@@ -17,6 +17,7 @@ interface OfflineCloudPlayer {
     suspend fun lastServerRaw(): String?
     suspend fun lastServer(): CloudServer?
     suspend fun lastSeen(): ZonedDateTime?
+    suspend fun firstSeen(): ZonedDateTime?
     suspend fun latestIpAddress(): Inet4Address?
 
     suspend fun playedBefore(): Boolean

surf-cloud-core/surf-cloud-core-client/src/main/kotlin/dev/slne/surf/cloud/core/client/player/ClientCloudPlayerImpl.kt

@@ -14,6 +14,7 @@ import dev.slne.surf.cloud.api.common.server.CloudServer
 import dev.slne.surf.cloud.core.client.util.luckperms
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.*
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataPacket.DataRequestType
+import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataResponse.FirstSeen
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataResponse.IpAddress
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataResponse.LastServer
 import dev.slne.surf.cloud.core.common.netty.network.protocol.running.ServerboundRequestPlayerDataResponse.Name
@@ -36,6 +37,7 @@ import net.kyori.adventure.title.TitlePart
 import net.luckperms.api.model.user.User
 import net.luckperms.api.platform.PlayerAdapter
 import java.net.Inet4Address
+import java.time.ZonedDateTime
 import java.util.*
 import kotlin.time.Duration
 
@@ -70,6 +72,10 @@ abstract class ClientCloudPlayerImpl<PlatformPlayer : Audience>(uuid: UUID) :
         return request<NameHistoryResponse>(DataRequestType.NAME_HISTORY).history
     }
 
+    override suspend fun firstSeen(): ZonedDateTime? {
+        return request<FirstSeen>(DataRequestType.FIRST_SEEN).firstSeen
+    }
+
     override suspend fun <R> withPersistentData(block: PersistentPlayerDataContainer.() -> R): R {
         val response = ServerboundRequestPlayerPersistentDataContainer(uuid).fireAndAwaitOrThrow()
 

surf-cloud-core/surf-cloud-core-client/src/main/kotlin/dev/slne/surf/cloud/core/client/player/OfflineCloudPlayerImpl.kt

@@ -24,6 +24,10 @@ class OfflineCloudPlayerImpl(uuid: UUID) : CommonOfflineCloudPlayerImpl(uuid) {
         return request(DataRequestType.LAST_SEEN)
     }
 
+    override suspend fun firstSeen(): ZonedDateTime? {
+        return request(DataRequestType.FIRST_SEEN)
+    }
+
     override suspend fun latestIpAddress(): Inet4Address? {
         return request(DataRequestType.LATEST_IP_ADDRESS)
     }

surf-cloud-core/surf-cloud-core-common/src/main/kotlin/dev/slne/surf/cloud/core/common/netty/network/protocol/running/ServerboundRequestPlayerDataPacket.kt

@@ -55,6 +55,11 @@ class ServerboundRequestPlayerDataPacket(val uuid: UUID, val type: DataRequestTy
                 return LastSeen(player.lastSeen())
             }
         },
+        FIRST_SEEN(::FirstSeen) {
+            override suspend fun readData(player: OfflineCloudPlayer): DataResponse {
+                return FirstSeen(player.firstSeen())
+            }
+        },
         DISPLAY_NAME(::DisplayName) {
             override suspend fun readData(player: OfflineCloudPlayer): DataResponse {
                 return DisplayName(player.displayName())
@@ -123,6 +128,14 @@ class ServerboundRequestPlayerDataResponse(val data: DataResponse) : ResponseNet
         }
     }
 
+    class FirstSeen(val firstSeen: ZonedDateTime?) : DataResponse(DataRequestType.FIRST_SEEN) {
+        constructor(buf: SurfByteBuf) : this(buf.readNullable { it.readZonedDateTime() })
+
+        override fun write(buf: SurfByteBuf) {
+            buf.writeNullable(firstSeen) { buf, dateTime -> buf.writeZonedDateTime(dateTime) }
+        }
+    }
+
     class DisplayName(val displayName: Component?) : DataResponse(DataRequestType.DISPLAY_NAME) {
         constructor(buf: SurfByteBuf) : this(buf.readNullable { it.readComponent() })
 
@@ -152,6 +165,7 @@ inline fun <reified T> DataResponse.getGenericValue(): T = when (this) {
     is IpAddress -> check(T::class == Inet4Address::class) { "Expected Inet4Address" }.let { ip as T }
     is LastServer -> check(T::class == String::class) { "Expected String" }.let { server as T }
     is LastSeen -> check(T::class == ZonedDateTime::class) { "Expected ZonedDateTime" }.let { lastSeen as T }
+    is FirstSeen -> check(T::class == ZonedDateTime::class) { "Expected ZonedDateTime" }.let { firstSeen as T }
     is DisplayName -> check(T::class == Component::class) { "Expected Component" }.let { displayName as T }
     is Name -> check(T::class == String::class) { "Expected String" }.let { name as T }
     is NameHistory -> check(T::class == ApiNameHistory::class) { "Expected ApiNameHistory" }.let { history as T }

surf-cloud-standalone/src/main/kotlin/dev/slne/surf/cloud/standalone/player/OfflineCloudPlayerImpl.kt

@@ -37,6 +37,9 @@ class OfflineCloudPlayerImpl(uuid: UUID) : CommonOfflineCloudPlayerImpl(uuid) {
     override suspend fun lastSeen(): ZonedDateTime? =
         player?.lastSeen() ?: service.findLastSeen(uuid)
 
+    override suspend fun firstSeen(): ZonedDateTime? =
+        player?.firstSeen() ?: service.findFirstSeen(uuid)
+
     override suspend fun latestIpAddress(): Inet4Address? =
         player?.latestIpAddress() ?: service.findLastIpAddress(uuid)
 

surf-cloud-standalone/src/main/kotlin/dev/slne/surf/cloud/standalone/player/StandaloneCloudPlayerImpl.kt

@@ -36,6 +36,7 @@ import net.kyori.adventure.title.Title
 import net.kyori.adventure.title.TitlePart
 import net.querz.nbt.tag.CompoundTag
 import java.net.Inet4Address
+import java.time.ZonedDateTime
 import java.util.*
 import java.util.concurrent.TimeUnit
 import kotlin.time.Duration
@@ -73,6 +74,8 @@ class StandaloneCloudPlayerImpl(uuid: UUID, val name: String, val ip: Inet4Addre
     private val ppdc = PersistentPlayerDataContainerImpl()
     private val ppdcMutex = Mutex()
 
+    private var firstSeenCache: ZonedDateTime? = null
+
     fun savePlayerData(tag: CompoundTag) {
         if (!ppdc.empty) {
             tag.put("ppdc", ppdc.toTagCompound())
@@ -107,6 +110,12 @@ class StandaloneCloudPlayerImpl(uuid: UUID, val name: String, val ip: Inet4Addre
         return anyServer.name
     }
 
+    override suspend fun firstSeen(): ZonedDateTime? {
+        return firstSeenCache ?: service.findFirstSeen(uuid).also {
+            firstSeenCache = it
+        }
+    }
+
     override suspend fun nameHistory(): NameHistory {
         return service.findNameHistories(uuid)
     }

surf-cloud-standalone/src/main/kotlin/dev/slne/surf/cloud/standalone/player/db/exposed/CloudPlayerService.kt

@@ -26,6 +26,7 @@ class CloudPlayerService : AbstractExposedDAOService<UUID, CloudPlayerEntity>({
 
     suspend fun findLastServer(uuid: UUID) = find(uuid) { lastServer }
     suspend fun findLastSeen(uuid: UUID) = find(uuid) { lastSeen }
+    suspend fun findFirstSeen(uuid: UUID) = find(uuid) { createdAt }
     suspend fun findLastIpAddress(uuid: UUID) = find(uuid) { lastIpAddress }
 
     suspend fun updateOnDisconnect(player: StandaloneCloudPlayerImpl, oldServer: Long?) {