-
Notifications
You must be signed in to change notification settings - Fork 21
/
Copy pathndjson-sort
executable file
·50 lines (44 loc) · 1.33 KB
/
ndjson-sort
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
#!/usr/bin/env node
var readline = require("readline"),
vm = require("vm"),
commander = require("commander"),
requires = require("./requires"),
expression = require("./expression"),
output = require("./output");
commander
.version(require("./package.json").version)
.usage("[options] [expression]")
.description("Sort values in a newline-delimited JSON stream.")
.option("-r, --require <name=module>", "require a module", requires, {a: undefined, b: undefined})
.parse(process.argv);
if (commander.args.length > 1) {
commander.outputHelp();
process.exit(1);
}
if (commander.args.length < 1) {
commander.args[0] = "a < b ? -1 : a > b ? 1 : a >= b ? 0 : NaN";
}
var i = -1,
results = [],
sandbox = commander.require,
compare = expression(commander.args[0]),
context = new vm.createContext(sandbox);
readline.createInterface({
input: process.stdin,
output: null
}).on("line", function(line) {
++i;
try {
results.push(JSON.parse(line));
} catch (error) {
console.error("stdin:" + (i + 1));
console.error(line);
console.error("^");
console.error("SyntaxError: " + error.message);
process.exit(1);
}
}).on("close", function() {
results
.sort(function(a, b) { return sandbox.a = a, sandbox.b = b, compare.runInContext(context); })
.forEach(output);
});