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
|
'use strict'
const {parse: parseUrl} = require('url')
const connect = require('./connect')
const createParser = require('./lib/response-parser')
const {
DEFAULT_PORT,
ALPN_ID,
} = require('./lib/util')
const {CODES} = require('./lib/statuses')
const _request = (pathOrUrl, opt, cb) => {
connect(opt, (err, socket) => {
if (err) return cb(err)
if (socket.alpnProtocol !== ALPN_ID) {
socket.destroy()
return cb(new Error('invalid or missing ALPN protocol'))
}
const res = createParser()
socket.pipe(res)
socket.once('error', (err) => {
socket.unpipe(res)
res.destroy(err)
})
const close = () => {
socket.destroy()
res.destroy()
}
let timeout = setTimeout(close, 20 * 1000)
res.once('header', (header) => {
clearTimeout(timeout)
// prepare res
res.socket = socket
res.statusCode = header.statusCode
res.statusMessage = header.statusMsg
res.meta = header.meta // todo: change name
// todo: res.abort(), res.destroy()
cb(null, res)
socket.emit('response', res)
})
// send request
socket.end(encodeURI(pathOrUrl) + ' \r\n')
})
}
const sendGeminiRequest = (pathOrUrl, opt, cb) => {
if (typeof pathOrUrl !== 'string' || !pathOrUrl) {
throw new Error('pathOrUrl must be a string & not empty')
}
if (typeof opt === 'function') {
cb = opt
opt = {}
}
const {
followRedirects,
cert, key, passphrase,
tlsOpt,
} = {
followRedirects: false,
cert: null, key: null, passphrase: null,
tlsOpt: {},
...opt,
}
const target = parseUrl(pathOrUrl)
const hostname = target.hostname || 'localhost'
const port = target.port || DEFAULT_PORT
const reqOpt = {
hostname, port,
cert, key, passphrase,
tlsOpt,
}
let onRes = cb
if (followRedirects) {
// todo: prevent endless redirects
onRes = (err, res) => {
if (err) return cb(err)
if (
res.statusCode === CODES.REDIRECT_TEMPORARY ||
res.statusCode === CODES.REDIRECT_PERMANENT
) {
const newTarget = parseUrl(res.meta)
_request(res.meta, {
...reqOpt,
host: newTarget.hostname || hostname,
port: newTarget.port || port,
}, onRes)
} else {
cb(null, res)
}
}
}
_request(pathOrUrl, reqOpt, onRes)
}
module.exports = sendGeminiRequest
|
