var pg = require('pg');

var config = {
	user: 'postgres', //env var: PGUSER
	database: 'alarm', //env var: PGDATABASE
	password: '', //env var: PGPASSWORD
	host: 'localhost', // Server hosting the postgres database
	port: 5432, //env var: PGPORT
	max: 10, // max number of clients in the pool
	idleTimeoutMillis: 30000, // how long a client is allowed to remain idle before being closed
};
var pool = new pg.Pool(config);
//867273025099537|1|2017/03/15|14:52:45|30.491575|50.395729|3|3|test user|test comment
function execSQL(sql,callback){
	pool.connect(function(err, client, done) {
		if(err) {
			return console.error('error fetching client from pool', err);
		}
		client.query(sql, function(err, result) {
			done();

			if(err) {
				return console.error('error running query', err);
			}

			if(callback && typeof callback == 'function') callback(result);
		});
	});

	pool.on('error', function (err, client) {
		console.error('idle client error', err.message, err.stack)
	});
}

function insertStatus(row){
	var sql = `
		INSERT INTO log(
			ip, chip, flash, imei, state_id, event_id, mcc, mnc,
			lac, cid, gsm_level, voltage, reserve_voltage, temperature)
		VALUES (
			'${row.ip || null}',
			${row.chip || 'null'},
			${row.flash || 'null'},
			${row.imei || 'null'},
			${row.state_id || 'null'},
			${row.event_id || 'null'},
			'${row.mcc || null}',
			'${row.mnc || null}',
			'${row.lac || null}',
			'${row.cid || null}',
			${row.gsm_level || 'null'},
			${row.voltage || 'null'},
			${row.reserve_voltage || 'null'},
			${row.temperature || 'null'}
		);
	`;

	execSQL(sql);
}

function sendSettings(callback){
	var sql = `select * from messages`;
	execSQL(sql,callback)
}

module.exports.pool = pool;
module.exports.insertStatus = insertStatus;
module.exports.sendSettings = sendSettings;
INSERT INTO monitoring_log_(imei, status, date, lat, lng, counter_1, counter_2, "user", comment)
    VALUES ('867273025099537', 1, '2017/03/15 14:52:45', '50.395729', '30.491575', '3', '3', 'test user', 'test comment');