first commit from project setup

Author: frckbrice

.gitignore

@@ -0,0 +1,2 @@
+node_modules
+.env

database-access/db-connection.js

@@ -0,0 +1,31 @@
+const MongoClient = require("mongodb").MongoClient;
+module.exports = {
+
+    connection: async () => {
+        // The MongoClient is the object that references the connection to our
+        // datastore (Atlas, for example)
+        const client = new MongoClient(process.env.DB_URI);
+
+        // The connect() method does not attempt a connection; instead it instructs
+        // the driver to connect using the settings provided when a connection
+        // is required.
+        try {
+            await client.connect();
+        } catch (err) {
+            console.log("error connecting to database", err);
+        }
+
+        // Provide the name of the database and collection you want to use.
+        // If the database and/or collection do not exist, the driver and Atlas
+        // will create them automatically when you first write data.
+        const datastoreName = "digital-market-place-updates";
+
+
+        // Create references to the database and collection in order to run
+        // operations on them.
+        const database = client.db(datastoreName);
+        // const userCollection = database.collection("users");
+
+        return database;
+    }
+}

database-access/index.js

@@ -0,0 +1,6 @@
+const dbConnection = require("./db-connection");
+const makeUserdb = require("./store-user")
+
+const userUseCase = makeUserdb({dbConnection});
+
+module.exports = userUseCase;

database-access/store-user.js

@@ -0,0 +1,57 @@
+
+
+module.exports = async function makeUser({ dbConnection }) {
+
+
+    return Object.freeze({
+        findAllUsers,
+        findUserById,
+        createUser,
+        updateUser,
+        deleteUser
+    })
+
+
+    async function findAllUsers() {
+        const db = await dbConnection()
+        const result = await db.collection('comments').find({})
+        return (await result.toArray()).map(({ _id: id, ...found }) => ({
+            id,
+            ...found
+        }))
+    }
+
+    async function findUserById() {
+        const db = await dbConnection()
+        const result = await db.collection('comments').find({ _id })
+        const found = await result.toArray()
+        if (found.length === 0) {
+            return null
+        }
+        const { _id: id, ...info } = found[0]
+        return { id, ...info }
+    }
+
+    async function createUser({ id: _id = Id.makeId(), ...userData }) {
+        const db = await dbConnection()
+        const result = await db
+            .collection('comments')
+            .insertOne({ _id, ...userData })
+        const { _id: id, ...insertedInfo } = result.ops[0]
+        return { id, ...insertedInfo }
+    }
+
+    async function updateUser({ id: _id, userData }) {
+        const db = await dbConnection()
+        const result = await db
+            .collection('comments')
+            .updateOne({ _id }, { $set: { ...userData } })
+        return result.modifiedCount > 0 ? { id: _id, ...userData } : null
+    }
+
+    async function deleteUser({ id: _id }) {
+        const db = await dbConnection()
+        const result = await db.collection('comments').deleteOne({ _id })
+        return result.deletedCount
+    }
+}

index.js

@@ -0,0 +1,40 @@
+
+
+const express = require('express');
+require('dotenv').config();
+const cors = require('cors');
+const { connection } = require('./database-access/db-connection.js');
+
+connection().then((db) => {
+    console.log("database connected: ", db.databaseName);
+})
+
+const app = express();
+
+const PORT = process.env.PORT || 5000;
+
+app.use(cors());
+app.use(express.json());
+app.use(express.urlencoded({extended: false}));
+
+
+
+app.use('/', (req, res) => {
+    res.send('hello world');
+});
+
+app.use((req, res, next) => {
+  const dntHeader = req.headers['dnt']; // Access DNT header (if present)
+  if (dntHeader === '1') {
+    console.log('User has DNT enabled');
+    // Implement logic to handle DNT preference (e.g., disable tracking features)
+  }
+  next(); // Pass control to the next middleware or route handler
+});
+
+
+
+
+app.listen(PORT, () => console.log(`Server started on port http://localhost:${PORT}`));
+
+module.exports = app;

package.json

@@ -0,0 +1,26 @@
+{
+  "name": "digital-market-place-updates",
+  "version": "1.0.0",
+  "description": "to sell products and services",
+  "main": "index.js",
+   "license": "ISC",
+  "author": {
+    "name": "avom brice ",
+    "address": "frckbrice <bricefrkc@gmail,com> (https://maebrie.vercel.app)",
+    "date": "jun 12 2024"
+  },
+  "scripts": {
+    "start": "node index.js",
+    "dev": "nodemon index.js"
+  },
+  "dependencies": {
+    "bcrypt": "^5.1.1",
+    "cors": "^2.8.5",
+    "cuid": "^3.0.0",
+    "dotenv": "^16.4.5",
+    "express": "^4.19.2",
+    "mongodb": "^6.7.0",
+    "nodemon": "^3.1.3",
+    "sanitize-html": "^2.13.0"
+  }
+}