Skip to content

Commit be4e65c

Browse files
committed
Clean up non-multipart video uploads
1 parent fd73997 commit be4e65c

2 files changed

Lines changed: 3 additions & 2 deletions

File tree

  • apps/web/app/api/desktop/[...route]
  • packages/web-backend/src/Videos

apps/web/app/api/desktop/[...route]/video.ts

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,6 +195,7 @@ app.get(
195195
if (clientSupportsUploadProgress)
196196
await db().insert(videoUploads).values({
197197
videoId: idToUse,
198+
mode: "singlepart",
198199
});
199200

200201
if (buildEnv.NEXT_PUBLIC_IS_CAP && NODE_ENV === "production")
@@ -346,7 +347,7 @@ app.post(
346347
);
347348

348349
if (video.upload) {
349-
if (uploaded === total && video.upload.mode === "singlepart") {
350+
if (uploaded === total && video.upload.mode !== "multipart") {
350351
await db()
351352
.delete(videoUploads)
352353
.where(eq(videoUploads.videoId, videoId));

packages/web-backend/src/Videos/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -330,7 +330,7 @@ export class Videos extends Effect.Service<Videos>()("Videos", {
330330
yield* db.use((db) =>
331331
db.transaction(async (tx) => {
332332
if (record.upload) {
333-
if (uploaded === total && record.upload.mode === "singlepart") {
333+
if (uploaded === total && record.upload.mode !== "multipart") {
334334
await tx
335335
.delete(Db.videoUploads)
336336
.where(Dz.eq(Db.videoUploads.videoId, videoId));

0 commit comments

Comments
 (0)