PeerTube/server/helpers/requests.ts

233 lines
5.8 KiB
TypeScript
Raw Normal View History

2019-02-21 17:19:16 +01:00
import { createWriteStream, remove } from 'fs-extra'
2021-03-09 14:01:44 +01:00
import got, { CancelableRequest, Options as GotOptions, RequestError } from 'got'
import { HttpProxyAgent, HttpsProxyAgent } from 'hpagent'
2021-03-08 14:24:11 +01:00
import { join } from 'path'
import { CONFIG } from '../initializers/config'
2021-06-14 18:06:58 +02:00
import { ACTIVITY_PUB, PEERTUBE_VERSION, REQUEST_TIMEOUT, WEBSERVER } from '../initializers/constants'
2021-03-08 14:24:11 +01:00
import { pipelinePromise } from './core-utils'
2018-11-16 16:48:17 +01:00
import { processImage } from './image-utils'
2019-02-21 17:19:16 +01:00
import { logger } from './logger'
import { getProxy, isProxyEnabled } from './proxy'
const httpSignature = require('http-signature')
2017-12-28 11:16:08 +01:00
2021-03-09 14:01:44 +01:00
export interface PeerTubeRequestError extends Error {
statusCode?: number
responseBody?: any
}
2021-03-08 14:24:11 +01:00
type PeerTubeRequestOptions = {
activityPub?: boolean
bodyKBLimit?: number // 1MB
httpSignature?: {
algorithm: string
authorizationHeaderName: string
keyId: string
key: string
headers: string[]
}
jsonResponse?: boolean
} & Pick<GotOptions, 'headers' | 'json' | 'method' | 'searchParams'>
const peertubeGot = got.extend({
...getAgent(),
2021-03-08 14:24:11 +01:00
headers: {
'user-agent': getUserAgent()
},
handlers: [
(options, next) => {
const promiseOrStream = next(options) as CancelableRequest<any>
2021-03-09 09:58:08 +01:00
const bodyKBLimit = options.context?.bodyKBLimit as number
2021-03-08 14:24:11 +01:00
if (!bodyKBLimit) throw new Error('No KB limit for this request')
2021-03-09 09:58:08 +01:00
const bodyLimit = bodyKBLimit * 1000
2021-03-08 14:24:11 +01:00
/* eslint-disable @typescript-eslint/no-floating-promises */
promiseOrStream.on('downloadProgress', progress => {
2021-03-09 09:58:08 +01:00
if (progress.transferred > bodyLimit && progress.percent !== 1) {
const message = `Exceeded the download limit of ${bodyLimit} B`
logger.warn(message)
// CancelableRequest
if (promiseOrStream.cancel) {
promiseOrStream.cancel()
return
}
// Stream
(promiseOrStream as any).destroy()
2021-03-08 14:24:11 +01:00
}
})
2019-07-16 14:52:24 +02:00
2021-03-08 14:24:11 +01:00
return promiseOrStream
}
],
hooks: {
beforeRequest: [
options => {
const headers = options.headers || {}
headers['host'] = options.url.host
},
options => {
const httpSignatureOptions = options.context?.httpSignature
if (httpSignatureOptions) {
const method = options.method ?? 'GET'
const path = options.path ?? options.url.pathname
if (!method || !path) {
throw new Error(`Cannot sign request without method (${method}) or path (${path}) ${options}`)
}
httpSignature.signRequest({
getHeader: function (header) {
return options.headers[header]
},
setHeader: function (header, value) {
options.headers[header] = value
},
method,
path
}, httpSignatureOptions)
}
}
]
2017-12-28 11:16:08 +01:00
}
2021-03-08 14:24:11 +01:00
})
2017-11-09 17:51:58 +01:00
2021-03-08 14:24:11 +01:00
function doRequest (url: string, options: PeerTubeRequestOptions = {}) {
const gotOptions = buildGotOptions(options)
return peertubeGot(url, gotOptions)
.catch(err => { throw buildRequestError(err) })
}
function doJSONRequest <T> (url: string, options: PeerTubeRequestOptions = {}) {
const gotOptions = buildGotOptions(options)
return peertubeGot<T>(url, { ...gotOptions, responseType: 'json' })
.catch(err => { throw buildRequestError(err) })
2017-11-09 17:51:58 +01:00
}
2016-02-05 18:03:20 +01:00
2021-03-08 14:24:11 +01:00
async function doRequestAndSaveToFile (
url: string,
2019-02-21 17:19:16 +01:00
destPath: string,
2021-03-08 14:24:11 +01:00
options: PeerTubeRequestOptions = {}
2019-02-21 17:19:16 +01:00
) {
2021-03-08 14:24:11 +01:00
const gotOptions = buildGotOptions(options)
2018-02-15 18:40:24 +01:00
2021-03-08 14:24:11 +01:00
const outFile = createWriteStream(destPath)
2019-02-21 17:19:16 +01:00
2021-03-08 14:24:11 +01:00
try {
await pipelinePromise(
peertubeGot.stream(url, gotOptions),
outFile
)
} catch (err) {
remove(destPath)
.catch(err => logger.error('Cannot remove %s after request failure.', destPath, { err }))
2019-02-21 17:19:16 +01:00
2021-03-08 14:24:11 +01:00
throw buildRequestError(err)
}
2017-11-10 14:34:45 +01:00
}
2018-12-04 16:02:49 +01:00
async function downloadImage (url: string, destDir: string, destName: string, size: { width: number, height: number }) {
const tmpPath = join(CONFIG.STORAGE.TMP_DIR, 'pending-' + destName)
2021-03-08 14:24:11 +01:00
await doRequestAndSaveToFile(url, tmpPath)
2018-11-16 16:48:17 +01:00
2018-12-04 16:02:49 +01:00
const destPath = join(destDir, destName)
try {
2019-04-24 09:56:25 +02:00
await processImage(tmpPath, destPath, size)
} catch (err) {
await remove(tmpPath)
throw err
}
2018-11-16 16:48:17 +01:00
}
function getAgent () {
if (!isProxyEnabled()) return {}
const proxy = getProxy()
logger.info('Using proxy %s.', proxy)
const proxyAgentOptions = {
keepAlive: true,
keepAliveMsecs: 1000,
maxSockets: 256,
maxFreeSockets: 256,
scheduling: 'lifo' as 'lifo',
proxy
}
return {
agent: {
http: new HttpProxyAgent(proxyAgentOptions),
https: new HttpsProxyAgent(proxyAgentOptions)
}
}
}
2019-07-16 14:52:24 +02:00
function getUserAgent () {
2019-07-17 10:03:55 +02:00
return `PeerTube/${PEERTUBE_VERSION} (+${WEBSERVER.URL})`
2019-07-16 14:52:24 +02:00
}
// ---------------------------------------------------------------------------
2016-02-05 18:03:20 +01:00
2017-05-15 22:22:03 +02:00
export {
2017-11-09 17:51:58 +01:00
doRequest,
2021-03-08 14:24:11 +01:00
doJSONRequest,
2018-11-16 16:48:17 +01:00
doRequestAndSaveToFile,
2021-10-15 08:32:06 +02:00
downloadImage,
peertubeGot
2017-05-15 22:22:03 +02:00
}
2019-02-21 17:19:16 +01:00
// ---------------------------------------------------------------------------
2021-03-08 14:24:11 +01:00
function buildGotOptions (options: PeerTubeRequestOptions) {
const { activityPub, bodyKBLimit = 1000 } = options
2019-02-21 17:19:16 +01:00
2021-03-08 14:24:11 +01:00
const context = { bodyKBLimit, httpSignature: options.httpSignature }
2019-02-21 17:19:16 +01:00
2021-03-08 14:24:11 +01:00
let headers = options.headers || {}
2021-03-10 11:17:20 +01:00
if (!headers.date) {
headers = { ...headers, date: new Date().toUTCString() }
}
2021-03-08 14:24:11 +01:00
2021-03-10 11:17:20 +01:00
if (activityPub && !headers.accept) {
2021-03-08 14:24:11 +01:00
headers = { ...headers, accept: ACTIVITY_PUB.ACCEPT_HEADER }
2019-02-21 17:19:16 +01:00
}
2021-03-08 14:24:11 +01:00
return {
method: options.method,
dnsCache: true,
2021-10-13 09:57:20 +02:00
timeout: REQUEST_TIMEOUT,
2021-03-08 14:24:11 +01:00
json: options.json,
searchParams: options.searchParams,
headers,
context
}
}
2021-03-09 14:01:44 +01:00
function buildRequestError (error: RequestError) {
const newError: PeerTubeRequestError = new Error(error.message)
2021-03-08 14:24:11 +01:00
newError.name = error.name
newError.stack = error.stack
2021-03-09 14:01:44 +01:00
if (error.response) {
newError.responseBody = error.response.body
newError.statusCode = error.response.statusCode
2021-03-08 14:24:11 +01:00
}
2021-03-09 14:01:44 +01:00
return newError
2019-02-21 17:19:16 +01:00
}