lamassu/lamassu-server
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

get cartridge counts from db

Browse source
This commit is contained in:
Josh Harvey 2014-11-28 10:53:38 -05:00
parent 238d4bd879
commit 209272eb26
4 changed files with 63 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

21
lib/postgresql_interface.js
View file

@ -10,9 +10,11 @@ var _ = require('lodash');
var logger = require('./logger');
/*
function inspect(rec) {
console.log(util.inspect(rec, {depth: null, colors: true}));
}
*/
function isUniqueViolation(err) {
return err.code === '23505';
@ -503,7 +505,7 @@ function insertDispense(client, session, tx, transactionId, counts, cb) {
exports.addDispense = function addDispense(session, tx) {
connect(function(cerr, client, done) {
if (cerr) return logger.error(cerr);
if (cerr) return;
async.waterfall([
async.apply(insertIncoming, client, session, tx, 0, tx.fiat,
@ -517,6 +519,23 @@ exports.addDispense = function addDispense(session, tx) {
});
};
exports.cartridgeCounts = function cartridgeCounts(session, cb) {
connect(function(cerr, client, done) {
if (cerr) return cb(cerr);
var sql = 'SELECT count1, count2 FROM dispenses ' +
'WHERE device_fingerprint=$1 ' +
'ORDER BY id DESC LIMIT 1';
query(client, sql, [session.fingerprint], function(err, results) {
done();
if (err) return cb(err);
var counts = results.rows.length === 1 ?
[results.rows[0].count1, results.rows[0].count2] :
[0, 0];
cb(null, counts);
});
});
};
/*
exports.init('postgres://lamassu:lamassu@localhost/lamassu');
connect(function(err, client, done) {