mirrors/foxy-moxy
2
0
Fork 0
mirror of https://git.sleeping.town/mirrors/foxy-moxy synced 2024-11-21 11:37:43 +00:00
Code Issues Projects Releases Packages Wiki Activity

factor our cluster into run.js

Browse source
This commit is contained in:
Jeffrey Sun 2017-05-03 16:06:47 -07:00
parent f5712fef77
commit a5b32e9d53
2 changed files with 29 additions and 26 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
run.js Normal file
View file

@ -0,0 +1,13 @@
const cluster = require('express-cluster');
const app = require('./server.js');
activePort = process.env.PORT || 3000;
cluster((worker) => {
app.listen(activePort, () => {
console.log('worker ' + worker.id + ' is listening on port ' + activePort);
});
}, {
'respawn': true, // workers will restart on failure
'verbose': true, // logs what happens to console
});

42
server.js
View file

@ -5,7 +5,6 @@ try {
}
const express = require('express');
const cluster = require('express-cluster');
const uuid = require('uuid/v4');
const sanitize = require('sanitize-filename');
const Canvas = require('canvas');
@ -22,31 +21,22 @@ function composeImage(width, height, seed) {
};
const cacheTimeout = 60 * 60 * 24 * 30;
const app = express();
cluster((worker) => {
const app = express();
app.get('/healthcheck', (req, res) => {
res.status(200).end();
});
app.get('/healthcheck', (req, res) => {
res.status(200).end();
});
app.get('/:width/:seed', (req, res) => {
let width = parseInt(req.params.width) || 400;
if (width > 400) width = 400;
const seed = sanitize(req.params.seed) || uuid();
const canvas = composeImage(width, width, seed);
const buffer = canvas.toBuffer();
res.set('Cache-Control', 'max-age=' + cacheTimeout);
res.set('Content-length', buffer.length);
res.type('png');
res.end(buffer, 'binary');
});
app.get('/:width/:seed', (req, res) => {
let width = parseInt(req.params.width) || 400;
if (width > 400) width = 400;
const seed = sanitize(req.params.seed) || uuid();
const canvas = composeImage(width, width, seed);
const buffer = canvas.toBuffer();
res.set('Cache-Control', 'max-age=' + cacheTimeout);
res.set('Content-length', buffer.length);
res.type('png');
res.end(buffer, 'binary');
});
activePort = process.env.PORT || 3000;
app.listen(activePort, () => {
console.log('worker ' + worker.id + ' is listening on port ' + activePort);
});
}, {
'respawn': true, // workers will restart on failure
'verbose': true, // logs what happens to console
})
module.exports = app;