]>
git.immae.eu Git - github/Chocobozzz/PeerTube.git/blob - src/utils.js
4 var config
= require('config')
5 var crypto
= require('crypto')
7 var openssl
= require('openssl-wrapper')
8 var request
= require('request')
9 var replay
= require('request-replay')
10 var ursa
= require('ursa')
12 var logger
= require('./logger')
16 var http
= config
.get('webserver.https') ? 'https' : 'http'
17 var host
= config
.get('webserver.host')
18 var port
= config
.get('webserver.port')
19 var algorithm
= 'aes-256-ctr'
21 // ----------- Private functions ----------
23 function makeRetryRequest (params
, from_url
, to_pod
, signature
, callbackEach
) {
24 // Append the signature
26 params
.json
.signature
= {
32 logger
.debug('Sending informations to %s.', to_pod
.url
, { params: params
})
34 // Replay 15 times, with factor 3
36 request
.post(params
, function (err
, response
, body
) {
37 callbackEach(err
, response
, body
, to_pod
.url
)
43 errorCodes: [ 'EADDRINFO', 'ETIMEDOUT', 'ECONNRESET', 'ESOCKETTIMEDOUT', 'ENOTFOUND', 'ECONNREFUSED' ]
45 ).on('replay', function (replay
) {
46 logger
.info('Replaying request to %s. Request failed: %d %s. Replay number: #%d. Will retry in: %d ms.',
47 params
.url
, replay
.error
.code
, replay
.error
.message
, replay
.number
, replay
.delay
)
51 // ----------- Public attributes ----------
52 utils
.certDir
= __dirname
+ '/../' + config
.get('storage.certs')
55 utils
.makeMultipleRetryRequest = function (all_data
, pods
, callbackEach
, callback
) {
57 callback
= callbackEach
58 callbackEach = function () {}
61 var url
= http
+ '://' + host
+ ':' + port
64 // Add signature if it is specified in the params
65 if (all_data
.method
=== 'POST' && all_data
.data
&& all_data
.sign
=== true) {
66 var myKey
= ursa
.createPrivateKey(fs
.readFileSync(utils
.certDir
+ 'peertube.key.pem'))
67 signature
= myKey
.hashAndSign('sha256', url
, 'utf8', 'hex')
70 // Make a request for each pod
71 for (var pod
of pods
) {
73 url: pod
.url
+ all_data
.path
,
74 method: all_data
.method
77 // Add data with POST requst ?
78 if (all_data
.method
=== 'POST' && all_data
.data
) {
79 logger
.debug('Make a POST request.')
82 if (all_data
.encrypt
=== true) {
83 var crt
= ursa
.createPublicKey(pod
.publicKey
)
86 ;(function (crt_copy
, copy_params
, copy_url
, copy_pod
, copy_signature
) {
87 utils
.symetricEncrypt(JSON
.stringify(all_data
.data
), function (err
, dataEncrypted
) {
90 var passwordEncrypted
= crt_copy
.encrypt(dataEncrypted
.password
, 'utf8', 'hex')
92 data: dataEncrypted
.crypted
,
93 key: passwordEncrypted
96 makeRetryRequest(copy_params
, copy_url
, copy_pod
, copy_signature
, callbackEach
)
98 })(crt
, params
, url
, pod
, signature
)
100 params
.json
= { data: all_data
.data
}
101 makeRetryRequest(params
, url
, pod
, signature
, callbackEach
)
104 logger
.debug('Make a GET/DELETE request')
105 makeRetryRequest(params
, url
, pod
, signature
, callbackEach
)
112 utils
.certsExist = function (callback
) {
113 fs
.exists(utils
.certDir
+ 'peertube.key.pem', function (exists
) {
114 return callback(exists
)
118 utils
.createCerts = function (callback
) {
119 utils
.certsExist(function (exist
) {
120 if (exist
=== true) {
121 var string
= 'Certs already exist.'
122 logger
.warning(string
)
123 return callback(new Error(string
))
126 logger
.info('Generating a RSA key...')
127 openssl
.exec('genrsa', { 'out': utils
.certDir
+ 'peertube.key.pem', '2048': false }, function (err
) {
129 logger
.error('Cannot create private key on this pod.', { error: err
})
132 logger
.info('RSA key generated.')
134 logger
.info('Manage public key...')
135 openssl
.exec('rsa', { 'in': utils
.certDir
+ 'peertube.key.pem', 'pubout': true, 'out': utils
.certDir
+ 'peertube.pub' }, function (err
) {
137 logger
.error('Cannot create public key on this pod .', { error: err
})
141 logger
.info('Public key managed.')
142 return callback(null)
148 utils
.createCertsIfNotExist = function (callback
) {
149 utils
.certsExist(function (exist
) {
150 if (exist
=== true) {
151 return callback(null)
154 utils
.createCerts(function (err
) {
160 utils
.generatePassword = function (callback
) {
161 crypto
.randomBytes(32, function (err
, buf
) {
166 callback(null, buf
.toString('utf8'))
170 utils
.symetricEncrypt = function (text
, callback
) {
171 utils
.generatePassword(function (err
, password
) {
176 var cipher
= crypto
.createCipher(algorithm
, password
)
177 var crypted
= cipher
.update(text
, 'utf8', 'hex')
178 crypted
+= cipher
.final('hex')
179 callback(null, { crypted: crypted
, password: password
})
183 utils
.symetricDecrypt = function (text
, password
) {
184 var decipher
= crypto
.createDecipher(algorithm
, password
)
185 var dec
= decipher
.update(text
, 'hex', 'utf8')
186 dec
+= decipher
.final('utf8')
190 utils
.cleanForExit = function (webtorrent_process
) {
191 logger
.info('Gracefully exiting')
192 process
.kill(-webtorrent_process
.pid
)
195 module
.exports
= utils