var dt = require('./dt.js');

var dt_node = new dt({master: true, port: 9999, key: 'asdf_any_length', nodes: ['127.0.0.1:9999', '127.0.0.1:10002']});

dt_node.emitter.addListener('started', function() {
	console.log('distributed table "started" event');
	dt_node.add_object({test: 'test'});
});

dt_node.emitter.addListener('object_added', function(object) {
	console.log('dt object_added event', object)
});

dt_node.emitter.addListener('object_removed', function(object) {
	console.log('dt object_removed event', object)
});

dt_node.emitter.addListener('message_received', function(m) {
	console.log('dt message_received event', m);
});

//set authorization status for an IP

//logout
ipac.ModifyAuth(&ip_ac, 0, "127.0.0.1")

//invalid login credentials
ipac.ModifyAuth(&ip_ac, 1, "127.0.0.1")

//authorized (valid login credentials)
ipac.ModifyAuth(&ip_ac, 2, "127.0.0.1")

//24 hours with 5 minute interval
rrd.Update(5*60, 24*60/5, 'GAUGE', []float64 {34, 100}, &rrdPtr);

//30 days with 1 hour interval
rrd.Update(60*60, 30*24, 'GAUGE', []float64 {34, 100}, &rrdPtr);

//365 days with 1 day interval
rrd.Update(24*60*60, 365*24, 'GAUGE', []float64 {34, 100}, &rrdPtr);

var sdb = require('./sdb.js');

// new database, read existing data from file
var mydb = new sdb('./my.db');

// insert
mydb.insert({a_simple_field: 'a_simple_value'});
mydb.insert({second_simple_field: 'second_simple_value'});

// update with $set and $add as upsert
mydb.update({second_simple_field: '2nd second_simple_value'}, {$set: {second_simple_field: '2nd second_simple_value'}, $add: {counter: 2}}, {upsert: true});

// find all
mydb.find({});

// index
mydb.index('a_simple_field', true, false);

// remove
mydb.remove({_id: doc[0]._id});

// $fulltext find
var data = mydb.find({title: {$fulltext: 'test is a'}});

// save to disk
mydb.save('./my.db');