max/chookchat
max/chookchat
1
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Add file upload support

Browse Source
This commit is contained in:
Maxwell Jeffress 2024-11-25 14:50:03 +11:00
parent 83fc6052ad
commit 500ac029df
2 changed files with 30 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
server/settings.gradle.kts
View File

@ -1,5 +1,5 @@
plugins {
id("org.gradle.toolchains.foojay-resolver-convention") version "0.8.0"
}
rootProject.name = "chookpen"
rootProject.name = "chookchat"

29
server/src/main/kotlin/Main.kt
View File

@ -2,6 +2,8 @@ package xyz.maxwellj.chookchat
import io.javalin.Javalin
import io.javalin.websocket.WsContext
import io.javalin.http.UploadedFile
import java.util.concurrent.ConcurrentHashMap
import java.util.UUID
@ -359,6 +361,33 @@ fun main(args: Array<String>) {
ctx.redirect("/index.html")
}
.get("/api/createaccount/{content}") { ctx -> ctx.result(createAccount(ctx.pathParam("content")))}
.post("/api/upload") { ctx ->
val uploadedFiles = ctx.uploadedFiles()
if (uploadedFiles.isEmpty()) {
ctx.status(400).result("No files uploaded")
return@post
}
val uploadedFile = uploadedFiles[0]
val originalFilename = uploadedFile.filename()
val uuid = UUID.randomUUID().toString()
val fileExtension = originalFilename.substringAfterLast(".", "")
val baseFilename = originalFilename.substringBeforeLast(".")
val newFilename = "${baseFilename}_${uuid}${if (fileExtension.isNotEmpty()) ".$fileExtension" else ""}"
val filePath = Paths.get("uploads", newFilename)
Files.copy(uploadedFile.content(), filePath)
val processedData = JSONObject().apply {
put("type", "fileStatus")
put("username", "system")
put("content", "success")
}
ctx.result(processedData.toString())
val processedData2 = JSONObject().apply {
put("type", "file")
put("username", "system")
put("content", "https://maxwellj.xyz/chookchat/uploads/$newFilename")
}
WsSessionManager.broadcast(processedData2.toString())
}
.ws("/api/websocket") { ws ->
ws.onConnect { ctx ->
WsSessionManager.addSession(ctx)