Awesome
scramjet-cli
Allows to run scramjet modules from command line facilitating input and output.
Install globally...
npm install -g scramjet-cli
... and use:
$ cat file.log | scr ./my-module > augmented.log
A module that fetches response body from each given url would look like this:
module.exports = (stream /* assumes StringStream */) => {
return stream
.lines()
.parse(url.parse)
.map(util.promisify(http.get))
.catch(e => console.warn("Error in stream", e.stack))
.map(x => JSON.parse(x));
};
Full usage:
Usage: scramjet [-i input] [-o output|-d] [-t StreamClass] [-p plg [-p plg]...] mod1 [mod2] ...
Options:
-i --input input - url to get, file path, empty or '-' for stdin, default: -
-o --output output - file path, '@' for print, empty or '-' for stdout, default: -
-d --display short for -o @, passes the outcome of last module to console.log
-t --type stream type, default: StringStream
-p --plugin import plugin module (argument for require)
module a module that will be passed with the stream and should return a stream
the module should return an async function that will be called
the async function will then be awaited and passed to then next
License
MIT - see LICENSE