From: Lanius Trolling <lanius@laniustrolling.dev>
Date: Mon, 15 Apr 2024 10:25:47 +0000 (-0400)
Subject: Add existing WebDAV tokens view
X-Git-Url: https://gitweb.starshipfights.net/?a=commitdiff_plain;h=9e0884ad4ce308def78f90c5d4060336d42e6dc5;p=factbooks

Add existing WebDAV tokens view
---

diff --git a/src/jvmMain/kotlin/info/mechyrdia/auth/WebDav.kt b/src/jvmMain/kotlin/info/mechyrdia/auth/WebDav.kt
index 2e952d3..e7eeb1e 100644
--- a/src/jvmMain/kotlin/info/mechyrdia/auth/WebDav.kt
+++ b/src/jvmMain/kotlin/info/mechyrdia/auth/WebDav.kt
@@ -1,5 +1,6 @@
 package info.mechyrdia.auth
 
+import com.mongodb.client.model.Filters
 import info.mechyrdia.data.*
 import info.mechyrdia.lore.adminPage
 import info.mechyrdia.lore.dateTime
@@ -8,6 +9,7 @@ import info.mechyrdia.route.Root
 import info.mechyrdia.route.href
 import info.mechyrdia.route.installCsrfToken
 import io.ktor.server.application.*
+import kotlinx.coroutines.flow.toList
 import kotlinx.html.*
 import kotlinx.serialization.Serializable
 import java.time.Instant
@@ -23,11 +25,19 @@ data class WebDavToken(
 		
 		override suspend fun initialize() {
 			Table.index(WebDavToken::holder)
+			Table.expire(WebDavToken::validUntil)
 		}
 	}
 }
 
-fun ApplicationCall.adminRequestWebDavToken(): HTML.() -> Unit {
+suspend fun ApplicationCall.adminRequestWebDavToken(): HTML.() -> Unit {
+	val nation = currentNation()
+		?: redirectHref(Root.Auth.LoginPage(Root.Auth(Root(error = "You must be logged in to request WebDav tokens"))))
+	
+	val existingTokens = WebDavToken.Table
+		.filter(Filters.eq(WebDavToken::holder.serialName, nation.id))
+		.toList()
+	
 	return adminPage("Request WebDav Token") {
 		div(classes = "message") {
 			div {
@@ -36,6 +46,33 @@ fun ApplicationCall.adminRequestWebDavToken(): HTML.() -> Unit {
 					installCsrfToken()
 					submitInput { value = "Request WebDav Token" }
 				}
+				
+				if (existingTokens.isNotEmpty()) {
+					p {
+						+"You already have the following tokens:"
+					}
+					
+					table {
+						tr {
+							th { +"Token" }
+							th { +"Expires at" }
+						}
+						
+						for (existingToken in existingTokens) {
+							tr {
+								td {
+									textInput {
+										readonly = true
+										value = existingToken.id.id
+									}
+								}
+								td {
+									dateTime(existingToken.validUntil)
+								}
+							}
+						}
+					}
+				}
 			}
 		}
 	}
diff --git a/src/jvmMain/kotlin/info/mechyrdia/data/Data.kt b/src/jvmMain/kotlin/info/mechyrdia/data/Data.kt
index 02a9671..c881da0 100644
--- a/src/jvmMain/kotlin/info/mechyrdia/data/Data.kt
+++ b/src/jvmMain/kotlin/info/mechyrdia/data/Data.kt
@@ -6,6 +6,7 @@ import com.mongodb.MongoClientSettings
 import com.mongodb.MongoDriverInformation
 import com.mongodb.client.model.*
 import com.mongodb.kotlin.client.coroutine.MongoDatabase
+import com.mongodb.kotlin.client.coroutine.expireAfter
 import com.mongodb.reactivestreams.client.MongoClients
 import com.mongodb.reactivestreams.client.gridfs.GridFSBucket
 import com.mongodb.reactivestreams.client.gridfs.GridFSBuckets
@@ -27,6 +28,7 @@ import org.bson.codecs.configuration.CodecRegistries
 import org.bson.codecs.kotlinx.KotlinSerializerCodecProvider
 import org.bson.conversions.Bson
 import java.security.SecureRandom
+import java.time.Instant
 import kotlin.reflect.KClass
 import kotlin.reflect.KProperty
 import kotlin.reflect.KProperty1
@@ -115,6 +117,10 @@ class DocumentTable<T : DataDocument<T>>(private val kClass: KClass<T>) {
 		collection().createIndex(Indexes.ascending(*properties.map { it.serialName }.toTypedArray()), IndexOptions().unique(true))
 	}
 	
+	suspend fun expire(property: KProperty1<T, Instant>) {
+		collection().createIndex(Indexes.ascending(property.serialName), IndexOptions().expireAfter(0L))
+	}
+	
 	suspend fun indexIf(condition: Bson, vararg properties: KProperty1<T, *>) {
 		collection().createIndex(Indexes.ascending(*properties.map { it.serialName }.toTypedArray()), IndexOptions().partialFilterExpression(condition))
 	}