test

src/controller/expenses.controller.js

@@ -0,0 +1,120 @@
+const expensesServices = require('../services/expenses.services');
+const usersService = require('../services/users.services');
+
+async function getExpenses(req, res) {
+  const { userId, categories, from, to } = req.query;
+
+  const expenses = await expensesServices.getExpenses({
+    userId: +userId,
+    categories,
+    from,
+    to,
+  });
+
+  res.send(expenses.map(expensesServices.normalize));
+}
+
+async function getExpenseById(req, res) {
+  const { id } = req.params;
+
+  if (!id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const expense = await expensesServices.getExpenseById(+id);
+
+  if (!expense) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.send(expensesServices.normalize(expense));
+}
+
+async function createExpense(req, res) {
+  const { userId, spentAt, title, amount, category, note } = req.body;
+
+  if (
+    userId == null ||
+    !spentAt ||
+    !title ||
+    amount == null ||
+    isNaN(+amount)
+  ) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const userExist = await usersService.getUserById(+userId);
+
+  if (!userExist) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const newExpense = await expensesServices.createExpense({
+    userId: +userId,
+    spentAt,
+    title,
+    amount,
+    category: category || '',
+    note: note || '',
+  });
+
+  res.status(201).send(expensesServices.normalize(newExpense));
+}
+
+async function deleteExpense(req, res) {
+  const { id } = req.params;
+
+  if (!id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const wasDeleted = await expensesServices.deleteExpense(+id);
+
+  if (!wasDeleted) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.status(204).send();
+}
+
+async function updateExpense(req, res) {
+  const { id } = req.params;
+
+  if (!id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const expenseExist = await expensesServices.getExpenseById(+id);
+
+  if (!expenseExist) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+
+  const { spentAt, title, amount, category, note } = req.body;
+
+  if (
+    spentAt === undefined &&
+    title === undefined &&
+    amount === undefined &&
+    category === undefined &&
+    note === undefined
+  ) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const updatedExpense = await expensesServices.updateExpense({
+    id: +id,
+    ...req.body,
+  });
+
+  if (!updatedExpense) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.send(expensesServices.normalize(updatedExpense));
+}
+
+module.exports = {
+  getExpenses,
+  getExpenseById,
+  createExpense,
+  deleteExpense,
+  updateExpense,
+};

src/controller/users.controller.js

@@ -0,0 +1,73 @@
+const usersService = require('../services/users.services');
+
+async function getUsers(req, res) {
+  const users = await usersService.getUsers();
+
+  res.send(users.map(usersService.normalize));
+}
+
+async function getUserById(req, res) {
+  const { id } = req.params;
+
+  if (!id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const user = await usersService.getUserById(+id);
+
+  if (!user) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.send(usersService.normalize(user));
+}
+
+async function createUser(req, res) {
+  const { name } = req.body;
+
+  if (!name) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const newUser = await usersService.createUser(name);
+
+  res.status(201).send(usersService.normalize(newUser));
+}
+
+async function deleteUser(req, res) {
+  const { id } = req.params;
+
+  if (!id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const wasDeleted = await usersService.deleteUser(+id);
+
+  if (!wasDeleted) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.status(204).send();
+}
+
+async function updateUser(req, res) {
+  const { id } = req.params;
+  const { name } = req.body;
+
+  if (!name || !id || isNaN(+id)) {
+    return res.status(400).json({ message: 'Bad Request' });
+  }
+
+  const updatedUser = await usersService.updateUser({ id: +id, name });
+
+  if (!updatedUser) {
+    return res.status(404).json({ message: 'Not found' });
+  }
+  res.send(usersService.normalize(updatedUser));
+}
+
+module.exports = {
+  getUsers,
+  getUserById,
+  createUser,
+  deleteUser,
+  updateUser,
+};

src/createServer.js

@@ -1,7 +1,35 @@
 'use strict';
 
+const express = require('express');
+const { usersRouter } = require('./routers/users.router');
+const cors = require('cors');
+const { expensesRouter } = require('./routers/expenses.router');
+const { User } = require('./models/User.model');
+const { Expense } = require('./models/Expense.model');
+const { sequelize } = require('./db.js');
 const createServer = () => {
-  // your code goes here
+  const syncDb = async () => {
+    try {
+      await sequelize.authenticate();
+      await User.sync();
+      await Expense.sync();
+    } catch (error) {
+      // eslint-disable-next-line no-console
+      console.error('DB sync failed:', error);
+    }
+  };
+
+  syncDb();
+
+  const app = express();
+
+  app.use(cors());
+  app.use(express.json());
+
+  app.use('/users', usersRouter);
+  app.use('/expenses', expensesRouter);
+
+  return app;
 };
 
 module.exports = {

src/db.js

@@ -21,12 +21,12 @@ const {
 */
 
 const sequelize = new Sequelize({
-  database: POSTGRES_DB || 'postgres',
+  database: POSTGRES_DB || 'test',
   username: POSTGRES_USER || 'postgres',
   host: POSTGRES_HOST || 'localhost',
   dialect: 'postgres',
   port: POSTGRES_PORT || 5432,
-  password: POSTGRES_PASSWORD || '123',
+  password: POSTGRES_PASSWORD || 'password',
 });
 
 module.exports = {

src/models/Expense.model.js

@@ -1,9 +1,38 @@
 'use strict';
 
+const { DataTypes } = require('sequelize');
 const { sequelize } = require('../db.js');
 
 const Expense = sequelize.define(
-  // your code goes here
+  'Expense',
+  {
+    userId: {
+      type: DataTypes.INTEGER,
+      allowNull: false,
+    },
+    spentAt: {
+      type: DataTypes.DATE,
+      allowNull: false,
+    },
+    title: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    amount: {
+      type: DataTypes.INTEGER,
+      allowNull: false,
+    },
+    category: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+    note: {
+      type: DataTypes.STRING,
+    },
+  },
+  {
+    tableName: 'expenses',
+  },
 );
 
 module.exports = {

src/models/User.model.js

@@ -1,9 +1,19 @@
 'use strict';
 
+const { DataTypes } = require('sequelize');
 const { sequelize } = require('../db.js');
 
 const User = sequelize.define(
-  // your code goes here
+  'User',
+  {
+    name: {
+      type: DataTypes.STRING,
+      allowNull: false,
+    },
+  },
+  {
+    tableName: 'users',
+  },
 );
 
 module.exports = {

src/routers/expenses.router.js

@@ -0,0 +1,15 @@
+const expensesController = require('../controller/expenses.controller');
+
+const Router = require('express').Router;
+
+const expensesRouter = Router();
+
+expensesRouter.get('/', expensesController.getExpenses);
+expensesRouter.get('/:id', expensesController.getExpenseById);
+expensesRouter.post('/', expensesController.createExpense);
+expensesRouter.delete('/:id', expensesController.deleteExpense);
+expensesRouter.patch('/:id', expensesController.updateExpense);
+
+module.exports = {
+  expensesRouter,
+};

src/routers/users.router.js

@@ -0,0 +1,15 @@
+const usersController = require('../controller/users.controller');
+
+const Router = require('express').Router;
+
+const usersRouter = Router();
+
+usersRouter.get('/', usersController.getUsers);
+usersRouter.get('/:id', usersController.getUserById);
+usersRouter.post('/', usersController.createUser);
+usersRouter.delete('/:id', usersController.deleteUser);
+usersRouter.patch('/:id', usersController.updateUser);
+
+module.exports = {
+  usersRouter,
+};