SSH & WebAssembly

SSH "root" AT "123.45.67.89" PASSWORD "mypassword" ENTER `ls /var/www` SET ?result
AFTER EMIT ?result("stdout")

SSH "deploy" AT "123.45.67.89" KEY "/root/keys/id_rsa" ENTER `git pull` SET ?result
AFTER EMIT ?result("stdout")

SSH "admin" AT "123.45.67.89" ON "2222" PASSWORD "mypassword" ENTER `uptime` SET ?result
AFTER EMIT ?result("stdout")

SSH "deploy" AT "123.45.67.89" KEY "/root/keys/id_rsa" ENTER `
cd /var/www/myapp
git pull
npm install --production
pm2 restart all
` SET ?result
AFTER EMIT ?result("stdout")

SSH "deploy" AT "123.45.67.89" KEY "/root/keys/id_rsa" UPLOAD "/root/config.json" TO "/var/www/myapp/config.json"

SSH "root" AT "123.45.67.89" PASSWORD "mypassword" DOWNLOAD "/var/log/app.log" INTO "/mounted/logs/app.log" SET ?path
AFTER EMIT ?path

SSH "root" AT "123.45.67.89" PASSWORD "mypassword" ENTER `systemctl is-active nginx` SET ?r
AFTER IF ?r("exit_code") IS EQUAL TO 0
OPEN
  EMIT "nginx is running"
CLOSE
OR
OPEN
  EMIT "nginx is down"
CLOSE

STRING "hello" SET ?var
AFTER WEBASSEMBLY GRANT ?var AS "varalias"

STRING "Ocalt" SET ?name
AFTER NUMBER 5 SET ?count
AFTER WEBASSEMBLY GRANT ?name AS "name"
AFTER WEBASSEMBLY GRANT ?count AS "count"

STRING "hello" SET ?var
AFTER WEBASSEMBLY GRANT ?var AS "varalias"
AFTER WEBASSEMBLY TYPE "php" ENTER `
echo $oql['varalias'];
` SET ?result
AFTER EMIT ?result

WEBASSEMBLY TYPE "wasm" ENTER "/root/modules/compute.wasm" SET ?result
AFTER EMIT ?result

WEBASSEMBLY TYPE "php" ENTER `
$im = imagecreatetruecolor(200, 120);
$bg  = imagecolorallocate($im, 20, 30, 60);
$fg  = imagecolorallocate($im, 232, 182, 44);
imagefilledrectangle($im, 0, 0, 199, 119, $bg);
imagefilledellipse($im, 100, 60, 80, 80, $fg);
imagepng($im, "/root/badge.png");
echo filesize("/root/badge.png") . " bytes";
` SET ?result
AFTER EMIT ?result

WEBASSEMBLY TYPE "python" ENTER `
import numpy as np
from sklearn.linear_model import LinearRegression
x = np.array([[1],[2],[3],[4]])
y = np.array([3, 5, 7, 9])
m = LinearRegression().fit(x, y)
print("slope", round(float(m.coef_[0]), 3), "intercept", round(float(m.intercept_), 3))
` SET ?result
AFTER EMIT ?result

WEBASSEMBLY TYPE "python" ENTER `
import torch
a = torch.tensor([[1., 2.], [3., 4.]])
print("determinant", float(torch.det(a)))
` SET ?result
AFTER EMIT ?result

STRING "Ocalt" SET ?name
AFTER WEBASSEMBLY GRANT ?name AS "name"
AFTER WEBASSEMBLY TYPE "java" ENTER `
List<String> parts = new ArrayList<>(Arrays.asList("c", "a", "b"));
Collections.sort(parts);
System.out.println("hello " + oql.get("name") + " " + String.join(",", parts));
` SET ?result
AFTER EMIT ?result
(* Output: hello Ocalt a,b,c *)

STRING "Ocalt" SET ?name
AFTER WEBASSEMBLY GRANT ?name AS "name"
AFTER WEBASSEMBLY TYPE "rust" ENTER `
fn main() {
    let name = std::env::var("OQL_name").unwrap_or_default();
    let mut parts = vec!["c", "a", "b"];
    parts.sort();
    println!("hello {} {}", name, parts.join(","));
}
` SET ?result
AFTER EMIT ?result
(* Output: hello Ocalt a,b,c *)

STRING "Ocalt" SET ?name
AFTER WEBASSEMBLY GRANT ?name AS "name"
AFTER WEBASSEMBLY TYPE "go" ENTER `
package main

import (
	"fmt"
	"os"
	"sort"
	"strings"
)

func main() {
	parts := []string{"c", "a", "b"}
	sort.Strings(parts)
	fmt.Println("hello", os.Getenv("OQL_name"), strings.Join(parts, ","))
}
` SET ?result
AFTER EMIT ?result
(* Output: hello Ocalt a,b,c *)

WEBASSEMBLY SERVE "api" TYPE "node" ENTER "/root/app/server.js" ON 3000 SET ?p
AFTER EMIT ?p("name") & " is up on port " & ?p("port")

WEBASSEMBLY SERVE "orders" TYPE "java" ENTER "/root/app/orders.jar" ON 8080 SET ?j
AFTER WEBASSEMBLY SERVE "engine" TYPE "binary" ENTER "/root/bin/engine" ON 9000 SET ?e
AFTER EMIT ?j("pid") & " and " & ?e("pid")

WEBASSEMBLY SERVE "api" TYPE "node" ENTER "/root/app/server.js" ON 3000 SET ?p
AFTER NETWORK MAP "api.internal" TO PROCESS "api" SET ?r
AFTER EMIT ?r("address")

WEBASSEMBLY PROCESSES SET ?procs
AFTER FOREACH ?procs SET ?p
OPEN
  EMIT ?p("name") & " on " & ?p("port") & " — "
  AFTER IF ?p("running") IS EQUAL TO true
  OPEN
    EMIT "running"
  CLOSE
  OR
  OPEN
    EMIT "stopped"
  CLOSE
CLOSE

AFTER WEBASSEMBLY STOP "api" SET ?ok