storage-upload/test/helper.client.js

90 lines
2.4 KiB
JavaScript
Raw Normal View History

2017-12-09 21:51:18 +00:00
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
}