import { ACTIVITY_PUB, BINARY_CONTENT_TYPES, PEERTUBE_VERSION, REQUEST_TIMEOUT, WEBSERVER } from '../initializers/constants'
import { pipelinePromise } from './core-utils'
import { processImage } from './image-utils'
-import { logger } from './logger'
+import { logger, loggerTagsFactory } from './logger'
import { getProxy, isProxyEnabled } from './proxy'
+const lTags = loggerTagsFactory('request')
+
const httpSignature = require('@peertube/http-signature')
export interface PeerTubeRequestError extends Error {
promiseOrStream.on('downloadProgress', progress => {
if (progress.transferred > bodyLimit && progress.percent !== 1) {
const message = `Exceeded the download limit of ${bodyLimit} B`
- logger.warn(message)
+ logger.warn(message, lTags())
// CancelableRequest
if (promiseOrStream.cancel) {
const gotOptions = buildGotOptions(options)
return peertubeGot(url, gotOptions)
+ .on('retry', logRetryFactory(url))
.catch(err => { throw buildRequestError(err) })
}
const gotOptions = buildGotOptions(options)
return peertubeGot<T>(url, { ...gotOptions, responseType: 'json' })
+ .on('retry', logRetryFactory(url))
.catch(err => { throw buildRequestError(err) })
}
)
} catch (err) {
remove(destPath)
- .catch(err => logger.error('Cannot remove %s after request failure.', destPath, { err }))
+ .catch(err => logger.error('Cannot remove %s after request failure.', destPath, { err, ...lTags() }))
throw buildRequestError(err)
}
const proxy = getProxy()
- logger.info('Using proxy %s.', proxy)
+ logger.info('Using proxy %s.', proxy, lTags())
const proxyAgentOptions = {
keepAlive: true,
timeout: REQUEST_TIMEOUT,
json: options.json,
searchParams: options.searchParams,
+ retry: 2,
headers,
context
}
return newError
}
+
+function logRetryFactory (url: string) {
+ return (retryCount: number, error: RequestError) => {
+ logger.debug('Retrying request to %s.', url, { retryCount, error, ...lTags() })
+ }
+}