diff --git a/package.json b/package.json index b88d0ee1f..011261da3 100644 --- a/package.json +++ b/package.json @@ -55,7 +55,7 @@ "http-proxy": "^1.13.1", "jade": "^1.11.0", "jquery": "^2.2.0", - "knex": "^0.10.0", + "knex": "^0.11.7", "moment": "^2.11.2", "multer": "^1.1.0", "numeral": "^1.5.3", diff --git a/processors/processReduce.js b/processors/processReduce.js index 2bf9dbe00..3fd6823b2 100644 --- a/processors/processReduce.js +++ b/processors/processReduce.js @@ -9,6 +9,10 @@ function processReduce(entries, match, meta) { return false; } + if (e.type === "DOTA_COMBATLOG_MODIFIER_REMOVE") + { + return false; + } if (e.type === "interval" && e.time % 60 !== 0) { return false; diff --git a/store/queries.js b/store/queries.js index 49974199e..05ecb64cd 100644 --- a/store/queries.js +++ b/store/queries.js @@ -279,9 +279,9 @@ function insertMatch(db, redis, match, options, cb) { if (err) { - return exit(err); + return cb(err); } - async.eachLimit(match.logs, 100, function(e, cb) + async.eachLimit(match.logs, 10000, function(e, cb) { trx('match_logs').insert(e).asCallback(cb); }, cb);