aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/middlewares/pods.js
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2016-10-01 14:23:50 +0200
committerChocobozzz <florian.bigard@gmail.com>2016-10-01 14:23:50 +0200
commit1ab844d8593fa84dfe65cad6b5bbf0e45efd7886 (patch)
tree2687c7f66caff9ed57b4adde2e6ae804016295d3 /server/middlewares/pods.js
parent825a5d9c5e6d8cbe005b44499aba4ce4ba069fe3 (diff)
downloadPeerTube-1ab844d8593fa84dfe65cad6b5bbf0e45efd7886.tar.gz
PeerTube-1ab844d8593fa84dfe65cad6b5bbf0e45efd7886.tar.zst
PeerTube-1ab844d8593fa84dfe65cad6b5bbf0e45efd7886.zip
Server: add port when making friends if it is not specified
Diffstat (limited to 'server/middlewares/pods.js')
-rw-r--r--server/middlewares/pods.js62
1 files changed, 62 insertions, 0 deletions
diff --git a/server/middlewares/pods.js b/server/middlewares/pods.js
new file mode 100644
index 000000000..116b02b3c
--- /dev/null
+++ b/server/middlewares/pods.js
@@ -0,0 +1,62 @@
1'use strict'
2
3const urlModule = require('url')
4
5const logger = require('../helpers/logger')
6
7const podsMiddleware = {
8 setBodyUrlsPort: setBodyUrlsPort,
9 setBodyUrlPort: setBodyUrlPort
10}
11
12function setBodyUrlsPort (req, res, next) {
13 for (let i = 0; i < req.body.urls.length; i++) {
14 const urlWithPort = getUrlWithPort(req.body.urls[i])
15
16 // Problem with the url parsing?
17 if (urlWithPort === null) {
18 return res.sendStatus(500)
19 }
20
21 req.body.urls[i] = urlWithPort
22 }
23
24 return next()
25}
26
27function setBodyUrlPort (req, res, next) {
28 const urlWithPort = getUrlWithPort(req.body.url)
29
30 // Problem with the url parsing?
31 if (urlWithPort === null) {
32 return res.sendStatus(500)
33 }
34
35 req.body.url = urlWithPort
36
37 return next()
38}
39
40// ---------------------------------------------------------------------------
41
42module.exports = podsMiddleware
43
44// ---------------------------------------------------------------------------
45
46function getUrlWithPort (url) {
47 const urlObj = urlModule.parse(url)
48
49 // Add the port if it is not specified
50 if (urlObj.port === null) {
51 if (urlObj.protocol === 'http:') {
52 return url + ':80'
53 } else if (urlObj.protocol === 'https:') {
54 return url + ':443'
55 } else {
56 logger.error('Unknown url protocol: ' + urlObj.protocol)
57 return null
58 }
59 }
60
61 return url
62}