advanced, bonus tp: add middleware recursivity

Author: Tronix117

controllers/party.js

@@ -0,0 +1,46 @@
+const Controller = require('../lib/controller');
+const Party = require('../models/party');
+
+
+module.exports = class PartyController extends Controller {
+  static routes = [
+    { method: 'GET', url: '/party', action: 'index' },
+    { method: 'POST', url: '/party', action: 'create' },
+    { method: 'PUT', url: '/party/current', action: 'guess' },
+    { method: 'GET', url: '/party/current', action: 'history' },
+  ]
+
+  index() {
+    return 'Create a party using POST'
+  }
+
+  create() {
+    Party.currentParty = new Party(
+      this.req.body.min || 0,
+      this.req.body.max || 100,
+    );
+
+    this.res.statusCode = 204;
+  }
+
+  guess() {
+    if (!Party.currentParty) {
+      throw new Error('No party');
+    }
+
+    const result = Party.currentParty.guess(req.body);
+    if (result === '=') {
+      return `Félicitation, le chiffre était ${Party.currentParty.number}`;
+    } else {
+      return result; // + or -
+    }
+  }
+
+  history() {
+    if (!Party.currentParty) {
+      throw new Error('No party');
+    }
+
+    return Party.currentParty.guesses.join(', ');
+  }
+}

lib/controller.js

@@ -0,0 +1,39 @@
+module.exports = class Controller {
+  constructor(req, res) {
+    this.req = req;
+    this.res = res;
+  }
+
+  callRoute(route) {
+    // Execute the action of the route
+    const result = this[route.action]();
+
+    // // =>
+    // const handler = this[route.action];
+    // // =>
+    // const handler = this['create'];
+    // // =>
+    // const handler = this.create;
+    // // =>
+    // const result = handler();
+// 
+    if (this.res.statusCode) {
+      this.res.statusCode = 200;
+    }
+
+    this.res.write(result);
+    this.res.end();
+  }
+
+  static middleware(req, res, next) {
+    for (const route of this.routes) {
+      if (req.method === route.method && req.url === route.url) {
+        const ctrl = new this(req, res)
+        ctrl.callRoute(route);
+        return;
+      }
+    }
+
+    next();
+  }
+}

main.js

@@ -1,69 +1,22 @@
 const http = require('http');
-const Party = require('./models/party');
 
-function bodyMiddleware(req, res, next) {
-  if (['GET', 'HEAD', 'DELETE', 'OPTIONS'].includes(req.method)) {
-    return next(req, res);
-  }
+const PartyController = require('./controllers/party');
+const bodyMiddleware = require('./middlewares/body');
+const errorMiddleware = require('./middlewares/error');
+const notFoundMiddleware = require('./middlewares/notFound');
 
-  let data = '';
-
-  req.on('data', (chunk) => data += chunk);
-  req.on('end', () => {
-    try {
-      data = JSON.parse(data);
-    } catch {
-      res.statusCode = 400
-      return res.end('JSON body is invalid');
-    }
-
-    req.body = data;
-
-    next(req, res);
-  })
-}
-
-function errorMiddleware(req, res, next) {
-  try {
-    next(req, res);
-  } catch (err) {
-    res.statusCode = 500;
-    res.end(err.message);
-  }
-}
 
 function handleRequest(req, res) {
-  bodyMiddleware(req, res, (req, res) => errorMiddleware(req, res, handleRouting));
-}
-
-function handleRouting(req, res) {
-  if (req.method === 'POST' && req.url === '/party') {
-    Party.currentParty = new Party(req.body.min || 0, req.body.max || 100);
-    res.statusCode = 204;
-  } else if (req.method === 'PUT' && req.url === '/party/current') {
-    if (!Party.currentParty) {
-      throw new Error('No party');
-    }
-
-    const result = Party.currentParty.guess(req.body);
-    if (result === '=') {
-      res.write(`Félicitation, le chiffre était ${Party.currentParty.number}`);
-    } else {
-      res.write(result); // + or -
-    }
-    res.statusCode = 200;
-  } else if (req.method === 'GET' && req.url === '/party/current') {
-    if (!Party.currentParty) {
-      throw new Error('No party');
-    }
-
-    res.statusCode = 200;
-    res.write(Party.currentParty.guesses.join(', '));
-  } else {
-    res.statusCode = 404;
-  }
-
-  res.end();
+  const middlewares = [
+    bodyMiddleware,
+    errorMiddleware,
+    PartyController.middleware,
+    notFoundMiddleware,
+  ]
+
+  // @todo apply middleware one after the other
+  // remplacer la ligne suivante, par quelque chose de dynamique
+  // bodyMiddleware(req, res, (req, res) => errorMiddleware(req, res, handleRouting));
 }
 
 

middlewares/body.js

@@ -0,0 +1,21 @@
+module.exports = function bodyMiddleware(req, res, next) {
+  if (['GET', 'HEAD', 'DELETE', 'OPTIONS'].includes(req.method)) {
+    return next(req, res);
+  }
+
+  let data = '';
+
+  req.on('data', (chunk) => data += chunk);
+  req.on('end', () => {
+    try {
+      data = JSON.parse(data);
+    } catch {
+      res.statusCode = 400
+      return res.end('JSON body is invalid');
+    }
+
+    req.body = data;
+
+    next(req, res);
+  })
+}

middlewares/error.js

@@ -0,0 +1,8 @@
+module.exports = function errorMiddleware(req, res, next) {
+  try {
+    next(req, res);
+  } catch (err) {
+    res.statusCode = 500;
+    res.end(err.message);
+  }
+}

middlewares/notFound.js

@@ -0,0 +1,4 @@
+module.exports = function notFoundMiddleware(req, res) {
+  res.statusCode = 404;
+  res.end();
+}