waku-lab/examples/experimental/web-chat/src/Message.ts

import { IDecodedMessage } from "@waku/interfaces";
import { ChatMessage } from "./chat_message";

export class Message {
  public chatMessage: ChatMessage;
  // WakuMessage timestamp
  public sentTimestamp: Date | undefined;

  constructor(chatMessage: ChatMessage, sentTimestamp: Date | undefined) {
    this.chatMessage = chatMessage;
    this.sentTimestamp = sentTimestamp;
  }

  static cmp(left: Message, right: Message): boolean {
    return left.timestamp.getTime() < right.timestamp.getTime();
  }

  static isEqual(left: Message, right: Message): boolean {
    return (
      left.timestamp.valueOf() === right.timestamp.valueOf() &&
      left.chatMessage.nick === right.chatMessage.nick &&
      left.chatMessage.payloadAsUtf8 === right.chatMessage.payloadAsUtf8
    );
  }

  static fromWakuMessage(wakuMsg: IDecodedMessage): Message | undefined {
    if (wakuMsg.payload) {
      try {
        const chatMsg = ChatMessage.decode(wakuMsg.payload);
        if (chatMsg) {
          return new Message(chatMsg, wakuMsg.timestamp);
        }
      } catch (e) {
        console.error("Failed to decode chat message", e);
      }
    }
    return;
  }

  static fromUtf8String(nick: string, text: string): Message {
    const now = new Date();
    return new Message(ChatMessage.fromUtf8String(now, nick, text), now);
  }

  get nick() {
    return this.chatMessage.nick;
  }

  get timestamp() {
    return this.chatMessage.timestamp;
  }

  get payloadAsUtf8() {
    return this.chatMessage.payloadAsUtf8;
  }
}