aboutsummaryrefslogtreecommitdiffhomepage
path: root/middlewares/index.js
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2015-06-09 17:41:40 +0200
committerChocobozzz <florian.bigard@gmail.com>2015-10-29 23:14:54 +0100
commit8c308c2bf7f658945d80be9d5880361238635f5b (patch)
tree2130ae60af58e59dab3df07a5d5cdd5174f91ae8 /middlewares/index.js
parent8cb4b4e00ee57eb98dfe1455b6d2de36fc561797 (diff)
downloadPeerTube-8c308c2bf7f658945d80be9d5880361238635f5b.tar.gz
PeerTube-8c308c2bf7f658945d80be9d5880361238635f5b.tar.zst
PeerTube-8c308c2bf7f658945d80be9d5880361238635f5b.zip
Spawn
Diffstat (limited to 'middlewares/index.js')
-rw-r--r--middlewares/index.js57
1 files changed, 57 insertions, 0 deletions
diff --git a/middlewares/index.js b/middlewares/index.js
new file mode 100644
index 000000000..c8139075a
--- /dev/null
+++ b/middlewares/index.js
@@ -0,0 +1,57 @@
1;(function () {
2 'use strict'
3
4 var ursa = require('ursa')
5 var fs = require('fs')
6
7 var logger = require('../src/logger')
8 var utils = require('../src/utils')
9 var PodsDB = require('../src/database').PodsDB
10
11 var middleware = {}
12
13 middleware.cache = function (cache) {
14 return function (req, res, next) {
15 // If we want explicitly a cache
16 // Or if we don't specify if we want a cache or no and we are in production
17 if (cache === true || (cache !== false && process.env.NODE_ENV === 'production')) {
18 res.setHeader('Cache-Control', 'public')
19 } else {
20 res.setHeader('Cache-Control', 'no-cache, no-store, max-age=0, must-revalidate')
21 }
22
23 next()
24 }
25 }
26
27 middleware.decryptBody = function (req, res, next) {
28 logger.debug('Decrypting body.')
29
30 PodsDB.findOne({ url: req.body.signature.url }, function (err, pod) {
31 if (err) {
32 logger.error('Cannot get signed url in decryptBody.', { error: err })
33 res.sendStatus(500)
34 }
35
36 logger.debug('Found one pod which could send the message.', { pod: pod.publicKey, url: req.body.signature.url })
37
38 var crt = ursa.createPublicKey(pod.publicKey)
39 var signature_ok = crt.hashAndVerify('sha256', new Buffer(req.body.signature.url).toString('hex'), req.body.signature.signature, 'hex')
40
41 if (signature_ok === true) {
42 var myKey = ursa.createPrivateKey(fs.readFileSync(utils.certDir + 'petube.key.pem'))
43 var decryptedKey = myKey.decrypt(req.body.key, 'hex', 'utf8')
44 logger.debug(decryptedKey)
45 req.body.data = JSON.parse(utils.symetricDecrypt(req.body.data, decryptedKey))
46 logger.debug('Decrypted.', { body: req.body })
47 } else {
48 logger.error('Signature is not okay in decryptBody for %s.', req.body.signature.url)
49 res.sendStatus(500)
50 }
51
52 next()
53 })
54 }
55
56 module.exports = middleware
57})()