const express = require("express");
const { MongoClient, ObjectId } = require("mongodb");
const cors = require("cors");

const app = express();
app.use(express.json());
app.use(cors());

const url = "mongodb://localhost:27017";
const client = new MongoClient(url);

let users;

async function connectDB() {
  await client.connect();
  const db = client.db("kamludb");
  users = db.collection("users");
  console.log("MongoDB Connected");
}

connectDB();


// CREATE
app.post("/users", async (req, res) => {
  const result = await users.insertOne(req.body);
  res.send(result);
});

// READ
app.get("/users", async (req, res) => {
  const data = await users.find().toArray();
  res.send(data);
});


// UPDATE
app.put("/users/:id", async (req, res) => {
  const id = req.params.id;
  const result = await users.updateOne(
    { _id: new ObjectId(id) },
    { $set: req.body }
  );
  res.send(result);
});

// DELETE
app.delete("/users/:id", async (req, res) => {
  const id = req.params.id;
  const result = await users.deleteOne({ _id: new ObjectId(id) });
  res.send(result);
});

app.listen(3000, () => {
  console.log("Server running on port 3000");
});