logos-messaging/js-noise
1
0
Fork 0
mirror of https://github.com/logos-messaging/js-noise.git synced 2026-01-02 13:43:08 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: Set default pubsubTopic

Browse Source
This commit is contained in:
Emil Ivanichkov 2024-04-09 19:25:54 +03:00
parent 292ccd68ee
commit d79b23553f
1 changed files with 21 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/codec.ts
View File

@ -1,5 +1,13 @@
import { DecodedMessage } from "@waku/core/lib/message/version_0"; import { DecodedMessage } from "@waku/core/lib/message/version_0";
import type { IDecodedMessage, IDecoder, IEncoder, IMessage, IMetaSetter, IProtoMessage } from "@waku/interfaces"; import {
DefaultPubsubTopic,
type IDecodedMessage,
type IDecoder,
type IEncoder,
type IMessage,
type IMetaSetter,
type IProtoMessage,
} from "@waku/interfaces";
import { WakuMessage } from "@waku/proto"; import { WakuMessage } from "@waku/proto";
import debug from "debug"; import debug from "debug";
@ -17,6 +25,8 @@ const version = 2;
* Used internally in the pairing object to represent a handshake message * Used internally in the pairing object to represent a handshake message
*/ */
export class NoiseHandshakeMessage extends DecodedMessage implements IDecodedMessage { export class NoiseHandshakeMessage extends DecodedMessage implements IDecodedMessage {
pubSubTopic = DefaultPubsubTopic;
get payloadV2(): PayloadV2 { get payloadV2(): PayloadV2 {
if (!this.payload) throw new Error("no payload available"); if (!this.payload) throw new Error("no payload available");
return PayloadV2.deserialize(this.payload); return PayloadV2.deserialize(this.payload);
@ -33,6 +43,8 @@ export class NoiseHandshakeEncoder implements IEncoder {
* @param hsStepResult the result of a step executed while performing the handshake process * @param hsStepResult the result of a step executed while performing the handshake process
* @param ephemeral makes messages ephemeral in the Waku network * @param ephemeral makes messages ephemeral in the Waku network
*/ */
pubsubTopic = DefaultPubsubTopic;
constructor( constructor(
public contentTopic: string, public contentTopic: string,
private hsStepResult: HandshakeStepResult, private hsStepResult: HandshakeStepResult,
@ -67,6 +79,8 @@ export class NoiseHandshakeDecoder implements IDecoder<NoiseHandshakeMessage> {
/** /**
* @param contentTopic content topic on which the encoded WakuMessages were sent * @param contentTopic content topic on which the encoded WakuMessages were sent
*/ */
pubsubTopic = DefaultPubsubTopic;
constructor(public contentTopic: string) {} constructor(public contentTopic: string) {}
fromWireToProtoObj(bytes: Uint8Array): Promise<IProtoMessage | undefined> { fromWireToProtoObj(bytes: Uint8Array): Promise<IProtoMessage | undefined> {
@ -101,10 +115,12 @@ export class NoiseHandshakeDecoder implements IDecoder<NoiseHandshakeMessage> {
*/ */
export class NoiseSecureMessage extends DecodedMessage implements IDecodedMessage { export class NoiseSecureMessage extends DecodedMessage implements IDecodedMessage {
private readonly _decodedPayload: Uint8Array; private readonly _decodedPayload: Uint8Array;
pubsubTopic: string;
constructor(pubSubTopic: string, proto: WakuMessage, decodedPayload: Uint8Array) { constructor(pubSubTopic: string, proto: WakuMessage, decodedPayload: Uint8Array) {
super(pubSubTopic, proto); super(pubSubTopic, proto);
this._decodedPayload = decodedPayload; this._decodedPayload = decodedPayload;
this.pubsubTopic = pubSubTopic;
} }
get payload(): Uint8Array { get payload(): Uint8Array {
@ -125,6 +141,8 @@ export class NoiseSecureTransferEncoder implements IEncoder {
* @param ephemeral whether messages should be tagged as ephemeral defaults to true. * @param ephemeral whether messages should be tagged as ephemeral defaults to true.
* @param metaSetter callback function that set the `meta` field. * @param metaSetter callback function that set the `meta` field.
*/ */
pubsubTopic = DefaultPubsubTopic;
constructor( constructor(
public contentTopic: string, public contentTopic: string,
private hsResult: HandshakeResult, private hsResult: HandshakeResult,
@ -179,6 +197,8 @@ export class NoiseSecureTransferDecoder implements IDecoder<NoiseSecureMessage>
* @param contentTopic content topic on which the encoded WakuMessages were sent * @param contentTopic content topic on which the encoded WakuMessages were sent
* @param hsResult handshake result obtained after the handshake is successful * @param hsResult handshake result obtained after the handshake is successful
*/ */
pubsubTopic = DefaultPubsubTopic;
constructor(public contentTopic: string, private hsResult: HandshakeResult) {} constructor(public contentTopic: string, private hsResult: HandshakeResult) {}
fromWireToProtoObj(bytes: Uint8Array): Promise<IProtoMessage | undefined> { fromWireToProtoObj(bytes: Uint8Array): Promise<IProtoMessage | undefined> {