twilio added

server/db/dbUtil.js

@@ -3,18 +3,26 @@ const MongoClient = require('mongodb').MongoClient;
 const dbConfig = require('./config/config');
 let callback, db;
 // exporting the mongo
-MongoClient.connect(dbConfig.dbUrl.remoteUrl,{ useNewUrlParser: true }, function(err, client){
- if(err) {
-  console.log(err);
-  throw err;
- }
+mongo = {
+connect: (callback)=> {
+ if(!db) MongoClient.connect(dbConfig.dbUrl.remoteUrl,{ useNewUrlParser: true }, function(err, client){
+
+
  console.log('Mongodb connected');
  db = client.db(dbConfig.dbName);
-
-
- client.close();
+ // client.close();
+ 
+ callback(err, mongo.getDb()); // db will be passed in the argument of call back
  });
+ else {
+ callback(null, mongo.getDb());
+ }
+},
+getDb: function(){
 
-module.exports = function(){
+ console.log('returned db is '+db);
  return db;
-}
+}
+
+}
+module.exports = mongo;

server/db/services/user.service.js

@@ -1,32 +1,51 @@
 // import db module
-let db = require('../dbUtil');
-console.log(db());
+let mongo = require('../dbUtil');
+let coll;
+mongo.connect((err, db)=>{
+ if(err) {
+ console.log(err);
+ throw err;
+}
+coll = db.collection('users');
+});
+
+// user services
+// var Promise = require('promise');
 let service = {};
-// let coll = db.collection('users');
 
 let ifRegistered = (user)=>{
- coll.find({user}).toArray(function(err, data) {
- if (err) {
- console.log(err);
- return false;
- } 
- else {
- console.log('user is registered');
- return true;
- }
- });
-}
-let createUser = ()=>{
- coll.insert(user,function(err, data) {
- if (err) {
- console.log(err);
- return false;
- } 
- else {
- console.log('user inserted');
- return true; 
+
+ return new Promise((resolve, reject)=>{
+
+ coll.find({mobile: user.mobile}).toArray(function(err, data) {
+ if (err) 
+ reject(err);
+ else {
+ if(data.length == 0) {
+ reject('User not found');
+
  }
- });
+ else
+ resolve(data);console.log();
+ }
+ });
+
+});
+
+};
+let createUser = (user)=>{
+
+ return new Promise((resolve, reject)=>{
+
+ coll.insert(user, function(err, data) {
+ if (err) {
+ reject(err);
+ } else {
+ resolve(data);
+ }
+ });
+
+});
 }
 // export service
 service.ifRegistered = ifRegistered;