dbConnector.js

"use strict";

/**
 * @desc defines DB schemata & connects to mongoDB
 */

var mongoose = require('mongoose');

/* definition of publicationSchema */
//_id attribute will be created automatically
var publicationSchema = new mongoose.Schema({
	title: String,
	abstract: String,
	author: String,
	authorID: String,
	publicationDate: Date,
	widgets: [mongoose.Schema.Types.ObjectId]
});

/* definition of userSchema */
//_id attribute will be created automatically
var userSchema = new mongoose.Schema({
	name: String,
	email: String,
	provider: String,
	providerID: String
});

/**
* @desc definition of the widget-schema
*/
var widgetSchema = new mongoose.Schema({
	publicationID: String,
	caption: String,
	fileType: String,
	widgetType: {type: String, enum: ['map', 'timeseries']}
});

var publicationModel = mongoose.model('Publication', publicationSchema);
var userModel = mongoose.model('User', userSchema);
var widgetModel = mongoose.model('Widget', widgetSchema);


/**
 * @desc function to connect the ODB driver to mongoDB
 * @param dbPort:   port on which mongoDB is listening
 * @param dbName:   name of the database to use
 * @param callback: function with parameter 'error' (node style callback)
 */
exports.connect = function(dbAddress, dbName, callback) {
	var uri = 'mongodb://' + dbAddress + '/' + dbName;
	var options = {};
	mongoose.connect(uri, options);

	mongoose.connection.on('error',  function() { callback('database connection error'); });
	mongoose.connection.once('open', function() { callback(null); });
};

/* the database models, that can be accessed for queries etc */
exports.models = {
	publications: publicationModel,
	users: userModel,
	widget: widgetModel
};