server/helpers/requests.js

   1 'use strict'
   2
   3 const replay = require('request-replay')
   4 const request = require('request')
   5
   6 const constants = require('../initializers/constants')
   7 const peertubeCrypto = require('./peertube-crypto')
   8
   9 const requests = {
  10   makeRetryRequest,
  11   makeSecureRequest
  12 }
  13
  14 function makeRetryRequest (params, callback) {
  15   replay(
  16     request(params, callback),
  17     {
  18       retries: constants.RETRY_REQUESTS,
  19       factor: 3,
  20       maxTimeout: Infinity,
  21       errorCodes: [ 'EADDRINFO', 'ETIMEDOUT', 'ECONNRESET', 'ESOCKETTIMEDOUT', 'ENOTFOUND', 'ECONNREFUSED' ]
  22     }
  23   )
  24 }
  25
  26 function makeSecureRequest (params, callback) {
  27   const requestParams = {
  28     url: constants.REMOTE_SCHEME.HTTP + '://' + params.toPod.host + params.path
  29   }
  30
  31   // Add data with POST requst ?
  32   if (params.method === 'POST') {
  33     requestParams.json = {}
  34
  35     // Add signature if it is specified in the params
  36     if (params.sign === true) {
  37       const host = constants.CONFIG.WEBSERVER.HOST
  38
  39       requestParams.json.signature = {
  40         host,
  41         signature: peertubeCrypto.sign(host)
  42       }
  43     }
  44
  45     // If there are data informations
  46     if (params.data) {
  47       // Encrypt data
  48       if (params.encrypt === true) {
  49         peertubeCrypto.encrypt(params.toPod.publicKey, JSON.stringify(params.data), function (err, encrypted) {
  50           if (err) return callback(err)
  51
  52           requestParams.json.data = encrypted.data
  53           requestParams.json.key = encrypted.key
  54
  55           request.post(requestParams, callback)
  56         })
  57       } else {
  58         // No encryption
  59         requestParams.json.data = params.data
  60         request.post(requestParams, callback)
  61       }
  62     } else {
  63       // No data
  64       request.post(requestParams, callback)
  65     }
  66   } else {
  67     request.get(requestParams, callback)
  68   }
  69 }
  70
  71 // ---------------------------------------------------------------------------
  72
  73 module.exports = requests