-
Notifications
You must be signed in to change notification settings - Fork 0
/
daffy-get.js
72 lines (64 loc) · 2.07 KB
/
daffy-get.js
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
const commandLineArgs = require('command-line-args');
const commandLineUsage = require('command-line-usage');
const fs = require("fs");
function usage() {
const usage = commandLineUsage([{ header: 'daffy-get.js', content: 'Pull the next item from a daffy server.' }, { header: 'Options', optionList: opts_def }]);
console.log(usage);
process.exit(0);
}
const opts_def = [
{ name: 'id', type: String, alias: 'i', defaultOption: true, defaultValue: '?', description: 'The dataset ID to use', typeLabel: '<id>' },
{ name: 'host', type: String, alias: 'H', defaultValue: 'localhost', description: 'Hostname of the daffy server', typeLabel: '<hostname>' },
{ name: 'port', type: Number, alias: 'P', defaultValue: 8033, description: 'Port of the daffy server', typeLabel: '<port>' },
{ name: 'secure', type: Boolean, alias: 's', defaultValue: false, description: 'Use https instead of http' },
{ name: 'help', type: Boolean, alias: 'h', defaultValue: false, description: 'Display this help.' }
];
const opts = commandLineArgs(opts_def);
if (opts.help) {
usage();
}
const proto = (opts.secure) ? "https:" : "http:";
const http = (opts.secure) ? require('https') : require('http');
const hostname = opts.host;
const port = opts.port;
if (opts.id==='?' || opts.id==='') {
usage();
}
const path = '/' + opts.id + '/next';
const req = http.request({
protocol: proto,
hostname: hostname,
port: port,
method: 'GET',
path: path,
}, function(res) {
let resp = "";
res.setEncoding('utf8');
res.on('data', (chunk) => {
resp += chunk;
});
res.on('end', () => {
if (res.statusCode < 300) {
console.log(resp);
process.exit(0);
}
else if (res.statusCode === 403) {
console.error("Dataset " + opts.id + " is exhausted.");
process.exit(1);
}
else if (res.statusCode === 404) {
console.error("Dataset " + opts.id + " not found.");
process.exit(2);
}
else {
console.error("Error: " + res.statusCode.toString() + " " + resp);
process.exit(3);
}
});
});
req.on("error", (e) => {
console.error("Communication error:");
console.error(e);
process.exit(4);
});
req.end();