changed mysql analytics to 'stats'
This commit is contained in:
parent
f5048ab0bd
commit
b3190004f4
13 changed files with 56 additions and 63 deletions
|
@ -2,11 +2,11 @@ const logger = require('winston');
|
|||
const db = require('../models');
|
||||
|
||||
module.exports = {
|
||||
getAnalyticsSummary: () => {
|
||||
logger.debug('retrieving analytics');
|
||||
getStatsSummary: () => {
|
||||
logger.debug('retrieving site statistics');
|
||||
const deferred = new Promise((resolve, reject) => {
|
||||
// get the raw analytics data
|
||||
db.Analytics
|
||||
// get the raw statistics data
|
||||
db.Stats
|
||||
.findAll()
|
||||
.then(data => {
|
||||
const resultHashTable = {};
|
|
@ -1,20 +1,20 @@
|
|||
const logger = require('winston');
|
||||
const { postToAnalytics } = require('./analytics');
|
||||
const { postToStats } = require('./statsHelpers.js');
|
||||
|
||||
module.exports = {
|
||||
handleRequestError (action, originalUrl, ip, error, res) {
|
||||
logger.error('Request Error >>', error);
|
||||
if (error === 'NO_CLAIMS' || error === 'NO_FREE_PUBLIC_CLAIMS') {
|
||||
postToAnalytics(action, originalUrl, ip, 'success');
|
||||
postToStats(action, originalUrl, ip, 'success');
|
||||
res.status(307).render('noClaims');
|
||||
} else if (error.response) {
|
||||
postToAnalytics(action, originalUrl, ip, error.response.data.error.messsage);
|
||||
postToStats(action, originalUrl, ip, error.response.data.error.messsage);
|
||||
res.status(error.response.status).send(error.response.data.error.message);
|
||||
} else if (error.code === 'ECONNREFUSED') {
|
||||
postToAnalytics(action, originalUrl, ip, 'Connection refused. The daemon may not be running.');
|
||||
postToStats(action, originalUrl, ip, 'Connection refused. The daemon may not be running.');
|
||||
res.status(503).send('Connection refused. The daemon may not be running.');
|
||||
} else {
|
||||
postToAnalytics(action, originalUrl, ip, error);
|
||||
postToStats(action, originalUrl, ip, error);
|
||||
res.status(400).send(JSON.stringify(error));
|
||||
}
|
||||
},
|
||||
|
|
|
@ -2,8 +2,8 @@ const db = require('../../models');
|
|||
const logger = require('winston');
|
||||
|
||||
module.exports = {
|
||||
postToAnalytics: (action, url, ipAddress, result) => {
|
||||
logger.silly('creating record for analytics');
|
||||
postToStats: (action, url, ipAddress, result) => {
|
||||
logger.silly('creating record for statistics db');
|
||||
// make sure the result is a string
|
||||
if (result && (typeof result !== 'string')) {
|
||||
result = result.toString();
|
||||
|
@ -13,7 +13,7 @@ module.exports = {
|
|||
ipAddress = ipAddress.toString();
|
||||
}
|
||||
// create record in the db
|
||||
db.Analytics.create({
|
||||
db.Stats.create({
|
||||
action,
|
||||
url,
|
||||
ipAddress,
|
|
@ -1,6 +1,6 @@
|
|||
module.exports = (sequelize, { STRING, TEXT }) => {
|
||||
const Analytics = sequelize.define(
|
||||
'Analytics',
|
||||
const Stats = sequelize.define(
|
||||
'Stats',
|
||||
{
|
||||
action: {
|
||||
type : STRING,
|
||||
|
@ -25,5 +25,5 @@ module.exports = (sequelize, { STRING, TEXT }) => {
|
|||
freezeTableName: true,
|
||||
}
|
||||
);
|
||||
return Analytics;
|
||||
return Stats;
|
||||
};
|
|
@ -65,7 +65,7 @@ canvas {
|
|||
float: left;
|
||||
}
|
||||
|
||||
/* analytics */
|
||||
/* statistics */
|
||||
.totals-row {
|
||||
border-top: 1px solid grey;
|
||||
border-bottom: 1px solid grey;
|
||||
|
|
|
@ -1,17 +0,0 @@
|
|||
const errorHandlers = require('../helpers/libraries/errorHandlers.js');
|
||||
const analyticsController = require('../controllers/analyticsController.js');
|
||||
|
||||
module.exports = (app) => {
|
||||
// route to show analytics
|
||||
app.get('/analytics', (req, res) => {
|
||||
// get and serve content
|
||||
analyticsController
|
||||
.getAnalyticsSummary()
|
||||
.then(result => {
|
||||
res.status(200).render('analytics', result);
|
||||
})
|
||||
.catch(error => {
|
||||
errorHandlers.handleRequestError(error, res);
|
||||
});
|
||||
});
|
||||
};
|
|
@ -5,7 +5,7 @@ const publishController = require('../controllers/publishController.js');
|
|||
const lbryApi = require('../helpers/libraries/lbryApi.js');
|
||||
const publishHelpers = require('../helpers/libraries/publishHelpers.js');
|
||||
const errorHandlers = require('../helpers/libraries/errorHandlers.js');
|
||||
const { postToAnalytics } = require('../helpers/libraries/analytics');
|
||||
const { postToStats } = require('../helpers/libraries/statsHelpers.js');
|
||||
|
||||
module.exports = app => {
|
||||
// route to run a claim_list request on the daemon
|
||||
|
@ -14,7 +14,7 @@ module.exports = app => {
|
|||
lbryApi
|
||||
.getClaimsList(params.claim)
|
||||
.then(claimsList => {
|
||||
postToAnalytics('publish', originalUrl, ip, 'success');
|
||||
postToStats('publish', originalUrl, ip, 'success');
|
||||
res.status(200).json(claimsList);
|
||||
})
|
||||
.catch(error => {
|
||||
|
@ -27,7 +27,7 @@ module.exports = app => {
|
|||
lbryApi
|
||||
.resolveUri(params.uri)
|
||||
.then(resolvedUri => {
|
||||
postToAnalytics('publish', originalUrl, ip, 'success');
|
||||
postToStats('publish', originalUrl, ip, 'success');
|
||||
res.status(200).json(resolvedUri);
|
||||
})
|
||||
.catch(error => {
|
||||
|
@ -40,7 +40,7 @@ module.exports = app => {
|
|||
// validate that a file was provided
|
||||
const file = files.speech || files.null;
|
||||
if (!file) {
|
||||
postToAnalytics('publish', originalUrl, ip, 'Error: file');
|
||||
postToStats('publish', originalUrl, ip, 'Error: file');
|
||||
res.status(400).send('Error: No file was submitted or the key used was incorrect. Files posted through this route must use a key of "speech" or null');
|
||||
return;
|
||||
}
|
||||
|
@ -48,14 +48,14 @@ module.exports = app => {
|
|||
const name = body.name || file.name.substring(0, file.name.indexOf('.'));
|
||||
const invalidCharacters = /[^\w,-]/.exec(name);
|
||||
if (invalidCharacters) {
|
||||
postToAnalytics('publish', originalUrl, ip, 'Error: name');
|
||||
postToStats('publish', originalUrl, ip, 'Error: name');
|
||||
res.status(400).send('Error: The name you provided is not allowed. Please use A-Z, a-z, 0-9, "_" and "-" only.');
|
||||
return;
|
||||
}
|
||||
// validate license
|
||||
const license = body.license || 'No License Provided';
|
||||
if ((license.indexOf('Public Domain') === -1) && (license.indexOf('Creative Commons') === -1)) {
|
||||
postToAnalytics('puplish', originalUrl, ip, 'Error: license');
|
||||
postToStats('puplish', originalUrl, ip, 'Error: license');
|
||||
res.status(400).send('Error: Only posts with a license of "Public Domain" or "Creative Commons" are eligible for publishing through spee.ch');
|
||||
return;
|
||||
}
|
||||
|
@ -73,7 +73,7 @@ module.exports = app => {
|
|||
case '1':
|
||||
break;
|
||||
default:
|
||||
postToAnalytics('publish', originalUrl, ip, 'Error: nsfw');
|
||||
postToStats('publish', originalUrl, ip, 'Error: nsfw');
|
||||
res.status(400).send('Error: NSFW value was not accepted. NSFW must be set to either true, false, "on", or "off"');
|
||||
return;
|
||||
}
|
||||
|
@ -89,7 +89,7 @@ module.exports = app => {
|
|||
publishController
|
||||
.publish(publishParams, fileName, fileType)
|
||||
.then(result => {
|
||||
postToAnalytics('publish', originalUrl, ip, 'success');
|
||||
postToStats('publish', originalUrl, ip, 'success');
|
||||
res.status(200).json(result);
|
||||
})
|
||||
.catch(error => {
|
||||
|
|
|
@ -1,5 +1,5 @@
|
|||
const logger = require('winston');
|
||||
const { postToAnalytics } = require('../helpers/libraries/analytics');
|
||||
const { postToStats } = require('../helpers/libraries/statsHelpers.js');
|
||||
|
||||
module.exports = app => {
|
||||
// route for the home page
|
||||
|
@ -11,7 +11,7 @@ module.exports = app => {
|
|||
// a catch-all route if someone visits a page that does not exist
|
||||
app.use('*', ({ originalUrl, ip }, res) => {
|
||||
logger.error(`Get request on ${originalUrl} from ${ip} which was a 404`);
|
||||
postToAnalytics('post', originalUrl, ip, 'Error: 404');
|
||||
postToStats('post', originalUrl, ip, 'Error: 404');
|
||||
res.status(404).render('fourOhFour');
|
||||
});
|
||||
};
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
const errorHandlers = require('../helpers/libraries/errorHandlers.js');
|
||||
const serveController = require('../controllers/serveController.js');
|
||||
const logger = require('winston');
|
||||
const { postToAnalytics } = require('../helpers/libraries/analytics');
|
||||
const { postToStats } = require('../helpers/libraries/statsHelpers.js');
|
||||
|
||||
function serveFile ({ fileName, fileType, filePath }, res) {
|
||||
logger.info(`serving file ${fileName}`);
|
||||
|
@ -42,7 +42,7 @@ module.exports = (app) => {
|
|||
serveController
|
||||
.getClaimByClaimId(params.name, params.claim_id)
|
||||
.then(fileInfo => {
|
||||
postToAnalytics('serve', originalUrl, ips, 'success');
|
||||
postToStats('serve', originalUrl, ips, 'success');
|
||||
serveFile(fileInfo, res);
|
||||
})
|
||||
.catch(error => {
|
||||
|
@ -58,7 +58,7 @@ module.exports = (app) => {
|
|||
serveController
|
||||
.getClaimByName(params.name)
|
||||
.then(fileInfo => {
|
||||
postToAnalytics('serve', originalUrl, ips, 'success');
|
||||
postToStats('serve', originalUrl, ips, 'success');
|
||||
serveFile(fileInfo, res);
|
||||
})
|
||||
.catch(error => {
|
||||
|
|
|
@ -1,31 +1,42 @@
|
|||
const errorHandlers = require('../helpers/libraries/errorHandlers.js');
|
||||
const showController = require('../controllers/showController.js');
|
||||
const logger = require('winston');
|
||||
const { postToAnalytics } = require('../helpers/libraries/analytics');
|
||||
const { postToStats } = require('../helpers/libraries/statsHelpers.js');
|
||||
const statsController = require('../controllers/statsController.js');
|
||||
|
||||
module.exports = (app) => {
|
||||
// route to fetch all free public claims
|
||||
// route to show the meme-fodder meme maker
|
||||
app.get('/meme-fodder/play', ({ originalUrl, ip }, res) => {
|
||||
logger.debug(`GET request on ${originalUrl} from ${ip}`);
|
||||
// get and serve content
|
||||
// get and serve the content
|
||||
showController
|
||||
.getAllClaims('meme-fodder')
|
||||
.then(orderedFreePublicClaims => {
|
||||
postToAnalytics('show', originalUrl, ip, 'success');
|
||||
postToStats('show', originalUrl, ip, 'success');
|
||||
res.status(200).render('memeFodder', { claims: orderedFreePublicClaims });
|
||||
})
|
||||
.catch(error => {
|
||||
errorHandlers.handleRequestError('show', originalUrl, ip, error, res);
|
||||
});
|
||||
});
|
||||
// route to fetch all free public claims
|
||||
// route to show statistics for spee.ch
|
||||
app.get('/stats', ({ originalUrl, ip }, res) => {
|
||||
// get and serve the content
|
||||
statsController
|
||||
.getStatsSummary()
|
||||
.then(result => {
|
||||
postToStats('show', originalUrl, ip, 'success');
|
||||
res.status(200).render('statistics', result);
|
||||
})
|
||||
.catch(error => {
|
||||
errorHandlers.handleRequestError(error, res);
|
||||
});
|
||||
});
|
||||
// route to display all free public claims at a given name
|
||||
app.get('/:name/all', ({ originalUrl, params, ip }, res) => {
|
||||
logger.debug(`GET request on ${originalUrl} from ${ip}`);
|
||||
// get and serve content
|
||||
// get and serve the content
|
||||
showController
|
||||
.getAllClaims(params.name)
|
||||
.then(orderedFreePublicClaims => {
|
||||
postToAnalytics('show', originalUrl, ip, 'success');
|
||||
postToStats('show', originalUrl, ip, 'success');
|
||||
res.status(200).render('allClaims', { claims: orderedFreePublicClaims });
|
||||
})
|
||||
.catch(error => {
|
||||
|
|
|
@ -2,7 +2,7 @@ const logger = require('winston');
|
|||
const publishController = require('../controllers/publishController.js');
|
||||
const publishHelpers = require('../helpers/libraries/publishHelpers.js');
|
||||
const errorHandlers = require('../helpers/libraries/errorHandlers.js');
|
||||
const { postToAnalytics } = require('../helpers/libraries/analytics');
|
||||
const { postToStats } = require('../helpers/libraries/statsHelpers.js');
|
||||
|
||||
module.exports = (app, siofu, hostedContentPath) => {
|
||||
const http = require('http').Server(app);
|
||||
|
@ -25,7 +25,7 @@ module.exports = (app, siofu, hostedContentPath) => {
|
|||
// listener for when file upload encounters an error
|
||||
uploader.on('error', ({ error }) => {
|
||||
logger.error('an error occured while uploading', error);
|
||||
postToAnalytics('publish', '/', null, error);
|
||||
postToStats('publish', '/', null, error);
|
||||
socket.emit('publish-status', error);
|
||||
});
|
||||
// listener for when file has been uploaded
|
||||
|
@ -39,18 +39,18 @@ module.exports = (app, siofu, hostedContentPath) => {
|
|||
publishController
|
||||
.publish(publishParams, file.name, file.meta.type)
|
||||
.then(result => {
|
||||
postToAnalytics('publish', '/', null, 'success');
|
||||
postToStats('publish', '/', null, 'success');
|
||||
socket.emit('publish-complete', { name: publishParams.name, result });
|
||||
})
|
||||
.catch(error => {
|
||||
error = errorHandlers.handlePublishError(error);
|
||||
postToAnalytics('publish', '/', null, error);
|
||||
postToStats('publish', '/', null, error);
|
||||
socket.emit('publish-failure', error);
|
||||
});
|
||||
} else {
|
||||
logger.error(`An error occurred in uploading the client's file`);
|
||||
socket.emit('publish-failure', 'file uploaded, but with errors');
|
||||
postToAnalytics('publish', '/', null, 'file uploaded, but with errors');
|
||||
postToStats('publish', '/', null, 'file uploaded, but with errors');
|
||||
// to-do: remove the file if not done automatically
|
||||
}
|
||||
});
|
||||
|
|
|
@ -56,7 +56,6 @@ app.set('view engine', 'handlebars');
|
|||
|
||||
// require express routes
|
||||
require('./routes/api-routes.js')(app);
|
||||
require('./routes/analytics-routes.js')(app);
|
||||
require('./routes/show-routes.js')(app);
|
||||
require('./routes/serve-routes.js')(app);
|
||||
require('./routes/home-routes.js')(app);
|
||||
|
|
|
@ -3,7 +3,7 @@
|
|||
{{> topBar}}
|
||||
</div>
|
||||
<div>
|
||||
<h3>Analytics</h3>
|
||||
<h3>Site Statistics</h3>
|
||||
<table>
|
||||
<tr>
|
||||
<th>action</th>
|
Loading…
Add table
Reference in a new issue