|
1 | 1 | import fs from "node:fs"; |
2 | 2 | import path from "node:path"; |
3 | 3 | import worker from "node:worker_threads"; |
4 | | -import {Discv5} from "@chainsafe/discv5"; |
| 4 | +import {Discv5, Discv5EventEmitter} from "@chainsafe/discv5"; |
5 | 5 | import {ENR, ENRData, SignableENR, SignableENRData} from "@chainsafe/enr"; |
6 | 6 | import {Observable, Subject} from "@chainsafe/threads/observable"; |
7 | 7 | import {expose} from "@chainsafe/threads/worker"; |
@@ -59,7 +59,7 @@ const discv5 = Discv5.create({ |
59 | 59 | }, |
60 | 60 | config: workerData.config, |
61 | 61 | metricsRegistry, |
62 | | -}); |
| 62 | +}) as Discv5 & Discv5EventEmitter; |
63 | 63 |
|
64 | 64 | // Load boot enrs |
65 | 65 | for (const bootEnr of workerData.bootEnrs) { |
@@ -93,13 +93,13 @@ const module: Discv5WorkerApi = { |
93 | 93 | discv5.enr.set(key, value); |
94 | 94 | }, |
95 | 95 | async kadValues(): Promise<ENRData[]> { |
96 | | - return discv5.kadValues().map((enr) => enr.toObject()); |
| 96 | + return discv5.kadValues().map((enr: ENR) => enr.toObject()); |
97 | 97 | }, |
98 | 98 | async discoverKadValues(): Promise<void> { |
99 | 99 | discv5.kadValues().map(onDiscovered); |
100 | 100 | }, |
101 | 101 | async findRandomNode(): Promise<ENRData[]> { |
102 | | - return (await discv5.findRandomNode()).map((enr) => enr.toObject()); |
| 102 | + return (await discv5.findRandomNode()).map((enr: ENR) => enr.toObject()); |
103 | 103 | }, |
104 | 104 | discovered() { |
105 | 105 | return Observable.from(subject); |
|
0 commit comments