index.js

const express = require("express");
const cors = require("cors");
const { MongoClient, ServerApiVersion, ObjectId } = require("mongodb");
require("dotenv").config();

const app = express();
const port = process.env.PORT || 5000;

// middleware
app.use(express.json());
app.use(cors());

const uri = `mongodb+srv://${process.env.DB_USER}:${process.env.DB_PASS}@cluster0.9crls8f.mongodb.net/?retryWrites=true&w=majority&appName=Cluster0`;

// Create a MongoClient with a MongoClientOptions object to set the Stable API version
const client = new MongoClient(uri, {
    serverApi: {
        version: ServerApiVersion.v1,
        strict: true,
        deprecationErrors: true,
    }
});

async function run() {
    try {
        // Connect the client to the server	(optional starting in v4.7)
        // await client.connect();

        const servicesCollection = client.db("homeRepairServiceDB").collection("services");
        const bookedServicesCollection = client.db("homeRepairServiceDB").collection("bookedServices");

        // Fetch services
        app.get("/services", async (req, res) => {
            const result = await servicesCollection.find().toArray();
            res.send(result);
        });

        // Add a new service
        app.post("/add-service", async (req, res) => {
            const serviceData = req.body;
            const result = await servicesCollection.insertOne(serviceData);
            res.send(result);
        });

        // Fetch services by id
        app.get("/services/:id", async (req, res) => {
            const result = await servicesCollection.findOne({ _id: new ObjectId(req.params.id) });
            res.send(result);
        });

        // Fetch services by email
        app.get("/services/provider/:email", async (req, res) => {
            const email = req.params.email;
            const services = await servicesCollection.find({ providerEmail: email }).toArray();
            res.send(services);
        });

        // Update service
        app.put("/update-service/:id", async (req, res) => {
            const query = { _id: new ObjectId(req.params.id) };
            const options = { upsert: true };

            const data = {
                $set: {
                    serviceName: req.body.serviceName,
                    price: req.body.price,
                    serviceArea: req.body.serviceArea,
                    description: req.body.description,
                }
            };

            const result = await servicesCollection.updateOne(query, data, options);
            res.send(result);
        });

        // Delete service
        app.delete("/services/:id", async (req, res) => {
            const id = req.params.id;
            const result = await servicesCollection.deleteOne({ _id: new ObjectId(id) });

            if (result.deletedCount === 1) {
                res.send(result);
            }
        });

        // Book a service
        app.post("/book-service", async (req, res) => {
            const serviceData = req.body;
            const result = await bookedServicesCollection.insertOne(serviceData);
            res.send(result);
        });

        // Fetch booked services by user email
        app.get("/booked-services/:email", async (req, res) => {
            const email = req.params.email;
            const bookedServices = await bookedServicesCollection.find({ userEmail: email }).toArray();
            res.send(bookedServices);
        });

        // Fetch booked services by provider email
        app.get("/booked-services/provider/:email", async (req, res) => {
            const email = req.params.email;
            const bookedServices = await bookedServicesCollection.find({ providerEmail: email }).toArray();
            res.send(bookedServices);
        });

        // Update booked service status
        app.put("/booked-services/:id/update-status", async (req, res) => {
            const id = req.params.id;
            const result = await bookedServicesCollection.updateOne(
                { _id: new ObjectId(id) },
                { $set: { status: req.body.status } }
            );
            res.send(result);
        });

        // Send a ping to confirm a successful connection
        // await client.db("admin").command({ ping: 1 });
        console.log("Pinged your deployment. You successfully connected to MongoDB!");
    } finally {
        // Ensures that the client will close when you finish/error
        // await client.close();
    }
}
run().catch(console.dir);

app.get("/", (req, res) => {
    res.send("Server is running...");
});

app.listen(port, () => {
    console.log(`Server is running on port ${port}`);
});