From f90e77549b87716bcb27f3cb6d83dc67930fe730 Mon Sep 17 00:00:00 2001 From: Josh Harvey Date: Sun, 4 Jan 2015 23:38:35 -0500 Subject: [PATCH] remove zeroConf stuff, which is moved over to Raqia --- lib/plugins.js | 12 ++-------- lib/postgresql_interface.js | 46 ------------------------------------- lib/routes.js | 1 - 3 files changed, 2 insertions(+), 57 deletions(-) diff --git a/lib/plugins.js b/lib/plugins.js index f51a2c6f..c123162b 100644 --- a/lib/plugins.js +++ b/lib/plugins.js @@ -211,14 +211,10 @@ function buildCartridges(counts) { } exports.pollQueries = function pollQueries(session, cb) { - async.parallel([ - async.apply(db.dispenseStatus, session), - async.apply(db.cartridgeCounts, session) - ], function(err, results) { + db.cartridgeCounts(session, function(err, result) { if (err) return cb(err); return cb(null, { - dispenseStatus: results[0], - cartridges: buildCartridges(results[1]) + cartridges: buildCartridges(result) }); }); }; @@ -346,10 +342,6 @@ exports.cashOut = function cashOut(session, tx, cb) { }); }; -exports.dispenseStatus = function dispenseStatus(session, cb) { - db.dispenseStatus(session, cb); -}; - exports.dispenseAck = function dispenseAck(session, tx) { db.addDispense(session, tx); }; diff --git a/lib/postgresql_interface.js b/lib/postgresql_interface.js index 2e21338e..5a02c65a 100644 --- a/lib/postgresql_interface.js +++ b/lib/postgresql_interface.js @@ -514,52 +514,6 @@ exports.addInitialIncoming = function addInitialIncoming(session, tx, cb) { }); }; -function lastTxStatus(client, session, cb) { - var sql = 'SELECT satoshis, stage, authority FROM transactions ' + - 'WHERE device_fingerprint=$1 AND session_id=$2 AND incoming=$3 ' + - 'ORDER BY id DESC LIMIT 1'; - var values = [session.fingerprint, session.id, true]; - - query(client, sql, values, cb); -} - -function initialRequest(client, session, cb) { - var sql = 'SELECT fiat, satoshis FROM transactions ' + - 'WHERE device_fingerprint=$1 AND session_id=$2 AND incoming=$3 ' + - 'AND stage=$4'; - var values = [session.fingerprint, session.id, true, 'initial_request']; - - query(client, sql, values, cb); -} - -exports.dispenseStatus = function dispenseStatus(session, cb) { - connect(function(cerr, client, done) { - if (cerr) return cb(cerr); - - async.parallel([ - async.apply(initialRequest, client, session), - async.apply(lastTxStatus, client, session) - ], function(err, results) { - done(); - if (err) return cb(err); - - var pending = (results[0].rows.length === 1) && - (results[1].rows.length === 1) && - (results[1].rows[0].stage === 'deposit'); - if (!pending) return cb(null, null); - - var requestedTx = results[0].rows[0]; - var lastTx = results[1].rows[0]; - - // TODO: handle multiple deposits - var status = (lastTx.satoshis < requestedTx.satoshis) ? - 'insufficientFunds' : - lastTx.authority; - cb(null, {status: status, fiat: requestedTx.fiat}); - }); - }); -}; - function lastDispenseCount(client, session, transactionId, cb) { var sql = 'SELECT count1, count2 FROM dispenses ' + 'WHERE device_fingerprint=$1 ' + diff --git a/lib/routes.js b/lib/routes.js index 5e0364b9..90b52198 100644 --- a/lib/routes.js +++ b/lib/routes.js @@ -61,7 +61,6 @@ function poll(req, res) { fiat: fiatBalance, locale: config.brain.locale, txLimit: parseInt(complianceSettings.maximum.limit, 10), - dispenseStatus: results.dispenseStatus, idVerificationEnabled: complianceSettings.idVerificationEnabled, cartridges: cartridges, twoWayMode: cartridges ? true : false