webServer.js

"use strict";

/* jshint node: true */

/*
 * This builds on the webServer of previous projects in that it exports the current
 * directory via webserver listing on a hard code (see portno below) port. It also
 * establishes a connection to the MongoDB named 'cs142project6'.
 *
 * To start the webserver run the command:
 *    node webServer.js
 *
 * Note that anyone able to connect to localhost:portNo will be able to fetch any file accessible
 * to the current user in the current directory or any of its children.
 *
 * This webServer exports the following URLs:
 * /              -  Returns a text status message.  Good for testing web server running.
 * /test          - (Same as /test/info)
 * /test/info     -  Returns the SchemaInfo object from the database (JSON format).  Good
 *                   for testing database connectivity.
 * /test/counts   -  Returns the population counts of the cs142 collections in the database.
 *                   Format is a JSON object with properties being the collection name and
 *                   the values being the counts.
 *
 * The following URLs need to be implemented:
 * /user/list     -  Returns an array containing all the User objects from the database.
 *                   (JSON format)
 * /user/:id      -  Returns the User object with the _id of id. (JSON format).
 * /photosOfUser/:id' - Returns an array with all the photos of the User (id). Each photo
 *                      should have all the Comments on the Photo (JSON format)
 *
 */

var mongoose = require('mongoose');
var async = require('async');


// Load the Mongoose schema for User, Photo, and SchemaInfo
var User = require('./schema/user.js');
var Photo = require('./schema/photo.js');
var SchemaInfo = require('./schema/schemaInfo.js');

var express = require('express');
var app = express();

mongoose.connect('mongodb://localhost/cs142project6');

// We have the express static module (http://expressjs.com/en/starter/static-files.html) do all
// the work for us.
app.use(express.static(__dirname));


app.get('/', function (request, response) {
    response.send('Simple web server of files from ' + __dirname);
});

/*
 * Use express to handle argument passing in the URL.  This .get will cause express
 * To accept URLs with /test/<something> and return the something in request.params.p1
 * If implement the get as follows:
 * /test or /test/info - Return the SchemaInfo object of the database in JSON format. This
 *                       is good for testing connectivity with  MongoDB.
 * /test/counts - Return an object with the counts of the different collections in JSON format
 */
app.get('/test/:p1', function (request, response) {
    // Express parses the ":p1" from the URL and returns it in the request.params objects.
    //console.log('/test called with param1 = ', request.params.p1);

    var param = request.params.p1 || 'info';

    if (param === 'info') {
        // Fetch the SchemaInfo. There should only one of them. The query of {} will match it.
        SchemaInfo.find({}, function (err, info) {
            if (err) {
                // Query returned an error.  We pass it back to the browser with an Internal Service
                // Error (500) error code.
                console.error('Doing /user/info error:', err);
                response.status(500).send(JSON.stringify(err));
                return;
            }
            if (info.length === 0) {
                // Query didn't return an error but didn't find the SchemaInfo object - This
                // is also an internal error return.
                response.status(500).send('Missing SchemaInfo');
                return;
            }

            // We got the object - return it in JSON format.
          //  console.log('SchemaInfo', info[0]);
            response.end(JSON.stringify(info[0]));
        });
    } else if (param === 'counts') {
        // In order to return the counts of all the collections we need to do an async
        // call to each collections. That is tricky to do so we use the async package
        // do the work.  We put the collections into array and use async.each to
        // do each .count() query.
        var collections = [
            {name: 'user', collection: User},
            {name: 'photo', collection: Photo},
            {name: 'schemaInfo', collection: SchemaInfo}
        ];
        async.each(collections, function (col, done_callback) {
            col.collection.count({}, function (err, count) {
                col.count = count;
                done_callback(err);
            });
        }, function (err) {
            if (err) {
                response.status(500).send(JSON.stringify(err));
            } else {
                var obj = {};
                for (var i = 0; i < collections.length; i++) {
                    obj[collections[i].name] = collections[i].count;
                }
                response.end(JSON.stringify(obj));

            }
        });
    } else {
        // If we know understand the parameter we return a (Bad Parameter) (400) status.
        response.status(400).send('Bad param ' + param);
    }
});

/*
 * URL /user/list - Return all the User object.
 */
app.get('/user/list', function (request, response) {
   // response.status(501).send("Not Implemented");
   var userCollections = User;
   var usersMetaData = [];
   userCollections.find(function(err, users){
        if (err) {
            response.status(500).send(JSON.stringify(err));
            return;
        } 
        for (var i = 0; i < users.length; i++) {
            var currentUser = users[i];
            var user = new Object();
            user.id = currentUser.id;
            console.log("/user/list", i, user.id);
            user.first_name = currentUser.first_name;
            user.last_name = currentUser.last_name;
            usersMetaData.push(user);
        }
       
        response.end(JSON.stringify(usersMetaData));
   });
});

/*
 * URL /user/:id - Return the information for User (id)
 */
app.get('/user/:id', function (request, response) {
    //response.status(501).send("Not Implemented");
    var userCollections = User;
    var param = request.params.id;
    console.log("/user/:id", param);
    userCollections.findOne({_id: param}, function(err, user){
        if (err) {
            response.status(500).send(JSON.stringify(err));
            return;
        } 
        if (!user) {
            response.status(500).send(JSON.stringify(err));
            return;
        }
        var currentUser = {};
        console.log(user);
        currentUser.first_name = user.first_name;
        currentUser.last_name = user.last_name;
        currentUser.location = user.location;
        currentUser.description = user.description;
        currentUser.occupation = user.occupation;
        currentUser.id = user._id;
        response.end(JSON.stringify(currentUser));
    });
});

/*
 * URL /photosOfUser/:id - Return the Photos for User (id)
 */
app.get('/photosOfUser/:id', function (request, response) {
   // response.status(501).send("Not Implemented");
   var photoCollections = Photo;
   var userCollections = User;
   
   var param = request.params.id;
   var photoResponse = [];
   
   var usersMetaData = [];
   userCollections.find(function(err, users){
        if (err) {
            response.status(500).send(JSON.stringify(err));
            return;
        } 
        for (var i = 0; i < users.length; i++) {
            var currentUser = users[i];
            var user = new Object();
            user.id = currentUser._id;
           // console.log("/user/list", i, user.id);
            user.first_name = currentUser.first_name;
            user.last_name = currentUser.last_name;
            usersMetaData.push(user);
        }
   });
   
   photoCollections.find({}, function(err, photos){
       if (err) {
           response.status(500).send(JSON.stringify(err));
           return;
       }
       for (var i = 0; i < photos.length; i++) {
           if (String(photos[i].user_id) === String(param)) {
               var currentPhoto = {};
               var photo = photos[i];
               currentPhoto.id = photo.id;
               currentPhoto.file_name = photo.file_name;
               currentPhoto.date_time = photo.date_time;
               currentPhoto.user_id = photo.user_id;
               currentPhoto.comments = [];
               for (var j = 0; j < photo.comments.length; j++) {
                   var currentComment = {};
                   var comment = photo.comments[j];
                   currentComment.comment = comment.comment;
                   currentComment.date_time = comment.date_time;
                   currentComment.user_id = comment.user_id;
                   currentComment.author = {};
                   for (var k = 0; k < usersMetaData.length; k++) {
                       if (String(usersMetaData[k].id) === String(comment.user_id)) {
                           currentComment.author.id = usersMetaData[k].id;
                           currentComment.author.first_name = usersMetaData[k].first_name;
                           currentComment.author.last_name = usersMetaData[k].last_name;
                       }
                   }
                   currentPhoto.comments.push(currentComment);
               }
               console.log(currentPhoto);
               photoResponse.push(currentPhoto);
           }
       }
     response.end(JSON.stringify(photoResponse));
   });
});


var server = app.listen(3000, function () {
    var port = server.address().port;
    console.log('Listening at http://localhost:' + port + ' exporting the directory ' + __dirname);
});