cerc-io/watcher-ts
16
1
Fork 0
mirror of https://github.com/cerc-io/watcher-ts synced 2025-01-04 18:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix update in sync status (#489)

Browse Source
This commit is contained in:
Nabarun Gogoi 2023-11-24 11:54:45 +05:30 committed by GitHub
parent 6decf61d4c
commit 9ee423f38e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 74 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

95
packages/util/src/database.ts
View File

@ -139,31 +139,50 @@ export class Database {
}
async updateSyncStatusIndexedBlock (repo: Repository<SyncStatusInterface>, blockHash: string, blockNumber: number, force = false): Promise<SyncStatusInterface> {
const entity = await repo.findOne();
let entity = await repo.findOne();
assert(entity);
if (force || blockNumber >= entity.latestIndexedBlockNumber) {
entity.latestIndexedBlockHash = blockHash;
entity.latestIndexedBlockNumber = blockNumber;
const updateData = {
latestIndexedBlockHash: blockHash,
latestIndexedBlockNumber: blockNumber
};
await repo.update(entity.id, updateData);
entity = {
...entity,
...updateData
};
}
return await repo.save(entity);
return entity;
}
async updateSyncStatusCanonicalBlock (repo: Repository<SyncStatusInterface>, blockHash: string, blockNumber: number, force = false): Promise<SyncStatusInterface> {
const entity = await repo.findOne();
let entity = await repo.findOne();
assert(entity);
if (force || blockNumber >= entity.latestCanonicalBlockNumber) {
entity.latestCanonicalBlockHash = blockHash;
entity.latestCanonicalBlockNumber = blockNumber;
const updateData = {
latestCanonicalBlockHash: blockHash,
latestCanonicalBlockNumber: blockNumber
};
await repo.update(entity.id, updateData);
entity = {
...entity,
...updateData
};
}
return await repo.save(entity);
return entity;
}
async updateSyncStatusChainHead (repo: Repository<SyncStatusInterface>, blockHash: string, blockNumber: number, force = false): Promise<SyncStatusInterface> {
let entity = await repo.findOne();
if (!entity) {
entity = repo.create({
chainHeadBlockHash: blockHash,
@ -177,47 +196,81 @@ export class Database {
initialIndexedBlockHash: blockHash,
initialIndexedBlockNumber: blockNumber
});
return repo.save(entity);
}
if (force || blockNumber >= entity.chainHeadBlockNumber) {
entity.chainHeadBlockHash = blockHash;
entity.chainHeadBlockNumber = blockNumber;
const updateData = {
chainHeadBlockHash: blockHash,
chainHeadBlockNumber: blockNumber
};
await repo.update(entity.id, updateData);
entity = {
...entity,
...updateData
};
}
return await repo.save(entity);
return entity;
}
async updateSyncStatusProcessedBlock (repo: Repository<SyncStatusInterface>, blockHash: string, blockNumber: number, force = false): Promise<SyncStatusInterface> {
const entity = await repo.findOne();
let entity = await repo.findOne();
assert(entity);
if (force || blockNumber >= entity.latestProcessedBlockNumber) {
entity.latestProcessedBlockHash = blockHash;
entity.latestProcessedBlockNumber = blockNumber;
const updateData = {
latestProcessedBlockHash: blockHash,
latestProcessedBlockNumber: blockNumber
};
await repo.update(entity.id, updateData);
entity = {
...entity,
...updateData
};
}
return await repo.save(entity);
return entity;
}
async updateSyncStatusIndexingError (repo: Repository<SyncStatusInterface>, hasIndexingError: boolean): Promise<SyncStatusInterface | undefined> {
const entity = await repo.findOne();
let entity = await repo.findOne();
if (!entity) {
return;
}
entity.hasIndexingError = hasIndexingError;
const updateData = {
hasIndexingError: hasIndexingError
};
return repo.save(entity);
await repo.update(entity.id, updateData);
entity = {
...entity,
...updateData
};
return entity;
}
async updateSyncStatus (repo: Repository<SyncStatusInterface>, syncStatus: DeepPartial<SyncStatusInterface>): Promise<SyncStatusInterface> {
const entity = await repo.findOne();
let entity = await repo.findOne();
assert(entity);
return await repo.save({
await repo.update(entity.id, syncStatus);
entity = {
...entity,
...syncStatus
});
};
return entity;
}
async getBlockProgress (repo: Repository<BlockProgressInterface>, blockHash: string): Promise<BlockProgressInterface | undefined> {