finish split by parts configHEADmain

# Conflicts:
#	src/main/java/com/pinapelz/frontend/App.kt

2 files changed, 29 insertions, 3 deletions

diff --git a/src/main/java/com/pinapelz/frontend/App.kt b/src/main/java/com/pinapelz/frontend/App.kt
index 2016bbf..a33d7ed 100644
--- a/src/main/java/com/pinapelz/frontend/App.kt
+++ b/src/main/java/com/pinapelz/frontend/App.kt
@@ -21,7 +21,7 @@ fun startFrontend(retriever: Retriever, fileSystem: FileSystem, webhooksFile: St
         println("Warning: Webhooks file not found: $webhooksFile")
         null
     }
-    val app = Javalin.create{}
+    val app = Javalin.create{};
 
     app.get("/") { ctx ->
         val directoryId = ctx.queryParam("dir")?.toIntOrNull() ?: 1
@@ -81,6 +81,7 @@ fun startFrontend(retriever: Retriever, fileSystem: FileSystem, webhooksFile: St
         val sortBy = ctx.queryParam("sortBy") ?: "created_at"
 
         val files = mutableListOf<Map<String, Any>>()
+
         val fileEntries = fileSystem.getFilesByDirectoryId(
             directoryId,
             search,
diff --git a/src/main/java/com/pinapelz/frontend/MultipartFileManager.kt b/src/main/java/com/pinapelz/frontend/MultipartFileManager.kt
index 257521d..70546dd 100644
--- a/src/main/java/com/pinapelz/frontend/MultipartFileManager.kt
+++ b/src/main/java/com/pinapelz/frontend/MultipartFileManager.kt
@@ -224,7 +224,7 @@ class MultipartFileManager(
 
         when (config) {
             is SplitConfig.BySize -> {
-                val partSize = config.sizeInBytes - (16 * 1024);
+                val partSize = config.sizeInBytes - (16 * 1024)
                 val numParts = ceil(fileSize.toDouble() / partSize.toDouble()).toInt()
                 println("Splitting file: ${fileSize} bytes into ${numParts} parts of max ${partSize} bytes each")
 
@@ -247,7 +247,32 @@ class MultipartFileManager(
                 }
             }
 
-            is SplitConfig.ByParts -> { // TODO: stubbed not yet implemented
+            is SplitConfig.ByParts -> {
+                val partSize = fileSize / config.numParts
+                var remainingBytes = fileSize
+                var offset = 0L
+
+                uploadedFile.content().use { inputStream ->
+                    for (partId in 1..config.numParts) {
+                        val partName = "part_$partId"
+                        val partPath = workingDir.resolve(partName)
+
+                        val currentPartSize = if (partId == config.numParts) remainingBytes else partSize
+                        val partBytes = ByteArray(currentPartSize.toInt())
+                        inputStream.read(partBytes, 0, currentPartSize.toInt())
+
+                        Files.write(partPath, partBytes)
+                        partsMeta += FilePartMeta(
+                            id = partId.toString(),
+                            name = partName,
+                            size = currentPartSize,
+                            path = partPath
+                        )
+
+                        offset += currentPartSize
+                        remainingBytes -= currentPartSize
+                    }
+                }
             }
         }
         val metadata = SplitMetadata(