forked from Kong/httpsnippet
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathhttpsnippet
More file actions
executable file
·125 lines (101 loc) · 2.88 KB
/
httpsnippet
File metadata and controls
executable file
·125 lines (101 loc) · 2.88 KB
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
#!/usr/bin/env node
'use strict';
var async = require('async');
var chalk = require('chalk');
var cmd = require('commander');
var debug = require('debug')('httpsnippet');
var fs = require('fs');
var HTTPSnippet = require('../src');
var path = require('path');
var pkg = require('../package.json');
cmd
.version(pkg.version)
.usage('[options] <file>')
.option('-t, --target <target>', 'target output')
.option('-c, --client [client]', 'target client library')
.option('-o, --output <directory>', 'write output to directory')
.option('-n, --output-name <name>', 'output file name')
.parse(process.argv);
if (!cmd.args.length || !cmd.target) {
cmd.help();
}
if (cmd.output) {
var dir = path.resolve(cmd.output);
if (!fs.existsSync(dir)) {
fs.mkdirSync(dir);
}
}
async.waterfall([
function isFile (next) {
var iterator = function (item, cb) {
cb(fs.statSync(item).isFile());
};
async.filter(cmd.args, iterator, function (results) {
next(null, results);
});
},
function read (files, next) {
var iterator = function (file, cb) {
fs.readFile(file, cb);
};
async.map(files, iterator, function (err, results) {
next(err, files, results);
});
},
function parse (files, buffers, next) {
var iterator = function (buffer, cb) {
try {
cb(null, JSON.parse(buffer));
} catch (e) {
debug('failed to parse source json');
cb('failed to parse source json', null);
}
};
async.map(buffers, iterator, function (err, results) {
next(err, files, results);
});
},
function snippet (files, sources, next) {
var iterator = function (source, cb) {
var snippet;
try {
snippet = new HTTPSnippet(source);
} catch (e) {
debug(e);
return cb(!e[0] ? 'invalid input' : (e[0].field + ' ' + e[0].message), null);
}
cb(null, snippet.convert(cmd.target, cmd.client));
};
async.map(sources, iterator, function (err, results) {
next(err, files, results);
});
},
function writeOutput (files, snippets, next) {
if (cmd.output) {
var iterator = function (file) {
var index = files.indexOf(file);
var name = path.basename(file, path.extname(file));
var filename = path.format({
dir: dir,
base: name + HTTPSnippet.extname(cmd.target)
});
fs.writeFile(filename, snippets[index] + '\n');
};
async.each(files, iterator);
}
next(null, files, snippets);
},
function log (files, snippets, next) {
if (!cmd.output) {
var iterator = function (file) {
var index = files.indexOf(file);
console.log('%s:\n%s\n', chalk.cyan.bold.underline(file), snippets[index]);
};
async.each(files, iterator);
}
}
], function (err, result) {
if (err) {
console.log('%s: %s', chalk.red.bold('ERROR'), err);
}
});