1
This commit is contained in:
parent
9af75f978b
commit
bb0ffedecd
@ -7,6 +7,8 @@ const BaseService = require('./baseservice');
|
||||
const metaFactory = require('../metadata/factory');
|
||||
const eventsFactory = require('./events/factory');
|
||||
|
||||
const LIMIT_COUNT = 100;
|
||||
|
||||
class DbEventProcess extends BaseService {
|
||||
|
||||
static #tableMaxIdxHash = {};
|
||||
@ -79,7 +81,7 @@ class DbEventProcess extends BaseService {
|
||||
const {err, rows} = await this.conn.execQuery(
|
||||
'SELECT * FROM ${tableName} WHERE `idx` > ? AND `idx` <= ? ' +
|
||||
'AND net_id = ? AND event_name = ? AND contract_address = ? AND ' +
|
||||
'state = ' + constant.EVENTDB_STATE_PENDING + ' ' +
|
||||
'status = ' + constant.EVENTDB_STATE_PENDING + ' ' +
|
||||
'LIMIT ' + LIMIT_COUNT,
|
||||
[
|
||||
startIdx.toString(),
|
||||
|
Loading…
x
Reference in New Issue
Block a user