import { HttpProxyAgent, HttpsProxyAgent } from 'hpagent'
import { join } from 'path'
import { CONFIG } from '../initializers/config'
-import { ACTIVITY_PUB, BINARY_CONTENT_TYPES, PEERTUBE_VERSION, REQUEST_TIMEOUT, WEBSERVER } from '../initializers/constants'
+import { ACTIVITY_PUB, BINARY_CONTENT_TYPES, PEERTUBE_VERSION, REQUEST_TIMEOUTS, WEBSERVER } from '../initializers/constants'
import { pipelinePromise } from './core-utils'
import { processImage } from './image-utils'
import { logger, loggerTagsFactory } from './logger'
}
type PeerTubeRequestOptions = {
+ timeout?: number
activityPub?: boolean
bodyKBLimit?: number // 1MB
httpSignature?: {
destPath: string,
options: PeerTubeRequestOptions = {}
) {
- const gotOptions = buildGotOptions(options)
+ const gotOptions = buildGotOptions({ ...options, timeout: options.timeout ?? REQUEST_TIMEOUTS.FILE })
const outFile = createWriteStream(destPath)
doRequestAndSaveToFile,
isBinaryResponse,
downloadImage,
+ getAgent,
findLatestRedirection,
peertubeGot
}
return {
method: options.method,
dnsCache: true,
- timeout: REQUEST_TIMEOUT,
+ timeout: options.timeout ?? REQUEST_TIMEOUTS.DEFAULT,
json: options.json,
searchParams: options.searchParams,
retry: 2,