pkg browse

Author: obfuscatedgenerated

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "ollieos",
-  "version": "1.1.3",
+  "version": "1.1.4",
   "description": "",
   "private": true,
   "main": "server.js",

package.json

@@ -0,0 +1,122 @@
+import {ANSI, NEWLINE} from "../../term_ctl";
+import type { WrappedTerminal } from "../../term_ctl";
+import { ProgramMainData } from "../../types"
+import {repo_query} from "./index";
+
+// extract from ANSI to make code less verbose
+const { STYLE, FG, CURSOR } = ANSI;
+
+const ROWS = 10;
+
+const view_pkg_info = async (term: WrappedTerminal, pkg_name: string) => {
+    const pkg_data = await repo_query.get_pkg_json(pkg_name);
+    const pkg_versions = await repo_query.get_pkg_versions(pkg_name);
+
+    term.clear();
+
+    term.write(NEWLINE);
+    term.writeln(`${STYLE.bold}${FG.cyan}${pkg_name}`);
+    term.write(STYLE.dim);
+    term.writeln("=".repeat(pkg_name.length));
+    term.writeln(STYLE.reset_all);
+
+    term.write(NEWLINE);
+    term.writeln("Available versions:");
+    for (const version of pkg_versions) {
+        term.writeln(`  - ${version}`);
+    }
+    term.write(NEWLINE);
+    term.writeln(`Description: ${pkg_data.description || "No description provided."}`);
+    term.writeln(`Author: ${pkg_data.author || "Unknown"}`);
+    term.writeln(`License: ${pkg_data.license || "Unknown"}`);
+    term.write(NEWLINE);
+
+    term.writeln(`${STYLE.dim}Press any key to return to the list...${STYLE.reset_all}`);
+
+    await term.wait_for_keypress();
+}
+
+// TODO: accept name argument to jump to specific package
+
+export const browse_subcommand = async (data: ProgramMainData) => {
+    // extract from data to make code less verbose
+    const { args, term } = data;
+
+    // remove subcommand name
+    args.shift();
+
+    const provided = await repo_query.get_provided_list();
+
+    let offset = 0;
+    let selected_index = 0;
+    const draw = () => {
+        term.clear();
+
+        term.write(NEWLINE);
+        term.writeln("(use up/down arrow keys to scroll, enter to show more info, q to quit)");
+        term.write(NEWLINE);
+        term.write(CURSOR.invisible);
+
+        // show ... if there are more items above
+        if (offset > 0) {
+            term.writeln(`  ${STYLE.dim}...${STYLE.reset_all}`);
+        } else {
+            term.write(NEWLINE);
+        }
+
+        const slice = provided.slice(offset, offset + ROWS);
+        for (const [index, name] of slice.entries()) {
+            if (offset + index === selected_index) {
+                term.writeln(`${FG.cyan}${STYLE.dim}> ${STYLE.no_bold_or_dim}${STYLE.bold}${name}${STYLE.reset_all}`);
+            } else {
+                term.writeln(`  ${name}`);
+            }
+        }
+
+        // show ... if there are more items below
+        if (offset + ROWS < provided.length) {
+            term.writeln(`  ${STYLE.dim}...${STYLE.reset_all}`);
+        } else {
+            term.write(NEWLINE);
+        }
+    }
+
+    // TODO: type to filter
+
+    let quit = false;
+    while (!quit) {
+        draw();
+
+        const key = await term.wait_for_keypress();
+        console.log(key);
+        switch (key.domEvent.key) {
+            case "q":
+                quit = true;
+                break;
+            case "ArrowUp":
+                if (selected_index > 0) {
+                    selected_index--;
+                    if (selected_index < offset) {
+                        offset--;
+                    }
+                }
+                break;
+            case "ArrowDown":
+                if (selected_index < provided.length - 1) {
+                    selected_index++;
+                    if (selected_index >= offset + ROWS) {
+                        offset++;
+                    }
+                }
+                break;
+            case "Enter": {
+                const pkg_name = provided[selected_index];
+                await view_pkg_info(term, pkg_name);
+                break;
+            }
+        }
+    }
+
+    term.write(CURSOR.visible);
+    return 0;
+}

src/programs/pkg/browse.ts

@@ -6,6 +6,7 @@ import type {Program} from "../../types";
 import type {AbstractFileSystem} from "../../filesystem";
 import {list_subcommand} from "./list";
 import {info_subcommand} from "./info";
+import {browse_subcommand} from "./browse";
 
 
 const REPO_URL = "https://ollieg.codes/pkg_repo";
@@ -133,6 +134,44 @@ export const repo_query = {
         }
 
         return await response.text();
+    },
+
+    get_provided_list: async () => {
+        // repo/provided.txt
+        const url = append_url_pathnames(repo_url_obj, ["provided.txt"]);
+
+        const response = await fetch(url.toString());
+        if (!response.ok) {
+            if (response.status === 404) {
+                return null;
+            }
+
+            throw new Error(`HTTP error! status: ${response.status}`);
+        }
+
+        // newline separated list of provided package names
+        const data = await response.text();
+        return data.split("\n").map((line) => line.trim()).filter((line) => line.length > 0);
+    },
+
+    get_pkg_versions: async (pkg: string) => {
+        pkg = encodeURI(pkg);
+        pkg = pkg.replace(/\./g, "%2E");
+
+        // repo/pkgs/pkg/versions.txt
+        const url = append_url_pathnames(repo_url_obj, ["pkgs", pkg, "versions.txt"]);
+        const response = await fetch(url.toString());
+        if (!response.ok) {
+            if (response.status === 404) {
+                return null;
+            }
+
+            throw new Error(`HTTP error! status: ${response.status}`);
+        }
+
+        // newline separated list of versions
+        const data = await response.text();
+        return data.split("\n").map((line) => line.trim()).filter((line) => line.length > 0);
     }
 }
 
@@ -461,8 +500,7 @@ export default {
                 term.writeln(`${PREFABS.error}Not implemented yet.${STYLE.reset_all}`);
                 break;
             case "browse":
-                term.writeln(`${PREFABS.error}Not implemented yet.${STYLE.reset_all}`);
-                break;
+                return await browse_subcommand(data);
             case "clean":
                 term.writeln(`${PREFABS.error}Not implemented yet.${STYLE.reset_all}`);
                 break;