Week 18: mongoDB API

package.json

@@ -13,8 +13,13 @@
     "@babel/node": "^7.16.8",
     "@babel/preset-env": "^7.16.11",
     "cors": "^2.8.5",
+    "dotenv": "^16.4.7",
     "express": "^4.17.3",
+    "express-list-endpoints": "^7.1.1",
     "mongoose": "^8.0.0",
     "nodemon": "^3.0.1"
+  },
+  "devDependencies": {
+    "@types/node": "^22.10.2"
   }
-}
+}

server.js

@@ -1,35 +1,113 @@
 import express from "express";
 import cors from "cors";
 import mongoose from "mongoose";
+import avocadoSalesData from "./data/avocado-sales.json";
+import dotenv from "dotenv";
+
+dotenv.config();
+
+const MONGO_URL = process.env.MONGODB_URI || "mongodb://127.0.0.1/project-mongo";
+
+// Connect to MongoDB
+mongoose
+  .connect(MONGO_URL, { useNewUrlParser: true, useUnifiedTopology: true })
+  .then(() => console.log("🚀 MongoDB successfully connected!"))
+  .catch((error) => console.error("Error connecting to MongoDB:", error));
+
+// Define Mongoose model
+const AvocadoSale = mongoose.model(
+  "AvocadoSale",
+  new mongoose.Schema({
+    id: Number,
+    date: String,
+    averagePrice: Number,
+    totalVolume: Number,
+    totalBagsSold: Number,
+    smallBagsSold: Number,
+    largeBagsSold: Number,
+    xLargeBagsSold: Number,
+    region: String,
+  }),
+  "avocados"
+);
 
-// If you're using one of our datasets, uncomment the appropriate import below
-// to get started!
-// import avocadoSalesData from "./data/avocado-sales.json";
-// import booksData from "./data/books.json";
-// import goldenGlobesData from "./data/golden-globes.json";
-// import netflixData from "./data/netflix-titles.json";
-// import topMusicData from "./data/top-music.json";
-
-const mongoUrl = process.env.MONGO_URL || "mongodb://localhost/project-mongo";
-mongoose.connect(mongoUrl);
-mongoose.Promise = Promise;
-
-// Defines the port the app will run on. Defaults to 8080, but can be overridden
-// when starting the server. Example command to overwrite PORT env variable value:
-// PORT=9000 npm start
-const port = process.env.PORT || 8080;
 const app = express();
+const port = process.env.PORT || 8080;
+
+// Seed the database if RESET_DB is set
+if (process.env.RESET_DB) {
+  const seedDatabase = async () => {
+    console.log("Resetting database...");
+    await AvocadoSale.deleteMany({});
+    const inserted = await AvocadoSale.insertMany(avocadoSalesData);
+    console.log(`✅ Database seeded with ${inserted.length} entries!`);
+  };
+  seedDatabase();
+}
 
-// Add middlewares to enable cors and json body parsing
 app.use(cors());
 app.use(express.json());
 
-// Start defining your routes here
+// Root endpoint
 app.get("/", (req, res) => {
-  res.send("Hello Technigo!");
+  res.json({
+    message: "Welcome to the Avocado Sales API!",
+    endpoints: [
+      { method: "GET", path: "/avocado-sales", description: "Get all sales or filter data" },
+      { method: "GET", path: "/avocado-sales/:id", description: "Get a single sale by ID" },
+    ],
+  });
+});
+
+// Endpoint to get all sales or filter data
+app.get("/avocado-sales", async (req, res) => {
+  const { region, date, min, max } = req.query;
+  const query = {};
+
+  // Build the query object based on the filters
+  if (region) query.region = new RegExp(region, "i");
+  if (date) query.date = date;
+  if (min || max) {
+    query.averagePrice = {};
+    if (min) query.averagePrice.$gte = Number(min);
+    if (max) query.averagePrice.$lte = Number(max);
+  }
+
+  console.log("Filters applied:", query); // Debugging log
+
+  try {
+    const sales = await AvocadoSale.find(query);
+    console.log("Sales found:", sales.length); // Debugging log
+
+    if (sales.length === 0) {
+      return res.status(404).json({
+        error: "No sales data found with the provided filters.",
+        filters: query,
+      });
+    }
+    res.json(sales);
+  } catch (error) {
+    console.error("Error retrieving sales data:", error);
+    res.status(500).json({ error: "Internal Server Error" });
+  }
+});
+
+// Endpoint to get a single sale by ID
+app.get("/avocado-sales/:id", async (req, res) => {
+  const { id } = req.params;
+  try {
+    const sale = await AvocadoSale.findOne({ id: Number(id) });
+    if (!sale) {
+      return res.status(404).json({ error: "No sales data found for the given ID." });
+    }
+    res.json(sale);
+  } catch (error) {
+    console.error("Error retrieving sale by ID:", error);
+    res.status(500).json({ error: "Internal Server Error" });
+  }
 });
 
 // Start the server
 app.listen(port, () => {
-  console.log(`Server running on http://localhost:${port}`);
+  console.log(`🚀 Server running on http://localhost:${port}`);
 });