Active player list

state/serverState.ts

@@ -1,49 +1,67 @@
-import { Tail } from "npm:tail";
 import { Sockpuppet } from "puppet/client";
 import { acceptEULA, checkEULA } from "../util/EULA.ts";
+import { Loader } from "../types/mcgrizzconf.ts";
+import { updateConfFile } from "../util/confFile.ts";
+import { IS_BROWSER } from "$fresh/runtime.ts";
+
+type MCServerEvent = 'message';
+type MCServerEventCallback = (msg: string) => void;
 
 class ServerState {
-  private status: "running" | "stopped" = "stopped";
+  private _status: "running" | "stopped" = "stopped";
+  public get status() {
+    return this._status;
+  }
 
   private command!: Deno.Command;
   private process!: Deno.ChildProcess;
 
-  private tail: Tail;
-
   private _eulaAccepted: boolean;
 
   private sockpuppet!: Sockpuppet;
   private _channelId = "blanaba";
-  public get channelId () {
+  public get channelId() {
     return this._channelId;
   }
   public get eulaAccepted() {
     return this._eulaAccepted;
   }
+  private stdin!: WritableStreamDefaultWriter; 
+
+  private _serverType: Loader = 'unset';
+  public get serverType(): Loader {
+    return this.serverType;
+  }
+  public set serverType(loader: Loader) {
+    updateConfFile({loader});
+    this._serverType = loader;
+  }
 
   constructor() {
     this._eulaAccepted = checkEULA();
     this.sockpuppet = new Sockpuppet(
       "ws://sockpuppet.cyborggrizzly.com",
       () => {
-        this.sockpuppet.joinChannel(this.channelId, (msg) => {this.sendStdIn(msg)});
+        this.sockpuppet.joinChannel(this.channelId, (msg) => {
+          this.sendStdIn(msg);
+        });
       },
     );
   }
 
-  public get stdin() {
-    return this.process.stdin;
-  }
-
   public get channel() {
-    return this.sockpuppet.getChannel(this.channelId)
+    return this.sockpuppet.getChannel(this.channelId);
   }
 
-  public sendStdIn(message: string) {
-    const msg = new TextEncoder().encode(message);
-    this.process.stdin.getWriter().write(msg);
+  public async sendStdIn(message: string) {
+    if (IS_BROWSER || !this.stdin) return;
+
+    const msg = new TextEncoder().encode(message + "\n");
+
+    await this.stdin.write(msg);
   }
 
+
   // "instance" should be moved to a private member once multi-instance support is implemented
   public startMCServer(instance = "server") {
     this.command = new Deno.Command("java", {
@@ -60,6 +78,11 @@ class ServerState {
 
     this.process = this.command.spawn();
 
+    const {readable, writable} = new TransformStream();
+    readable.pipeTo(this.process.stdin);
+    this.stdin = writable.getWriter();
+
+    this._status = "running";
     this.startStream();
   }
 
@@ -68,14 +91,39 @@ class ServerState {
     const decoder = new TextDecoder();
 
     while (true) {
-      const {done, value} = await stream.read();
+      const { done, value } = await stream.read();
       if (value) {
-        this.channel?.send(decoder.decode(value));
+        const line = decoder.decode(value);
+        this.channel?.send(line);
+        const stdoutMsg = new CustomEvent('stdoutmsg', {
+          detail: line
+        })
+        globalThis.dispatchEvent(stdoutMsg);
       }
       if (done) break;
     }
   }
 
+  public gracefullyStopMCServer() {
+    this._status = "stopped";
+    this.sendStdIn("stop");
+  }
+
+  public forceStopMCServer() {
+    this._status = "stopped";
+    this.process.kill();
+  }
+
+  public async restartMCServer() {
+    if (this.status === "running") {
+      await this.sendStdIn("stop");
+      // while (true) {
+      await this.process.status;
+      // }
+    }
+    this.startMCServer();
+  }
+
   public acceptEULA() {
     this._eulaAccepted = true;
     acceptEULA();