Initial push of files to repo from local machine

Author: waffelhaus92

dal.js

@@ -0,0 +1,78 @@
+const MongoClient = require('mongodb').MongoClient;
+const url = 'mongodb://localhost:27017';
+let db = null;
+
+// connect to mongo
+MongoClient.connect(url, { useUnifiedTopology: true }, function (err, client) {
+    console.log("Connected successfully to db server");
+
+    // connect to myproject database
+    db = client.db('myproject');
+});
+
+// create user account using the collection.insertOne function
+function create(name, email, password) {
+    return new  Promise((resolve, reject) => {
+        const collection = db.collection('users');
+        const doc = { name, email, password, balance: 0 };
+        collection.insertOne(doc, {w:1}, function(err, result) {
+            err ? reject(err) : resolve(doc);
+        });
+    })
+}
+
+// find user account 
+function find(email) {
+    return new Promise((resolve, reject) => {
+        const customers = db
+            .collection('users')
+            .find({ email: email })
+            .toArray(function (err, docs) {
+                err ? reject(err) : resolve(docs);
+            });
+    })
+}
+
+// find user account
+function findOne(email) {
+    return new Promise((resolve, reject) => {
+        const customers = db
+            .collection('users')
+            .findOne({ email: email })
+            .then((doc) => resolve(doc))
+            .catch((err) => reject(err));
+    })
+}
+
+// update - deposit/withdraw amount
+function update(email, amount) {
+    return new Promise((resolve, reject) => {
+        const customers = db
+            .collection('users')
+            .findOneAndUpdate(
+                { email: email },
+                { $inc: { balance: amount } },
+                { returnOriginal: false },
+                function (err, documents) {
+                    err ? reject(err) : resolve(documents);
+                }
+            );
+
+
+    });
+}
+
+// return all users by using the collection.find method
+function all(){
+    return new Promise((resolve, reject) => {
+        const customers = db
+        .collection('users')
+        .find({})
+        .toArray(function(err, docs) {
+            err ? reject(err) : resolve(docs);
+        });
+    })
+}
+
+
+module.exports = { create, findOne, find, update, all };

index.js

@@ -0,0 +1,103 @@
+var express = require('express');
+var app     = express();
+var cors    = require('cors');
+var dal     = require('./dal.js');
+const e = require('express');
+
+// used to serve static files from public directory
+app.use(express.static('public'));
+app.use(cors());
+
+// create user account
+app.get('/account/create/:name/:email/:password', function (req, res) {
+
+    // check if account exists
+    dal.find(req.params.email).
+        then((users) => {
+
+            // if user exists, return error message
+            if(users.length > 0){
+                console.log('User already in exists');
+                res.send('User already in exists');    
+            }
+            else{
+                // else create user
+                dal.create(req.params.name,req.params.email,req.params.password).
+                    then((user) => {
+                        console.log(user);
+                        res.send(user);            
+                    });            
+            }
+
+        });
+});
+
+
+// login user 
+app.get('/account/login/:email/:password', function (req, res) {
+
+    dal.find(req.params.email).
+        then((user) => {
+
+            // if user exists, check password
+            if(user.length > 0){
+                if (user[0].password === req.params.password){
+                    res.send(user[0]);
+                }
+                else{
+                    res.send('Login failed: wrong password');
+                }
+            }
+            else{
+                res.send('Login failed: user not found');
+            }
+    });
+    
+});
+
+// find user account
+app.get('/account/find/:email', function (req, res) {
+
+    dal.find(req.params.email).
+        then((user) => {
+            console.log(user);
+            res.send(user);
+    });
+});
+
+// find one user by email - alternative to find
+app.get('/account/findOne/:email', function (req, res) {
+
+    dal.findOne(req.params.email).
+        then((user) => {
+            console.log(user);
+            res.send(user);
+    });
+});
+
+
+// update - deposit/withdraw amount
+app.get('/account/update/:email/:amount', function (req, res) {
+
+    var amount = Number(req.params.amount);
+
+    dal.update(req.params.email, amount).
+        then((response) => {
+            console.log(response);
+            res.send(response);
+    });    
+});
+
+// all accounts
+app.get('/account/all', function (req, res) {
+
+    dal.all().
+        then((docs) => {
+            console.log(docs);
+            res.send(docs);
+    });
+});
+
+var port = 3000;
+app.listen(port);
+console.log('Running on port: ' + port);

mongo_test.js

@@ -0,0 +1,33 @@
+const MongoClient = require('mongodb').MongoClient;
+const url = 'mongodb://localhost:27017';
+ 
+// connect to mongo
+MongoClient.connect(url, {useUnifiedTopology: true}, function(err, client) {
+  console.log("Connected successfully to server");
+
+    // database Name
+    const dbName = 'myproject';
+    const db = client.db(dbName);
+
+    // new user
+    var name = 'user' + Math.floor(Math.random()*10000);
+    var email = name + '@mit.edu';
+
+    // insert into customer table
+    var collection = db.collection('customers');
+    var doc = {name, email};
+    collection.insertOne(doc, {w:1}, function(err, result) {
+        console.log('Document insert');
+    });
+
+    var customers = db
+        .collection('customers')
+        .find()
+        .toArray(function(err, docs) {
+            console.log('Collection:',docs);
+
+            // clean up
+            client.close();            
+    });    
+
+});