Improve BOS API

- `domain.runtime` with autoloader
- `api.bos.listFlows()`
- `api.bos.getFlow({ name })`
- `api.bos.saveFlow({ name, source })`

application/api/bos.1/getFlow.js

@@ -3,7 +3,7 @@
 
   async method({ name }) {
     const filePath = `./application/flow/${name}.md`;
-    const source = await node.fs.promises.readFile(filePath, 'utf8');
+    const source = await node.fsp.readFile(filePath, 'utf8');
     return { name, source };
   },
 });

application/api/bos.1/listFlows.js

@@ -0,0 +1,10 @@
+({
+  access: 'public',
+
+  async method({}) {
+    const dirPath = `./application/flow/`;
+    const files = await node.fsp.readdir(dirPath);
+    const names = files.map((file) => node.path.basename(file, '.md'));
+    return { names };
+  },
+});

application/api/bos.1/saveFlow.js

@@ -0,0 +1,10 @@
+({
+  access: 'public',
+
+  async method({ name, source }) {
+    const filePath = `./application/flow/${name}.md`;
+    await node.fsp.writeFile(filePath, source);
+    await domain.runtime.load({ name: filePath });
+    return { success: true };
+  },
+});

application/api/bos.1/startFlow.js

@@ -2,23 +2,19 @@
   access: 'public',
 
   async method({ name }) {
-    const { clients, processes } = domain.flow;
-
     context.client.on('close', () => {
       clients.delete(context.client);
     });
 
-    const filePath = `./application/flow/${name}.md`;
-    const src = await node.fs.promises.readFile(filePath, 'utf8');
-    const domainProcess = npm.lowscript.parseProcess(src);
-    const instance = await npm.lowscript.startProcess(domainProcess);
+    const proc = domain.runtime.flows.get(name);
+    const flow = await npm.lowscript.startProcess(proc);
 
-    instance.on('step', (step) => {
+    flow.on('step', (step) => {
       context.client.emit('demo/step', { step });
     });
 
-    processes.set(context.client, instance);
-    clients.set(instance, context.client);
+    domain.flow.processes.set(context.client, instance);
+    domain.flow.clients.set(instance, context.client);
 
     return { success: true };
   },

application/domain/runtime/load.js

@@ -0,0 +1,8 @@
+async ({ name }) => {
+  const filePath = `./application/flow/${name}.md`;
+  const src = await node.fsp.readFile(filePath, 'utf8');
+  const procedures = npm.lowscript.parseProcess(src);
+  for (const proc of procedures) {
+    domain.runtime.flows.set(proc.name, proc);
+  }
+};

application/domain/runtime/start.js

@@ -0,0 +1,12 @@
+async () => {
+  domain.runtime.clients = new Map();
+  domain.runtime.processes = new Map();
+  domain.runtime.flows = new Map();
+
+  const dirPath = `./application/flow/`;
+  const files = await node.fsp.readdir(dirPath);
+  for (const file of files) {
+    const name = node.path.basename(file, '.md');
+    await domain.runtime.load({ name });
+  }
+};

package.json

@@ -35,6 +35,7 @@
   },
   "dependencies": {
     "impress": "^2.6.8",
+    "lowscript": "0.0.2",
     "metasql": "^2.0.2",
     "pg": "^8.7.3",
     "redis": "^4.0.4"