55 lines
1.5 KiB
TypeScript
55 lines
1.5 KiB
TypeScript
|
|
import { getNumber } from "../utils/index.js";
|
|
|
|
import type { Subscriber } from "./abstract-provider.js";
|
|
|
|
|
|
//#TODO: Temp
|
|
import type { Provider } from "./provider.js";
|
|
export interface ConnectionRpcProvider extends Provider {
|
|
//send(method: string, params: Array<any>): Promise<any>;
|
|
_subscribe(param: Array<any>, processFunc: (result: any) => void): number;
|
|
_unsubscribe(filterId: number): void;
|
|
}
|
|
|
|
export class BlockConnectionSubscriber implements Subscriber {
|
|
#provider: ConnectionRpcProvider;
|
|
#blockNumber: number;
|
|
|
|
#filterId: null | number;
|
|
|
|
constructor(provider: ConnectionRpcProvider) {
|
|
this.#provider = provider;
|
|
this.#blockNumber = -2;
|
|
this.#filterId = null;
|
|
}
|
|
|
|
start(): void {
|
|
this.#filterId = this.#provider._subscribe([ "newHeads" ], (result: any) => {
|
|
const blockNumber = getNumber(result.number);
|
|
const initial = (this.#blockNumber === -2) ? blockNumber: (this.#blockNumber + 1)
|
|
for (let b = initial; b <= blockNumber; b++) {
|
|
this.#provider.emit("block", b);
|
|
}
|
|
this.#blockNumber = blockNumber;
|
|
});
|
|
}
|
|
|
|
stop(): void {
|
|
if (this.#filterId != null) {
|
|
this.#provider._unsubscribe(this.#filterId);
|
|
this.#filterId = null;
|
|
}
|
|
}
|
|
|
|
pause(dropWhilePaused?: boolean): void {
|
|
if (dropWhilePaused) { this.#blockNumber = -2; }
|
|
this.stop();
|
|
}
|
|
|
|
resume(): void {
|
|
this.start();
|
|
}
|
|
}
|
|
|