create-server.js 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677
  1. // Forked workers will run this code when found to not be
  2. // the master of the cluster.
  3. var http = require('http');
  4. var url = require('url');
  5. var h = require('./helper');
  6. // Handlers, one for each db config
  7. var MongodbRawHandler = require('./handlers/mongodb-raw');
  8. var MySQLRawHandler = require('./handlers/mysql-raw');
  9. // Mongoose is a popular Node/MongoDB driver
  10. var MongooseHandler = require('./handlers/mongoose');
  11. // Sequelize is a popular Node/SQL driver
  12. var SequelizeHandler = require('./handlers/sequelize');
  13. // Node's redis package uses the C bindings of the hiredis library
  14. var HiredisHandler = require('./handlers/redis');
  15. module.exports = http.createServer(function (req, res) {
  16. var values = url.parse(req.url, true);
  17. var route = values.pathname;
  18. var basicHandlers = {
  19. '/json': h.responses.jsonSerialization,
  20. '/plaintext': h.responses.plaintext,
  21. '/mongoose/db': MongooseHandler.SingleQuery,
  22. '/mongoose/fortunes': MongooseHandler.Fortunes,
  23. '/mongodb/db': MongodbRawHandler.SingleQuery,
  24. '/mongodb/fortunes': MongodbRawHandler.Fortunes,
  25. '/sequelize/db': SequelizeHandler.SingleQuery,
  26. '/sequelize/fortunes': SequelizeHandler.Fortunes,
  27. '/mysql/db': MySQLRawHandler.SingleQuery,
  28. '/mysql/fortunes': MySQLRawHandler.Fortunes,
  29. '/hiredis/db': HiredisHandler.SingleQuery,
  30. '/hiredis/fortunes': HiredisHandler.Fortunes
  31. }
  32. if (basicHandlers[route]) {
  33. return basicHandlers[route](req, res);
  34. } else {
  35. var queries = ~~(values.query.queries) || 1;
  36. queries = Math.min(Math.max(queries, 1), 500);
  37. var queriesHandlers = {
  38. '/mongoose/queries': MongooseHandler.MultipleQueries,
  39. '/mongoose/updates': MongooseHandler.Updates,
  40. '/mongodb/queries': MongodbRawHandler.MultipleQueries,
  41. '/mongodb/updates': MongodbRawHandler.Updates,
  42. '/sequelize/queries': SequelizeHandler.MultipleQueries,
  43. '/sequelize/updates': SequelizeHandler.Updates,
  44. '/mysql/queries': MySQLRawHandler.MultipleQueries,
  45. '/mysql/updates': MySQLRawHandler.Updates,
  46. '/hiredis/queries': HiredisHandler.MultipleQueries,
  47. '/hiredis/updates': HiredisHandler.Updates
  48. }
  49. if (queriesHandlers[route]) {
  50. return queriesHandlers[route](queries, req, res);
  51. } else {
  52. return h.responses.routeNotImplemented(req, res);
  53. }
  54. }
  55. }).listen(8080, function() {
  56. console.log("NodeJS worker listening on port 8080");
  57. });