waku-org
/
js-waku
mirror of https://github.com/waku-org/js-waku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

remove static props used for instance state

This commit is contained in:
Felicio Mununga 2022-05-29 15:01:36 +02:00
parent 911ce4a836
commit 606a2da96c
No known key found for this signature in database
GPG Key ID: B4572D17D9BE6ECA
1 changed files with 0 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/lib/waku.ts
View File

@ -101,9 +101,6 @@ export interface CreateOptions {
// TODO: listen to and emit libp2p (error) events // TODO: listen to and emit libp2p (error) events
// TODO?: do "started" check in all methods // TODO?: do "started" check in all methods
export class Waku { export class Waku {
private static started = false;
private static stopping = false;
public libp2p: Libp2p; public libp2p: Libp2p;
public relay: WakuRelay; public relay: WakuRelay;
public store: WakuStore; public store: WakuStore;
@ -152,12 +149,6 @@ export class Waku {
* Create and start new waku node. * Create and start new waku node.
*/ */
static async create(options?: CreateOptions): Promise<Waku> { static async create(options?: CreateOptions): Promise<Waku> {
if (Waku.started) {
throw "Already started";
}
Waku.started = true;
// Get an object in case options or libp2p are undefined // Get an object in case options or libp2p are undefined
const libp2pOpts = Object.assign({}, options?.libp2p); const libp2pOpts = Object.assign({}, options?.libp2p);
@ -293,13 +284,6 @@ export class Waku {
} }
async stop(): Promise<void> { async stop(): Promise<void> {
if (Waku.stopping) {
// FIXME?: do not throw
throw "Already stopping";
}
Waku.stopping = true;
for (const timer of [ for (const timer of [
...Object.values(this.pingKeepAliveTimers), ...Object.values(this.pingKeepAliveTimers),
...Object.values(this.relayKeepAliveTimers), ...Object.values(this.relayKeepAliveTimers),
@ -310,9 +294,6 @@ export class Waku {
this.relayKeepAliveTimers = {}; this.relayKeepAliveTimers = {};
await this.libp2p.stop(); await this.libp2p.stop();
Waku.stopping = false;
Waku.started = false;
} }
/** /**