Add session id to cloudflare CredentialRequest

FAForever · Nov 29, 2024 · fe1fe12 · fe1fe12
1 parent f0700bd
commit fe1fe12
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/src/main/kotlin/com/faforever/icebreaker/service/cloudflare/CloudflareApiClient.kt b/src/main/kotlin/com/faforever/icebreaker/service/cloudflare/CloudflareApiClient.kt
@@ -13,7 +13,7 @@ import org.eclipse.microprofile.rest.client.inject.RegisterRestClient
 @Consumes(MediaType.APPLICATION_JSON)
 interface CloudflareApiClient {
 
-    data class CredentialRequest(val ttl: Long)
+    data class CredentialRequest(val ttl: Long, val customIdentifier: String?)
     data class CredentialResponse(val iceServers: IceServers) {
         data class IceServers(val urls: List<String>, val username: String, val credential: String)
     }

diff --git a/src/main/kotlin/com/faforever/icebreaker/service/cloudflare/CloudflareSessionHandler.kt b/src/main/kotlin/com/faforever/icebreaker/service/cloudflare/CloudflareSessionHandler.kt
@@ -31,7 +31,10 @@ class CloudflareSessionHandler(
 
     override fun getIceServersSession(sessionId: String): List<Session.Server> =
         cloudflareApiAdapter.requestIceServers(
-            credentialRequest = CloudflareApiClient.CredentialRequest(ttl = fafProperties.tokenLifetimeSeconds()),
+            credentialRequest = CloudflareApiClient.CredentialRequest(
+                ttl = fafProperties.tokenLifetimeSeconds(),
+                customIdentifier = sessionId,
+            ),
         ).let {
             listOf(
                 Session.Server(