fix some bugs & chmod

package.json

@@ -1,9 +1,5 @@
 {
   "name": "@ragestudio/relic-core",
-  "private": true,
-  "workspaces": [
-    "packages/*"
-  ],
   "repository": "https://github.com/srgooglo/rs_bundler",
   "author": "SrGooglo <srgooglo@ragestudio.net>",
   "license": "MIT",

packages/core/package.json

@@ -1,6 +1,6 @@
 {
 	"name": "@ragestudio/relic-core",
-  "version": "0.19.1",
+	"version": "0.20.3",
 	"license": "MIT",
 	"author": "RageStudio",
 	"description": "RageStudio Relic, yet another package manager.",
@@ -16,6 +16,7 @@
 	"dependencies": {
 		"@foxify/events": "^2.1.0",
 		"adm-zip": "^0.5.12",
+		"aria2": "^4.1.2",
 		"axios": "^1.6.8",
 		"checksum": "^1.0.0",
 		"cli-color": "^2.0.4",

packages/core/src/generic_steps/torrent.js

@@ -1,10 +1,13 @@
 import path from "node:path"
+import fs from "node:fs"
 
 import parseStringVars from "../utils/parseStringVars"
-//import downloadTorrent from "../helpers/downloadTorrent"
+import downloadTorrent from "../helpers/downloadTorrent"
 
 export default async (pkg, step, logger, abortController) => {
-    throw new Error("Not implemented")
+    if (!step.magnet) {
+        throw new Error(`Magnet is required for torrent step`)
+    }
 
     if (typeof step.path === "undefined") {
         step.path = `.`
@@ -38,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

@@ -15,6 +15,10 @@ export default async function reinstall(pkg_id) {
             return null
         }
 
+        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)
+
         const task = globalThis.relic_core.tasks.find((task) => task.id === pkg_id)
 
         if (task) {

packages/core/src/handlers/install.js

@@ -10,7 +10,7 @@ import Apply from "../handlers/apply"
 
 const BaseLog = Logger.child({ service: "INSTALLER" })
 
-export default async function install(manifest) {
+export default async function install(manifest, options = {}) {
     let id = null
     let abortController = new AbortController()
 
@@ -112,7 +112,7 @@ export default async function install(manifest) {
             return false
         }
 
-        if (Array.isArray(manifest.installSteps)) {
+        if (Array.isArray(manifest.installSteps) && !options.noInstallSteps) {
             Log.info(`Executing generic install steps...`)
 
             global._relic_eventBus.emit(`pkg:update:state`, {

packages/core/src/helpers/downloadTorrent.js

@@ -1,7 +1,5 @@
-import fs from "node:fs"
-import path from "node:path"
-import cliProgress from "cli-progress"
 import humanFormat from "human-format"
+import aria2 from "aria2"
 
 function convertSize(size) {
     return `${humanFormat(size, {
@@ -17,6 +15,7 @@ export default async function downloadTorrent(
         onProgress,
         onDone,
         onError,
+        taskId,
     } = {}
 ) {
     let progressInterval = null
@@ -30,51 +29,54 @@ export default async function downloadTorrent(
         speedString: "0B/s",
     }
 
-    const client = new WebTorrent()
+    const client = new aria2({
+        host: "localhost",
+        port: 6800,
+        secure: false,
+        secret: "",
+        path: "/jsonrpc"
+    })
 
-    await new Promise((resolve, reject) => {
+    await client.open()
-        client.add(magnet, (torrentInstance) => {
-            const progressBar = new cliProgress.SingleBar({
-                format: "[{bar}] {percentage}% | {total_formatted} | {speed}/s | {eta_formatted}",
-                barCompleteChar: "\u2588",
-                barIncompleteChar: "\u2591",
-                hideCursor: true
-            }, cliProgress.Presets.shades_classic)
 
+    let downloadId = await client.call(
+        "addUri",
+        [magnet],
+        {
+            dir: destination,
+        },
+    )
+
+    async function stopDownload() {
+        await client.call("remove", downloadId)
+        clearInterval(progressInterval)
+    }
+
+    await new Promise(async (resolve, reject) => {
         if (typeof onStart === "function") {
-                onStart(torrentInstance)
+            onStart()
         }
 
-            progressBar.start(tickProgress.total, 0, {
+        if (taskId) {
-                speed: "0B/s",
+            global._relic_eventBus.once(`task:cancel:${taskId}`, stopDownload)
-                total_formatted: tickProgress.totalString,
-            })
-
-            torrentInstance.on("done", () => {
-                progressBar.stop()
-                clearInterval(progressInterval)
-
-                if (typeof onDone === "function") {
-                    onDone(torrentInstance)
         }
 
-                resolve(torrentInstance)
+        progressInterval = setInterval(async () => {
-            })
+            const data = await client.call("tellStatus", downloadId)
 
-            torrentInstance.on("error", (error) => {
+            console.log(data)
-                progressBar.stop()
-                clearInterval(progressInterval)
 
-                if (typeof onError === "function") {
+            if (data.status === "complete") {
-                    onError(error)
+                if (Array.isArray(data.followedBy) && data.followedBy[0]) {
-                } else {
+                    // replace downloadId
-                    reject(error)
+                    downloadId = data.followedBy[0]
+                }
             }
-            })
 
-            progressInterval = setInterval(() => {
+            tickProgress.total = parseInt(data.totalLength)
-                tickProgress.speed = torrentInstance.downloadSpeed
+            tickProgress.speed = parseInt(data.downloadSpeed)
-                tickProgress.transferred = torrentInstance.downloaded
+            tickProgress.transferred = parseInt(data.completedLength)
+            tickProgress.connections = data.connections
 
             tickProgress.transferredString = convertSize(tickProgress.transferred)
             tickProgress.totalString = convertSize(tickProgress.total)
@@ -83,11 +85,56 @@ export default async function downloadTorrent(
             if (typeof onProgress === "function") {
                 onProgress(tickProgress)
             }
-
-                progressBar.update(tickProgress.transferred, {
-                    speed: tickProgress.speedString,
-                })
         }, 1000)
-        })
+
-    })
+        client.on("onDownloadStart", async ([{ gid }]) => {
+            const data = await client.call("tellStatus", gid)
+
+            console.log(data)
+
+            if (typeof data.following !== "undefined") {
+                if (data.following === downloadId) {
+                    downloadId = data.gid
+                }
+            }
+        })
+
+        client.on("onBtDownloadComplete", ([{ gid }]) => {
+            if (gid !== downloadId) {
+                return false
+            }
+
+            if (typeof onDone === "function") {
+                onDone()
+            }
+
+            stopDownload()
+
+            return resolve({
+                downloadId,
+            })
+        })
+
+        client.on("onDownloadError", ([{ gid }]) => {
+            if (gid !== downloadId) {
+                return false
+            }
+
+            stopDownload()
+
+            if (typeof onError === "function") {
+                onError()
+            }
+
+            return reject()
+        })
+    })
+
+    await client.call("remove", downloadId)
+
+    if (taskId) {
+        global._relic_eventBus.off(`task:cancel:${taskId}`, stopDownload)
+    }
+
+    return downloadId
 }

packages/core/src/helpers/setup.js

@@ -69,7 +69,7 @@ export default async () => {
                 await fs.promises.mkdir(path.resolve(Vars.binaries_path, prerequisite.id), { recursive: true })
 
                 if (typeof prerequisite.url === "function") {
-                    prerequisite.url = await prerequisite.url(resolveOs(), os.arch())
+                    prerequisite.url = await prerequisite.url(os.platform(), os.arch())
                     Log.info(`Resolved url: ${prerequisite.url}`)
                 }
 

packages/core/src/index.js

@@ -4,6 +4,7 @@ import { onExit } from "signal-exit"
 import open from "open"
 
 import SetupHelper from "./helpers/setup"
+import { execa } from "./libraries/execa"
 import Logger from "./logger"
 
 import Settings from "./classes/Settings"
@@ -29,7 +30,7 @@ export default class RelicCore {
 		this.params = params
 	}
 
-    eventBus = global._relic_eventBus = new EventEmitter()
+	eventBus = (global._relic_eventBus = new EventEmitter())
 
 	logger = Logger
 
@@ -41,14 +42,34 @@ export default class RelicCore {
 			vars: Vars,
 		}
 
+		console.log(`Checking runtime_path >`, Vars.runtime_path)
+
+		if (!fs.existsSync(Vars.runtime_path)) {
+			fs.mkdirSync(Vars.runtime_path, { recursive: true })
+		}
+
 		await DB.initialize()
 
 		await Settings.initialize()
 
-        if (!await Settings.get("packages_path")) {
+		if (!(await Settings.get("packages_path"))) {
 			await Settings.set("packages_path", Vars.packages_path)
 		}
 
+		this.aria2c_instance = execa(
+			Vars.aria2_bin,
+			[
+				"--enable-rpc",
+				"--rpc-listen-all=true",
+				"--rpc-allow-origin-all",
+				"--file-allocation=none",
+			],
+			{
+				stdout: "inherit",
+				stderr: "inherit",
+			},
+		)
+
 		onExit(this.onExit)
 	}
 
@@ -56,6 +77,10 @@ export default class RelicCore {
 		if (fs.existsSync(Vars.cache_path)) {
 			fs.rmSync(Vars.cache_path, { recursive: true, force: true })
 		}
+
+		if (this.aria2c_instance) {
+			this.aria2c_instance.kill("SIGINT")
+		}
 	}
 
 	async setup() {
@@ -83,7 +108,8 @@ export default class RelicCore {
 			return open(Vars.runtime_path)
 		}
 
-        const packagesPath = await Settings.get("packages_path") ?? Vars.packages_path
+		const packagesPath =
+			(await Settings.get("packages_path")) ?? Vars.packages_path
 
 		return open(packagesPath + "/" + pkg_id)
 	}

packages/core/src/manifest/libs/extract/index.js

@@ -0,0 +1,34 @@
+import extractFile from "../../../utils/extractFile"
+import { execa } from "../../../libraries/execa"
+import Vars from "../../../vars"
+
+export default class Extract {
+    async extractFull(file, dest, { password } = {}) {
+        const args = [
+            "x",
+            "-y",
+        ]
+
+        if (password) {
+            args.push(`-p"${password}"`)
+        }
+
+        args.push(`-o"${dest}"`)
+
+        args.push(`"${file}"`)
+
+        const cmd = `${Vars.sevenzip_bin} ${args.join(" ")}`
+
+        console.log(cmd)
+
+        await execa(cmd, {
+            shell: true,
+            stdout: "inherit",
+            stderr: "inherit",
+        })
+    }
+
+    async autoExtract(file, dest) {
+        return await extractFile(file, dest)
+    }
+}

packages/core/src/manifest/libs/fs/index.js

@@ -36,4 +36,36 @@ export default class SecureFileSystem {
     existsSync(...args) {
         return fs.existsSync(...args)
     }
+
+    async rename(from, to) {
+        this.checkOutsideJail(from)
+        this.checkOutsideJail(to)
+
+        return await fs.promises.rename(from, to)
+    }
+
+    async writeFile(path, data, options) {
+        this.checkOutsideJail(path)
+        return await fs.promises.writeFile(path, data, options)
+    }
+
+    async readDir(path) {
+        this.checkOutsideJail(path)
+        return await fs.promises.readdir(path)
+    }
+
+    async rm(path, options) {
+        this.checkOutsideJail(path)
+        return await fs.promises.rm(path, options)
+    }
+
+    async mkdir(path, options) {
+        this.checkOutsideJail(path)
+        return await fs.promises.mkdir(path, options)
+    }
+
+    async stat(path) {
+        this.checkOutsideJail(path)
+        return await fs.promises.stat(path)
+    }
 }

packages/core/src/manifest/libs/index.js

@@ -2,6 +2,7 @@ import Open from "./open"
 import Path from "./path"
 import Fs from "./fs"
 import Auth from "./auth"
+import Extract from "./extract"
 
 // Third party libraries
 import Mcl from "./mcl"
@@ -11,5 +12,6 @@ export default {
     path: Path,
     open: Open,
     auth: Auth,
-    mcl: Mcl
+    extract: Extract,
+    mcl: Mcl,
 }

packages/core/src/prerequisites.js

@@ -9,9 +9,11 @@ export default [
     {
         id: "7z-bin",
         finalBin: Vars.sevenzip_bin,
-        url: resolveRemoteBinPath(`${baseURL}/7zip-bin`, process.platform === "win32" ? "7za.exe" : "7za"),
+        url: resolveRemoteBinPath(`${baseURL}/7z-full`, "7z.zip"),
-        destination: Vars.sevenzip_bin,
+        destination: path.resolve(Vars.binaries_path, "7z.zip"),
+        extract: path.resolve(Vars.binaries_path, "7z-bin"),
         rewriteExecutionPermission: true,
+        deleteBeforeExtract: true,
     },
     {
         id: "git-bin",
@@ -24,14 +26,13 @@ export default [
         deleteBeforeExtract: true,
     },
     {
-        id: "rclone-bin",
+        id: "aria2",
-        finalBin: Vars.rclone_bin,
+        finalBin: Vars.aria2_bin,
-        url: resolveRemoteBinPath(`${baseURL}/rclone`, "rclone-bin.zip"),
+        url: async (os, arch) => {
-        destination: path.resolve(Vars.binaries_path, "rclone-bin.zip"),
+            return `https://storage.ragestudio.net/rstudio/binaries/aria2/${os}/${arch}/${os === "win32" ? "aria2c.exe" : "aria2c"}`
-        extract: path.resolve(Vars.binaries_path, "rclone-bin"),
+        },
-        requireOs: ["win32"],
+        destination: Vars.aria2_bin,
-        rewriteExecutionPermission: true,
+        rewriteExecutionPermission: Vars.aria2_bin,
-        deleteBeforeExtract: true,
     },
     {
         id: "java22_jre_bin",
@@ -43,7 +44,7 @@ export default [
                 params: {
                     arch: arch,
                     java_version: "22",
-                    os: os,
+                    os: os === "win32" ? "windows" : os,
                     archive_type: "zip",
                     javafx_bundled: "false",
                     java_package_type: "jre",
@@ -77,7 +78,7 @@ export default [
                 params: {
                     arch: arch,
                     java_version: "17",
-                    os: os,
+                    os: os === "win32" ? "windows" : os,
                     archive_type: "zip",
                     javafx_bundled: "false",
                     java_package_type: "jre",

packages/core/src/utils/resolveRemoteBinPath.js

@@ -2,10 +2,10 @@ export default (pre, post) => {
     let url = null
 
     if (process.platform === "darwin") {
-        url = `${pre}/mac/${process.arch}/${post}`
+        url = `${pre}/darwin/${process.arch}/${post}`
     }
     else if (process.platform === "win32") {
-        url = `${pre}/win/${process.arch}/${post}`
+        url = `${pre}/win32/${process.arch}/${post}`
     }
     else {
         url = `${pre}/linux/${process.arch}/${post}`

packages/core/src/vars.js

@@ -2,7 +2,7 @@ import path from "node:path"
 import upath from "upath"
 import resolveUserDataPath from "./utils/resolveUserDataPath"
 
-const isWin = process.platform.includes("win")
+const isWin = process.platform.includes("win32")
 const isMac = process.platform.includes("darwin")
 
 const runtimeName = "rs-relic"
@@ -11,15 +11,48 @@ const userdata_path = resolveUserDataPath()
 const runtime_path = upath.normalizeSafe(path.join(userdata_path, runtimeName))
 const cache_path = upath.normalizeSafe(path.join(runtime_path, "cache"))
 const packages_path = upath.normalizeSafe(path.join(runtime_path, "packages"))
-const binaries_path = upath.normalizeSafe(path.resolve(runtime_path, "binaries"))
+const binaries_path = upath.normalizeSafe(
+	path.resolve(runtime_path, "binaries"),
+)
 const db_path = upath.normalizeSafe(path.resolve(runtime_path, "db.json"))
 
 const binaries = {
-    sevenzip_bin: upath.normalizeSafe(path.resolve(binaries_path, "7z-bin", isWin ? "7za.exe" : "7za")),
+	sevenzip_bin: upath.normalizeSafe(
-    git_bin: upath.normalizeSafe(path.resolve(binaries_path, "git-bin", "bin", isWin ? "git.exe" : "git")),
+		path.resolve(binaries_path, "7z-bin", isWin ? "7za.exe" : "7z"),
-    rclone_bin: upath.normalizeSafe(path.resolve(binaries_path, "rclone-bin", isWin ? "rclone.exe" : "rclone")),
+	),
-    java22_jre_bin: upath.normalizeSafe(path.resolve(binaries_path, "java22_jre_bin", (isMac ? "Contents/Home/bin/java" : (isWin ? "bin/java.exe" : "bin/java")))),
+	git_bin: upath.normalizeSafe(
-    java17_jre_bin: upath.normalizeSafe(path.resolve(binaries_path, "java17_jre_bin", (isMac ? "Contents/Home/bin/java" : (isWin ? "bin/java.exe" : "bin/java")))),
+		path.resolve(
+			binaries_path,
+			"git-bin",
+			"bin",
+			isWin ? "git.exe" : "git",
+		),
+	),
+	aria2_bin: upath.normalizeSafe(
+		path.resolve(binaries_path, "aria2", isWin ? "aria2c.exe" : "aria2c"),
+	),
+	java22_jre_bin: upath.normalizeSafe(
+		path.resolve(
+			binaries_path,
+			"java22_jre_bin",
+			isMac
+				? "Contents/Home/bin/java"
+				: isWin
+					? "bin/java.exe"
+					: "bin/java",
+		),
+	),
+	java17_jre_bin: upath.normalizeSafe(
+		path.resolve(
+			binaries_path,
+			"java17_jre_bin",
+			isMac
+				? "Contents/Home/bin/java"
+				: isWin
+					? "bin/java.exe"
+					: "bin/java",
+		),
+	),
 }
 
 export default {

packages/gui/electron-builder.yml

@@ -26,10 +26,10 @@ dmg:
 linux:
   target:
     - AppImage
-    - snap
     - deb
-  maintainer: electronjs.org
+  maintainer: ragestudio.net
   category: Utility
+  icon: resources/icon.png
 appImage:
   artifactName: ${productName}-${version}.${ext}
 npmRebuild: false

packages/gui/package.json

@@ -1,7 +1,8 @@
 {
-  "name": "@ragestudio/relic-gui",
+	"name": "relic-gui",
-  "version": "0.19.1",
+	"version": "0.20.3",
 	"description": "RageStudio Relic, yet another package manager.",
+	"homepage": "https://relic.ragestudio.net",
 	"main": "./out/main/index.js",
 	"author": "RageStudio",
 	"license": "MIT",
@@ -24,7 +25,7 @@
 		"@getstation/electron-google-oauth2": "^14.0.0",
 		"@imjs/electron-differential-updater": "^5.1.7",
 		"@loadable/component": "^5.16.3",
-    "@ragestudio/relic-core": "^0.19.1",
+		"@ragestudio/relic-core": "^0.20.3",
 		"antd": "^5.13.2",
 		"classnames": "^2.3.2",
 		"electron-differential-updater": "^4.3.2",