forked from Witcoin-io/witcoin
-
Notifications
You must be signed in to change notification settings - Fork 0
/
validate-transactions.js
77 lines (63 loc) · 2.37 KB
/
validate-transactions.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
let request = require('request');
let DataBase = require('./lib/DataBase');
let BitcoinParser = require("./lib/parsers/BitcoinParser.js");
let BitcoinCashParser = require("./lib/parsers/BitcoinCashParser.js");
let LitecoinParser = require("./lib/parsers/LitecoinParser.js");
let DashParser = require("./lib/parsers/DashParser.js");
let BancorParser = require("./lib/parsers/BancorParser.js");
let AragonParser = require("./lib/parsers/AragonParser.js");
function getSpecificParser(coin){
var parser;
if (coin === "BTC") {
parser = new BitcoinParser();
} else if (coin === "BCH") {
parser = new BitcoinCashParser();
} else if (coin === "LTC") {
parser = new LitecoinParser();
} else if (coin === "DASH") {
parser = new DashParser();
} else if (coin === "BNT") {
parser = new BancorParser();
} else if (coin === "ANT") {
parser = new AragonParser();
}
return parser;
}
function validateTransaction(coin, tx) {
return (new Promise(function(resolve, reject) {
var parser = getSpecificParser(coin);
request(parser.getTxApiUrl(tx), function (error, response, body, callback) {
if (!error && response.statusCode === 200 && !parser.emptyBody(body)) {
var parsed = JSON.parse(body);
// Confirmations in BlockChain
if (parser.validTransaction(parsed)) {
// Get value
var value = parser.getTransactionValue(parsed);
var integer = parser.toIntegerValue(value);
// Get origin addresses
var origin = parser.getOriginAddresses(parsed);
// Get timestamp
var time = parser.getTimestamp(parsed);
// ALL OK, Validate
database.validateTransaction(tx,coin,integer,origin,time);
resolve(true);
} else {
resolve(false);
}
} else {
resolve(false);
}
});
}));
}
var database = new DataBase({});
var promises = [];
database.getTransactions(function(rows){
for(var i=0; i<rows.length; i++){
var row = rows[i];
promises.push(validateTransaction(row.coin, row.hash));
}
Promise.all(promises).then(function(){
database.close();
});
});