set up groundwork for interactive mode

Author: raine

.gitignore

@@ -2,3 +2,5 @@
 /node_modules
 npm-debug.log
 lib/
+.cache
+dist/

.npmignore

@@ -6,3 +6,4 @@ test
 Makefile
 wercker.yml
 stuff
+.cache

.prettierrc

@@ -0,0 +1,8 @@
+{
+  "printWidth": 80,
+  "proseWrap": "always",
+  "semi": false,
+  "singleQuote": true,
+  "bracketSpacing": true,
+  "arrowParens": "always"
+}

package-lock.json

@@ -11,11 +11,16 @@
   "scripts": {
     "test": "make test",
     "test-ci": "make test && make test-func",
-    "test-local": "make test && make docker-test-func"
+    "test-local": "make test && make docker-test-func",
+    "build-web:watch": "parcel serve --no-source-maps web/index.html",
+    "build:watch": "watchy -w 'src/**' -- make"
   },
   "bin": {
     "ramda": "./bin/ramda"
   },
+  "browser": {
+    "./lib/config": false
+  },
   "author": "Raine Virta <[email protected]>",
   "license": "ISC",
   "dependencies": {
@@ -24,23 +29,33 @@
     "camelize": "^1.0.0",
     "debug": "^4.1.0",
     "editor": "^1.0.0",
+    "express": "^4.16.4",
     "fast-csv": "^2.4.1",
     "flat": "^4.1.0",
     "is-there": "^4.4.3",
     "livescript": "^1.6.0",
     "minimist": "^1.2.0",
+    "opn": "^5.4.0",
+    "polka": "^0.5.1",
     "ramda": "0.26.1",
+    "serve-static": "^1.13.2",
     "split2": "^3.0.0",
+    "string-argv": "^0.1.1",
     "through2": "^3.0.0",
     "transduce-stream": "^0.5.0"
   },
   "devDependencies": {
     "chai": "^4.2.0",
     "concat-stream": "^1.6.2",
+    "lodash.debounce": "^4.0.8",
     "mocha": "^5.2.0",
+    "parcel-bundler": "^1.10.3",
+    "react": "^16.6.3",
+    "react-dom": "^16.6.3",
     "rewire": "^4.0.1",
     "shelljs": "^0.8.3",
     "sinon": "^7.2.2",
+    "string-to-stream": "^1.1.1",
     "strip-ansi": "^5.0.0"
   }
 }

package.json

@@ -10,6 +10,7 @@ HELP =
     """
     Usage: ramda [options] [function] ...
 
+          --interactive    interactive mode
       -f, --file           read a function from a js/ls file instead of args; useful for
                            larger scripts
       -c, --compact        compact output for JSON and tables
@@ -66,7 +67,7 @@ export parse = (argv) ->
     argv = map (wrap-number-lookup << wrap-function), argv.slice 2
     args = camelize minimist argv,
         string: <[ file input-type output-type json-path csv-delimiter ]>
-        boolean: <[ compact slurp unslurp pretty verbose version raw-input raw-output configure no-stdin js transduce headers ]>
+        boolean: <[ compact slurp unslurp pretty verbose version raw-input raw-output configure no-stdin js transduce headers interactive ]>
         alias: parse-aliases HELP
         default: {+stdin, +headers, 'csv-delimiter': \,}
 

src/argv.ls

@@ -1,6 +1,6 @@
 #!/usr/bin/env lsc
 require! {vm, JSONStream, path: Path, split2, fs, camelize}
-require! <[ ./argv ./config ]>
+require! <[ ./argv ./config ./server ]>
 require! './compile-fun'
 require! through2: through
 require! stream: {PassThrough}
@@ -128,7 +128,18 @@ make-input-stream = (die, opts, stdin) ->
     if opts.stdin then make-stdin-parser die, opts, stdin
     else               blank-obj-stream!
 
-main = (process-argv, stdin, stdout, stderr) ->
+append-buffer =
+    (buf1, buf2) -> Buffer.concat([ buf1, buf2 ])
+
+get-stream-as-promise = (stream, cb) ->
+    new Promise (resolve, reject) ->
+        res = null
+        stream
+            .pipe reduce-stream append-buffer, Buffer.alloc-unsafe 0
+            .on 'data', (chunk) -> res := chunk
+            .on 'end', -> resolve res
+
+main = (process-argv, stdin, stdout, stderr) ->>
     stdout.on \error ->
         if it.code is 'EPIPE' then process.exit 0
 
@@ -142,10 +153,17 @@ main = (process-argv, stdin, stdout, stderr) ->
 
     if opts.help    then return die argv.help!
     if opts.version then return die <| require '../package.json' .version
+
     if opts.configure
-        return config.edit (err) ->
+        config.edit (err) ->
             if err != 0 or err then die err
             else process.exit 0
+        return
+
+    if opts.interactive
+        raw-stdin-buf = await get-stream-as-promise stdin
+        server.start log-error, raw-stdin-buf, process-argv
+        return
 
     if opts.file
         try fun = require Path.resolve opts.file

src/main.ls

@@ -0,0 +1,17 @@
+require! {path: Path}
+require! polka
+require! 'serve-static'
+require! opn
+
+export start = (log-error, raw-stdin-buf, process-argv) ->
+    app = polka!
+        .use serve-static (Path.join __dirname, '..', 'dist'), {'index': ['index.html']}
+        .get '/stdin', (req, res) ->
+            res.write-head 200, 'Content-Type': 'text/plain'
+            res.end raw-stdin-buf
+        .get '/argv', (req, res) ->
+            res.write-head 200, 'Content-Type': 'application/json'
+            res.end JSON.stringify process-argv.slice 2
+        .listen 63958, (err) ->
+            log-error "listening at port #{app.server.address().port}"
+            opn "http://localhost:#{app.server.address().port}", { wait: false }

src/server.ls

@@ -0,0 +1,11 @@
+<!doctype html>
+<html lang="en">
+<head>
+  <meta name="viewport" content="width=device-width, initial-scale=1.0">
+  <meta charset="utf-8">
+</head>
+<body>
+  <div id="root"></div>
+  <script src="./index.js"></script>
+</body>
+</html>

web/index.html

@@ -0,0 +1,68 @@
+import React from 'react'
+import { render } from 'react-dom'
+import stringToStream from 'string-to-stream'
+import JSONStream from 'JSONStream'
+import livescript from 'livescript'
+import debounce from 'lodash.debounce'
+import compileFun from '../lib/compile-fun'
+import { parse } from '../lib/argv'
+import stringArgv from 'string-argv'
+
+const getStdin = () =>
+  window
+    .fetch('/stdin', {
+      headers: { 'Content-Type': 'text/plain; charset=utf-8' }
+    })
+    .then((res) => res.text())
+
+getStdin().then((str) => {
+  doRender({ stdin: str })
+})
+
+const die = (msg) => console.error(msg)
+
+class App extends React.Component {
+  constructor(props) {
+    super(props)
+    this.onInputChange = this.onInputChange.bind(this)
+    this.evalInput = debounce(this.evalInput.bind(this), 300)
+    this.state = {
+      input: props.input
+    }
+
+    this.evalInput()
+  }
+
+  onInputChange(ev) {
+    const val = ev.target.value
+    this.setState({ input: val }, this.evalInput)
+  }
+
+  evalInput() {
+    const { stdin } = this.props
+    const { input } = this.state
+    const argv = stringArgv(input, 'node', 'dummy.js')
+    const opts = parse(argv)
+    const fun = compileFun(opts, die)
+  }
+
+  render() {
+    return (
+      <div>
+        <input
+          type="text"
+          value={this.state.input}
+          onChange={(ev) => {
+            ev.persist()
+            this.onInputChange(ev)
+          }}
+        />
+      </div>
+    )
+  }
+}
+
+const doRender = (props) =>
+  render(<App {...props} />, document.getElementById('root'))
+
+doRender({ stdin: null, input: 'identity' })