use new queue

packages/server/services/files/file.service.js

@@ -30,9 +30,12 @@ class API extends Server {
 		limits: {},
 	}
 
-	queuesManager = new TaskQueueManager({
+	queuesManager = new TaskQueueManager(
-		workersPath: `${__dirname}/queues`,
+		{
-	})
+			workersPath: `${__dirname}/queues`,
+		},
+		this,
+	)
 
 	async onInitialize() {
 		global.sse = this.contexts.SSEManager

packages/server/services/files/queues/TransmuxedUpload/index.js

@@ -29,7 +29,7 @@ export default {
 				transmuxOptions: transmuxOptions,
 				cachePath: cachePath,
 				onProgress: (progress) => {
-					job.progress(progress)
+					job.updateProgress(progress)
 				},
 			})
 

packages/server/services/files/routes/upload/chunk/post.js

@@ -60,15 +60,21 @@ export default {
 
 				if (req.headers["transmux"] || limits.useCompression === true) {
 					// add a background task
-					const job = await global.queues.createJob("remote_upload", {
+					const job = await global.queues.createJob(
-						filePath: build.filePath,
+						"remote_upload",
-						parentDir: req.auth.session.user_id,
+						{
-						service: limits.useProvider,
+							filePath: build.filePath,
-						useCompression: limits.useCompression,
+							parentDir: req.auth.session.user_id,
-						transmux: req.headers["transmux"] ?? false,
+							service: limits.useProvider,
-						transmuxOptions: req.headers["transmux-options"],
+							useCompression: limits.useCompression,
-						cachePath: tmpPath,
+							transmux: req.headers["transmux"] ?? false,
-					})
+							transmuxOptions: req.headers["transmux-options"],
+							cachePath: tmpPath,
+						},
+						{
+							useSSE: true,
+						},
+					)
 
 					const sseChannelId = job.sseChannelId