Hw03 mongodb

app.js

@@ -1,25 +1,31 @@
-const express = require('express')
-const logger = require('morgan')
-const cors = require('cors')
+const express = require("express");
+const logger = require("morgan");
+const cors = require("cors");
 
-const contactsRouter = require('./routes/api/contacts')
+require("dotenv").config();
 
-const app = express()
+const contactsRouter = require("./routes/api/contacts");
+const connectDB = require("./data-db");
 
-const formatsLogger = app.get('env') === 'development' ? 'dev' : 'short'
+const app = express();
 
-app.use(logger(formatsLogger))
-app.use(cors())
-app.use(express.json())
+const formatsLogger = app.get("env") === "development" ? "dev" : "short";
 
-app.use('/api/contacts', contactsRouter)
+app.use(logger(formatsLogger));
+app.use(cors());
+app.use(express.json());
+
+app.use("/api/contacts", contactsRouter);
 
 app.use((req, res) => {
-  res.status(404).json({ message: 'Not found' })
-})
+	res.status(404).json({ message: "Not found" });
+});
 
 app.use((err, req, res, next) => {
-  res.status(500).json({ message: err.message })
-})
+	const statusCode = res.statusCode === 200 ? 500 : res.statusCode;
+	res.status(statusCode).json({ message: err.message });
+});
+
+connectDB();
 
-module.exports = app
+module.exports = app;

data-db.js

@@ -0,0 +1,16 @@
+require("dotenv").config();
+
+const mongoose = require("mongoose");
+
+async function connectDB() {
+	const MONGO_URI = process.env.MONGO_URI;
+
+	await mongoose
+		.connect(MONGO_URI)
+		.then(() => console.log("Database connection successful"))
+		.catch((error) => {
+			console.error("Database connection error:", error.message);
+			process.exit(1);
+		});
+}
+module.exports = connectDB;

models/contactSchema.js

@@ -0,0 +1,22 @@
+const mongoose = require("mongoose");
+
+const contactSchema = new mongoose.Schema({
+	name: {
+		type: String,
+		required: [true, "Set name for contact"],
+	},
+	email: {
+		type: String,
+	},
+	phone: {
+		type: String,
+	},
+	favorite: {
+		type: Boolean,
+		default: false,
+	},
+});
+
+const Contact = mongoose.model("Contact", contactSchema);
+
+module.exports = Contact;

models/contacts.js

@@ -1,19 +1,92 @@
-// const fs = require('fs/promises')
+const Contact = require("./contactSchema.js");
 
-const listContacts = async () => {}
+async function listContacts() {
+	try {
+		const contacts = await Contact.find();
+		return contacts;
+	} catch (error) {
+		console.error("Błąd podczas pobierania kontaktów:", error.message);
+		throw error;
+	}
+}
+
+async function getContactById(id) {
+	try {
+		const contact = await Contact.findById(id);
+		if (!contact) {
+			return null;
+		}
+		return contact;
+	} catch (error) {
+		console.error("Błąd podczas pobierania kontaktu:", error.message);
+	}
+}
+
+async function removeContact(id) {
+	try {
+		const deleted = await Contact.findByIdAndDelete(id);
+		if (!deleted) {
+			return null;
+		}
+		return `Usunięto kontakt: ${deleted}`;
+	} catch (error) {
+		console.error("Błąd podczas usuwania kontaktu:", error.message);
+	}
+}
 
-const getContactById = async (contactId) => {}
+async function addContact(newContactData) {
+	try {
+		const newContact = await Contact.create(newContactData);
+		return `Dodano nowy kontakt: ${newContact}`;
+	} catch (error) {
+		console.error("Błąd podczas tworzenia kontaktu:", error.message);
+	}
+}
 
-const removeContact = async (contactId) => {}
+async function updateContact(id, updateFields) {
+	try {
+		const contactExists = await Contact.findById(id);
+		if (!contactExists) {
+			return null;
+		}
+		const updatedContact = await Contact.findByIdAndUpdate(
+			id,
+			updateFields,
+			{ new: true, runValidators: true }
+		);
+		return `Zaktualizowano kontakt: ${updatedContact}`;
+	} catch (error) {
+		console.error("Błąd podczas aktualizacji kontaktu:", error.message);
+	}
+}
 
-const addContact = async (body) => {}
+async function updateStatusContact(id, favorite) {
+	try {
+		const contactExists = await Contact.findById(id);
+		if (!contactExists) {
+			return null;
+		}
 
-const updateContact = async (contactId, body) => {}
+		const updatedContact = await Contact.findByIdAndUpdate(
+			id,
+			{ favorite },
+			{ new: true, runValidators: true }
+		);
 
-module.exports = {
-  listContacts,
-  getContactById,
-  removeContact,
-  addContact,
-  updateContact,
+		return `Zaktualizowano status kontaktu: ${updatedContact}`;
+	} catch (error) {
+		console.error(
+			"Błąd podczas aktualizacji statusu kontaktu:",
+			error.message
+		);
+	}
 }
+
+module.exports = {
+	addContact,
+	listContacts,
+	getContactById,
+	updateContact,
+	removeContact,
+	updateStatusContact,
+};

models/validation.js

@@ -0,0 +1,9 @@
+const Joi = require("joi");
+
+const contactSchema = Joi.object({
+	name: Joi.string().min(3).max(30).required(),
+	email: Joi.string().email().required(),
+	phone: Joi.string().min(10).max(15).required(),
+});
+
+module.exports = { contactSchema };