candidates.js

import db from "./mongodbconn.js";
import express from "express";
import { ObjectId } from "mongodb";

const router = express.Router();
let index = 5;

router.get("/", async (req, res) => {
  let collection = await db.collection("candidates");
  let query = {
    ...(req.query.fname ? { fname: req.query.fname } : {}),
    ...(req.query.lname ? { lname: req.query.lname } : {}),
    ...(req.query.email ? { email: req.query.email } : {}),
  };
  let results = await collection.find(query).limit(50).toArray();

  res.send(results).status(200);
});

router.get("/:id", async (req, res) => {
  let collection = await db.collection("candidates");
  let query = { id: parseInt(req.params.id) };
  let result = await collection.findOne(query);

  if (!result) res.send("Not found").status(404);
  else res.send(result).status(200);
});

router.post("/", async (req, res) => {
  let collection = await db.collection("candidates");
  let newDocument = {
    id: index++,
    fname: req.body.fname,
    lname: req.body.lname,
    email: req.body.email,
    score: req.body.score,
  };
  let result = await collection.insertOne(newDocument);
  res.send(newDocument).status(204);
});

router.put("/:id", async (req, res) => {
  const query = { id: parseInt(req.params.id) };
  const updates = {
    $set: {
      fname: req.body.fname,
      lname: req.body.lname,
      email: req.body.email,
      score: req.body.score,
    },
  };

  let collection = await db.collection("candidates");
  let result = await collection.updateOne(query, updates);
  res.send(result).status(200);
});

router.delete("/:id", async (req, res) => {
  const query = { id: parseInt(req.params.id) };

  const collection = db.collection("candidates");
  let result = await collection.deleteOne(query);

  res.send(result).status(200);
});

export default router;