const pg = require('pg');
var moment = require('moment');
var dbparams = {user:"dbuser", database:"mydb", password:"mypw", host:"localhost"};
var client = new pg.Client(dbparams);

function new_suspect(name, sha256, sha1, md5, callback) {
	client.connect();
	const q = client.query({
		text: 'INSERT INTO suspects (sha256, sha1, md5) VALUES ($1, $2, $3) ON CONFLICT (sha256) DO NOTHING;',
		values: [sha256, sha1, md5] });

	q.on('error', (err) => { client.end(); throw err; });
	q.on('end', (result) => { client.end(); callback(result); });
}

function new_case(uuid, unixtime, sha256, fname, callback) {
	client.connect();
	var formatted = moment(unixtime, 'YYYY-MM-DD HH:mm:ss');
	const q = client.query({
		text: 'INSERT INTO cases (uuid, submittime, sha256, fname) VALUES ($1, $2, $3, $4)',
		values: [uuid, formatted, sha256, fname]});

	q.on('error', (err) => { client.end(); throw err; });
	q.on('end', (result) => { client.end(); callback(result); });
}

new_suspect("myfile", "1338c8c7dfc752f349cafecbdddf6c0e7b8a83d19d0660f4631b87cef41b9560", "a1de3c86f2c211d79b2cedc58ff9a62b25569b64", "ab09a708827debdfaaab789a0fc45643", console.log);
new_case("0b369929-9438-441e-8af9-b7c9e18a205d", 1489269470.868, "1338c8c7dfc752f349cafecbdddf6c0e7b8a83d19d0660f4631b87cef41b9560", "myfile", console.log);

/* error follows:
events.js:160
      throw er; // Unhandled 'error' event
      ^

Error: write EPIPE
    at exports._errnoException (util.js:1022:11)
    at WriteWrap.afterWrite (net.js:801:14)
*/