Implement full crud (#13)

* Use NYC instead of Istanbul

* Implement user show

* Implement user update

* Implement user delete

* Remove istanbul dependency

* Update cleanup script

* Update eslint to support async/await

Author: talyssonoc

.eslintrc

@@ -4,6 +4,9 @@
     "es6": true,
     "mocha": true
   },
+  "parserOptions": {
+    "ecmaVersion": 2017
+  },
   "extends": "eslint:recommended",
   "rules": {
     "comma-spacing": ["error", { "before": false, "after": true }],

.gitignore

@@ -2,3 +2,4 @@
 node_modules
 config/database.js
 coverage/
+.nyc_output

.istanbul.yml

@@ -0,0 +1,13 @@
+{
+  "cwd": "./src",
+  "exclude": [
+    "container.js",
+    "app/Application.js",
+    "interfaces/http/Server.js"
+  ],
+  "reporter": [
+    "html",
+    "lcov",
+    "text-summary"
+  ]
+}

.nycrc

@@ -11,7 +11,7 @@
     "start": "node cluster.js",
     "dev": "cross-env NODE_PATH=. NODE_ENV=development nodemon",
     "test": "cross-env NODE_PATH=. NODE_ENV=test mocha",
-    "coverage": "cross-env NODE_PATH=. NODE_ENV=test istanbul cover node_modules/mocha/bin/_mocha",
+    "coverage": "cross-env NODE_PATH=. NODE_ENV=test nyc mocha",
     "lint": "eslint {src,test,config}/**/*.js",
     "sequelize": "cross-env NODE_PATH=. sequelize",
     "console": "cross-env NODE_PATH=. node src/interfaces/console/index.js",
@@ -31,6 +31,7 @@
     "cross-env": "^3.2.3",
     "del": "^2.2.2",
     "dotenv": "^4.0.0",
+    "eslint": "^4.7.2",
     "express": "^4.15.2",
     "express-status-monitor": "^0.1.9",
     "http-status": "^1.0.1",
@@ -48,12 +49,11 @@
     "chai-change": "^2.1.2",
     "chance": "^1.0.6",
     "dirty-chai": "^2.0.1",
-    "eslint": "^3.17.1",
     "factory-girl": "^4.0.0",
-    "istanbul": "^0.4.5",
     "listr": "^0.11.0",
     "mocha": "^3.2.0",
     "nodemon": "^1.11.0",
+    "nyc": "^11.2.1",
     "replace-in-file": "^2.5.0",
     "supertest": "^3.0.0",
     "supertest-as-promised": "^4.0.2"

package.json

@@ -26,13 +26,12 @@ const tasks = new Listr([
       return replace({
         files: containerPath,
         from: [
-          /\s*const.*app\/user'\);/,
+          /\s*const \{(\n.*)+.*app\/user'\);/,
           /\s*const.*UsersRepository'\);/,
           /\, User: UserModel/,
           /\s*usersRepository.*\}\]/,
           /\,\s*UserModel/,
-          /createUser.*\n/,
-          /\s*getAllUsers.*GetAllUsers/,
+          /\s+createUser(.|\n)+.*DeleteUser\n/,
         ],
         to: ''
       });

scripts/cleanup.js

@@ -0,0 +1,27 @@
+const Operation = require('src/app/Operation');
+
+class DeleteUser extends Operation {
+  constructor({ usersRepository }) {
+    super();
+    this.usersRepository = usersRepository;
+  }
+
+  async execute(userId) {
+    const { SUCCESS, ERROR, NOT_FOUND } = this.outputs;
+
+    try {
+      await this.usersRepository.remove(userId);
+      this.emit(SUCCESS);
+    } catch(error) {
+      if(error.message === 'NotFoundError') {
+        return this.emit(NOT_FOUND, error);
+      }
+
+      this.emit(ERROR, error);
+    }
+  }
+}
+
+DeleteUser.setOutputs(['SUCCESS', 'ERROR', 'NOT_FOUND']);
+
+module.exports = DeleteUser;

src/app/user/DeleteUser.js

@@ -0,0 +1,26 @@
+const Operation = require('src/app/Operation');
+
+class GetUser extends Operation {
+  constructor({ usersRepository }) {
+    super();
+    this.usersRepository = usersRepository;
+  }
+
+  async execute(userId) {
+    const { SUCCESS, NOT_FOUND } = this.outputs;
+
+    try {
+      const user = await this.usersRepository.getById(userId);
+      this.emit(SUCCESS, user);
+    } catch(error) {
+      this.emit(NOT_FOUND, {
+        type: error.message,
+        details: error.details
+      });
+    }
+  }
+}
+
+GetUser.setOutputs(['SUCCESS', 'ERROR', 'NOT_FOUND'])
+
+module.exports = GetUser;

src/app/user/GetUser.js

@@ -0,0 +1,32 @@
+const Operation = require('src/app/Operation');
+
+class UpdateUser extends Operation {
+  constructor({ usersRepository }) {
+    super();
+    this.usersRepository = usersRepository;
+  }
+
+  async execute(userId, userData) {
+    const {
+      SUCCESS, NOT_FOUND, VALIDATION_ERROR, ERROR
+    } = this.outputs;
+
+    try {
+      const user = await this.usersRepository.update(userId, userData);
+      this.emit(SUCCESS, user);
+    } catch(error) {
+      switch(error.message) {
+      case 'ValidationError':
+        return this.emit(VALIDATION_ERROR, error);
+      case 'NotFoundError':
+        return this.emit(NOT_FOUND, error);
+      default:
+        this.emit(ERROR, error);
+      }
+    }
+  }
+}
+
+UpdateUser.setOutputs(['SUCCESS', 'NOT_FOUND', 'VALIDATION_ERROR', 'ERROR']);
+
+module.exports = UpdateUser;

src/app/user/UpdateUser.js

@@ -1,4 +1,7 @@
 module.exports = {
   GetAllUsers: require('./GetAllUsers'),
-  CreateUser: require('./CreateUser')
+  CreateUser: require('./CreateUser'),
+  GetUser: require('./GetUser'),
+  UpdateUser: require('./UpdateUser'),
+  DeleteUser: require('./DeleteUser')
 };