forked from Mirrors/doipjs
Remove request handling
This commit is contained in:
parent
81b56341cc
commit
8dc0372ea7
1 changed files with 1 additions and 69 deletions
|
@ -13,10 +13,6 @@ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
||||||
See the License for the specific language governing permissions and
|
See the License for the specific language governing permissions and
|
||||||
limitations under the License.
|
limitations under the License.
|
||||||
*/
|
*/
|
||||||
const bent = require('bent')
|
|
||||||
const req = bent('GET')
|
|
||||||
const utils = require('./utils')
|
|
||||||
|
|
||||||
const list = [
|
const list = [
|
||||||
'dns',
|
'dns',
|
||||||
'irc',
|
'irc',
|
||||||
|
@ -71,70 +67,6 @@ const match = (uri, opts) => {
|
||||||
return matches
|
return matches
|
||||||
}
|
}
|
||||||
|
|
||||||
const directRequestHandler = (spData, opts) => {
|
|
||||||
return new Promise(async (resolve, reject) => {
|
|
||||||
const url = spData.proof.fetch ? spData.proof.fetch : spData.proof.uri
|
|
||||||
if (!url) {
|
|
||||||
reject('No valid URI provided')
|
|
||||||
return
|
|
||||||
}
|
|
||||||
let res
|
|
||||||
|
|
||||||
switch (spData.proof.format) {
|
|
||||||
case 'json':
|
|
||||||
req(url, null, {
|
|
||||||
Accept: 'application/json',
|
|
||||||
'User-Agent': `doipjs/${require('../package.json').version}`,
|
|
||||||
})
|
|
||||||
.then(async (res) => {
|
|
||||||
return await res.json()
|
|
||||||
})
|
|
||||||
.then((res) => {
|
|
||||||
resolve(res)
|
|
||||||
})
|
|
||||||
.catch((e) => {
|
|
||||||
reject(e)
|
|
||||||
})
|
|
||||||
break
|
|
||||||
case 'text':
|
|
||||||
req(url)
|
|
||||||
.then(async (res) => {
|
|
||||||
return await res.text()
|
|
||||||
})
|
|
||||||
.then((res) => {
|
|
||||||
resolve(res)
|
|
||||||
})
|
|
||||||
.catch((e) => {
|
|
||||||
reject(e)
|
|
||||||
})
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
reject('No specified proof data format')
|
|
||||||
break
|
|
||||||
}
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
const proxyRequestHandler = (spData, opts) => {
|
|
||||||
return new Promise(async (resolve, reject) => {
|
|
||||||
const url = spData.proof.fetch ? spData.proof.fetch : spData.proof.uri
|
|
||||||
req(utils.generateProxyURL(spData.proof.format, url, opts), null, {
|
|
||||||
Accept: 'application/json',
|
|
||||||
})
|
|
||||||
.then(async (res) => {
|
|
||||||
return await res.json()
|
|
||||||
})
|
|
||||||
.then((res) => {
|
|
||||||
resolve(res.content)
|
|
||||||
})
|
|
||||||
.catch((e) => {
|
|
||||||
reject(e)
|
|
||||||
})
|
|
||||||
})
|
|
||||||
}
|
|
||||||
|
|
||||||
exports.list = list
|
exports.list = list
|
||||||
exports.data = data
|
exports.data = data
|
||||||
exports.match = match
|
exports.match = match
|
||||||
exports.directRequestHandler = directRequestHandler
|
|
||||||
exports.proxyRequestHandler = proxyRequestHandler
|
|
Loading…
Reference in a new issue