/
httpsnippet
executable file
·125 lines (101 loc) · 2.85 KB
/
httpsnippet
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] <files ...>')
.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)
}
})