for dylan

Author: lanmower

api/run.js

@@ -5,7 +5,7 @@ const express = require('express')
  * @returns {Object} - The router object.
  */
 const init = (node) => {
-  
+
   const runKey = async (req, res) => {
     console.log("run called");
     let body = req.body;
@@ -38,7 +38,7 @@ const init = (node) => {
       res.status(500).end();
     }
   };
-  
+
   const findKey = async (req, res) => {
     console.log("find called", req.params);
     try {
@@ -66,9 +66,5 @@ const init = (node) => {
   router.post("/key/:pk", runKey);
   return router;
 };
-process.on('unhandledException', (reason, promise) => {
-  console.log('Unhandled Rejection at:', reason.stack || reason)
-  // Recommended: send the information to sentry.io
-  // or whatever crash reporting service you use
-})
+
 module.exports = init;

api/server.js

@@ -1,46 +1,60 @@
 /**
  * Loads the environment variables and starts the server.
  */
-require("dotenv").config();
-const express = require("express");
-const tasks = require("./tasks.js");
-const run = require("./run.js");
-const nodes = require("./nodes.js");
-const fs = require("fs");
-const node = require("hyper-ipc-secure")();
+require("dotenv").config()
+const express = require("express")
+const tasks = require("./tasks.js")
+const run = require("./run.js")
+const nodes = require("./nodes.js")
+const stores = require("./stores.js")
+const fs = require("fs")
+
+
+let node = require("hyper-ipc-secure")()
+
+async function exitHandler(options, exitCode) {
+  console.log('restarted node')
+  node = require("hyper-ipc-secure")()
+}
+
+process.on('exit', exitHandler.bind(null, 'cleanup'))
+process.on('uncaughtException', exitHandler.bind(null, 'uncaughtException'))
+process.on('unhandledRejection', exitHandler.bind(null, 'unhandledRejection'))
+
 /**
  * Creates a folder if it doesn't exist.
  * @param {string} folderPath - The path of the folder.
  */
 function createFolderIfNotExists(folderPath) {
   if (!fs.existsSync(folderPath)) {
     // If the folder doesn't exist, create it
-    fs.mkdirSync(folderPath);
+    fs.mkdirSync(folderPath)
     console.log(`Folder "${folderPath}" created.`)
   } else {
     console.log(`Folder "${folderPath}" already exists.`)
   }
 }
-createFolderIfNotExists("saves");
-const app = express();
-const port = process.env.PORT || 3011;
-app.use(express.json());
+createFolderIfNotExists("saves")
+const app = express()
+const port = process.env.PORT || 3011
+app.use(express.json())
 app.use(express.urlencoded({
   extended: true
-}));
+}))
 app.use((function (req, res, next) {
-  res.setHeader("Access-Control-Allow-Origin", "*");
-  res.setHeader("Access-Control-Allow-Methods", "GET, POST, OPTIONS, PUT, PATCH, DELETE");
-  res.setHeader("Access-Control-Allow-Headers", "X-Requested-With, content-type");
-  res.setHeader("Access-Control-Allow-Credentials", true);
+  res.setHeader("Access-Control-Allow-Origin", "*")
+  res.setHeader("Access-Control-Allow-Methods", "GET, POST, OPTIONS, PUT, PATCH, DELETE")
+  res.setHeader("Access-Control-Allow-Headers", "X-Requested-With, content-type")
+  res.setHeader("Access-Control-Allow-Credentials", true)
   next()
-}));
-const vault = nodes(node);
+}))
+const vault = nodes(node)
 console.log(vault)
-app.use("/vault", vault);
-app.use("/task", tasks(node));
-app.use("/run", run(node));
-app.use(express.static('public'));
+app.use("/vault", vault)
+app.use("/task", tasks(node))
+app.use("/stores", stores)
+app.use("/run", run(node))
+app.use(express.static('public'))
 app.listen(port, (() => {
   console.log(`Example app listening on port ${port}`)
-}));
+}))

api/stores.js

@@ -5,7 +5,7 @@ const Hyperswarm = require('hyperswarm')
 const dbs = []
 
 const prepDb = async (name) => {
-    if(dbs[name]) return dbs[name];
+    if (dbs[name]) return dbs[name];
     const core = new Hypercore('./' + name)
     await core.ready()
     const db = new Hyperbee(core, { keyEncoding: 'utf-8', valueEncoding: 'binary' })
@@ -16,4 +16,35 @@ const prepDb = async (name) => {
     return db
 }
 
-module.exports = { prepDb }
+const init = (node) => {
+
+    const save = async (req, res) => {
+        const db = await prepDb('./' + req.params.db)
+        console.log(req.body, req.params)
+        await db.put(req.params.name, JSON.stringify(req.body))
+        res.write("{success:true}")
+        res.status(200).end()
+    };
+
+    const load = async (req, res) => {
+        const db = await prepDb('./' + req.params.db)
+        try {
+            const lookup = await db.get(req.params.name);
+            console.log(lookup.value.toString('utf-8'))
+            res.write(lookup.value)
+            res.status(200).end();
+        } catch (e) {
+            console.error(e);
+            res.write(JSON.stringify({
+                error: e
+            }));
+            res.status(500).end();
+        }
+    };
+    router.get("/load/:name", load);
+    router.post("/save/:name", save);
+    console.log('stores')
+    return router;
+}
+
+module.exports = init

api/tasks.js

@@ -67,9 +67,7 @@ const init = (node) => {
   };
   console.log('tasks')
   const router = express.Router();
-  router.get("/load/:name", loadTask);
   router.post("/run/:pk/:actionname", runTask);
-  router.post("/save/:name", saveTask);
   return router;
 };
 

ui/src/routes/flow/+page.svelte

@@ -22,7 +22,7 @@
         );
         const key = await keyFetch.json();
       const subFetch = await fetch(
-          `http://localhost:3011/vault/getSub/${newName}`,
+          `http://localhost:3011/vault/getSub/call-${newName}`,
           {
             method: "POST",
             body: JSON.stringify({ key }),
@@ -94,7 +94,7 @@
     };
   
     const save = async (incalls, taskName) => {
-      const url = `http://localhost:3011/task/save/${taskName}`
+      const url = `http://localhost:3011/store/save/task/${taskName}`
       const fetched = await fetch(url, {
         headers: { "Content-Type": "application/json" },
         method: "POST",
@@ -103,7 +103,7 @@
       console.log(calls)
     };
     const load = async (taskName) => {
-      const url = `http://localhost:3011/task/load/${taskName}`
+      const url = `http://localhost:3011/store/load/task/${taskName}`
       const fetched = await fetch(url, { method: "GET" })
       const json = await fetched.json();
       console.log({json});

ui/src/routes/keys/components/Host.svelte

@@ -29,7 +29,7 @@
         })
         const key = await keyFetch.json();
 
-        const subFetch = await fetch(`http://localhost:3011/vault/getSub/${keyName}`, {
+        const subFetch = await fetch(`http://localhost:3011/vault/getSub/call-${keyName}`, {
             method: "POST",
             body: JSON.stringify({ key }),
             headers: {