improve torrent cancelationm

packages/core/src/generic_steps/torrent.js

@@ -41,7 +41,8 @@ export default async (pkg, step, logger, abortController) => {
                 use_id_only: true,
                 status_text: `Downloaded ${progress.transferredString} / ${progress.totalString} | ${progress.speedString}/s`,
             })
-        }
+        },
+        taskId: pkg.id
     })
 
 }

packages/core/src/handlers/cancelInstall.js

@@ -20,6 +20,10 @@ export default async function reinstall(pkg_id) {
         if (task) {
             BaseLog.warn(`Task not found [${pkg_id}]`)
             await task.abortController.abort()
+
+            global._relic_eventBus.emit(`pkg:install:cancel`, pkg_id)
+            global._relic_eventBus.emit(`pkg:install:cancel:${pkg_id}`, pkg_id)
+            global._relic_eventBus.emit(`task:cancel:${pkg_id}`, pkg_id)
         }
 
         await UninstallHandler(pkg_id)

packages/core/src/helpers/downloadTorrent.js

@@ -1,6 +1,3 @@
-import fs from "node:fs"
-import path from "node:path"
-import cliProgress from "cli-progress"
 import humanFormat from "human-format"
 import aria2 from "aria2"
 
@@ -18,6 +15,7 @@ export default async function downloadTorrent(
         onProgress,
         onDone,
         onError,
+        taskId,
     } = {}
 ) {
     let progressInterval = null
@@ -54,9 +52,17 @@ export default async function downloadTorrent(
             onStart()
         }
 
+        if (typeof taskId === "string") {
+            // TODO: Unregister me when task is cancelled or finished
+            global._relic_eventBus.once(`task:cancel:${taskId}`, () => {
+                client.call("remove", [downloadId])
+                clearInterval(progressInterval)
+                reject()
+            })
+        }
+
         progressInterval = setInterval(async () => {
             const data = await client.call("tellStatus", downloadId)
-            const isMetadata = data.totalLength === "0" && data.status === "active"
 
             console.log(data)