wentwrong · AndreyBelym · Feb 18, 2020 · Feb 11, 2020 · Feb 11, 2020 · Feb 12, 2020
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -6,7 +6,7 @@
   "scripts": {
     "start": "node src/index.js",
     "start-debug": "cross-env DEBUG=gh-canary:* npm run start",
-    "lint": "eslint src test",
+    "lint": "eslint src/server test",
     "test": "npm run lint && mocha test/**/*-test.js",
     "test-debug": "cross-env DEBUG=gh-canary:* npm test",
     "watch": "npm test -- -w",
@@ -27,13 +27,17 @@
     "cross-env": "^7.0.0",
     "eslint": "^6.8.0",
     "mocha": "^7.0.1",
+    "morgan": "^1.9.1",
     "proxyquire": "^2.1.3",
     "sinon": "^8.1.1"
   },
   "dependencies": {
+    "@octokit/rest": "^16.43.1",
     "debug": "^4.1.1",
+    "dedent": "^0.7.0",
     "dotenv": "^8.2.0",
     "express": "^4.17.1",
+    "globby": "^11.0.0",
     "got": "^10.4.0"
   }
 }
diff --git a/src/app.js b/src/app.js
diff --git a/src/client/public/index.html b/src/client/public/index.html
@@ -0,0 +1,16 @@
+<!doctype html>
+<html lang="en">
+<head>
+    <meta charset="utf-8">
+    <title>Dashboard</title>
+    <meta name="description" content="Dashboard for github pull-requests notifier">
+    <meta name="author" content="wentwrong">
+    <script src="script.js"></script>
+</head>
+
+<body>
+    <div class="pull-requests">
+    </div>
+    <script>new App()</script>
+</body>
+</html>
diff --git a/src/client/public/script.js b/src/client/public/script.js
@@ -0,0 +1,33 @@
+class App {
+    constructor() {
+        this.pullRequestsDiv = document.querySelector('.pull-requests');
+        this.renderPage();
+    }
+
+    async renderPage () {
+        try {
+            const response = await fetch('api/v1/pulls/list');
+            const { pullRequestList } = await response.json();
+
+            pullRequestList.forEach(pr => this._createNewPullRequestDiv(pr));
+        }
+        catch (err) {
+            console.log(err);
+            const errorMessage = document.createElement('div');
+            errorMessage.innerHTML = 'An error has occured while fetching data from server.';
+
+            this.pullRequestsDiv.appendChild(errorMessage);
+        }
+    }
+
+    _createNewPullRequestDiv (pullRequest) {
+        const pullRequestDiv = document.createElement('div');
+
+        pullRequestDiv.innerHTML = (`<p>
+                                    <a href="${pullRequest['html_url']}">
+                                    ${pullRequest['title']}
+                                    </a> by ${pullRequest['user']['login']}</p>`);
+
+        this.pullRequestsDiv.appendChild(pullRequestDiv);
+    }    
+}
diff --git a/src/config.js b/src/config.js
diff --git a/src/index.js b/src/index.js
@@ -1,8 +1,7 @@
-const App = require('./app');
+const App = require('./server/app');
 
 if (require.main === module) {
     const app = new App();
-
     app.run();
 }
 

diff --git a/src/server/app.js b/src/server/app.js
@@ -0,0 +1,42 @@
+const config = require('./config');
+const express = require('express');
+const Server = require('./my-server');
+const createRoutes = require('./routes');
+const morgan = require('morgan');
+
+class App {
+    constructor ({ port = config.PORT, host = config.HOST } = {}) {
+        this.port = port;
+        this.host = host;
+    }
+
+    async _configExpress (e) {
+        const routes = await createRoutes(config.ROUTES_DIR);
+
+        e.use(routes);
+
+        if (config.NODE_ENV === 'development')
+            e.use(morgan('dev'));
+
+
+        e.use(express.static(config.STATIC_DIR));
+
+        return e;
+    }
+
+    async run () {
+        const configuredExpress = await this._configExpress(express());
+
+        this.server = new Server(configuredExpress, this.port, this.host);
+        await this.server.start();
+    }
+
+    async close () {
+        if (this.server)
+            await this.server.stop();
+        else
+            throw new Error('Stop when application not running');
+    }
+}
+
+module.exports = App;
diff --git a/src/server/config.js b/src/server/config.js
@@ -0,0 +1,28 @@
+require('dotenv').config();
+const debug = require('./debug');
+
+process
+    .on('unhandledRejection', reason => {
+        debug.error('Unhandled promise rejection');
+        debug.error(reason);
+    })
+    .on('uncaughtException', err => {
+        debug.error('Uncaught exception');
+        debug.error(err);
+    });
+
+const [ OWNER, REPO ] = process.env.REPO_SLUG ?
+    process.env.REPO_SLUG.split('/') : [ null, null ];
+
+module.exports = {
+    PORT:               process.env.PORT || 3000,
+    HOST:               process.env.HOST || '127.0.0.1',
+    NODE_ENV:           process.env.NODE_ENV || 'production',
+    OWNER,
+    REPO,
+    API_PREFIX:         '/api/v1',
+    MOCK_GITHUB_PREFIX: '/github-api',
+    STATIC_DIR:         'src/client/public',
+    ROUTES_DIR:         'src/server/routes',
+    GITHUB_API_URL:     'https://api.github.com'
+};
diff --git a/src/server/controllers/pullcontroller.js b/src/server/controllers/pullcontroller.js
@@ -0,0 +1,39 @@
+const config = require('../config');
+const debug = require('../debug');
+const { Octokit } = require('@octokit/rest');
+
+class PullController {
+    static async list (req, res) {
+        const octokit = Octokit({
+            baseUrl: config.GITHUB_API_URL
+        });
+
+        const options = octokit.pulls.list.endpoint.merge({
+            owner: config.OWNER,
+            repo:  config.REPO
+        });
+
+        try {
+            const pullRequests = [];
+
+            for await (const page of octokit.paginate.iterator(options))
+                pullRequests.push(page['data'].filter(pr => pr['author_association'] === 'NONE'));
+
+            res.send({ pullRequestList: pullRequests.flat() });
+        }
+        catch (err) {
+            debug.error(`Error happened when ${req.ip} requests ${req.path}`);
+            debug.error(err);
+
+            res
+                .status(500)
+                .json({ error: 'An error has occured while fetching pull-requests from server.' });
+        }
+    }
+
+    static async addComment (req, res) {
+        return res.json({ message: 'NOT IMPLEMENTED YET' });
+    }
+}
+
+module.exports = PullController;
diff --git a/src/debug.js → src/server/debug.js b/src/debug.js → src/server/debug.js
@@ -2,5 +2,6 @@ const debug = require('debug');
 
 module.exports = {
     log:   debug('gh-canary:log'),
+    warn:  debug('gh-canary:warn'),
     error: debug('gh-canary:error')
 };
diff --git a/src/my-server.js → src/server/my-server.js b/src/my-server.js → src/server/my-server.js
@@ -32,8 +32,14 @@ class Server {
             log(`Server started on ${this.host}:${this.port}`);
         }
         catch (err) {
-            error(`Server failed to start`);
-
+            switch (err.code) {
+                case 'EACCES':
+                    error(`Server requires elevated privileges`);
+                    break;
+                case 'EADDRINUSE':
+                    error(`Server is already in use`);
+                    break;
+            }
             throw err;
         }
     }

diff --git a/src/server/routes/api/v1/pulls/index.js b/src/server/routes/api/v1/pulls/index.js
@@ -0,0 +1,14 @@
+const express = require('express');
+const PullController = require('../../../../controllers/pullcontroller');
+
+class PullsRouter extends express.Router {
+    constructor (...props) {
+        super(...props);
+
+        this.get('/list', PullController.list)
+            .post('/addComment', PullController.addComment);
+
+    }
+}
+
+module.exports = PullsRouter;
diff --git a/src/server/routes/index.js b/src/server/routes/index.js
@@ -0,0 +1,29 @@
+const path = require('path');
+const globby = require('globby');
+const debug = require('../debug');
+const mainRouter = require('express').Router();
+
+async function createRoutes (routesDir) {
+    try {
+        const files = await globby('**/!(index.js)/*.js', { cwd: path.resolve(routesDir) });
+
+        files
+            .map(filename => ({
+                routePrefix: path.dirname(filename),
+                Router:      require(`./${filename}`)
+            }))
+            .map(({
+                routePrefix,
+                Router
+            }) => mainRouter.use(`/${routePrefix}`, new Router()));
+
+        return mainRouter;
+    }
+    catch (err) {
+        debug.error('An error has occured when processing app routes');
+        debug.error(err);
+        throw err;
+    }
+}
+
+module.exports = createRoutes;
diff --git a/static/index.html b/static/index.html
diff --git a/test/routes/index-test.js b/test/routes/index-test.js
@@ -1,8 +1,8 @@
 const { expect } = require('chai');
 const got = require('got');
-const App = require('../../');
+const App = require('../../src/index');
 
-describe('Index page', () => {
+describe('Index', () => {
     const app = new App();
 
     before(async () => {
@@ -13,10 +13,10 @@ describe('Index page', () => {
         await app.close();
     });
 
-    it('app should show "Hello Node.js" message', async () => {
-        const response = await got(`http://${app.server.host}:${app.server.port}`);
+    it(`should return 200 response`, async () => {
+        const response = await got(`http://${app.server.host}:${app.server.port}/`);
 
+        expect(response.body).contain('Dashboard');
         expect(response.statusCode).equal(200);
-        expect(response.body).include('Hello Node.js');
     });
 });