Merge pull request #149 from Vikrantsingh22/123-create_add_endpoint_for_infrastructure

#123 feat: Add infrastructure route, controller, model, and service files

Author: Hitansh159

app.js

@@ -8,6 +8,7 @@ import { logger } from "#util";
 import indexRouter from "#routes/index";
 import usersRouter from "#routes/users";
 import authRouter from "#routes/auth";
+import infrastructureRouter from "#routes/infrastructure";
 
 const app = express();
 const currDirName = dirname(fileURLToPath(import.meta.url));
@@ -26,5 +27,6 @@ app.use(express.static(path.join(currDirName, "public")));
 app.use("/", indexRouter);
 app.use("/users", usersRouter);
 app.use("/auth", authRouter);
+app.use("/infrastructure", infrastructureRouter);
 
 export default app;

controller/infrastructure.js

@@ -0,0 +1,18 @@
+import { createinfrastructure } from "#services/infrastructure";
+import { logger } from "#util";
+
+async function addinfrastructure(req, res) {
+  const {
+    name, type, wing, floor, capacity,
+  } = req.body;
+  try {
+    const newinfrastructure = await createinfrastructure(name, type, wing, floor, capacity);
+    res.json({ res: `added user ${newinfrastructure.id}` });
+  } catch (error) {
+    logger.error("Error while inserting", error);
+    res.status(500);
+    res.json({ err: "Error while inserting in DB" });
+  }
+}
+
+export default { addinfrastructure };

models/infrastructure.js

@@ -0,0 +1,42 @@
+import connector from "#models/databaseUtil";
+
+const infrastructureSchema = {
+  name: { type: String, required: true },
+  type: { type: String, required: true },
+  wing: { type: String, required: true },
+  floor: { type: Number, required: true },
+  capacity: { type: Number, required: true },
+};
+
+const Infrastructure = connector.model("Infrastructure", infrastructureSchema);
+
+async function remove(filter) {
+  const res = await Infrastructure.findOneAndDelete(filter);
+  return res;
+}
+
+async function create(name, type, wing, floor, capacity) {
+  const infrastructure = new Infrastructure({
+    name,
+    type,
+    wing,
+    floor,
+    capacity,
+  });
+  const infrastructureDoc = await infrastructure.save();
+  return infrastructureDoc;
+}
+
+async function read(filter, limit = 1) {
+  const infrastructureData = await Infrastructure.find(filter).limit(limit);
+  return infrastructureData;
+}
+
+async function update(filter, updateObject) {
+  const infrastructure = await Infrastructure.findOneAndUpdate(filter, updateObject, { new: true });
+  return infrastructure;
+}
+
+export default {
+  create, read, update, remove,
+};

routes/infrastructure.js

@@ -0,0 +1,7 @@
+import express from "express";
+import infrastructureController from "#controller/infrastructure";
+
+const router = express.Router();
+router.post("/add", infrastructureController.addinfrastructure);
+
+export default router;

services/infrastructure.js

@@ -0,0 +1,10 @@
+import infrastructure from "#models/infrastructure";
+import databaseError from "#error/database";
+
+export async function createinfrastructure(name, type, wing, floor, capacity) {
+  const newinfrastructure = await infrastructure.create(name, type, wing, floor, capacity);
+  if (newinfrastructure.name === name) {
+    return newinfrastructure;
+  }
+  throw new databaseError.DataEntryError("infrastructure");
+}