90 lines
2.4 KiB
JavaScript
90 lines
2.4 KiB
JavaScript
|
import request from 'request-json'
|
||
|
|
|
||
|
|
import defaults from '../api/defaults'
|
||
|
|
import config from '../config'
|
||
|
|
|
||
|
|
function parseBody(body, reject) {
|
||
|
|
try {
|
||
|
|
return JSON.parse(body)
|
||
|
|
} catch (error) {
|
||
|
|
// eslint-disable-next-line no-console
|
||
|
|
console.log(body)
|
||
|
|
return reject(error)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
function callback(resolve, reject) {
|
||
|
|
return (err, res, rawBody) => {
|
||
|
|
let body = rawBody
|
||
|
|
if (err) {
|
||
|
|
return reject(err)
|
||
|
|
}
|
||
|
|
if (typeof body === 'string' && body) {
|
||
|
|
body = parseBody(body, reject)
|
||
|
|
}
|
||
|
|
if (res.statusCode >= 300 ||
|
||
|
|
res.statusCode < 200) {
|
||
|
|
return reject(body)
|
||
|
|
}
|
||
|
|
resolve(body)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
export default function createClient(host = config.get('server:port'), opts) {
|
||
|
|
let options = defaults(opts, {})
|
||
|
|
|
||
|
|
let client = request.createClient('', options)
|
||
|
|
let prefix
|
||
|
|
|
||
|
|
prefix = `http://localhost:${host}`
|
||
|
|
client.headers['x-request-id'] = 'asdf'
|
||
|
|
|
||
|
|
client.auth = (user) => {
|
||
|
|
// let m = helperDB.model('user', {
|
||
|
|
// id: user.id,
|
||
|
|
// level: (user.get && user.get('level')) || 1,
|
||
|
|
// institute_id: (user.get && user.get('institute_id')) || null,
|
||
|
|
// password: (user.get && user.get('password')) || null,
|
||
|
|
// })
|
||
|
|
// let token = jwt.createUserToken(m)
|
||
|
|
// client.headers.authorization = `Bearer ${token}`
|
||
|
|
}
|
||
|
|
|
||
|
|
// Simple wrappers to wrap into promises
|
||
|
|
client.getAsync = (path) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
if (path.slice(0, 4) === 'http') {
|
||
|
|
return client.get(path, callback(resolve, reject))
|
||
|
|
}
|
||
|
|
client.get(prefix + path, callback(resolve, reject))
|
||
|
|
})
|
||
|
|
|
||
|
|
// Simple wrappers to wrap into promises
|
||
|
|
client.saveFileAsync = (path, destination) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
client.saveFile(prefix + path, destination, callback(resolve, reject, true))
|
||
|
|
})
|
||
|
|
|
||
|
|
client.postAsync = (path, data) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
client.post(prefix + path, data, callback(resolve, reject))
|
||
|
|
})
|
||
|
|
|
||
|
|
client.putAsync = (path, data) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
client.put(prefix + path, data, callback(resolve, reject))
|
||
|
|
})
|
||
|
|
|
||
|
|
client.deleteAsync = (path) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
client.del(prefix + path, callback(resolve, reject))
|
||
|
|
})
|
||
|
|
|
||
|
|
client.sendFileAsync = (path, files, data) =>
|
||
|
|
new Promise((resolve, reject) => {
|
||
|
|
client.sendFile(prefix + path, files, data || {}, callback(resolve, reject))
|
||
|
|
})
|
||
|
|
|
||
|
|
return client
|
||
|
|
}
|