From fcd9c5d7026e65349c47b6816fee4cb9f9b90840 Mon Sep 17 00:00:00 2001 From: David Echelberger Date: Thu, 20 Jan 2022 15:44:39 -0500 Subject: [PATCH 1/3] [activatePool-stream-init] initializing stream in /activatepool Signed-off-by: David Echelberger --- src/tokens/tokens.service.ts | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/tokens/tokens.service.ts b/src/tokens/tokens.service.ts index 74c794f..174458e 100644 --- a/src/tokens/tokens.service.ts +++ b/src/tokens/tokens.service.ts @@ -104,6 +104,9 @@ export class TokensService { */ async init() { this.stream = await this.eventstream.createOrUpdateStream(this.topic); + console.log('init'); + console.log(this.topic); + console.log(this.stream); await this.eventstream.getOrCreateSubscription( this.instanceUrl, this.stream.id, @@ -146,6 +149,7 @@ export class TokensService { } async activatePool(dto: TokenPoolActivate) { + this.stream = await this.eventstream.createOrUpdateStream(this.topic); await Promise.all([ this.eventstream.getOrCreateSubscription( `${this.baseUrl}/${this.instancePath}`, From e56b118e1e026d6605c2db2f3efec00733dda2fe Mon Sep 17 00:00:00 2001 From: David Echelberger Date: Thu, 20 Jan 2022 15:47:43 -0500 Subject: [PATCH 2/3] [activatePool-stream-init] removing logs Signed-off-by: David Echelberger --- src/tokens/tokens.service.ts | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/tokens/tokens.service.ts b/src/tokens/tokens.service.ts index 174458e..14de58d 100644 --- a/src/tokens/tokens.service.ts +++ b/src/tokens/tokens.service.ts @@ -104,9 +104,6 @@ export class TokensService { */ async init() { this.stream = await this.eventstream.createOrUpdateStream(this.topic); - console.log('init'); - console.log(this.topic); - console.log(this.stream); await this.eventstream.getOrCreateSubscription( this.instanceUrl, this.stream.id, From cebf5974aa5653ada7b2732fe8e010d8d21ef554 Mon Sep 17 00:00:00 2001 From: David Echelberger Date: Thu, 20 Jan 2022 15:50:15 -0500 Subject: [PATCH 3/3] [activatePool-stream-init] only call if undefined Signed-off-by: David Echelberger --- src/tokens/tokens.service.ts | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/tokens/tokens.service.ts b/src/tokens/tokens.service.ts index 14de58d..a2c0982 100644 --- a/src/tokens/tokens.service.ts +++ b/src/tokens/tokens.service.ts @@ -146,7 +146,9 @@ export class TokensService { } async activatePool(dto: TokenPoolActivate) { - this.stream = await this.eventstream.createOrUpdateStream(this.topic); + if(this.stream === undefined) { + this.stream = await this.eventstream.createOrUpdateStream(this.topic); + } await Promise.all([ this.eventstream.getOrCreateSubscription( `${this.baseUrl}/${this.instancePath}`,