TheAnachronism/docspell
1
0
Fork 0
mirror of https://github.com/TheAnachronism/docspell.git synced 2025-06-22 02:18:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use temporary files when receiving large data

Browse Source
This commit is contained in:
eikek
2022-03-18 23:57:36 +01:00
parent cafd3d7f65
commit e3ed0ba24d
1 changed files with 21 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
modules/restserver/src/main/scala/docspell/restserver/routes/UploadRoutes.scala
View File

@ -20,7 +20,6 @@ import docspell.restserver.http4s.ResponseGenerator
import org.http4s._
import org.http4s.circe.CirceEntityEncoder._
import org.http4s.dsl.Http4sDsl
import org.http4s.multipart.Multipart
import org.log4s._
object UploadRoutes {
@ -80,17 +79,26 @@ object UploadRoutes {
): F[Response[F]] = {
import dsl._
for {
multipart <- req.as[Multipart[F]]
updata <- readMultipart(
multipart,
"webapp",
logger,
prio,
cfg.backend.files.validMimeTypes
)
result <- backend.upload.submitEither(updata, accOrSrc, true, itemId)
res <- Ok(basicResult(result))
} yield res
val decodeMultipart =
EntityDecoder
.mixedMultipartResource(
maxSizeBeforeWrite = 10 * 1024 * 1024
)
.evalMap(_.decode(req, strict = false).value)
.rethrow
decodeMultipart.use { multipart =>
for {
updata <- readMultipart(
multipart,
"webapp",
logger,
prio,
cfg.backend.files.validMimeTypes
)
result <- backend.upload.submitEither(updata, accOrSrc, true, itemId)
res <- Ok(basicResult(result))
} yield res
}
}
}