Skip to content
Snippets Groups Projects
Unverified Commit ae72d682 authored by Xiao Gui's avatar Xiao Gui
Browse files

hotfix: remove request

parent a3d3e054
No related branches found
No related tags found
No related merge requests found
......@@ -94,7 +94,10 @@ const _ = (async () => {
}))
await configureAuth(app)
app.use('/user', require('./user'))
/**
* TODO fix user import
*/
// app.use('/user', require('./user'))
/**
* saneUrl end points
......
const request = require('request')
const got = require('got')
const qs = require('querystring')
class Logger {
......@@ -11,7 +11,7 @@ class Logger {
this.password = password
}
emit(logLevel, message, callback){
async emit(logLevel, message, callback){
const {
name,
protocol,
......@@ -26,17 +26,9 @@ class Logger {
const formData = {
json: JSON.stringify(message)
}
if (callback) {
request.post({
url,
formData
}, callback)
} else {
return request.post({
url,
formData
})
}
await got.post(url, {
formData
})
}
}
......
const request = require('request')
const got = require('got')
const { NotFoundError } = require('./store')
const { OBJ_STORAGE_ROOT_URL } = process.env
......@@ -11,14 +11,7 @@ class Store {
new NotFoundError()
)
}
return new Promise((rs, rj) => {
request.get(`${OBJ_STORAGE_ROOT_URL}/${id}`, (err, resp, body) => {
if (err) return rj(err)
if (resp.statusCode === 404) return rj(new NotFoundError())
if (resp.statusCode >= 400) return rj(resp)
return rs(body)
})
})
return got(`${OBJ_STORAGE_ROOT_URL}/${id}`).text()
}
async del(id){
......
const request = require('request')
const got = require('got')
const apiPath = '/api/v4'
const saneUrlVer = `0.0.1`
......@@ -31,31 +31,18 @@ class GitlabSnippetStore {
}
_promiseRequest(...arg) {
return new Promise((rs, rj) => {
request(...arg, (err, resp, body) => {
if (err) return rj(err)
if (resp.statusCode >= 400) return rj(resp)
rs(body)
})
})
return got(...arg).text()
}
_request({ addPath = '', method = 'GET', headers = {}, opt = {} } = {}) {
return new Promise((rs, rj) => {
request(`${this.url}${addPath}`, {
method,
headers: {
'PRIVATE-TOKEN': this.token,
...headers
},
qs: { per_page: 1000 },
...opt
}, (err, resp, body) => {
if (err) return rj(err)
if (resp.statusCode >= 400) return rj(resp)
return rs(body)
})
})
return got(`${this.url}${addPath}?per_page=1000`, {
method,
headers: {
'PRIVATE-TOKEN': this.token,
...headers
},
...opt
}).text()
}
async get(id) {
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment