basic telnet service

Author: obfuscatedgenerated

src/programs/@ALL.ts

@@ -39,12 +39,13 @@ export { default as ps } from "./ps";
 export { default as kill } from "./kill";
 export { default as spark } from "./spark";
 
-export { default as ipc_bg_test } from "./ipc_bg_test";
-export { default as ipc_fg_test } from "./ipc_fg_test";
+export { default as hello_http } from "./hello_http";
+export { default as telnetd } from "./telnetd";
 
 // shhhhh!
+export { default as ipc_bg_test } from "./ipc_bg_test";
+export { default as ipc_fg_test } from "./ipc_fg_test";
 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

@@ -55,14 +55,11 @@ export default {
     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, kernel } = data;
 
-        kernel.get_env_info()
-
         if (!kernel.has_network_manager()) {
             term.writeln(`${term.ansi.PREFABS.error}No network manager found. This program requires a network manager to function.${term.ansi.STYLE.reset_all}`);
             return 1;

src/programs/telnetd.ts

@@ -0,0 +1,58 @@
+import type { Program } from "../types";
+
+export default {
+    name: "telnetd",
+    description: "Telnet service",
+    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, kernel } = data;
+
+        if (!kernel.has_network_manager()) {
+            term.writeln(`${term.ansi.PREFABS.error}No network manager found. This program requires a network manager to function.${term.ansi.STYLE.reset_all}`);
+            return 1;
+        }
+
+        const net_manager = kernel.get_network_manager();
+        if (!await net_manager.is_up(true)) {
+            term.writeln(`${term.ansi.PREFABS.error}Network is down!${term.ansi.STYLE.reset_all}`);
+            return 1;
+        }
+
+        const server = await process.network_listen(2323);
+        server.add_event_listener("connection", (socket) => {
+            socket.add_event_listener("data", (incoming_data) => {
+                // filter out telnet commands (starting with 0xFF) for now
+                const filtered_data = new Uint8Array(incoming_data.length);
+                let j = 0;
+                for (let i = 0; i < incoming_data.length; i++) {
+                    if (incoming_data[i] === 0xFF) {
+                        i += 2; // skip the command and its option
+                    } else {
+                        filtered_data[j++] = incoming_data[i];
+                    }
+                }
+                const final_data = filtered_data.slice(0, j);
+
+                const raw = new TextDecoder().decode(final_data);
+
+                // echo back
+                socket.send(raw);
+
+                // for full lines just acknowledge it for now
+                if (raw.includes("\r")) {
+                    socket.send("You sent: " + raw.trim() + "\r\n> ");
+                }
+            });
+
+            socket.send("\r\nWelcome to the OllieOS Telnet service!\r\n> ");
+        });
+
+        process.detach();
+        return 0;
+    }
+} as Program;