http server test

Author: obfuscatedgenerated

src/os_loader.ts

@@ -19,6 +19,7 @@ import { initial_fs_setup } from "./initial_fs_setup";
 import {DOMWindowManager} from "./window_impl/dom";
 
 import "./load_global_externals";
+import {PorterBridgeNetworkManager} from "./network_impl/porter";
 
 export const boot_os = async (on_init_spawned?: (kernel: Kernel) => Promise<void>) => {
     // create a program registry by importing all programs
@@ -65,6 +66,9 @@ export const boot_os = async (on_init_spawned?: (kernel: Kernel) => Promise<void
     // create a dom window manager
     const wm = new DOMWindowManager();
 
+    // create network manager
+    const net_manager = new PorterBridgeNetworkManager();
+
     // create a terminal using the registry and filesystem
     const term = new WrappedTerminal({
         screenReaderMode: false,
@@ -114,7 +118,7 @@ export const boot_os = async (on_init_spawned?: (kernel: Kernel) => Promise<void
     });
 
     // create the kernel
-    const kernel = new Kernel(term, fs, prog_reg, sfx_reg, wm);
+    const kernel = new Kernel(term, fs, prog_reg, sfx_reg, wm, net_manager);
     kernel.set_env_info(document.body.dataset.version, "web");
 
     // boot the kernel and check for a false return (indicating boot failure). should probably never return true as the os should hopefully always run!

src/programs/@ALL.ts

@@ -44,6 +44,7 @@ export { default as ipc_fg_test } from "./ipc_fg_test";
 
 // shhhhh!
 export { default as tb_test } from "./taskbar_test";
+export { default as hello_http } from "./hello_http";
 
 export { default as trigger_create_trigger } from "./pkg/triggers/create_trigger";
 export { default as trigger_remove_trigger } from "./pkg/triggers/remove_trigger";

src/programs/hello_http.ts

@@ -0,0 +1,32 @@
+import type { Program } from "../types";
+
+export default {
+    name: "hello_http",
+    description: "Exposes an HTTP server on port 8080 that responds with 'Hello, World!' to any request.",
+    usage_suffix: "",
+    arg_descriptions: {},
+    compat: "2.0.0",
+    hide_from_help: true,
+    completion: async () => [],
+    main: async (data) => {
+        // extract from data to make code less verbose
+        const { term, process } = data;
+
+        const server = await process.network_listen(8080);
+        server.add_event_listener("connection", (socket) => {
+            socket.add_event_listener("data", (s_data) => {
+                const decoder = new TextDecoder();
+                term.writeln("Received HTTP request:");
+                term.writeln(decoder.decode(s_data));
+            });
+
+            socket.send("HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nContent-Length: 13\r\n\r\nHello, World!");
+            socket.close();
+        });
+
+        term.writeln("HTTP server started on port 8080. Press any key to stop the server.");
+        await term.wait_for_keypress();
+
+        return 0;
+    }
+} as Program;