alex_app1/app.js

/**
 * Module dependencies.
 */
var fs = require('fs');
var path = require('path');
//var mongo = require('mongodb');
var async = require('async');
var mongo = require('mongoskin');
var BSON = mongo.BSONPure;
var db = mongo.db('localhost:27017/test');
var testcollection = db.collection('testcollection');
var exercisecollection = db.collection('exercisecollection');
var util = require('util');
//var extname;
var app = require('http').createServer(function handler(request, response) {


console.log('request starting...;' + request.url);

  switch(request.url) {

     case '/admin':
            filePath = './admin.html';

        extname = path.extname(filePath);
        contentType = 'text/html';
        switch (extname) {
            case '.js':
                contentType = 'text/javascript';
                break;
            case '.css':
                contentType = 'text/css';
                break;
        }
        path.exists(filePath, function(exists) {

            if (exists) {
                fs.readFile(filePath, function(error, content) {
                    if (error) {
                        response.writeHead(500);
                        response.end();
                    }
                    else {
                        response.writeHead(200, { 'Content-Type': contentType });
                        response.end(content, 'utf-8');
                    }
                });
            }
            else {
                response.writeHead(404);
                response.end();
            }
        });
     break;
    case '/placeholder':
        break;
 //  default case
     default:
        var filePath = '.' + request.url;
        if (filePath == './')
            filePath = './index.html';

        extname = path.extname(filePath);
        contentType = 'text/html';
        switch (extname) {
            case '.js':
                contentType = 'text/javascript';
                break;
            case '.css':
                contentType = 'text/css';
                break;
        }
        path.exists(filePath, function(exists) {

            if (exists) {
                fs.readFile(filePath, function(error, content) {
                    if (error) {
                        response.writeHead(500);
                        response.end();
                    }
                    else {
                        response.writeHead(200, { 'Content-Type': contentType });
                        response.end(content, 'utf-8');
                    }
                });
            }
            else {
                response.writeHead(404);
                response.end();
            }
        });
     }
}).listen(3000);


var io = require('socket.io');
io = io.listen(app);
io.configure('development', function(){
io.set("transports", ["websocket"]);
});

io.sockets.on('connection', function(socket) {
    // console.log('Client connected');

  // socket.on('getactivites', function(data) {
  //       // console.log('getactivites');
  //       testcollection.find().toArray(function(err, result) {
  //           if (err) throw err;
  //           socket.emit('populateactivities', result);
  //       });
  //   });
  ///////////////////////////////////////////
    socket.on('getactivites', function(data) {
        console.log('getactivities');
        testcollection.find().toArray(function(err, result) {
            if (err) throw err;
                        async.forEachSeries(result, 
                            function(item,callback2) {
                                async.forEachSeries(item.Activities.Activity.Lap, 
                                    function(itemx,callback3){
                                        exercisecollection.findById(itemx.selection, function(err, exresult) {
                                            if (err) throw err;
                                                itemx.exercisename = exresult.exercise.name;
                                                itemx.exercisemuscledata = exresult.exercise.muscledata;
                                                itemx.exerciseclass = exresult.exercise.type;
                                        callback3();
                                        });
                            }, function(err){
                                callback2();
                            });                       
                         }, function(err){
                            socket.emit('populateactivities', result); 
                         });
        });
});
///////////////////////////////////////
    socket.on('getactivitybyid', function(id) {
        testcollection.findById(id, function(err, result) {
            if (err) throw err;

                                async.forEachSeries(item.Activities.Activity.Lap, 
                                    function(itemx,callback3){
                                        exercisecollection.findById(itemx.selection, function(err, exresult) {
                                            if (err) throw err;
                                                itemx.exercisename = exresult.exercise.name;
                                                itemx.exercisemuscledata = exresult.exercise.muscledata;
                                                itemx.exerciseclass = exresult.exercise.type;
                                        callback3();
                                        });
                            }, function(err){callback2();});

        });
    });
////////////////////////
    socket.on('addactivity', function(data, docid) {
        var document_id;
        // console.log('addactivity' + docid);
        // console.log('add_activity_data' + JSON.stringify(data));
        if (docid  === null) {
                 document_id = new BSON.ObjectID();
         }
         else {
            document_id = new BSON.ObjectID(docid);
          }
                //var document_id = new BSON.ObjectID(docid);
                // console.log('inserted BSONID' + document_id);
                testcollection.update({_id:document_id}, data,{upsert:true} , function(err, result) {
                if (err) throw err;
                         exercisecollection.find().toArray(function(err, result) {
                         if (err) throw err;
                                socket.emit('populateexercises', result);
                         });
                });


    });

/////////////////////
        socket.on('delactivity', function(id) {
            testcollection.removeById(id,function(err, reply){
                if (err) throw err;
                       waiting = 0;
                       waitingj = 0;
                        testcollection.find().toArray(function(err, result) {
                            if (err) throw err;
                                    for (var j in result) {
                                        console.log('getactivities' + JSON.stringify(result));
                                        var eresult = result;
                                        var i;
                                        waitingj ++;
                                        for(i in result[j].Activities.Activity.Lap) {
                                                //////////////
                                                waiting ++;
                                                getbyidall(eresult,result[j].Activities.Activity.Lap[i].selection,i,j);
                                                ////////////////////
                                                console.log('below_i  = ' + i);
                                                //console.log('DATA  = ' + JSON.stringify(callback));
                                            }
                                    }
                        });
        });
    });
 ///////////////////
     socket.on('getexercises', function(data) {
     // console.log('emit exercises');
        exercisecollection.find().toArray(function(err, result) {
            if (err) throw err;
            socket.emit('populateexercises', result);
        });
    });
/////////////////////
    socket.on('updateexercises', function(data, docid) {
        // console.log('updateexecises' + JSON.stringify(data));
        if (docid  == 'undefined') {
                //console.log('edited updateexecises' + JSON.stringify(data));
                exercisecollection.insert(data, function(err, result) {
                if (err) throw err;
                        exercisecollection.find().toArray(function(err, result) {
                        if (err) throw err;
                        socket.emit('populateexercises', result);
                        });
                });
        }
        else {
                var document_id = new BSON.ObjectID(docid);
                exercisecollection.update({_id:document_id}, data,{upsert:true} , function(err, result) {
                if (err) throw err;
                         exercisecollection.find().toArray(function(err, result) {
                         if (err) throw err;
                             //console.log('populateexercises');
                                socket.emit('populateexercises', result);
                         });
                });

        }
    });
////////////////////
  socket.on('getexercisebyid', function(id) {
        // console.log('getexercisebyid');
        exercisecollection.findById(id, function(err, result) {
            if (err) throw err;
            socket.emit('populateexercisebyid', result);
        });
    });


////////////////
        socket.on('delexercise', function(id) {
            exercisecollection.removeById(id,function(err, reply){
                if (err) throw err;
                exercisecollection.find().toArray(function(err, result) {
                    if (err) throw err;
                    socket.emit('populateexercises', result);
            });
        });
    });
//////////////////
 ///////////////////
     socket.on('getexerciselist', function(data) {
     // console.log('emit exercises  = ' + data);
        exercisecollection.find({'exercise.type': data }).toArray(function(err, result) {
            if (err) throw err;
            console.log('emited exercises  = ' + JSON.stringify(result));
            socket.emit('populateexerciselist', data , result);
        });
    });
/////////////////////
});