LumeWeb
/
libethsync
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

refactor: split subscribe into syncToLatestBlock

This commit is contained in:
Derrick Hammer 2023-07-13 03:18:05 -04:00
parent 4836ddb32e
commit 11791ff08b
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 13 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/baseClient.ts
View File

@ -154,18 +154,22 @@ export default abstract class BaseClient {
protected async subscribe(callback?: (ei: ExecutionInfo) => void) { protected async subscribe(callback?: (ei: ExecutionInfo) => void) {
setInterval(async () => { setInterval(async () => {
try { await this.syncToLatestBlock(callback);
const ei = await this.getLatestExecution();
if (ei && ei.blockHash !== this.latestBlockHash) {
this.latestBlockHash = ei.blockHash;
return await callback?.(ei);
}
} catch (e) {
console.error(e);
}
}, POLLING_DELAY); }, POLLING_DELAY);
} }
public async syncToLatestBlock(callback?: (ei: ExecutionInfo) => void) {
try {
const ei = await this.getLatestExecution();
if (ei && ei.blockHash !== this.latestBlockHash) {
this.latestBlockHash = ei.blockHash;
return await callback?.(ei);
}
} catch (e) {
console.error(e);
}
}
protected async getLatestExecution(): Promise<ExecutionInfo | null> { protected async getLatestExecution(): Promise<ExecutionInfo | null> {
await this._sync(); await this._sync();
const update = await this.options.optimisticUpdateCallback(); const update = await this.options.optimisticUpdateCallback();