index.js

require('dotenv').config()
const express = require('express');
const jwt = require('jsonwebtoken');
const { MongoClient, ServerApiVersion, ObjectId } = require('mongodb');
const port = process.env.PORT || 5000;
const stripe = require('stripe')(process.env.PAYMENT_SECRET_KEY);
const app = express();
const cors = require('cors');
// middleware
const corsOptions = {
    origin: '*',
    credentials: true,
    optionSuccessStatus: 200,
}

app.use(cors(corsOptions))
app.use(express.json());



///jwt token verify
const verifyJWT = (req, res, next) => {
    const authorization = req.headers.authorization;
    // console.log(authorization)
    if (!authorization) {
        return res.status(401).send({ error: true, message: 'unauthorized access' });
    }
    //bearer token
    const token = authorization.split(' ')[1];
    jwt.verify(token, process.env.ACCESS_TOKEN_SECRET, (err, decoded) => {
        if (err) {
            return res.status(401).send({ error: true, message: 'unauthorized access' });
        }
        req.decoded = decoded;
        next();
    })
}

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

// 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)

        const ClassesCollection = client.db("SportsAcademy").collection("Classes");
        const paymenstsCollection = client.db("SportsAcademy").collection("payments");
        // const paymenstsCollection=client.db
        const bookingCollection = client.db("SportsAcademy").collection("booking");
        const UserCollection = client.db("SportsAcademy").collection("users");
        const BlogsCollection = client.db("SportsAcademy").collection("blog");
        const ChoseOneCollection = client.db("SportsAcademy").collection("choseone");
        const ChoseTwoCollection = client.db("SportsAcademy").collection("chosetwo");
    
        // 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!");
        app.get('/', (req, res) => {
            res.send('Sports is Running')
        })


        //jwt token verify
        app.post('/jwt', (req, res) => {
            const user = req.body;
            const token = jwt.sign(user, process.env.ACCESS_TOKEN_SECRET, { expiresIn: '3h' })
            res.send({ token })
        })

        //popular classes api
        app.get('/popularclasses', async (req, res) => {
            const result = await ClassesCollection.find({ status: 'approved' }).sort({ students_enrolled: -1 }).limit(6).toArray()
            res.send(result)
        })

        app.get('/blog',async(req,res)=>{
            const result=await BlogsCollection.find().toArray();
            res.send(result)
        })
        app.get('/choseone',async(req,res)=>{
            const result=await ChoseOneCollection.find().toArray();
            res.send(result)
        })
        app.get('/chosetwo',async(req,res)=>{
            const result=await ChoseTwoCollection.find().toArray();
            res.send(result)
        })





        //veryfie Admin 

        const verifyAdmin = async (req, res, next) => {
            const email = req.decoded.email;
            const query = { email: email }
            const user = await UserCollection.findOne(query);
            if (user?.role !== 'admin') {
                return res.status(403).send({ error: true, message: 'forbidden message' });
            }
            next();
        }


        //stripe api payment
        app.post('/create-payment-intent', verifyJWT, async (req, res) => {
            const { price } = req.body;
            console.log("price from backend", price)
            const convert = parseFloat(price)
            const amount = parseFloat(convert * 100);
            // console.log('from after parse', amount)
            const paymentIntent = await stripe.paymentIntents.create({
                amount: amount,
                currency: 'usd',
                payment_method_types: ['card']
            });

            res.send({
                clientSecret: paymentIntent.client_secret
            })
        })
        //payments intend api
        app.post('/payment', verifyJWT, async (req, res) => {
            const payment = req.body;
            const query = { _id: new ObjectId(payment.itemsId) }
            const confirm = await bookingCollection.deleteOne(query)
            const result = await paymenstsCollection.insertOne(payment)
            res.send({ confirm, result })
        })



        //popular instructor api
        app.get('/popularinstructor', async (req, res) => {
            const result = await UserCollection.find({ role: "instructor" }).sort({ students_enrolled: -1 }).limit(6).toArray()
            res.send(result)
        })

        // collection.find({ status: 'approved' })
        app.get('/classes', async (req, res) => {
            const result = await ClassesCollection.find({ status: 'approved' }).toArray()
            res.send(result)
        })

        app.post('/booking', async (req, res) => {
            const bookings = req.body;
            const result = await bookingCollection.insertOne(bookings)
            res.send(result)

        })
        //get all users
        app.get('/users', verifyJWT, verifyAdmin, async (req, res) => {
            const result = await UserCollection.find().toArray();
            res.send(result);
        });
        //post  all users
        app.post('/users', async (req, res) => {
            const user = req.body;
            const query = { email: user.email }
            const existingUser = await UserCollection.findOne(query);
            if (existingUser) {
                return res.send({ message: 'user already exists' })
            }
            const result = await UserCollection.insertOne(user);
            // console.log(user)
            res.send(result);
        });

        // My booking Delete 
        app.delete('/bookings/:id', async (req, res) => {
            const id = req.params.id;
            const query = { _id: new ObjectId(id) }
            const result = await bookingCollection.deleteOne(query)
            res.send(result)
        })

        // post class a instructor
        app.post('/addclasses', async (req, res) => {
            const { className, classImageURL, instructorEmail, availableSeats, price, instructorName } = req.body;
            const newClass = { className, classImageURL, instructorEmail, availableSeats, price, instructorName, status: 'pending' };
            try {
                await ClassesCollection.insertOne(newClass);
                res.json({ message: 'Class added successfully and pending for approval.' });
            } catch (err) {
                // console.error(err);
                res.status(500).json({ message: 'Failed to add class.' });
            }
        });


        // Route for getting all classes
        app.get('/fullclasses', async (req, res) => {
            const result = await ClassesCollection.find().toArray()
            res.send(result)

        });

        //check admin
        app.get('/users/admin/:email', verifyJWT, async (req, res) => {
            const email = req.params.email;
            // console.log(email)
            if (req.decoded.email !== email) {
                res.send({ admin: false })
            }
            const query = { email: email }
            const user = await UserCollection.findOne(query);
            const result = { admin: user?.role === 'admin' }
            res.send(result);
        })

        // /instructor api
        app.get('/users/instructor/:email', verifyJWT, async (req, res) => {
            const email = req.params.email;
            if (req.decoded.email !== email) {
                res.send({ instructor: false })
            }
            const query = { email: email }
            const user = await UserCollection.findOne(query);
            const result = { instructor: user?.role === 'instructor' }
            res.send(result);
        })
        //get my booking api
        app.get("/mybookings/:email", async (req, res) => {
            const bookings = await bookingCollection.find({ email: req.params.email }).toArray();
            res.send(bookings);
        });

        //my payment 
        app.get("/mypayments/:email", async (req, res) => {
            const payments = await paymenstsCollection.find({ email: req.params.email }).toArray();
            res.send(payments);
        });

        //get all my class i am added
        app.get("/myclass/:email", async (req, res) => {
            // console.log('email', req.params.email)
            const Class = await ClassesCollection.find({
                instructorEmail: req.params.email
            }).toArray();
            res.send(Class);
        });

        //update  my class
        app.get("/update/:id", async (req, res) => {
            const id = req.params.id;
            const update = { _id: new ObjectId(id) }
            const result = await ClassesCollection.findOne(update)
            res.send(result)
        })


        //get payment  number api


        //update product 
        app.post("/updateclass/:id", async (req, res) => {
            const id = req.params.id;
            const body = req.body;
            const filter = { _id: new ObjectId(id) };
            const updatedclass = {
                $set: {
                    className: body.className,
                    classImageURL: body.classImageURL,
                    price: body.price,
                    availableSeats: body.availableSeats
                },
            };
            const result = await ClassesCollection.updateOne(filter, updatedclass,);
            res.send(result);
        });



        //admin api
        app.patch('/users/admin/:id', verifyJWT, async (req, res) => {
            const id = req.params.id;
            // console.log(id);
            const filter = { _id: new ObjectId(id) };
            const updateDoc = {
                $set: {
                    role: 'admin'
                },
            };
            const result = await UserCollection.updateOne(filter, updateDoc);
            res.send(result);
        })


        ///payment get api
        app.get('/payment/:id', async (req, res) => {
            const id = req.params.id;
            // console.log(id)
            const query = { _id: new ObjectId(id) }
            const result = await bookingCollection.findOne(query)
            // console.log(result)
            res.send(result)
        })



        //instructor api
        app.patch('/users/instructor/:id', verifyJWT, async (req, res) => {
            const id = req.params.id;
            // console.log(id);
            const filter = { _id: new ObjectId(id) };
            const updateDoc = {
                $set: {
                    role: 'instructor'
                },
            };
            const result = await UserCollection.updateOne(filter, updateDoc);
            res.send(result);
        })
        app.patch('/api/updatestatus/:id', async (req, res) => {
            const id = req.params.id;
            // console.log(id);
            const filter = { _id: new ObjectId(id) };
            const updateDoc = {
                $set: {
                    status: 'approved'
                },
            };
            const result = await ClassesCollection.updateOne(filter, updateDoc);
            res.send(result);
        })
        app.patch('/api/updatestatusdenied/:id', async (req, res) => {
            const id = req.params.id;
            // console.log(id);
            const filter = { _id: new ObjectId(id) };
            const updateDoc = {
                $set: {
                    status: 'denied'
                },
            };
            const result = await ClassesCollection.updateOne(filter, updateDoc);
            res.send(result);
        })
    } finally {

    }
}
run().catch(console.dir);
app.listen(port, () => {
    console.log(`Server listening on port ${port}`);
});