Added passport for signup

1 files changed, 402 insertions, 243 deletions

diff --git a/node_simple.js b/node_simple.js
index 5f91c0e..1c34590 100644
--- a/node_simple.js
+++ b/node_simple.js
@@ -1,27 +1,30 @@
 // a simple node driver to interact with mongo database
 
 /* TO DO:
-* 1. get all exams given course code -- order by year desc ? DONE
-* 1B. get the title of the course ? DONE
-* 2. add upload date and user name  ? DONE
-* 3. remove exam ? DONE
-* 4a. get all questions for a given exam_id ? PENDING
-* 4b. add exam id to each question returned. ? PENDING
-* 6. get all solutions provided question_id and exam_id ? PENDING
-* 5. answers ? CURRENTLY WORKING ON -- need to add field for solutions provider, and updating.
-* 7. ....TBD
-* */
+ * 1. get all exams given course code -- order by year desc ? DONE
+ * 1B. get the title of the course ? DONE
+ * 2. add upload date and user name  ? DONE
+ * 3. remove exam ? DONE
+ * 4a. get all questions for a given exam_id ? DONE
+ * 4b. add exam id to each question returned. ? PENDING
+ * 6. get all solutions provided question_id and exam_id ? DONE
+ * 5. solutions ? CURRENTLY WORKING ON -- need to add field for solutions provider, and updating.
+ * 7. add university field to courses, exams ? PENDING
+ * 8. make a user ? DONE
+ * 9.
+ * */
 
 
 /* I pass in exam id and you give me the number of questions and the comments and solutions associated with each question?*/
 
 /* Tables SO FAR:
-* 1. exams
-* 2. courses
-* 3. solutions
-* 4.
-*
-* */
+ * 1. exams
+ * 2. courses
+ * 3. solutions
+ * 4. users
+ * 5. logins
+ *
+ * */
 
 /*Tables schema SO FAR:*/
 // |======================================================exams==================================================================================|
@@ -44,6 +47,18 @@
 // |"354ff71ed078933079d6467e"|"578a44ff71ed097fc3079d6e"  |1    |"answer"| 1   |[{},{}] |
 // |..........|
 
+// |========================================users===============================================================================|
+// |_______ _id_________|email_________|user_name__|f_name__|l_name__|uni___|departm.|answered|messeges|comments|phone|followers|
+// |====================|==============|===========|========|========|======|========|========|========|========|=====|=========|
+// |"3.....efsdfsdf...."|blah@blah.com |"some_user"|"f.name"|"l.name"|"uofT"|CS      |40      |30      |15      |() - |[{},{}]  |
+// |..........|
+
+// |====================================login===================================|
+// |_________ _id_____________|email____________|user_name|pass_________________|
+// |==========================|=================|=========|=====================|
+// |"askjdfklajsdf..........."|"asdf@asdf.com   |"asdfasd"|(some hasehd thing)  |
+// |..........|
+
 var exports = module.exports = {};
 
 const debug_mode = false;
@@ -55,8 +70,10 @@ var ObjectId = require('mongodb').ObjectID;
 var assert = require('assert');
 
 // Standard URI format: mongodb://[dbuser:dbpassword@]host:port/dbname
-//var uri = 'mongodb://general:assignment4@ds057862.mlab.com:57862/solutions_repo';
-var uri = 'mongodb://localhost:27017/db';
+var uri = 'mongodb://general:assignment4@ds057862.mlab.com:57862/solutions_repo';
+
+// Keep this for testing on local machine, do not remove. - Humair
+//var uri = 'mongodb://localhost:27017/db';
 
 
 //***********************PRELIMINARY TESTING******************************************|
@@ -67,6 +84,137 @@ var uri = 'mongodb://localhost:27017/db';
 
 
 
+/*
+ * This function creates and adds a user to users table.
+ * IFF both the email and the user_name are not in the database already.
+ * If either of them exist, the user is NOT added.
+ * Params: fields - [email, user_name, f_name, l_name, uni, department, password, phone_num]
+ * */
+exports.add_user = function (fields, callbackUser) {
+    console.log("inside add_user");
+    // create a user object
+    var user_data = {
+        email: fields[0],
+        user_name: fields[1],
+        f_name: fields[2],
+        l_name: fields[3],
+        university: fields[4],
+        department: fields[5],
+        answered: 0,
+        messages: 0,
+        comments: 0,
+        phone_num: fields[7],
+        followers: []
+    };
+
+    var login_data = {
+        email: fields[0],
+        user_name: fields[1],
+        password: fields[6]
+    };
+
+    // find out if this user already exists by checking their email
+    exports.find_user( fields[0] ,callbackUser,  function (result) {
+        console.log("inside find_user");
+        if  (result == false) {
+            console.log("no such user found");
+
+            // find out if the user_name is taken
+            exports.find_user_name( fields[1], callbackUser,  function (docs) {
+                if (docs == false) {        // if not ...
+                    // continue
+                    console.log("user name is valid");
+
+                    // when both are valid add the user to the users and logins table
+                    mongoFactory.getConnection(uri)
+                        .then(function (db) {
+
+                            var users = db.collection('users');
+                            var logins = db.collection('logins');
+
+                            users.insertOne( user_data, function (err) {
+                                if (err) callbackUser(false, true, "Unable to add user.");
+                                else {
+                                    console.log("user has been added to users");
+                                    callbackUser(true, false, "User has been added.");
+                                }
+                            });
+
+                            logins.insertOne( login_data, function (err) {
+                                if (err) callbackUser(false, true, "Login has not been added.");
+                                else{
+                                    callbackUser(true, false,  "Login added.");
+                                }
+                            });
+
+                            db.close();
+                        })
+                        .catch(function (err) {
+                            callbackUser(false, true,  "Unable to connect.");
+                        })
+                }
+                else {
+                    callbackUser(false, false, "Username is taken.");
+                }
+            });
+        }
+        else {
+            callbackUser(false, false, "User with this email already exists.");
+        }
+    });
+};
+
+/*
+ * This (helper) function returns true IFF user_name already exists in the database
+ * Params: user_name - the user name
+ * */
+exports.find_user_name = function (user_name, callbackUser, callback) {
+    // make a connection
+    mongoFactory.getConnection(uri)
+        .then(function (db) {
+
+            var logins = db.collection('logins');
+            logins.find( { user_name: user_name } ).toArray(function (err, result) {
+                if (err) throw err;
+                else if (result.length == 0) {  // nothing was found  so this user is new
+                    callback(false);
+                }
+                else {
+                    callback(true);
+                }
+            });
+            // db.close();
+        })
+        .catch(function (err) {
+            console.err(err);
+        })
+};
+
+/*
+ * This (helper) function returns true IFF email already exists in the database
+ * */
+exports.find_user = function (email, callbackUser, callback) {
+    // make a connection
+    mongoFactory.getConnection(uri)
+        .then(function (db) {
+
+            var logins = db.collection('logins');
+            logins.find( { email: email } ).toArray(function (err, result) {
+                if (err) throw err;
+                else if (result.length == 0) {  // nothing was found  so this user is new
+                    callback(false, callbackUser);
+                }
+                else {
+                    callback(true, callbackUser);
+                }
+            });
+            // db.close();
+        })
+        .catch(function (err) {
+            console.err(err);
+        })
+};
+
 
 // this function returns an array where is element contains info for a particular question
 // such as the question number (_id), number of solutions (count), and number of comments
@@ -102,7 +250,7 @@ exports.get_exam_info_by_ID = function (exam_id, callback) {
                     }
 
 
-            ]).toArray(function (err, result) {
+                ]).toArray(function (err, result) {
                 // console.log(result);
                 callback(result);
 
@@ -112,15 +260,19 @@ exports.get_exam_info_by_ID = function (exam_id, callback) {
             console.err(err);
         })
 
-}
-
+};
 
 
+/*
+ * This function will add a comment to the solutions table
+ * Params: sol_id - id of the solution to which to add the comment
+ *         fields - [text, by]
+ * */
 exports.add_comment = function (sol_id, fields) {
     var Data = {
         text: fields[0],
-        date: fields[1],
-        by: fields[2]
+        date: new Date(),
+        by: fields[1]
     };
 
     mongoFactory.getConnection(uri)
@@ -140,7 +292,9 @@ exports.add_comment = function (sol_id, fields) {
         .catch(function (err) {
             console.error(err);
         })
-}
+};
+
+
 
 // get all solutions given an exam_id and the question number
 exports.get_all_solutions = function (exam_id, q_num, callback) {
@@ -166,11 +320,11 @@ exports.get_all_solutions = function (exam_id, q_num, callback) {
 
         })
         .catch(function () {
-          console.error(err);
+            console.error(err);
         })
 
 
-}
+};
 
 /*
  * This function will add a solution to the solutions table in the database .
@@ -209,7 +363,7 @@ exports.add_solution = function (fields) {
             console.error(err);
         });
 
-}
+};
 
 
 
@@ -220,174 +374,180 @@ exports.add_solution = function (fields) {
  * */
 exports.get_all_exams = function (course_code, callback) {
 
-  // get a connection
-  mongoFactory.getConnection(uri)
-      .then(function(db) {
+    // get a connection
+    mongoFactory.getConnection(uri)
+        .then(function(db) {
 
-        // get the exams table
-        var exam_collection = db.collection('exams');
+            // get the exams table
+            var exam_collection = db.collection('exams');
 
-        // search exams table with given course code
-        exam_collection.find(
-            { course_code: course_code }
-        ).sort({ year: -1}).toArray( function (err, docs) {   // order by year
-          if (err) throw err;
+            // search exams table with given course code
+            exam_collection.find(
+                { course_code: course_code }
+            ).sort({ year: -1}).toArray( function (err, docs) {   // order by year
+                if (err) throw err;
 
-          else {    // get the title
-            exports.find_course(course_code, function (result, data) {
+                else {    // get the title
+                    exports.find_course(course_code, function (result, data) {
 
-              if (result == true) {
-                // append the title from data to each exam object from docs
-                docs.forEach(function (doc) {
-                  doc.title = data[0].title;
-                });
+                        if (result == true) {
+                            // append the title from data to each exam object from docs
+                            docs.forEach(function (doc) {
+                                doc.title = data[0].title;
+                            });
 
-                if (debug_mode == true){
-                  console.log(docs);
-                  console.log(data);
-                }
-                /*callback(docs);     // send back the data*/
-              }
-              else if (result == false) {    // no such course was found
-                console.log("This course has not been added to the database.");
-              }
-              callback(docs);     // send back the data
+                            if (debug_mode == true){
+                                console.log(docs);
+                                console.log(data);
+                            }
+                            /*callback(docs);     // send back the data*/
+                        }
+                        else if (result == false) {    // no such course was found
+                            console.log("This course has not been added to the database.");
+                        }
+                        callback(docs);     // send back the data
 
+                    });
+                }
             });
-          }
+        })
+        .catch(function(err) {
+            console.error(err);
         });
-      })
-      .catch(function(err) {
-        console.error(err);
-      });
-
-}
-
 
+};
 
 /*
-* This function will add an exam to the database UNLESS the exams already exists.
-* If the exams table is empty, this will create one and then add the data.
-* Note: this assumes that (course_code + year + term + type) together form a unique exam.
-* i.e there can't be two exams occurring for the same course in the same year in the same term with the same type.
-* Params: fields - an array of format ["course_code", year, "term",
-*                 ["instructor1",...,"instructor n"], page_count, question_count
-*                 "upload_date", "user_name"]
-*         questions_array - a array by format ["q_1", "q_2", ... , "q_question_count"]
-* */
-exports.add_exam = function (fields, questions_array) {
-
-   // construct an exam object
-   var Data =
-   {
-     course_code: fields[0],
-     year: fields[1],
-     term: fields[2],
-     type: fields[3],
-     instructors: fields[4],
-     page_count: fields[5],
-     questions_count: fields[6],
-     questions_list: [],
-     upload_date: fields[7],
-     uploaded_by: fields[8]
-   };
-
-   // create the questions objects
-   for (var i = 1; i <= Data.questions_count; i++) {
-     Data.questions_list.push(
-        {
-          q_id: i,
-          question: questions_array[i - 1]
-        }
-     );
-   }
-
-  // first see if the exam already exists
-  // pass in course_code, year, term and type...
-  exports.find_exam([fields[0], fields[1], fields[2], fields[3]], function(result) {
+ * This function will add an exam to the database UNLESS the exams already exists.
+ * If the exams table is empty, this will create one and then add the data.
+ * Note: this assumes that (course_code + year + term + type) together form a unique exam.
+ * i.e there can't be two exams occurring for the same course in the same year in the same term with the same type.
+ * Params: fields - an array of format ["course_code", year, "term",
+ *                 ["instructor1",...,"instructor n"], page_count, question_count
+ *                 "upload_date", "user_name"]
+ *         questions_array - a array by format ["q_1", "q_2", ... , "q_question_count"]
+ *
+ * callback parameter takes a boolean to indicate whether insert was successful
+ * and an output status message.*/
+exports.add_exam = function (fields, questions_array, serverCallback) {
+
+    // construct an exam object
+    var Data =
+    {
+        course_code: fields[0],
+        year: fields[1],
+        term: fields[2],
+        type: fields[3],
+        instructors: fields[4],
+        page_count: fields[5],
+        questions_count: fields[6],
+        questions_list: [],
+        upload_date: fields[7],
+        uploaded_by: fields[8]
+    };
 
-    if (result == true) {     // meaning that the exam was found
-      console.log("This exam already exists in the database");
+    // create the questions objects
+    for (var i = 1; i <= Data.questions_count; i++) {
+        Data.questions_list.push(
+            {
+                q_id: i,
+                question: questions_array[i - 1]
+            }
+        );
     }
 
-    else {    // add Data to the database
-      // make a connection
-      mongoFactory.getConnection(uri)
-          .then(function(db) {
+    // first see if the exam already exists
+    // pass in course_code, year, term and type...
+    exports.find_exam([fields[0], fields[1], fields[2], fields[3]], serverCallback, function(result, serverCallback) {
 
-            // find the exams table
-            var exam_collection = db.collection('exams');
-            // insert data into table
-            exam_collection.insert(Data, function(err) {
-              if (err) throw err;
-              else {
-                console.log("exam added");
-                db.close(function (err) {   // close the connection when done
-                  if (err) throw err;
+        if (result == true) {     // meaning that the exam was found
+            serverCallback(false, "This exam already exists in the database.");
+            console.log("This exam already exists in the database");
+        }
+
+        else {    // add Data to the database
+            // make a connection
+            mongoFactory.getConnection(uri)
+                .then(function(db) {
+
+                    // find the exams table
+                    var exam_collection = db.collection('exams');
+                    // insert data into table
+                    exam_collection.insert(Data, function(err) {
+                        if (err) {
+                            serverCallback(false, "Error: Could not add exam into database.");
+                            throw err;
+                        }
+                        else {
+                            console.log("exam added");
+                            serverCallback(true, "Exam Successfully added.");
+                            db.close(function (err) {   // close the connection when done
+                                if (err) throw err;
+                            });
+                        }
+                    });
+                })
+                .catch(function(err) {
+                    serverCallback(false, "Error: Could not establish connection with database.");
+                    console.error(err);
                 });
-              }
-            });
-          })
-          .catch(function(err) {
-            console.error(err);
-          });
-    }
-  });
-}
+        }
+    });
+};
 
 
 /*
-* This function will return TRUE if the provided exam info already exists in the database
-* OR FALSE if it does not exist in the database.
-* Params: fields - an array of format ["course_code", year, "term", "type"]
-*
-* */
-exports.find_exam = function (fields, callback) {
-
-  var course_code = fields[0];
-  var year = fields[1];
-  var term = fields[2];
-  var type = fields[3];
-
-  // console.log(Data);
-
-  // check the data to see if this exam exists...
-
-  // first make a connection
-  mongoFactory.getConnection(uri)
-    .then(function(db) {
-
-      // fetch the exams table
-      var exams = db.collection('exams');
-
-      // look for the exam
-      exams.find(
-          {
-            course_code: course_code,
-            year: year,
-            term: term,
-            type: type
-          }
-      ).toArray(function (err, docs) {
-        if (err) throw err;
-
-        if (docs.length == 0) { // if this exam doesnt exist.... add it
-          callback(false);
-        }
-        else {  // exam was found
-          callback(true);
-        }
-      });
+ * This function will return TRUE if the provided exam info already exists in the database
+ * OR FALSE if it does not exist in the database.
+ * Params: fields - an array of format ["course_code", year, "term", "type"]
+ *
+ * */
+exports.find_exam = function (fields, serverCallback, callback) {
+
+    var course_code = fields[0];
+    var year = fields[1];
+    var term = fields[2];
+    var type = fields[3];
 
-/*      db.close(function (err) {
-        if (err) throw err;
-      });*/
+    // console.log(Data);
 
-    })
-    .catch(function(err) {
-      console.error(err);
-    });
-}
+    // check the data to see if this exam exists...
+
+    // first make a connection
+    mongoFactory.getConnection(uri)
+        .then(function(db) {
+
+            // fetch the exams table
+            var exams = db.collection('exams');
+
+            // look for the exam
+            exams.find(
+                {
+                    course_code: course_code,
+                    year: year,
+                    term: term,
+                    type: type
+                }
+            ).toArray(function (err, docs) {
+                if (err) throw err;
+
+                if (docs.length == 0) { // if this exam doesnt exist.... add it
+                    callback(false, serverCallback);
+                }
+                else {  // exam was found
+                    callback(true, serverCallback);
+                }
+            });
+
+            /*      db.close(function (err) {
+             if (err) throw err;
+             });*/
+
+        })
+        .catch(function(err) {
+            console.error(err);
+        });
+};
 
 
 /*
@@ -399,39 +559,39 @@ exports.find_exam = function (fields, callback) {
  * */
 exports.add_course = function (course_code, title) {
 
-  var courseData = {
-    course_code: course_code,
-    title: title
-  };
-
-  exports.find_course(course_code, function (result) {
+    var courseData = {
+        course_code: course_code,
+        title: title
+    };
 
-    if (result == true){
-      console.log("course already exists");
-    }
-    else if (result == false) {    // add it
-      mongoFactory.getConnection(uri)
-          .then(function(db) {
+    exports.find_course(course_code, function (result) {
 
-            // find the exams table
-            var courses = db.collection('courses');
-            // insert data into table
-            courses.insert(courseData, function(err) {
-              if (err) throw err;
-              else {
-                console.log("couse added");
-                db.close(function (err) {   // close the connection when done
-                  if (err) throw err;
+        if (result == true){
+            console.log("course already exists");
+        }
+        else if (result == false) {    // add it
+            mongoFactory.getConnection(uri)
+                .then(function(db) {
+
+                    // find the exams table
+                    var courses = db.collection('courses');
+                    // insert data into table
+                    courses.insert(courseData, function(err) {
+                        if (err) throw err;
+                        else {
+                            console.log("couse added");
+                            db.close(function (err) {   // close the connection when done
+                                if (err) throw err;
+                            });
+                        }
+                    });
+                })
+                .catch(function(err) {
+                    console.error(err);
                 });
-              }
-            });
-          })
-          .catch(function(err) {
-            console.error(err);
-          });
-    }
-  });
-}
+        }
+    });
+};
 
 
 /*
@@ -441,38 +601,38 @@ exports.add_course = function (course_code, title) {
  *
  * */
 exports.find_course = function (course_code, callback) {
-  // check the data to see if this exam exists...
-
-  // first make a connection
-  mongoFactory.getConnection(uri)
-      .then(function(db) {
-
-        // fetch the courses table
-        var courses = db.collection('courses');
-
-        // look for the courses
-        courses.find(
-            { course_code: course_code }
-        ).toArray(function (err, docs) {
-          if (err) throw err;
-
-          if (docs.length == 0) { // if this course doesnt exist.... add it
-            callback(false);
-          }
-          else {  // course was found
-            callback(true, docs);
-          }
-        });
+    // check the data to see if this exam exists...
+
+    // first make a connection
+    mongoFactory.getConnection(uri)
+        .then(function(db) {
 
-/*              db.close(function (err) {
-         if (err) throw err;
-         });*/
+            // fetch the courses table
+            var courses = db.collection('courses');
+
+            // look for the courses
+            courses.find(
+                { course_code: course_code }
+            ).toArray(function (err, docs) {
+                if (err) throw err;
+
+                if (docs.length == 0) { // if this course doesnt exist.... add it
+                    callback(false);
+                }
+                else {  // course was found
+                    callback(true, docs);
+                }
+            });
+
+            /*              db.close(function (err) {
+             if (err) throw err;
+             });*/
 
-      })
-      .catch(function(err) {
-        console.error(err);
-      });
-}
+        })
+        .catch(function(err) {
+            console.error(err);
+        });
+};
 
 
 /*
@@ -517,7 +677,7 @@ exports.remove_exam = function (fields) {
         .catch(function(err) {
             console.error(err);
         });
-}
+};
 
 
 //get_exam_byID("578a44ff71ed097fc3079d6e");
@@ -542,15 +702,13 @@ exports.get_exam_byID = function (id) {
         .catch(function(err) {
             console.error(err);
         });
-}
+};
 
-/*    IGNORE BELOW *********************************************************************************
 
-
- /*
+/*
  * userObj = {fs: fs, ls: ls, email: email, username: username, pass_hash: pass_hash, univ: univ, dept: dept}
  *
- * */
+ *
 exports.addUser = function (userObj) {
     mongoFactory.getConnection(uri)
         .then(function(db) {
@@ -561,12 +719,13 @@ exports.addUser = function (userObj) {
             });
 
         });
-}
+} */
+
 
 
-exports.findUser = function ()
+/*    IGNORE BELOW *********************************************************************************
+
 
-ONLY FOR SYNTAX REFERENCE
 
  /!*
  * Then we need to give Boyz II Men credit for their contribution