2023-03-07 15:29:41 +11:00
|
|
|
import {
|
|
|
|
|
DecodedMessage as DecodedMessageV0,
|
2023-08-16 20:18:13 +05:30
|
|
|
proto
|
2023-03-07 15:29:41 +11:00
|
|
|
} from "@waku/core/lib/message/version_0";
|
|
|
|
|
import type { IDecodedMessage } from "@waku/interfaces";
|
|
|
|
|
|
|
|
|
|
export class DecodedMessage
|
|
|
|
|
extends DecodedMessageV0
|
|
|
|
|
implements IDecodedMessage
|
|
|
|
|
{
|
|
|
|
|
private readonly _decodedPayload: Uint8Array;
|
|
|
|
|
|
|
|
|
|
constructor(
|
2023-10-16 12:52:32 +05:30
|
|
|
pubsubTopic: string,
|
2023-03-07 15:29:41 +11:00
|
|
|
proto: proto.WakuMessage,
|
|
|
|
|
decodedPayload: Uint8Array,
|
|
|
|
|
public signature?: Uint8Array,
|
2023-08-16 20:18:13 +05:30
|
|
|
public signaturePublicKey?: Uint8Array
|
2023-03-07 15:29:41 +11:00
|
|
|
) {
|
2023-10-16 12:52:32 +05:30
|
|
|
super(pubsubTopic, proto);
|
2023-03-07 15:29:41 +11:00
|
|
|
this._decodedPayload = decodedPayload;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
get payload(): Uint8Array {
|
|
|
|
|
return this._decodedPayload;
|
|
|
|
|
}
|
|
|
|
|
}
|