kosmos/lndhub
8
0
Fork 0
Code Issues Pull Requests Releases Activity

FIX: better locking when importing onchain tx

Browse Source
This commit is contained in:
Overtorment 2019-01-07 17:25:04 +00:00
parent b7073abb0e
commit d8bd2aacdf
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
class/User.js
View File

@ -1,3 +1,5 @@
import { Lock } from './Lock';
var crypto = require('crypto'); var crypto = require('crypto');
var lightningPayReq = require('bolt11'); var lightningPayReq = require('bolt11');
import { BigNumber } from 'bignumber.js'; import { BigNumber } from 'bignumber.js';
@ -304,20 +306,18 @@ export class User {
} }
if (!already_imported && tx.category === 'receive') { if (!already_imported && tx.category === 'receive') {
let locked = await this._redis.get('importing_' + tx.txid); // first, locking...
if (locked) { let lock = new Lock(this._redis, 'importing_' + tx.txid);
// race condition, someone's already importing this tx if (!(await lock.obtainLock())) {
// someone's already importing this tx
return; return;
} }
// locking...
await this._redis.set('importing_' + tx.txid, 1);
await this._redis.expire('importing_' + tx.txid, 3600);
let userBalance = await this.getBalance(); let userBalance = await this.getBalance();
userBalance += new BigNumber(tx.amount).multipliedBy(100000000).toNumber(); userBalance += new BigNumber(tx.amount).multipliedBy(100000000).toNumber();
await this.saveBalance(userBalance); await this.saveBalance(userBalance);
await this._redis.rpush('imported_txids_for_' + this._userid, tx.txid); await this._redis.rpush('imported_txids_for_' + this._userid, tx.txid);
await lock.releaseLock();
} }
} }
} }