157 lines
3.9 KiB
JavaScript
157 lines
3.9 KiB
JavaScript
const app = require('j7/app');
|
|
const utils = require('j7/utils');
|
|
const bcutils = require('j7/bcutils');
|
|
const log = require('j7/log');
|
|
const constant = require('common/constant');
|
|
const BaseService = require('./baseservice');
|
|
|
|
const LIMIT_COUNT = 100;
|
|
|
|
class Erc721Refresher extends BaseService {
|
|
|
|
async init(bc, net, refresher) {
|
|
const {err, conn} = await app.getDbConn(constant.BCEVENTDB_NAME);
|
|
this.conn = conn;
|
|
this.bc = bc;
|
|
this.net = net;
|
|
this.refresher = refresher;
|
|
this.lastIdx = BigInt(0);
|
|
this.conf = this.refresher['conf'];
|
|
this.progInfo = this.refresher['progressInfo'];
|
|
await this.start();
|
|
}
|
|
|
|
async start() {
|
|
while (true) {
|
|
await this.pullEvent();
|
|
await utils.sleep(2000 + utils.randRange(500, 1500));
|
|
}
|
|
}
|
|
|
|
async pullEvent() {
|
|
const logHead = this.genLogHead('pullEvent ');
|
|
try {
|
|
const {err, rows} = await this.conn.execQuery(
|
|
'SELECT * FROM t_erc721_refresh WHERE idx > ' + this.lastIdx.toString() + ' ' +
|
|
'AND net_id = ? AND contract_address = ? AND status = 0 ' +
|
|
'LIMIT ' + LIMIT_COUNT,
|
|
[
|
|
this.getNetId(),
|
|
this.getContractAddress()
|
|
]);
|
|
if (err) {
|
|
throw err;
|
|
}
|
|
if (rows.length > 0) {
|
|
await utils.serial(
|
|
rows,
|
|
async (row) => {
|
|
await this.refresh(row);
|
|
}
|
|
);
|
|
} else {
|
|
this.lastIdx = BigInt(0);
|
|
}
|
|
} catch (err) {
|
|
log.error(logHead + err);
|
|
await utils.sleep(5000 + utils.randRange(1000, 3000));
|
|
}
|
|
}
|
|
|
|
getNetId() {
|
|
return this.net['net_id'];
|
|
}
|
|
|
|
getContractAddress() {
|
|
return this.bc.getContractAddressByName(this.getContractName());
|
|
}
|
|
|
|
getContractName() {
|
|
return this.conf['contract_name'];
|
|
}
|
|
|
|
genLogHead(msg) {
|
|
const head = this.getNetId() + '.' + this.getContractName() + ' erc721 refresher ' + msg;
|
|
return head;
|
|
}
|
|
|
|
async refresh(row) {
|
|
while (true) {
|
|
await this.bc.mustBeActive();
|
|
const oldBlockNumber = this.bc.getCurrBlockNumber();
|
|
let oldOwner = await this.getOwner();
|
|
while (oldBlockNumber + 8 > this.bc.getCurrBlockNumber()) {
|
|
await utils.sleep(1000 + utils.randRange(0, 500));
|
|
}
|
|
|
|
await this.bc.mustBeActive();
|
|
const newBlockNumber = this.bc.getCurrBlockNumber();
|
|
let newOwner = await this.getOwner();
|
|
|
|
if (oldOwner == newOwner) {
|
|
const ok = await this.updateConfirmed(newOwner, oldBlockNumber, row);
|
|
if (ok) {
|
|
await this.update
|
|
(row,
|
|
[
|
|
['status', 1]
|
|
]);
|
|
break;
|
|
}
|
|
}
|
|
await utils.sleep(1000 + utils.randRange(500, 1500));
|
|
|
|
}
|
|
}
|
|
|
|
async updateConfirmed(newOwner, blockNumber, row) {
|
|
const {err, nftDbConn} = await app.getDbConn(constant.BCNFTDB_NAME);
|
|
if (err) {
|
|
log.error('updateConfirmed:' + this.tokenId + ' err:' + err);
|
|
return false;
|
|
}
|
|
try {
|
|
{
|
|
const {err} = await nftDbConn.update(
|
|
't_nft',
|
|
[
|
|
['net_id', row['net_id']],
|
|
['token_id', row['token_id']],
|
|
['contract_address', row['contract_address']],
|
|
],
|
|
[
|
|
['owner_address', bcutils.toNormalAddress(newOwner)],
|
|
['confirm_count', () => {
|
|
return 'confirm_count + 1';
|
|
}],
|
|
['confirm_block_number', blockNumber]
|
|
]);
|
|
if (err) {
|
|
log.error('updateConfirmed:' + this.tokenId + ' err:' + err);
|
|
return false;
|
|
}
|
|
}
|
|
} finally {
|
|
nftDbConn.release();
|
|
}
|
|
return true;
|
|
}
|
|
|
|
async update(row, fields) {
|
|
const {err} = await this.conn.update(
|
|
't_erc721_refresh',
|
|
[
|
|
['idx', row['idx']],
|
|
['net_id', row['net_id']],
|
|
['token_id', row['token_id']],
|
|
['contract_address', row['contract_address']],
|
|
['refresh_count', row['refresh_count']],
|
|
],
|
|
fields,
|
|
);
|
|
}
|
|
|
|
}
|
|
|
|
module.exports = Erc721Refresher;
|