diff --git a/backend/app.js b/backend/app.js index e51a2cd..47356c6 100644 --- a/backend/app.js +++ b/backend/app.js @@ -98,7 +98,12 @@ var blockInterval = setInterval( function() { rpc.z_listreceivedbyaddress(fullnode.addr, 1).then(txs => { var re = /.*ZGO::(.*)\sReply-To:\s(z\w+)/; async.each (txs, function(txData, callback) { - var memo = hexToString(txData.memo); + var memo = hexToString(txData.memo).replace(/\0/g, ''); + txmodel.updateOne({txid: txData.txid}, { confirmations: txData.confirmations, amount:txData.amount, memo: memo}, {new:true, upsert:true}, function(err,docs) { + if (err) { + console.log(err); + } + }); if (re.test(memo)) { //console.log('Processing tx:', memo); var match = re.exec(memo); @@ -109,7 +114,12 @@ var blockInterval = setInterval( function() { var amount = txData.amount; var expiration = blocktime; //console.log(' ', session, blocktime); - if (txData.confirmations >= 10 ) { + txmodel.updateOne({txid: txData.txid}, { address: address, session: session, confirmations: txData.confirmations, amount:txData.amount, memo: memo}, {new:true, upsert:true}, function(err,docs) { + if (err) { + console.log(err); + } + }); + if (txData.confirmations >= 6 ) { usermodel.findOne({address: address, session: session, blocktime: blocktime}).then(function(doc){ if (doc != null) { console.log('Found user'); @@ -162,17 +172,7 @@ var blockInterval = setInterval( function() { }).catch((err) => { console.log(err); }); - txmodel.deleteMany({session: session}, function(err) { - if (err) console.log(err); - console.log('Deleted confirmed login'); - }); - } else { - txmodel.updateOne({address: address, session: session}, { confirmations: txData.confirmations, amount:txData.amount}, {new:true, upsert:true}, function(err,docs) { - if (err) { - console.log(err); - } - }); - } + } } } }, function (err) { @@ -230,8 +230,8 @@ app.get('/api/users', (req, res, next) => { }); app.get('/api/pending', (req, res, next) => { - console.log('Get: /api/pending'); - txmodel.find({'session': req.query.session}). + console.log('Get: /api/pending', req.query.session); + txmodel.find({'session': req.query.session, 'confirmations': {$lt: 10}}). then((documents) => { if (documents.length > 0) { //console.log('pending', documents); diff --git a/backend/models/tx.js b/backend/models/tx.js index d55ba1d..570b325 100644 --- a/backend/models/tx.js +++ b/backend/models/tx.js @@ -4,7 +4,9 @@ const txSchema = mongoose.Schema({ address: {type: String}, session: {type: String, required:true}, confirmations: {type: Number, required:true}, - amount: {type: Number, required:true} + amount: {type: Number, required:true}, + txid: {type:String, required:true}, + memo: {type:String} }); module.exports = mongoose.model('Tx', txSchema); diff --git a/src/app/login/login.component.html b/src/app/login/login.component.html index 7a12851..032e8c5 100644 --- a/src/app/login/login.component.html +++ b/src/app/login/login.component.html @@ -56,10 +56,10 @@

Login received!

- It needs {{10 - tx.confirmations}} more confirmations. + It needs {{6 - tx.confirmations}} more confirmations.
- +
Session length @@ -69,6 +69,7 @@ +

Wrong pin!