🔧 Update version in package.json

[rbdr/dasein] / lib / dasein.js

diff --git a/lib/dasein.js b/lib/dasein.js
index 38654a4822261fe447ece81d6fbba384ce16ef8a..5b8486a09806a132be9ae8d262b39c331a677313 100644 (file)
--- a/lib/dasein.js
+++ b/lib/dasein.js
@@ -1,17 +1,29 @@
 'use strict';
 
 const Koa = require('koa');
 'use strict';
 
 const Koa = require('koa');

+const KoaBodyParser = require('koa-bodyparser');

 const KoaJwt = require('koa-jwt');
 const KoaJwt = require('koa-jwt');

-const KoaStatic = require('koa-static');

 const KoaRoute = require('koa-route');
 const KoaRoute = require('koa-route');

+const KoaSend = require('koa-send');
+const KoaStatic = require('koa-static');
+const Path = require('path');

 
 const AuthHandler = require('./handlers/auth');
 
 const AuthHandler = require('./handlers/auth');

+const PostsHandler = require('./handlers/posts');
+const CommentsHandler = require('./handlers/comments');

 
 const internals = {};
 
 internals.k401Location = '/401.html';
 internals.kMainLocation = '/';
 
 
 const internals = {};
 
 internals.k401Location = '/401.html';
 internals.kMainLocation = '/';
 

+/**
+ * The Dasein class is the main entry point for the application.
+ *
+ * @class Dasein
+ * @param {Dasein.tConfiguration} config the initialization options to
+ * extend the instance
+ */

 module.exports = internals.Dasein = class Dasein {
 
   constructor(config) {
 module.exports = internals.Dasein = class Dasein {
 
   constructor(config) {


@@ -19,6 +31,14 @@ module.exports = internals.Dasein = class Dasein {
     Object.assign(this, config);
   }
 
     Object.assign(this, config);
   }
 

+  /**
+   * Initializes the application and starts listening. Also prints a
+   * nice robotic banner with information.
+   *
+   * @function run
+   * @memberof Dasein
+   * @instance
+   */

   run() {
 
     this._initializeServer();
   run() {
 
     this._initializeServer();


@@ -28,15 +48,18 @@ module.exports = internals.Dasein = class Dasein {
     return Promise.resolve();
   }
 
     return Promise.resolve();
   }
 

+  // Initializes the Koa application and all the handlers.
+

   _initializeServer() {
 
   _initializeServer() {
 

-    this._app = Koa();
+    const self = this;

 
 

-    this._app.keys = this.cookieKeys;
+    this._app = Koa();

 
     this._app.use(KoaStatic(this.staticDirectory));
 
     this._app.use(KoaStatic(this.staticDirectory));

+    this._app.use(KoaBodyParser());

 
 

-    // Redirect all 401s to the 401 static page
+    // Error handler

 
     this._app.use(function * (next) {
 
 
     this._app.use(function * (next) {
 


@@ -44,51 +67,87 @@ module.exports = internals.Dasein = class Dasein {
         yield next;
       }
       catch (err) {
         yield next;
       }
       catch (err) {

-        if (err.status === 401) {
-          return this.redirect(internals.k401Location);
+        this.status = err.status || 500;
+
+        const response = {
+          error: err.message,
+          status: this.status
+        };
+
+        if (response.status === 401) {
+          response.error === 'Protected resource, use Authorization header to get access';

         }
 
         }
 

-        throw err;
+        this.body = response;
+
+        this.app.emit('error', err, this);

       }
     });
 
     this._app.use(KoaJwt({
       secret: this.jwt.secret,
       }
     });
 
     this._app.use(KoaJwt({
       secret: this.jwt.secret,

-      passthrough: true,
-      cookie: this.jwt.cookieName
+      passthrough: true

     }));
 
     }));
 

-    // Handlers for Twitter Auth Related Routes
+    this._initializeAuthRoutes();
+    this._initializePostsRoutes();
+    this._initializeCommentsRoutes();
+
+    this._app.use(function * () {
+
+      yield KoaSend(this, Path.join(self.staticDirectory, 'index.html'));
+    });
+
+  }
+
+  // Initialize routes for auth
+
+  _initializeAuthRoutes() {

 
     const authHandler = new AuthHandler({
 
     const authHandler = new AuthHandler({

-      hostname: this.hostname,

       jwt: this.jwt,
       twitter: this.twitter
     });
       jwt: this.jwt,
       twitter: this.twitter
     });

-    this._app.use(KoaRoute.get('/login', authHandler.login()));
-    this._app.use(KoaRoute.get('/login-callback', authHandler.callback()));
-    this._app.use(KoaRoute.get('/logout', authHandler.logout()));
+    this._app.use(KoaRoute.get('/api/auth/login', authHandler.login()));
+    this._app.use(KoaRoute.post('/api/auth/callback', authHandler.callback()));
+  }

 
 

-    // The index
+  // Initialize routes for posts

 
 

-    this._app.use(function * () {
+  _initializePostsRoutes() {

 
 

-      if (this.state.user) {
-        this.body = `<img src="${this.state.user.profile_image_url_https}"> Hello ${this.state.user.screen_name}`;
-        return;
-      }
+    const postsHandler = new PostsHandler({
+      ttl: this.ttl,
+      redis: this.redis
+    });
+    this._app.use(KoaRoute.get('/api/posts', postsHandler.findAll()));
+    this._app.use(KoaRoute.get('/api/posts/:id', postsHandler.find()));
+    this._app.use(KoaRoute.post('/api/posts', postsHandler.create()));
+    this._app.use(KoaRoute.delete('/api/posts/:id', postsHandler.delete()));

 
 

-      this.body = 'Go to /login to login';
-      return;
+  }
+
+  // Initialize routes for comments
+
+  _initializeCommentsRoutes() {
+
+    const commentsHandler = new CommentsHandler({
+      ttl: this.ttl,
+      redis: this.redis

     });
     });

+    this._app.use(KoaRoute.get('/api/posts/:postId/comments', commentsHandler.findAll()));
+    this._app.use(KoaRoute.post('/api/posts/:postId/comments', commentsHandler.create()));

   }
 
   }
 

+  // Starts listening
+

   _startServer() {
 
     this._app.listen(this.port);
   }
 
   // Prints the banner.
   _startServer() {
 
     this._app.listen(this.port);
   }
 
   // Prints the banner.

+

   _printBanner() {
 
     console.log('        .');
   _printBanner() {
 
     console.log('        .');