diff --git a/packages/rln/src/codec.ts b/packages/rln/src/codec.ts index 25a441b9bb..62cb68dad9 100644 --- a/packages/rln/src/codec.ts +++ b/packages/rln/src/codec.ts @@ -5,8 +5,7 @@ import type { IMessage, IProtoMessage, IRateLimitProof, - IRoutingInfo, - PubsubTopic + IRoutingInfo } from "@waku/interfaces"; import { Logger } from "@waku/utils"; @@ -29,10 +28,6 @@ export class RLNEncoder implements IEncoder { this.idSecretHash = identityCredential.IDSecretHash; } - public get pubsubTopic(): PubsubTopic { - return this.encoder.pubsubTopic; - } - public async toWire(message: IMessage): Promise { message.rateLimitProof = await this.generateProof(message); log.info("Proof generated", message.rateLimitProof); @@ -61,6 +56,10 @@ export class RLNEncoder implements IEncoder { ); } + public get pubsubTopic(): string { + return this.encoder.pubsubTopic; + } + public get routingInfo(): IRoutingInfo { return this.encoder.routingInfo; } @@ -98,7 +97,7 @@ export class RLNDecoder private readonly decoder: IDecoder ) {} - public get pubsubTopic(): PubsubTopic { + public get pubsubTopic(): string { return this.decoder.pubsubTopic; } diff --git a/packages/tests/src/lib/service_node.ts b/packages/tests/src/lib/service_node.ts index 7048c763bc..a71526f9dc 100644 --- a/packages/tests/src/lib/service_node.ts +++ b/packages/tests/src/lib/service_node.ts @@ -448,11 +448,7 @@ export class ServiceNode { if (body) options.body = JSON.stringify(body); const response = await fetch(`${this.httpUrl}${endpoint}`, options); - log.info( - `Received REST Response: `, - response.status, - response.statusText - ); + log.info(`Received REST Response: `, response.status); return await processResponse(response); } catch (error) { log.error(`${this.httpUrl} failed with error:`, error);