initial windows support & bug fixes

Adding initial windows support and some bug fixes.
https://github.com/bun-bm2/bm2/issues/19

Author: ra-sun-god

README.md

@@ -106,7 +106,7 @@ BM2 replaces PM2's Node.js internals with Bun-native APIs. It uses `Bun.spawn` f
 
 **Process Persistence** — Save the current process list and resurrect it after a daemon restart or system reboot. Combined with startup script generation, your applications survive server reboots.
 
-**Startup Script Generation** — Automatically generate and install systemd (Linux) or launchd (macOS) service configurations so the BM2 daemon starts at boot.
+**Startup Script Generation** — Automatically generate and install systemd (Linux), launchd (macOS), or Task Scheduler (Windows) service configurations so the BM2 daemon starts at boot.
 
 **Remote Deployment** — A built-in deploy system that handles SSH-based deployment with git pull, release directory management, symlink rotation, and pre/post-deploy hooks.
 
@@ -885,7 +885,7 @@ Multi-host deployment is supported. Specify an array of hosts to deploy to all o
 
 #### bm2 startup
 
-Generate and display a startup script for your operating system. On Linux, this generates a systemd unit file. On macOS, this generates a launchd plist.
+Generate and display a startup script for your operating system. On Linux, this generates a systemd unit file. On macOS, this generates a launchd plist. On Windows, this generates a Task Scheduler configuration and PowerShell script.
 
 ```
 bm2 startup
@@ -931,7 +931,7 @@ bm2 save
 bm2 startup install
 ```
 
-On reboot, systemd or launchd starts the BM2 daemon, and the daemon automatically runs resurrect to restore your processes.
+On reboot, systemd, launchd, or Task Scheduler starts the BM2 daemon, and the daemon automatically runs resurrect to restore your processes.
 
 ---
 

package.json

@@ -62,7 +62,8 @@
 	},
 	"os": [
 		"linux",
-		"darwin"
+		"darwin",
+		"win32"
 	],
 	"dependencies": {
 		"chalk": "^5.6.2",

src/cluster-manager.ts

@@ -57,9 +57,9 @@ export class ClusterManager {
        const ext = config.script.split(".").pop()?.toLowerCase();
        if (ext === "ts" || ext === "tsx" || ext === "js" || ext === "jsx" || ext === "mjs") {
          cmd.push("bun", "run");
-       } else if (ext === "py") {
-         cmd.push("python3");
-       } else {
+        } else if (ext === "py") {
+          cmd.push(process.platform === "win32" ? "python" : "python3");
+        } else {
          cmd.push("bun", "run");
        }
      }

src/daemon-v1.ts

@@ -302,6 +302,14 @@ export default class Daemon {
         case "moduleList": {
           return { type: "moduleList", data: moduleManager.list(), success: true, id: msg.id };
         }
+        case "daemonReload": {
+          if (!this.server) {
+            this.server = this.startServer();
+          } else {
+            this.server.reload(this.getServerOpts() as any);
+          }
+          return { type: "daemonReload", data: "Daemon reloaded", success: true, id: msg.id };
+        }
         case "ping": {
           return {
             type: "pong",

src/daemon.ts

@@ -166,11 +166,13 @@
      return stdout;
    }
 
-   private async localExec(command: string): Promise<string> {
-     const proc = Bun.spawn(["sh", "-c", command], {
-       stdout: "pipe",
-       stderr: "pipe",
-     });
+    private async localExec(command: string): Promise<string> {
+      const isWin = process.platform === "win32";
+      const cmd = isWin ? ["cmd.exe", "/c", command] : ["sh", "-c", command];
+      const proc = Bun.spawn(cmd, {
+        stdout: "pipe",
+        stderr: "pipe",
+      });
 
      const stdout = await new Response(proc.stdout).text();
      const stderr = await new Response(proc.stderr).text();

src/deploy.ts

@@ -14,13 +14,12 @@
  * Author: Zak <zak@maxxpainn.com>
  */
 
-import { join, dirname } from "path";
+import { join, dirname, basename } from "path";
 import { appendFile, rename, unlink, readdir } from "fs/promises";
 import { LOG_DIR, DEFAULT_LOG_MAX_SIZE, DEFAULT_LOG_RETAIN } from "./constants";
 import type {  LogEntry, LogRotateOptions } from "./types";
 import { watch } from "fs";
 import type { ReadableStreamController } from "bun";
-import { $ } from "bun"
 import { EOL } from 'node:os';
 
 const isoRegex: RegExp = /\d{4}-\d{2}-\d{2}T\d{2}:\d{2}:\d{2}(?:\.\d+)?(?:Z|[+-]\d{2}:?\d{2})?/;
@@ -152,11 +151,12 @@ export class LogManager {
 
       const level = (fp == paths.errFile) ? "err" : "out";
 
-      const rawLog = await $`tail -n ${lines} ${fp}`.text();
+      const rawLog = await f.text();
 
        return rawLog
          .split("\n")
          .filter(Boolean)
+         .slice(-lines)
          .map(l => this.parseLine(l, level));
 
     }))).flat();
@@ -168,8 +168,6 @@ export class LogManager {
     if (sortedLogs.length > lines) {
       sortedLogs = sortedLogs.slice(-lines)
     }
-    
-    console.log(sortedLogs)
 
     return sortedLogs
   }
@@ -243,16 +241,25 @@ export class LogManager {
 
         await rename(src, dst);
         if (options.compress) {
-          // Fire-and-forget compression doesn't block the next rename
-          bgTasks.push(Bun.spawn(["gzip", "-f", dst]).exited); 
+          bgTasks.push((async () => {
+            try {
+              const srcFile = Bun.file(dst);
+              if (await srcFile.exists()) {
+                const data = await srcFile.arrayBuffer();
+                const compressed = Bun.gzipSync(new Uint8Array(data));
+                await Bun.write(`${dst}.gz`, compressed);
+                await unlink(dst);
+              }
+            } catch {}
+          })());
         }
       }
     }
 
     await Bun.write(filePath, ""); // Instantly truncate and reclaim space
 
     const dir = dirname(filePath);
-    const baseName = filePath.split("/").pop()!;
+    const baseName = basename(filePath);
 
     // Background cleanup
     bgTasks.push(