repository.js

/* global process, __dirname */
(function () {
    "use strict";
    
    var q = require("q"),
        _ = require('lodash');
    
    var db = (function () {
        var Datastore = require('nedb');
        var dbfile = function (collection) {
            var path = __dirname + "/__data/";
            return path + collection + ".db"
        };

        var collections = {};
        ["Route", "Cycle", "Address", "User", "Notification"].forEach(function (entity) {
            collections[entity] = new Datastore({ filename: dbfile(entity), autoload: true });
        });

        return collections;
    })();

    var generateUniqueId = function () {
      var d = Date.now();
      var uuid = 'xxxxxxxx-xxxx-4xxx-yxxx-xxxxxxxxxxxx'.replace(/[xy]/g, function (c) {
          var r = (d + Math.random() * 16) % 16 | 0;
          d = Math.floor(d / 16);
          return (c == 'x' ? r : (r & 0x3 | 0x8)).toString(16);
      });
      return uuid;
    };
    
    var stripDatabaseIds = function (collection) {
        _.forEach(collection, function (item) {
            delete (item["_id"]);
        });
    };
    
    var get = function (query) {
        var collection = this,
            deferred = q.defer();
        
        try {
            db[collection].find(query || {}, function (err, items) {
                if (err || !items) {
                    console.log("No items found");
                }
                else {
                    console.log((items.length) + " items found");
                    stripDatabaseIds(items);
                }

                deferred.resolve(items);
            });
        }
        catch (ex) {
            console.error(ex);
            deferred.reject(ex);
        }
        
        return deferred.promise;
    };
    
    var put = function (entity) {
        var collection = this,
            deferred = q.defer();
        
        try {
            db[collection].insert(entity, function (err, newEntity) {
                if (err || !newEntity) {
                    console.log("Insert failed");
                }

                deferred.resolve(newEntity);
            });
        }
        catch (ex) {
            console.error(ex);
            deferred.reject(ex);
        }
        
        return deferred.promise;
    };
    
    var service = {
        get: function (collection, query) {
            return get.call(collection, query);
        },
        put: function (collection, entity) {
            return put.call(collection, entity);
        },
        getUsers:  get.bind("User")
    };
    
    module.exports = service;
})();