updated wasm adapter to support streaming compilation

Author: tysonrm

wasm/.vscode/settings.json oldwasm/wasm/.vscode/settings.jsonwasm/.vscode/settings.json renamed to oldwasm/wasm/.vscode/settings.json

@@ -0,0 +1,20 @@
+{
+  "targets": {
+    "debug": {
+      "binaryFile": "build/untouched.wasm",
+      "textFile": "build/untouched.wat",
+      "sourceMap": true,
+      "debug": true
+    },
+    "release": {
+      "binaryFile": "build/optimized.wasm",
+      "textFile": "build/optimized.wat",
+      "sourceMap": true,
+      "optimizeLevel": 3,
+      "shrinkLevel": 0,
+      "converge": false,
+      "noAssert": false
+    }
+  },
+  "options": {}
+}

wasm/README.md oldwasm/wasm/README.mdwasm/README.md renamed to oldwasm/wasm/README.md

@@ -0,0 +1,182 @@
+import * as aegis from './aegis'
+import * as nn from './neural-net'
+//import * as nn from "./neural-net";
+//import * as tst from "./test";
+
+const key: i32 = 0
+const val: i32 = 1
+
+class ModelSpec {
+  modelName: string
+  endpoint: string
+  constructor (name: string, endpoint: string) {
+    this.modelName = name
+    this.endpoint = endpoint
+  }
+}
+
+export function getModelSpec (): ModelSpec {
+  return new ModelSpec('wasm', 'wasm')
+}
+
+export const ArrayOfStrings_ID = idof<string[]>()
+
+function findVal (key: string, keys: string[], vals: string[]): string {
+  for (let i: i32 = 0; i < keys.length; i++) {
+    if (keys[i] == key) {
+      return vals[i].toString()
+    }
+  }
+  return ''
+}
+
+export function modelFactory (keys: string[], values: string[]): string[][] {
+  const arr = new Array<string[]>(3)
+  arr[0] = ['key1', findVal('key1', keys, values)]
+  arr[1] = ['key2', findVal('key2', keys, values)]
+  arr[2] = ['fibonacci', findVal('fibonacci', keys, values)]
+  return arr
+}
+
+export function getPorts (keys: string[], vals: string[]): string[][] {
+  //aegis.log("getPorts called  " + keys[0] + ":" + vals[0]);
+  const ports = new Array<string[]>(2)
+  //service,type,consumesEvent,producesEvent,callback,undo
+  ports[0] = ['port1', 'dFlow,outbound,dFlow_start,port1_done,port1Cb,1']
+  ports[1] = ['port2', 'dFlow,outbound,port1_done,port2_done,port2Cb,1']
+  return ports
+}
+
+export function port1Cb (keys: string[], vals: string[]): string[][] {
+  const cfg = [
+    ['port', 'port1'],
+    ['callback', 'port1Cb'],
+    ['consumesEvent', 'dFlow_start'],
+    ['producesEvent', 'port1_done']
+  ]
+  aegis.log(
+    'porf invokced' + cfg[0][0] + ' ' + cfg[0][1] + ' ' + cfg[0][2] + cfg[0][3]
+  )
+  return cfg
+}
+
+export function port2Cb (keys: string[], vals: string[]): string[][] {
+  const cfg = [
+    ['port', 'port2'],
+    ['callback', 'port2Cb'],
+    ['consumesEvent', 'port1_done'],
+    ['producesEvent', 'port2_done']
+  ]
+  aegis.log(
+    'porf invoked' + cfg[0][0] + ' ' + cfg[0][1] + ' ' + cfg[0][2] + cfg[0][3]
+  )
+  return cfg
+}
+
+export function getCommands (): string[][] {
+  const commands = new Array<string[]>(7)
+  commands[0] = ['serviceMeshListen', 'tell wasm module to begin listening']
+  commands[1] = ['serviceMeshNotify', 'tell wasm module to send broadcast']
+  commands[2] = ['serviceMeshCallback', 'subscribed event fired']
+  commands[3] = ['runFibonacci', 'remote calculate fibonacci']
+  commands[4] = ['fibonacci', 'calculate fibonacci for a number']
+  commands[5] = ['deployModule', 'request deployment of a module']
+  commands[6] = ['commandEx', 'command example']
+  return commands
+}
+
+export function commandEx (keys: string[], vals: string[]): string[][] {
+  aegis.log('\ncommandEx called ' + keys[0] + ':' + vals[0])
+  const retval = new Array<string[]>(1)
+  retval[0] = ['key1', 'commandEx_update!']
+  return retval
+}
+
+export function serviceMeshListen (keys: string[], vals: string[]): void {
+  aegis.log('serviceMeshListen: ' + keys[0] + ': ' + vals[0])
+  const eventName = findVal('eventName', keys, vals)
+  aegis.addListener(eventName, 'serviceMeshCallback')
+}
+
+export function serviceMeshNotify (keys: string[], vals: string[]): void {
+  const modelName = findVal('modelName', keys, vals)
+  const modelId = findVal('modelId', keys, vals)
+  const eventName = findVal('eventName', keys, vals)
+  const eventData = new Array<string[]>(3)
+  aegis.log('wasm notify called with args: ' + modelName + ': ' + modelId)
+  eventData[0] = [keys[0], vals[0]]
+  eventData[1] = ['modelName', modelName]
+  eventData[2] = ['modelId', modelId]
+  aegis.fireEvent(eventName || 'wasmWebListen', eventData, 1)
+}
+
+export function serviceMeshCallback (
+  keys: string[],
+  vals: string[]
+): string[][] {
+  aegis.log('websocket callback fired: ' + keys[0] + ': ' + vals[0])
+  const eventName = findVal('eventName', keys, vals)
+  const eventData = new Array<string[]>(2)
+  eventData[0] = [keys[0], vals[0]]
+  eventData[1] = [keys[1], vals[1]]
+  aegis.fireEvent(eventName + 'callback', eventData, 1)
+  return [['key1', 'serviceMeshCallback']]
+}
+
+export function fibonacci (x: number): number {
+  if (x === 0) {
+    return 0
+  }
+  if (x === 1) {
+    return 1
+  }
+  return fibonacci(x - 1) + fibonacci(x - 2)
+}
+
+export function runFibonacci (keys: string[], vals: string[]): string[][] {
+  let val: number = 0
+  let startTime: i64 = Date.now()
+
+  for (let i = 0; i < keys.length; i++) {
+    if ('fibonacci' == keys[i]) {
+      val = parseInt(vals[i])
+      break
+    }
+  }
+  const sum = fibonacci(val)
+  const ret = new Array<string[]>(2)
+  ret[0] = ['result', sum.toString()]
+  ret[1] = ['time', (Date.now() - startTime).toString()]
+  return ret
+}
+
+export function portEx (keys: string[], vals: string[]): void {
+  aegis.log('portEx calling port wasmTestPort' + keys[0] + ':' + vals[0])
+  return
+}
+
+export function onUpdate (keys: string[], vals: string[]): string[][] {
+  return [['updatedByWasm', new Date(Date.now()).toISOString()]]
+}
+
+export function onDelete (keys: string[], vals: string[]): i8 {
+  // return negative to stop the action
+  aegis.log('onDelete called')
+  return -1
+}
+
+export function validate (keys: string[], vals: string[]): void {
+  aegis.log('onUpdate called')
+  return
+}
+
+export function test (keys: string[], values: string[]): string[][] {
+  const key1 = keys[0] == 'key1' ? values[0] : 'default'
+  const key2 = keys[1] == 'key2' ? values[1] : 'default'
+  const arr = new Array<string[]>(3)
+  arr[0] = ['key1', key1]
+  arr[1] = ['key2', key2]
+  arr[2] = ['key3', 'alwaysThisValue']
+  aegis.log('test called')
+  return arr
+}

oldwasm/wasm/asconfig.json

@@ -0,0 +1,6 @@
+{
+  "extends": "assemblyscript/std/assembly.json",
+  "include": [
+    "./**/*.ts"
+  ]
+}