From 941ce27293286845516f46bf9e5e9c80c0dbf353 Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Mon, 22 Jan 2024 17:49:42 -0500 Subject: [PATCH] fix: only process completed upload if its final --- storage/storage.go | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/storage/storage.go b/storage/storage.go index 838778c..f5ab816 100644 --- a/storage/storage.go +++ b/storage/storage.go @@ -360,7 +360,15 @@ func (s *StorageServiceImpl) tusWorker() { } case info := <-s.tus.CompleteUploads: - err := s.ScheduleTusUpload(info.Upload.ID, 0) + if !info.Upload.IsFinal { + continue + } + err := s.TusUploadCompleted(info.Upload.ID) + if err != nil { + s.portal.Logger().Error("Could not complete tus upload", zap.Error(err)) + continue + } + err = s.ScheduleTusUpload(info.Upload.ID, 0) if err != nil { s.portal.Logger().Error("Could not schedule tus upload", zap.Error(err)) continue