-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
77 lines (65 loc) · 2.2 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
const express = require("express");
const app = express();
const port = process.env.PORT || 5000;
const { MongoClient, ServerApiVersion, ObjectId } = require("mongodb");
// Middleware
const cors = require("cors");
app.use(express.json());
app.use(cors());
require("dotenv").config();
app.get("/", (req, res) => {
res.send("Ema-John server is Running.....");
});
const uri = `mongodb+srv://${process.env.DB_User}:${process.env.DB_Password}@cluster0.joz6qi9.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)
// await client.connect();
client.connect();
const productCollection = client.db("EmaJohnDB").collection("products");
app.get("/products", async (req, res) => {
const page = parseInt(req.query.page) || 0;
const limit = parseInt(req.query.limit) || 10;
const skip = page * limit;
const result = await productCollection
.find()
.skip(skip)
.limit(limit)
.toArray();
res.send(result);
});
app.get("/totalProducts", async (req, res) => {
const result = await productCollection.estimatedDocumentCount();
res.send({ totalProduct: result });
});
app.post("/productsByIds", async (req, res) => {
console.log("api hitting..");
const ids = req.body;
const objectIds = ids.map(id => new ObjectId(id))
console.log(ids);
const query = { _id: { $in: objectIds } };
const result = await productCollection.find(query).toArray();
res.send(result);
});
// 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!"
);
} finally {
// Ensures that the client will close when you finish/error
// await client.close();
}
}
run().catch(console.dir);
app.listen(port, () => {
console.log("The Server is running on port", port);
});