load projects

nose/bin/load.ts

@@ -0,0 +1,12 @@
+import { apps } from "@/webapp"
+import { Thread } from "@/shell"
+
+export default function (project: string) {
+    const state = Thread.getStore()
+
+    if (apps().includes(project) && state) {
+        state.project = project
+    }
+
+    return state?.project ? `loaded ${project}` : `failed to load ${project}`
+}

nose/bin/project.ts

@@ -0,0 +1,5 @@
+import { Thread } from "@/shell"
+
+export default function () {
+    return Thread.getStore()?.project || "none"
+}

nose/bin/projects.ts

@@ -0,0 +1,5 @@
+import { apps } from "@/webapp"
+
+export default function () {
+    return apps().join(" ")
+}

src/server.tsx

@@ -73,7 +73,7 @@ app.get("/ws", upgradeWebSocket(async c => {
 
             if (!data) return
 
-            const result = await runCommand(data.data as string)
+            const result = await runCommand(data.session || "", data.id || "", data.data as string)
             send(ws, { id: data.id, type: "output", data: result })
         },
         onClose: (event, ws) => {

src/shell.ts

@@ -5,8 +5,19 @@ import type { CommandResult } from "./shared/types"
 import { join } from "path"
 import { NOSE_SYS_BIN, NOSE_USR_BIN } from "./config"
 import { isFile } from "./utils"
+import { AsyncLocalStorage } from "async_hooks"
 
-export async function runCommand(input: string): Promise<CommandResult> {
+export const Thread = new AsyncLocalStorage<State>()
+
+type State = {
+    id?: string
+    session?: string
+    project?: string
+}
+
+const sessions: Map<string, State> = new Map()
+
+export async function runCommand(session: string, id: string, input: string): Promise<CommandResult> {
     const [cmd = "", ...args] = input.split(" ")
 
     if (!commandExists(cmd)) {
@@ -16,8 +27,15 @@ export async function runCommand(input: string): Promise<CommandResult> {
     let status: "ok" | "error" = "ok"
     let output = ""
 
+    let state = sessions.get(session)
+    if (!state) {
+        state = { session, id, project: "" }
+        sessions.set(session, state)
+    }
+    state.id = id
+
     try {
-        [status, output] = await exec(cmd, args)
+        [status, output] = await Thread.run(state, async () => await exec(cmd, args))
     } catch (err) {
         status = "error"
         output = errorMessage(err)