GLOBAL.DEBUG = true;
fs = require('fs');
sys = require("sys");
test = require("assert");
var csv = require('csv');
var mongodb = require('./mongodb/lib/mongodb');

var mongo = new mongodb.MongoDB();

mongo.addListener('connection', function(){

	aloha = mongo.getCollection('AlohaDataSet');

	csv().fromPath('AlohaDataSet.txt').transform(function(data, index){
		var newData = {
			'ItemName': data[0],
			'Price': data[1],
			'ItemCategory':	data[2],
			'DateOfBusiness': data[3],
			'StoreID': data[4],
			'CardNumber': data[5],
			'FirstName': data[6],
			'LastName': data[7]
		};

		return newData;

	}).on('data', function(data, index){

		console.log('Processing data: '+ index);

		aloha.insert({
			'FirstName': data.FirstName,
			'LastName': data.LastName,
			'CardNumber': data.CardNumber,
			'ItemName': data.ItemName,
			'Price': data.Price,
			'ItemCategory': data.ItemCategory,
			'DateOfBusiness': data.DateOfBusiness,
			'StoreID': data.StoreID
		});

	}).on('end', function(count){
		console.log(count);
	});

});

mongo.addListener('close', function(){
	sys.puts('Closing Connection');
});


mongo.addListener('ready', function(){
	sys.puts('ready to rock and roll');
});


mongo.connect({
	hostname: 'dbh10.mongolab.com',
	port: 27107,
	db: 'alohadataset',
	username: 'username',
	password: 'password'
});