pixelplanet/src/server.js

/* @flow */

import url from 'url';
import path from 'path';
import compression from 'compression';
import express from 'express';
import http from 'http';
import etag from 'etag';


// import baseCss from './components/base.tcss';
import forceGC from './core/forceGC';
import assets from './assets.json'; // eslint-disable-line import/no-unresolved
import logger from './core/logger';
import rankings from './core/ranking';
import models from './data/models';
import chatProvider from './core/ChatProvider';
import { expressTTag } from './core/ttag';

import SocketServer from './socket/SocketServer';
import APISocketServer from './socket/APISocketServer';

import {
  api,
  tiles,
  chunks,
  admintools,
  resetPassword,
} from './routes';
import generateGlobePage from './ssr-components/Globe';
import generateMainPage from './ssr-components/Main';

import { SECOND, MONTH } from './core/constants';
import { PORT, HOST, GUILDED_INVITE } from './core/config';

import { startAllCanvasLoops } from './core/tileserver';

startAllCanvasLoops();


const app = express();
app.disable('x-powered-by');


// Call Garbage Collector every 30 seconds
setInterval(forceGC, 15 * 60 * SECOND);

// create http server
const server = http.createServer(app);

//
// websockets
// -----------------------------------------------------------------------------
const usersocket = new SocketServer();
const apisocket = new APISocketServer();
function wsupgrade(request, socket, head) {
  const { pathname } = url.parse(request.url);

  if (pathname === '/ws') {
    usersocket.wss.handleUpgrade(request, socket, head, (ws) => {
      usersocket.wss.emit('connection', ws, request);
    });
  } else if (pathname === '/mcws') {
    apisocket.wss.handleUpgrade(request, socket, head, (ws) => {
      apisocket.wss.emit('connection', ws, request);
    });
  } else {
    socket.destroy();
  }
}
server.on('upgrade', wsupgrade);


//
// API
// -----------------------------------------------------------------------------
app.use('/api', api);


//
// Serving Zoomed Tiless
// -----------------------------------------------------------------------------
app.use('/tiles', tiles);


/*
 * use gzip compression for following calls
/* level from -1 (default, 6) to 0 (no) from 1 (fastest) to 9 (best)
 * Set custon filter to make sure that .bmp files get compressed
 */
app.use(compression({
  level: 3,
  filter: (req, res) => {
    if (res.getHeader('Content-Type') === 'application/octet-stream') {
      return true;
    }
    return compression.filter(req, res);
  },
}));


//
// public folder
// (this should be served with nginx or other webserver)
// -----------------------------------------------------------------------------
app.use(express.static(path.join(__dirname, 'public'), {
  maxAge: 3 * MONTH,
  extensions: ['html'],
}));


//
// Redirecct to guilded
// -----------------------------------------------------------------------------
app.use('/guilded', (req, res) => {
  res.redirect(GUILDED_INVITE);
});


//
// Serving Chunks
// -----------------------------------------------------------------------------
app.get('/chunks/:c([0-9]+)/:x([0-9]+)/:y([0-9]+)(/)?:z([0-9]+)?.bmp', chunks);

//
// Admintools
// -----------------------------------------------------------------------------
app.use('/admintools', admintools);

/*
 * decide which language to use
 */
app.use(expressTTag);


//
// Password Reset Link
// -----------------------------------------------------------------------------
app.use('/reset_password', resetPassword);


//
// 3D Globe (react generated)
// -----------------------------------------------------------------------------
const globeEtag = etag(
  assets.globe.js.join('_'),
  { weak: true },
);
app.get('/globe', async (req, res) => {
  res.set({
    'Cache-Control': `private, max-age=${15 * 60}`, // seconds
    'Content-Type': 'text/html; charset=utf-8',
    ETag: globeEtag,
  });

  if (req.headers['if-none-match'] === globeEtag) {
    res.status(304).end();
    return;
  }

  res.status(200).send(generateGlobePage(req.lang));
});


//
// Main Page (react generated)
// -----------------------------------------------------------------------------
const indexEtag = etag(
  assets.client.js.join('_'),
  { weak: true },
);

app.get('/', async (req, res) => {
  res.set({
    'Cache-Control': `private, max-age=${15 * 60}`, // seconds
    'Content-Type': 'text/html; charset=utf-8',
    ETag: indexEtag,
  });

  if (req.headers['if-none-match'] === indexEtag) {
    res.status(304).end();
    return;
  }

  res.status(200).send(generateMainPage(req.lang));
});


//
// ip config
// -----------------------------------------------------------------------------
// use this if models changed:
const promise = models.sync({ alter: { drop: false } })
// const promise = models.sync()
  .catch((err) => logger.error(err.stack));
promise.then(() => {
  rankings.updateRanking();
  chatProvider.initialize();
  server.listen(PORT, HOST, () => {
    const address = server.address();
    logger.log(
      'info',
      `web is running at http://${address.host}:${address.port}/`,
    );
  });
});