Basic implementation of a CRUD server with mongodb

server/db.js

@@ -0,0 +1,30 @@
+const MongoClient = require('mongodb').MongoClient
+
+const mongo_url = process.env.MONGO || 'mongodb:https://localhost:27017/db'
+
+let client = null
+let db = null
+
+module.exports = () => {
+ if (!client || !db) {
+ throw new Error('Database connection has not been initialized.')
+ }
+ return db
+}
+
+module.exports.init = () => {
+ client = new MongoClient(mongo_url, {
+ useNewUrlParser: true
+ })
+ return new Promise((res, rej) => {
+ client.connect(function(err) {
+ if (err) {
+ rej(err)
+ return
+ }
+ db = client.db('bob')
+ res(db)
+ //console.log(`Initialized database connection on ${mongo_url}.`)
+ })
+ })
+}

server/index.js

@@ -1,11 +1,64 @@
+const bodyParser = require('body-parser')
 const express = require('express')
+const db = require('./db')
+const model = require('./model')
 
-const PORT = process.argv[2] || 9000
+const PORT = process.env.PORT || 9000
+
+db.init()
+ .then(db => console.log('Initialized database connection.'))
+ .catch(err => console.error('Error initializing database connection.', err))
 
 const app = express()
 
-app.get('/', (req, res) => {
- res.send('Hello World!')
+app.use(bodyParser.json())
+
+//Logs all requests.
+app.use((req, res, next) => {
+ console.log(`${req.ip}: ${req.method} ${req.originalUrl}`)
+ next()
+})
+
+app.get('/order', (req, res, next) =>
+ model
+ .getAllOrders()
+ .then(orders => {
+ if (orders) res.json({ success: true, orders })
+ else res.status(404).json({ success: false, orders: null })
+ })
+ .catch(next)
+)
+
+app.get('/order/:orderId', (req, res, next) => {
+ const orderId = req.params.orderId
+ model
+ .getOrderById(orderId)
+ .then(order => {
+ if (order) res.json({ success: true, order })
+ else res.status(404).json({ success: true, order: null })
+ })
+ .catch(next)
+})
+
+app.post('/order', (req, res, next) => {
+ //verification steps?
+ model
+ .addOrder(req.body)
+ .then(order => res.json({ success: true, order }))
+ .catch(next)
+})
+
+//Logs all responses.
+app.use((req, res, next) => {
+ console.log(`${req.ip}: ${req.method} ${req.originalUrl} response: ${res.body}`)
+ next()
+})
+
+//Logs errors and responds properly.
+app.use((err, req, res, next) => {
+ console.error(err.stack)
+ res.status(500).json({ success: false, error: err.stack })
+ next()
 })
 
 app.listen(PORT, () => console.log(`Listening on port ${PORT}.`))

server/model.js

@@ -0,0 +1,36 @@
+const db = require('./db')
+const assert = require('assert')
+const ObjectID = require('mongodb').ObjectID
+const factory = db => ({
+ getAllOrders: () =>
+ new Promise((res, rej) => {
+ db()
+ .collection('orders')
+ .find({})
+ .toArray((err, docs) => {
+ err ? rej(err) : res(docs)
+ })
+ }),
+ getOrderById: orderId =>
+ new Promise((res, rej) => {
+ db()
+ .collection('orders')
+ .find({ _id: new ObjectID(orderId) })
+ .toArray((err, docs) => {
+ err ? rej(err) : res(docs[0])
+ })
+ }),
+
+ addOrder: orderData =>
+ new Promise((res, rej) => {
+ db()
+ .collection('orders')
+ .insertOne(orderData, (err, order) => {
+ err ? rej(err) : res(orderData)
+ })
+ })
+})
+
+module.exports = factory(db)
+
+module.exports.factory = factory

server/package.json

@@ -4,8 +4,8 @@
  "description": "",
  "main": "index.js",
  "scripts": {
- "start": "PORT=9000 node index.js",
- "dev": "PORT=9000 nodemon index.js",
+ "start": "node index.js",
+ "dev": "nodemon index.js",
  "test": "jest"
  },
  "repository": {