[POC] end-user-programming "REPL" exploration

package.json

@@ -51,6 +51,7 @@
     "webpack-cli": "^3.1.0"
   },
   "dependencies": {
+    "@types/node-localstorage": "^1.3.0",
     "automerge": "^0.9.1",
     "browser-process-hrtime": "^0.1.2",
     "bs58": "^4.0.1",
@@ -68,8 +69,10 @@
     "hypercore-archiver": "^4.6.0",
     "hyperdiscovery": "^8.0.0",
     "js-crc": "^0.2.0",
+    "json-fn": "^1.1.1",
     "lodash": "^4.17.10",
     "micromatch": "^3.1.10",
+    "node-localstorage": "^1.3.1",
     "random-access-chrome-file": "^1.1.1",
     "react": "^16.5.2",
     "react-dom": "^16.5.2",

src/apps/repl/.gitignore

@@ -0,0 +1,2 @@
+.cache
+default

src/apps/repl/repl

@@ -0,0 +1,3 @@
+#!/usr/bin/env bash
+
+../../../node_modules/.bin/cross-env TS_NODE_FILES=1 TS_NODE_CACHE_DIRECTORY=.cache TS_NODE_SKIP_IGNORE=1 node -r ts-node/register ./repl.ts $@

src/apps/repl/repl.ts

@@ -0,0 +1,105 @@
+import { LocalStorage } from "node-localstorage"
+
+interface Global {
+  localStorage: LocalStorage
+}
+
+declare var global: Global
+
+global.localStorage = new LocalStorage("./localstorage")
+
+const raf = require("random-access-file")
+import * as Link from "capstone/Link"
+import * as Peek from "../../data/Peek"
+import * as Workspace from "../../plugins/Workspace"
+import * as repl from "repl"
+import CloudClient from "discovery-cloud/Client"
+import Content from "capstone/Content"
+import Handle from "capstone/Handle"
+import { Model as REPLModel } from "capstone/REPL"
+import Store from "capstone/Store"
+import StoreBackend from "capstone/StoreBackend"
+import { Doc } from "automerge/frontend"
+import { Hypermerge } from "hypermerge"
+import { last } from "lodash"
+import { parse } from "json-fn"
+
+const workspaceUrl = process.argv[2]
+
+const DEBUG = false
+
+const hm = new Hypermerge({ storage: raf })
+const storeBackend = new StoreBackend(hm)
+Content.store = new Store()
+
+storeBackend.sendQueue.subscribe(msg => {
+  if (DEBUG) {
+    console.log("backend msg", msg)
+  }
+  Content.store.onMessage(msg)
+})
+
+Content.store.sendQueue.subscribe(msg => {
+  if (DEBUG) {
+    console.log("frontend msg", msg)
+  }
+  storeBackend.onMessage(msg)
+})
+
+hm.joinSwarm(
+  new CloudClient({
+    url: "wss://discovery-cloud.herokuapp.com",
+    // url: "ws://localhost:8080",
+    id: hm.id,
+    stream: hm.stream,
+  }),
+)
+
+const startRepl = (replUrl: string) => {
+  repl.start({
+    prompt: ">>> ",
+    eval: (cmd: string, context: any, filename: string, callback: Function) => {
+      if (!cmd || !cmd.length) {
+        callback()
+      }
+
+      const handle = Content.open<REPLModel>(replUrl)
+
+      handle.change(doc => {
+        if (!doc.commands) {
+          doc.commands = [{ code: cmd }]
+        } else {
+          doc.commands.push({ code: cmd })
+        }
+
+        return doc
+      })
+
+      handle.subscribe(doc => {
+        const lastCmd = last(doc.commands)
+        if (!lastCmd) return
+
+        const { result } = lastCmd as { result: string }
+        if (!result) return
+
+        const parsed = parse(result)
+
+        handle.close()
+
+        callback(parsed.error, parsed.result)
+      })
+    },
+  })
+}
+
+hm.ready.then(hm => {
+  if (DEBUG) {
+    Peek.enable()
+  }
+
+  Content.once<Workspace.Model>(workspaceUrl, workspace => {
+    console.log(`Welcome to Capstone REPL! (${workspace.replUrl})`)
+
+    setTimeout(() => startRepl(workspace.replUrl), 10)
+  })
+})

src/components/App.tsx

@@ -5,11 +5,15 @@ import { Content } from "capstone"
 import Stats from "./Stats"
 import * as Debug from "debug"
 import * as css from "./css/App.css"
+import * as Board from "../plugins/Board"
+import * as UUID from "capstone/UUID"
 
 import "../plugins"
 
 const log = Debug("component:app")
 
+window.hooks = {}
+
 type State = {
   url?: string
   shouldHideFPSCounter?: boolean
@@ -26,6 +30,24 @@ export default class App extends React.Component<State> {
       shouldHideFPSCounter: Content.store.shouldHideFPSCounter(),
     })
 
+    Content.once(url, workspace => {
+      if (!workspace.rootUrl) return
+
+      Content.change<Board.Model>(workspace.rootUrl as string, rootBoard => {
+        const id = UUID.create()
+
+        rootBoard.cards[id] = {
+          id,
+          url: workspace.replUrl as string,
+          x: 100,
+          y: 100,
+          z: 1,
+          width: 300,
+          height: 500,
+        }
+      })
+    })
+
     setTimeout(() => {
       // This fn is triggered by the same observable setWorkspace writes to.
       // Without the timeout, some receive the workspace in the wrong order