-
Notifications
You must be signed in to change notification settings - Fork 5
/
index.js
138 lines (108 loc) · 3.05 KB
/
index.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
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
126
127
128
129
130
131
132
133
134
135
136
137
138
/*
eslint
no-multi-spaces: ["error", {exceptions: {"VariableDeclarator": true}}]
padded-blocks: ["error", {"classes": "always"}]
max-len: ["error", 80]
*/
'use strict'
const https = require('https')
const parse = require('json-parse-safe')
const isValidCoordinates = require('is-valid-coordinates')
const isObject = require('is.object')
const qs = require('qs')
const getPropValue = require('get-property-value')
class Geocoder {
constructor (options) {
this.format = '&format=json'
this.httpOptions = {
hostname: getPropValue(options, 'url') || 'nominatim.openstreetmap.org',
basePath: getPropValue(options, 'basePath') || '',
port: getPropValue(options, 'port') || 443,
agent: false,
headers: {
'User-Agent': getPropValue(options, 'userAgent') || 'node-open-geocoder'
}
}
this.timeout = getPropValue(options, 'timeout') || 10000
}
geocode (addr, options) {
const callOptions = isObject(options)
? `&${qs.stringify(options)}`
: '&addressdetails=1&polygon_geojson=1'
this.httpOptions.path = '/search?q=' +
encodeURI(addr.replace(/ /g, '+')) +
callOptions +
this.format
return this
}
reverse (lon, lat) {
if (!isValidCoordinates(lon, lat)) {
softOverrideMethod(this, 'end', (cb) => {
cb(new Error('Invalid coordinates!'))
})
} else {
this.httpOptions.path =
`/reverse?lon=${lon}&lat=${lat}${this.format}&addressdetails=1`
}
return this
}
end (cb) {
const req = https.get(this.httpOptions, responseHandler.bind(this, cb))
req.setTimeout(this.timeout, timeoutCb)
req.once('error', onError)
function timeoutCb () {
this.timedout = true
this.abort()
}
function onError (err) {
err = this.timedout
? timeoutError(err.message, this.socket.timeoutMs)
: err
cb(err)
}
}
}
module.exports = function geocoderExports (url) {
return new Geocoder(url)
}
//
// help functions
//
function responseHandler (handler, res) {
const statusCode = res.statusCode
const contentType = res.headers['content-type']
let error
if (statusCode !== 200) {
error = new Error(`Request Failed.\nStatus Code: ${statusCode}`)
} else if (!/^application\/json/.test(contentType)) {
error = new Error('Invalid content-type.\n' +
`Expected application/json but received ${contentType}`)
}
if (error) {
res.resume()
return handler(error)
}
res.setEncoding('utf8')
let rawData = ''
res
.on('data', onData)
.once('end', onEnd)
function onData (chunk) {
rawData += chunk
}
function onEnd () {
const json = parse(rawData)
return json.error
? handler(json.error)
: handler(null, json.value)
}
}
function timeoutError (reason, timeout) {
const err = new Error(`${reason} ${timeout}ms exceeded`)
err.timeout = timeout
err.code = 'ECONNABORTED'
return err
}
function softOverrideMethod (self, methodName, newMethod) {
self[methodName] = newMethod
}