// Ensure that this class matches the proto interface while
import { Reader } from 'protobufjs/minimal';

// Protecting the user from protobuf oddities
import * as proto from '../proto/waku/v2/message';

export const DEFAULT_CONTENT_TOPIC = '/waku/2/default-content/proto';
const DEFAULT_VERSION = 0;

export class WakuMessage {
  public constructor(public proto: proto.WakuMessage) {}

  /**
   * Create Message with a utf-8 string as payload
   * @param utf8
   * @param contentTopic
   * @returns {WakuMessage}
   */
  static fromUtf8String(
    utf8: string,
    contentTopic: string = DEFAULT_CONTENT_TOPIC
  ): WakuMessage {
    const payload = Buffer.from(utf8, 'utf-8');
    return new WakuMessage({
      payload,
      version: DEFAULT_VERSION,
      contentTopic,
    });
  }

  /**
   * Create Message with a byte array as payload
   * @param payload
   * @param contentTopic
   * @returns {WakuMessage}
   */
  static fromBytes(
    payload: Uint8Array,
    contentTopic: string = DEFAULT_CONTENT_TOPIC
  ): WakuMessage {
    return new WakuMessage({
      payload,
      version: DEFAULT_VERSION,
      contentTopic,
    });
  }

  static decode(bytes: Uint8Array): WakuMessage {
    const wakuMsg = proto.WakuMessage.decode(Reader.create(bytes));
    return new WakuMessage(wakuMsg);
  }

  encode(): Uint8Array {
    return proto.WakuMessage.encode(this.proto).finish();
  }

  get payloadAsUtf8(): string {
    if (!this.proto.payload) {
      return '';
    }

    return Array.from(this.proto.payload)
      .map((char) => {
        return String.fromCharCode(char);
      })
      .join('');
  }

  get payload(): Uint8Array | undefined {
    return this.proto.payload;
  }

  get contentTopic(): string | undefined {
    return this.proto.contentTopic;
  }

  get version(): number | undefined {
    return this.proto.version;
  }
}