add fibonacci

src/main.rs

@@ -369,7 +369,7 @@ fn make_app(current_dir: &std::ffi::OsString) -> Command {
                 .short('t')
                 .long("template")
                 .help("Template to create")
-                .value_parser(["chat"])
+                .value_parser(["chat", "fibonacci"])
                 .default_value("chat")
             )
             .arg(Arg::new("UI")

src/new/mod.rs

@@ -12,6 +12,7 @@ pub enum Language {
 #[derive(Clone)]
 pub enum Template {
     Chat,
+    Fibonacci,
 }
 
 impl Language {
@@ -28,6 +29,7 @@ impl Template {
     fn to_string(&self) -> String {
         match self {
             Template::Chat => "chat",
+            Template::Fibonacci => "fibonacci",
         }.to_string()
     }
 }
@@ -47,6 +49,7 @@ impl From<&String> for Template {
     fn from(s: &String) -> Self {
         match s.as_str() {
             "chat" => Template::Chat,
+            "fibonacci" => Template::Fibonacci,
             _ => panic!("uqdev: template must be 'chat'; not '{s}'"),
         }
     }

src/new/templates/javascript/no-ui/chat/{package_name}/src/lib.js

@@ -23,7 +23,6 @@ function inputBytesToString(byteObject) {
 }
 
 function handleMessage(ourNode, messageArchive) {
-    printToTerminal(0, `{package_name}: 0 '${ourNode}'`);
     const [source, message] = receive();
 
     if (message.tag == 'response') {

src/new/templates/javascript/no-ui/fibonacci/.gitignore

@@ -0,0 +1,7 @@
+*/target/
+pkg/*.wasm
+*.swp
+*.swo
+*/wasi_snapshot_preview1.wasm
+*/wit/
+*/componentize.mjs

src/new/templates/javascript/no-ui/fibonacci/pkg/manifest.json

@@ -0,0 +1,13 @@
+[
+    {
+        "process_name": "{package_name}",
+        "process_wasm_path": "/{package_name}.wasm",
+        "on_exit": "Restart",
+        "request_networking": true,
+        "request_messaging": [
+            "net:sys:uqbar"
+        ],
+        "grant_messaging": [],
+        "public": true
+    }
+]

src/new/templates/javascript/no-ui/fibonacci/pkg/metadata.json

@@ -0,0 +1,5 @@
+{
+    "package": "{package_name}",
+    "publisher": "{publisher}",
+    "version": [0, 1, 0]
+}

src/new/templates/javascript/no-ui/fibonacci/{package_name}/package.json

@@ -0,0 +1,14 @@
+{
+  "name": "{package_name}",
+  "version": "0.1.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "author": "{publisher}",
+  "license": "MIT",
+  "dependencies": {
+    "@bytecodealliance/componentize-js": "0.5.0"
+  }
+}

src/new/templates/javascript/no-ui/fibonacci/{package_name}/src/lib.js

@@ -0,0 +1,101 @@
+// 240103: Date.now() always returns 0, so this timing does not currently work.
+
+import { printToTerminal, receive, sendResponse } from "uqbar:process/standard@0.5.0";
+
+function parseAddress(addressString) {
+    const [node, rest] = addressString.split('@');
+    const [process, packageName, publisher] = rest.split(':');
+    return { node, process, packageName, publisher };
+}
+
+function inputBytesToString(byteObject) {
+    // Determine the size of the Uint8Array
+    const size = Object.keys(byteObject).length;
+    const byteArray = new Uint8Array(size);
+
+    // Assign the bytes to the array
+    for (let i = 0; i < size; i++) {
+        byteArray[i] = byteObject[i];
+    }
+
+    // Convert the Uint8Array to a string
+    const string = new TextDecoder().decode(byteArray);
+
+    return {bytes: byteArray, string: string};
+}
+
+function fibonacci(n) {
+    if (n === 0) return 0;
+    if (n === 1) return 1;
+    return fibonacci(n - 1) + fibonacci(n - 2);
+}
+
+function handleMessage(ourNode) {
+    const [source, message] = receive();
+
+    if (message.tag == 'response') {
+        printToTerminal(0, `{package_name}: unexpected Response: ${JSON.stringify(message.val)}`);
+        process.exit(1);
+    } else if (message.tag == 'request') {
+        const { bytes: ipcBytes, string: ipc0 } = inputBytesToString(message.val.ipc)
+        const ipc = JSON.parse(ipc0);
+        const encoder = new TextEncoder();
+        if (ipc.Number) {
+            const number = ipc.Number;
+            const start = Date.now();
+            const result = fibonacci(number);
+            const duration = (Date.now() - start) * 1000000;
+            printToTerminal(0, `{package_name}: fibonacci(${number}) = ${result}; ${duration}ns`);
+            sendResponse(
+                {
+                    inherit: false,
+                    ipc: encoder.encode(JSON.stringify({ Number: result })),
+                    metadata: null
+                },
+                null
+            );
+        } else if (ipc.Numbers) {
+            const [number, numberTrials] = ipc.Numbers;
+            let durations = [];
+            for (let i = 0; i < numberTrials; i++) {
+                const start = Date.now();
+                const result = fibonacci(number);
+                const duration = (Date.now() - start) * 1000000;
+                durations.push(duration);
+            }
+            const result = fibonacci(number);
+            const mean = durations.reduce((sum, item) => sum + item, 0) / numberTrials;
+            const absoluteDeviation = durations
+                .map(item => Math.abs(item - mean))
+                .reduce((sum, item) => sum + item, 0) / numberTrials;
+            printToTerminal(
+                0,
+                `{package_name}: fibonacci(${number}) = ${result}; ${mean}±${absoluteDeviation}ns averaged over ${numberTrials} trials`,
+            );
+            sendResponse(
+                {
+                    inherit: false,
+                    ipc: encoder.encode(JSON.stringify({ Numbers: [result, numberTrials] })),
+                    metadata: null
+                },
+                null
+            );
+        } else {
+            throw new Error(`Unexpected Request: ${ipc}`)
+        }
+    }
+}
+
+export function init(our) {
+    printToTerminal(0, `{package_name}: begin (javascript)`);
+
+    const { node: ourNode } = parseAddress(our);
+
+    while (true) {
+        try {
+            handleMessage(ourNode);
+        } catch (error) {
+            printToTerminal(0, `{package_name}: got error ${error}`);
+        }
+    }
+}

src/new/templates/python/no-ui/fibonacci/.gitignore

@@ -0,0 +1,7 @@
+*/target/
+pkg/*.wasm
+*.swp
+*.swo
+*/wasi_snapshot_preview1.wasm
+*/wit/
+*/process_env

src/new/templates/python/no-ui/fibonacci/pkg/manifest.json

@@ -0,0 +1,13 @@
+[
+    {
+        "process_name": "{package_name}",
+        "process_wasm_path": "/{package_name}.wasm",
+        "on_exit": "Restart",
+        "request_networking": true,
+        "request_messaging": [
+            "net:sys:uqbar"
+        ],
+        "grant_messaging": [],
+        "public": true
+    }
+]

src/new/templates/python/no-ui/fibonacci/pkg/metadata.json

@@ -0,0 +1,5 @@
+{
+    "package": "{package_name}",
+    "publisher": "{publisher}",
+    "version": [0, 1, 0]
+}

src/new/templates/python/no-ui/fibonacci/{package_name}/src/lib.py

@@ -0,0 +1,92 @@
+import json
+import time
+
+import process
+from process.imports.standard import (
+    MessageRequest,
+    MessageResponse,
+    Response,
+    print_to_terminal,
+    receive,
+    send_response,
+)
+from process.types import Err
+
+def parse_address(address_string):
+    node, _, rest = address_string.partition("@")
+    process, _, rest = rest.partition(":")
+    package, _, rest = rest.partition(":")
+    publisher, _, rest = rest.partition(":")
+
+    return node, process, package, publisher
+
+def fibonacci(n):
+    if n == 0:
+        return 0
+    elif n == 1:
+        return 1
+    else:
+        return fibonacci(n-1) + fibonacci(n-2)
+
+def handle_message(our_node):
+    result = receive()
+    if isinstance(result, Err):
+        raise Exception(f"{result}")
+    source, message = result
+
+    match message:
+        case MessageResponse():
+            raise Exception(f"unexpected Response: {message}")
+        case MessageRequest():
+            if source.node != our_node:
+                raise Exception(f"dropping foreign Request from {source}")
+            ipc = json.loads(message.value.ipc.decode("utf-8"))
+            if "Number" in ipc:
+                number = ipc["Number"]
+                start = time.perf_counter_ns()
+                result = fibonacci(number)
+                duration = time.perf_counter_ns() - start
+                print_to_terminal(
+                    0,
+                    f"{package_name}: fibonacci({number}) = {result}; {duration}ns",
+                )
+                send_response(
+                    Response(False, json.dumps({"Number": result}).encode("utf-8"), None),
+                    None,
+                )
+            elif "Numbers" in ipc:
+                number, number_trials = ipc["Numbers"]
+                durations = []
+                for _ in range(number_trials):
+                    start = time.perf_counter_ns()
+                    result = fibonacci(number)
+                    duration = time.perf_counter_ns() - start
+                    durations.append(duration)
+                mean = sum(durations) / number_trials
+                absolute_deviation = sum(abs(item - mean) for item in durations) / number_trials
+                print_to_terminal(
+                    0,
+                    f"{package_name}: fibonacci({number}) = {result}; {duration}±{absolute_deviation}ns averaged over {number_trials} trials",
+                )
+                send_response(
+                    Response(
+                        False,
+                        json.dumps({"Numbers": [result, number_trials]}).encode("utf-8"),
+                        None,
+                    ),
+                    None,
+                )
+            else:
+                raise Exception(f"Unexpected Request: {ipc}")
+
+class Process(process.Process):
+    def init(self, our):
+        print_to_terminal(0, "{package_name}: begin (python)")
+
+        our_node, _, _, _ = parse_address(our)
+
+        while True:
+            try:
+                handle_message(our_node)
+            except Exception as e:
+                print(f"{package_name}: error: {e}")

src/new/templates/rust/no-ui/fibonacci/.gitignore

@@ -0,0 +1,7 @@
+*/target/
+pkg/*.wasm
+*.swp
+*.swo
+*/wasi_snapshot_preview1.wasm
+*/wit/
+*/process_env

src/new/templates/rust/no-ui/fibonacci/pkg/manifest.json

@@ -0,0 +1,13 @@
+[
+    {
+        "process_name": "{package_name}",
+        "process_wasm_path": "/{package_name}.wasm",
+        "on_exit": "Restart",
+        "request_networking": true,
+        "request_messaging": [
+            "net:sys:uqbar"
+        ],
+        "grant_messaging": [],
+        "public": true
+    }
+]

src/new/templates/rust/no-ui/fibonacci/pkg/metadata.json

@@ -0,0 +1,5 @@
+{
+    "package": "{package_name}",
+    "publisher": "{publisher}",
+    "version": [0, 1, 0]
+}

src/new/templates/rust/no-ui/fibonacci/{package_name}/Cargo.toml

@@ -0,0 +1,23 @@
+[package]
+name = "{package_name}"
+version = "0.1.0"
+edition = "2021"
+
+[profile.release]
+panic = "abort"
+opt-level = "s"
+lto = true
+
+[dependencies]
+anyhow = "1.0"
+bincode = "1.3.3"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+uqbar_process_lib = { git = "ssh://git@github.com/uqbar-dao/process_lib.git", rev = "56c29d9" }
+wit-bindgen = { git = "https://github.com/bytecodealliance/wit-bindgen", rev = "efcc759" }
+
+[lib]
+crate-type = ["cdylib"]
+
+[package.metadata.component]
+package = "uqbar:process"