server.js

#!/usr/bin/env node

'use strict'

const restClient = require('request-promise')
const express = require('express')
const morgan = require('morgan')
const _ = require('underscore')
const bodyParser = require('body-parser')
const session = require('express-session')
const moment = require('moment')
const Q = require('q')
const bluebird = require('bluebird')
const Await = require('asyncawait/await')
const Async = require('asyncawait/async')
const mongodb = require('mongodb')
const gju = require('geojson-utils')
const nodemailer = require('nodemailer')


module.exports = (() => {

    const serviceURL = '/mydata'
    const dbName = 'databaseName'
    const defaultDBConnection = `mongodb://localhost/${dbName}`
    const mongoCollectionName = 'collectionName'

    let mongoClient = bluebird.promisifyAll(mongodb).MongoClient;

    let port = process.env.PORT || 5000

    let app = express()

    let dbURI = process.env.MONGODB_URI || defaultDBConnection
    let db

    console.log('dbURI', dbURI)
    mongoClient.connect(dbURI)
        .then(ddb => {
            console.log('connected to mongo')
            db = ddb
        })
        .catch(er => {
            console.log('error connecting to mongo', er)
        })

    app.use(function(req, res, next) {
        res.header("Access-Control-Allow-Origin", "*");
        res.header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept, contentType");
        res.header("Access-Control-Allow-Methods", "POST, GET, OPTIONS, PUT, DELETE");
        next();
    });

    app.use(express.static('.'))
    app.use(bodyParser.json())
    app.use(bodyParser.urlencoded({
        extended: true
    }))

    let getData = (req, res) => {
        db.collection(mongoCollectionName)
            .find({})
            .sort({
                dateTime: -1
            })
            .limit(1)
            .toArray()
            .then(queryResult => {
                if (!queryResult || queryResult.length <= 0) {
                    res.status(404).json({
                        "result": "no data for you"
                    })
                } else {
                    res.json({
                        data: queryResult
                    })
                }
            })
            .catch(err => {
                console.log("error", err)
                res.status(500).json({
                    "error": err
                })
            })
    }


    let setData = (req, res) => {
        console.log('body ', req.body);
        if (!req.body) {
            console.log('body is missing')
            res.status(500).json({
                "error": "missing body"
            })
            return false
        }

        req.body.dateTime = moment().toDate()
        db.collection(mongoCollectionName).insertOne(req.body)
            .then((insertResult) => {
                res.status(201).json({
                    "insertResult": insertResult
                })
            })
            .catch((er) => {
                console.log('error on insert', er)
                res.status(500).json({
                    "error": er
                })
            })
    }

    app.post(serviceURL, setData)
    app.get(serviceURL, getData)

    app.listen(port, '0.0.0.0', () => {
        console.log(`listening on ${port}`)
    })

})()