✨ feat: user registration implemented

Author: badriysha

migrations/1626445730031_create-table-users.js

@@ -0,0 +1,26 @@
+/* eslint-disable camelcase */
+exports.up = pgm => {
+    pgm.createTable('users', {
+        id: {
+            type: 'VARCHAR(50)',
+            prrimaryKey: true,
+        },
+        username: {
+            type: 'VARCHAR(50)',
+            unique: true,
+            notNull: true,
+        },
+        password: {
+            type: 'TEXT',
+            notNull: true,
+        },
+        fullname: {
+            type: 'TEXT',
+            notNull: true,
+        },
+    });
+};
+
+exports.down = pgm => {
+    pgm.dropTable('users');
+};

src/api/users/handler.js

@@ -0,0 +1,83 @@
+const ClientError = require('../../exceptions/ClientError');
+
+class UsersHandler {
+    constructor(service, validator) {
+        this._service = service;
+        this._validator = validator;
+
+        // Bind This
+        this.postUsersHandler = this.postUsersHandler.bind(this);
+        this.getUserByIdHandler = this.getUserByIdHandler.bind(this);
+    }
+
+    async postUsersHandler(request, h) {
+        try {
+            this._validator.validateUserPayload(request.payload);
+
+            const  { username, password, fullname } = request.payload;
+
+            const userId = await this._service.addUser({ username, password, fullname });
+            const response = h.response({
+                status: 'success',
+                message: 'User berhasil ditambahkan',
+                data: {
+                    userId,
+                },
+            });
+            response.code(201);
+            return response;
+        } catch (error) {
+            if (error instanceof ClientError) {
+                const response = h.response({
+                    status: 'fail',
+                    message: error.message,
+                });
+                response.code(error.statusCode);
+                return response;
+            }
+
+            // error Server!
+            const response = h.response({
+                status: 'error',
+                message: 'Maaf, terjadi kesalahan pada server kami.',
+            });
+            response.code(500);
+            console.error(error)
+            return response;
+        }
+    }
+
+    async getUserByIdHandler(request, h) {
+        try {
+            const { id } = request.params;
+            const user = await this._service.getUserById(id);
+
+            return {
+                status: 'success',
+                data: {
+                    user,
+                },
+            };
+        } catch (error) {
+            if (error instanceof ClientError) {
+                const response = h.response({
+                    status: 'fail',
+                    message: error.message,
+                });
+                response.code(error.statusCode);
+                return response;
+            }
+
+            // error Server!
+            const response = h.response({
+                status: 'error',
+                message: 'Maaf, terjadi kesalahan pada server kami.',
+            });
+            response.code(500);
+            console.error(error)
+            return response;
+        }
+    }
+}
+
+module.exports = UsersHandler;

src/api/users/index.js

@@ -0,0 +1,12 @@
+const UsersHandler = require('./handler');
+const routes = require('./routes');
+
+
+module.exports = {
+    name: 'users',
+    version: '1.0.0',
+    register: async (server, { service, validator }) => {
+        const usersHandler = new UsersHandler(service, validator);
+        server.route(routes(usersHandler));
+    },
+};

src/api/users/routes.js

@@ -0,0 +1,14 @@
+const routes = (handler) => [
+    {
+        method: 'POST',
+        path: '/users',
+        handler: handler.postUsersHandler,
+    },
+    {
+        method: 'GET',
+        path: '/users/{id}',
+        handler: handler.getUserByIdHandler,
+    },
+];
+
+module.exports = routes;

src/server.js

@@ -1,12 +1,21 @@
 require('dotenv').config();
 
 const Hapi = require('@hapi/hapi');
+
+// notes
 const notes = require('./api/notes');
 const NotesService = require('./services/postgres/NotesService');
 const NotesValidator = require('./validator/notes');
 
+// users
+const users = require('./api/users');
+const UsersService = require('./services/postgres/UsersService');
+const UsersValidator = require('./validator/users');
+
 const init = async () => {
   const notesService = new NotesService();
+  const usersService = new UsersService();
+
   const server = Hapi.server({
     port: process.env.PORT,
     host: process.env.HOST,
@@ -17,13 +26,22 @@ const init = async () => {
     },
   });
 
-  await server.register({
-    plugin: notes,
-    options: {
-      service: notesService,
-      validator: NotesValidator,
-    }
-  });
+  await server.register([
+    {
+      plugin: notes,
+      options: {
+        service: notesService,
+        validator: NotesValidator,
+      },
+    },
+    {
+      plugin: users,
+      options: {
+        service: usersService,
+        validator: UsersValidator,
+      },
+    },
+  ]);
 
   await server.start();
   console.log(`Server berjalan pada ${server.info.uri}`);

src/services/postgres/UsersService.js

@@ -0,0 +1,60 @@
+const { Pool } = require('pg');
+const { nanoid } = require('nanoid');
+const bcrypt = require('bcrypt');
+
+const InvariantError = require('../../exceptions/InvariantError');
+const NotFoundError = require('../../exceptions/NotFoundError');
+
+class UsersService {
+    constructor() {
+        this._pool = new Pool();
+    }
+
+    async addUser({ username, password, fullname }) {
+        // TODO: Verifikasi username, pastikan belum terdaftar.
+        await this.verifyNewUsername(username);
+
+        // TODO: Bila verifikasi lolos, masukan user ke database.
+        const id = `user-${nanoid(16)}`;
+        const hashedPassword = await bcrypt.hash('password', 10);
+        const query = {
+            text: 'INSERT INTO users VALUES($1, $2, $3, $4) RETURNING id',
+            values: [id, username, hashedPassword, fullname],
+        };
+
+        const result = await this._pool.query(query);
+        if (result.rows.length < 0) {
+            throw new InvariantError('User gagal ditambahkan');
+        }
+
+        return result.rows[0].id;
+    }
+
+    async getUserById(userId) {
+        const query = {
+            text: 'SELECT id, username, fullname FROM users WHERE id = $1',
+            values: [userId],
+        };
+
+        const result = await this._pool.query(query);
+        if (!result.rows.length) {
+            throw new NotFoundError('User tidak ditemukan');
+        }
+
+        return result.rows[0];
+    }
+
+    async verifyNewUsername(username) {
+        const query = {
+            text: 'SELECT username FROM users WHERE username = $1',
+            values: [username],
+        };
+
+        const result = await this._pool.query(query);
+        if (result.rows.length > 0) {
+            throw new InvariantError('Gagal menambahkan user. Username sudah digunakan.');
+        }
+    }
+}
+
+module.exports = UsersService;

src/validator/users/index.js

@@ -0,0 +1,13 @@
+const InvariantError = require('../../exceptions/InvariantError');
+const { userPayloadSchema } = require('./schema');
+
+const UsersValidator = {
+    validateUserPayload: (payload) => {
+        const validationResult = userPayloadSchema.validate(payload);
+        if (validationResult.error) {
+            throw new InvariantError(validationResult.error.message)
+        }
+    },
+};
+
+module.exports = UsersValidator;

src/validator/users/schema.js

@@ -0,0 +1,9 @@
+const Joi = require('joi');
+
+const userPayloadSchema = Joi.object({
+    username: Joi.string().required(),
+    password: Joi.string().required(),
+    fullname: Joi.string().required(),
+});
+
+module.exports = { userPayloadSchema };