spee.ch/routes/serve-routes.js

189 lines
6.3 KiB
JavaScript
Raw Normal View History

const logger = require('winston');
2017-08-03 02:13:02 +02:00
const { serveFile, showFile, showFileLite, getShortUrlFromClaimId } = require('../helpers/serveHelpers.js');
2017-08-03 20:14:50 +02:00
const { getAssetByChannel, getAssetByShortUrl, getAssetByClaimId, getAssetByName } = require('../controllers/serveController.js');
2017-08-03 02:13:02 +02:00
const { handleRequestError } = require('../helpers/errorHandlers.js');
2017-08-04 06:59:22 +02:00
const { postToStats, sendGoogleAnalytics } = require('../controllers/statsController.js');
const SERVE = 'SERVE';
const SHOW = 'SHOW';
const SHOWLITE = 'SHOWLITE';
const CHANNEL = 'CHANNEL';
const SHORTURL = 'SHORTURL';
const CLAIMID = 'CLAIMID';
2017-08-03 20:14:50 +02:00
const NAME = 'NAME';
function getAsset (claimType, channelName, shortUrl, fullClaimId, name) {
switch (claimType) {
case CHANNEL:
return getAssetByChannel(channelName, name);
case SHORTURL:
return getAssetByShortUrl(shortUrl, name);
case CLAIMID:
return getAssetByClaimId(fullClaimId, name);
2017-08-03 20:14:50 +02:00
case NAME:
return getAssetByName(name);
default:
return new Error('that claim type was not found');
}
}
2017-08-04 06:59:22 +02:00
function serveOrShowAsset (fileInfo, method, headers, originalUrl, ip, res) {
2017-08-03 20:14:50 +02:00
// add file extension to the file info
fileInfo['fileExt'] = fileInfo.fileName.substring(fileInfo.fileName.lastIndexOf('.'));
// serve or show
switch (method) {
case SERVE:
serveFile(fileInfo, res);
2017-08-04 06:59:22 +02:00
sendGoogleAnalytics(method, headers, ip, originalUrl);
2017-08-03 20:14:50 +02:00
postToStats('serve', originalUrl, ip, fileInfo.name, fileInfo.claimId, 'success');
return fileInfo;
case SHOWLITE:
showFileLite(fileInfo, res);
postToStats('show', originalUrl, ip, fileInfo.name, fileInfo.claimId, 'success');
return fileInfo;
case SHOW:
return getShortUrlFromClaimId(fileInfo.claimId, fileInfo.height, fileInfo.name)
2017-08-03 20:14:50 +02:00
.then(shortUrl => {
fileInfo['shortUrl'] = shortUrl;
showFile(fileInfo, res);
postToStats('show', originalUrl, ip, fileInfo.name, fileInfo.claimId, 'success');
return fileInfo;
})
.catch(error => {
console.log('thowing error...');
throw error;
});
default:
logger.error('I did not recognize that method');
break;
}
}
function isValidClaimId (claimId) {
2017-08-04 06:59:22 +02:00
return ((claimId.length === 40) && !/[^A-Za-z0-9]/g.test(claimId));
}
function isValidShortUrl (claimId) {
return claimId.length === 1; // really it should evaluate the short url itself
}
function isValidShortUrlOrClaimId (input) {
return (isValidClaimId(input) || isValidShortUrl(input));
}
2017-06-30 02:10:14 +02:00
module.exports = (app) => {
// route to serve a specific asset
app.get('/:identifier/:name', ({ headers, ip, originalUrl, params }, res) => {
let identifier = params.identifier;
let name = params.name;
let claimType;
let channelName = null;
let shortUrl = null;
let fullClaimId = null;
let method;
let extension;
// parse the name
const positionOfExtension = name.indexOf('.');
if (positionOfExtension >= 0) {
extension = name.substring(positionOfExtension);
2017-08-04 07:09:36 +02:00
name = name.substring(0, positionOfExtension);
/* patch because twitter player preview adds '>' before file extension */
if (name.indexOf('>') >= 0) {
name = name.substring(0, name.indexOf('>'));
}
/* end patch */
logger.debug('file extension =', extension);
if (headers['accept'] && headers['accept'].split(',').includes('text/html')) {
method = SHOWLITE;
} else {
method = SERVE;
}
} else {
method = SHOW;
}
/* patch for backwards compatability with spee.ch/name/claim_id */
if (isValidShortUrlOrClaimId(name) && !isValidShortUrlOrClaimId(identifier)) {
let tempName = name;
name = identifier;
identifier = tempName;
}
2017-08-04 06:59:22 +02:00
/* end */
logger.debug('claim name =', name);
logger.debug('method =', method);
// parse identifier for whether it is a channel, short url, or claim_id
if (identifier.charAt(0) === '@') {
channelName = identifier.substring(1);
logger.debug('channel name =', channelName);
claimType = CHANNEL;
} else if (identifier.length === 40) {
fullClaimId = identifier;
logger.debug('full claim id =', fullClaimId);
claimType = CLAIMID;
} else if (identifier.length < 40) {
shortUrl = identifier;
logger.debug('short url =', shortUrl);
claimType = SHORTURL;
} else {
2017-08-04 06:59:22 +02:00
logger.error('The URL provided could not be parsed');
res.send('that url is invalid');
return;
};
// 1. retrieve the asset and information
getAsset(claimType, channelName, shortUrl, fullClaimId, name)
// 2. serve or show
.then(fileInfo => {
if (!fileInfo) {
res.status(200).render('noClaims');
2017-08-03 20:14:50 +02:00
} else {
2017-08-04 06:59:22 +02:00
return serveOrShowAsset(fileInfo, method, headers, originalUrl, ip, res);
}
})
2017-08-04 20:32:21 +02:00
// 3. update the file
.then(fileInfoForUpdate => {
2017-08-04 20:32:21 +02:00
// if needed, this is where we would update the file
})
.catch(error => {
handleRequestError('serve', originalUrl, ip, error, res);
});
});
// route to serve the winning asset at a claim
2017-07-05 18:26:22 +02:00
app.get('/:name', ({ headers, ip, originalUrl, params }, res) => {
2017-08-03 20:14:50 +02:00
// parse name param
let name = params.name;
let method;
2017-08-04 07:09:36 +02:00
let fileExtension;
2017-08-03 20:14:50 +02:00
if (name.indexOf('.') !== -1) {
method = SERVE;
if (headers['accept'] && headers['accept'].split(',').includes('text/html')) {
method = SHOWLITE;
}
2017-08-04 07:09:36 +02:00
fileExtension = name.substring(name.indexOf('.'));
2017-08-03 20:14:50 +02:00
name = name.substring(0, name.indexOf('.'));
2017-08-04 07:09:36 +02:00
logger.debug('file extension =', fileExtension);
2017-08-03 20:14:50 +02:00
} else {
method = SHOW;
if (headers['accept'] && !headers['accept'].split(',').includes('text/html')) {
method = SERVE;
}
}
logger.debug('claim name = ', name);
logger.debug('method =', method);
// 1. retrieve the asset and information
getAsset(NAME, null, null, null, name)
// 2. serve or show
.then(fileInfo => {
if (!fileInfo) {
res.status(200).render('noClaims');
} else {
2017-08-04 06:59:22 +02:00
return serveOrShowAsset(fileInfo, method, headers, originalUrl, ip, res);
2017-08-03 20:14:50 +02:00
}
})
// 3. update the database
.then(fileInfoForUpdate => {
2017-08-04 20:32:21 +02:00
// if needed, this is where we would update the file
2017-08-03 20:14:50 +02:00
})
.catch(error => {
handleRequestError('serve', originalUrl, ip, error, res);
});
});
};