package.json

@@ -1,6 +1,6 @@
 {
   "name": "openrewind",
-  "version": "0.10.0",
+  "version": "0.8.0",
   "type": "module",
   "description": "Your second brain, superpowered.",
   "main": "dist/electron/index.js",
@@ -21,7 +21,6 @@
     "@alikia/random-key": "npm:@jsr/alikia__random-key",
     "@electron/remote": "^2.1.2",
     "@hono/node-server": "^1.13.7",
-    "@types/node-os-utils": "^1.3.4",
     "@unly/universal-language-detector": "^2.0.3",
     "better-sqlite3": "^11.6.0",
     "dayjs": "^1.11.13",
@@ -42,7 +41,6 @@
     "image-size": "^1.1.1",
     "jotai": "^2.11.0",
     "memory-cache": "^0.2.0",
-    "node-os-utils": "^1.3.7",
     "pino": "^9.6.0",
     "react": "^18.3.1",
     "react-dom": "^18.3.1",

src/electron/backend/scheduler.ts

@@ -1,5 +1,3 @@
-import osu from "node-os-utils";
-
 type TaskId = string;
 type TaskFunction = () => void;
 
@@ -11,7 +9,6 @@ interface Task {
 	nextRun?: number;
 	isPaused: boolean;
 	delayUntil?: number;
-	requiredSystemState: SystemState;
 }
 
 export interface TaskStatus {
@@ -20,27 +17,15 @@ export interface TaskStatus {
     nextRun?: string;
 }
 
-type SystemState = "ANY" | "LOW_POWER" | "IDLE";
-
 export class Scheduler {
 	private tasks: Map<TaskId, Task> = new Map();
 	private timer: NodeJS.Timeout | null = null;
-	private monitorTimer: NodeJS.Timeout | null = null;
-	private cpuUsage: number = 0;
-
 	constructor(private readonly minTickInterval: number = 500) {
 		this.start();
 	}
 
 	private start(): void {
 		this.scheduleNextTick();
-		this.monitorTimer = setInterval(() => this.monitor(), 1000);
-	}
-
-	private monitor(): void {
-	    osu.cpu.usage().then((cpuPercentage) => {
-	        this.cpuUsage = cpuPercentage / 100;
-	    })
 	}
 
 	private scheduleNextTick(): void {
@@ -81,17 +66,7 @@ export class Scheduler {
 			return;
 		}
 
-		const taskRequiredLowPower = task.requiredSystemState === "LOW_POWER";
+		const isTaskReadyForIntervalRun = task.interval && task.nextRun && now >= task.nextRun;
-		const cpuUsage = this.cpuUsage;
-		const isSystemLowPower = cpuUsage < 0.75;
-		const isTaskReadyForLowPowerRun = taskRequiredLowPower ? isSystemLowPower : true;
-		const reachedTaskNextRun = task.interval && task.nextRun && now >= task.nextRun;
-		const isTaskReadyForIntervalRun = reachedTaskNextRun && isTaskReadyForLowPowerRun;
-		
-		if (!isTaskReadyForLowPowerRun) {
-			this.delayTask(task.id, 1000)
-		}
-
 		if (isTaskReadyForIntervalRun) {
 			task.func();
 			task.lastRun = now;
@@ -125,17 +100,15 @@ export class Scheduler {
 	 * @param id A unique string identifier for the task.
 	 * @param func The function to be executed by the task.
 	 * @param interval The interval (in milliseconds) between task executions.
-	 * @param requiredSystemState The required system state for the task to run.
 	 */
-	addTask(id: TaskId, func: TaskFunction, interval?: number, requiredSystemState: SystemState = "ANY"): void {
+	addTask(id: TaskId, func: TaskFunction, interval?: number): void {
 		this.tasks.set(id, {
 			id,
 			func,
 			interval,
 			isPaused: false,
 			lastRun: undefined,
-			nextRun: interval ? Date.now() + interval : undefined,
+			nextRun: interval ? Date.now() + interval : undefined
-			requiredSystemState: requiredSystemState,
 		});
 
 		this.scheduleNextTick();
@@ -199,9 +172,6 @@ export class Scheduler {
 		const task = this.tasks.get(id);
 		if (task) {
 			task.delayUntil = Date.now() + delayMs;
-			if (task.nextRun) {
-				task.nextRun += delayMs;
-			}
 		}
 
 		this.scheduleNextTick();
@@ -245,9 +215,5 @@ export class Scheduler {
 			clearTimeout(this.timer);
 			this.timer = null;
 		}
-		if (this.monitorTimer) {
-			clearTimeout(this.monitorTimer);
-			this.monitorTimer = null;
-		}
 	}
 }

src/electron/index.ts

@@ -112,7 +112,7 @@ app.on("ready", () => {
 	initDatabase().then((db) => {
 		scheduler.addTask("screenshot", takeScreenshot, 2000);
 		scheduler.addTask("check-encoding", checkFramesForEncoding, 5000);
-		scheduler.addTask("process-encoding", processEncodingTasks, 10000, "LOW_POWER");
+		scheduler.addTask("process-encoding", processEncodingTasks, 10000);
 		scheduler.addTask("delete-screenshots", deleteUnnecessaryScreenshots, 20000);
 		dbConnection = db;
 		cache.put("server:dbConnection", dbConnection);