machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Adding types to callback functions.

Browse Source
This commit is contained in:
softsimon
2020-06-09 02:08:46 +07:00
parent 1db06f8009
commit 5feaa1fa8e
5 changed files with 33 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
backend/src/api/mempool.ts
View File

@@ -6,7 +6,8 @@ class Mempool {
private inSync: boolean = false;
private mempoolCache: { [txId: string]: TransactionExtended } = {};
private mempoolInfo: MempoolInfo = { size: 0, bytes: 0 };
private mempoolChangedCallback: Function | undefined;
private mempoolChangedCallback: ((newMempool: { [txId: string]: TransactionExtended; }, newTransactions: TransactionExtended[],
deletedTransactions: TransactionExtended[]) => void) | undefined;
private txPerSecondArray: number[] = [];
private txPerSecond: number = 0;
@@ -22,7 +23,8 @@ class Mempool {
return this.inSync;
}
public setMempoolChangedCallback(fn: Function) {
public setMempoolChangedCallback(fn: (newMempool: { [txId: string]: TransactionExtended; },
newTransactions: TransactionExtended[], deletedTransactions: TransactionExtended[]) => void) {
this.mempoolChangedCallback = fn;
}
@@ -122,7 +124,7 @@ class Mempool {
// Replace mempool to clear deleted transactions
const newMempool = {};
const deletedTransactions: Transaction[] = [];
const deletedTransactions: TransactionExtended[] = [];
for (const tx in this.mempoolCache) {
if (transactions.indexOf(tx) > -1) {
newMempool[tx] = this.mempoolCache[tx];