import type { Uint8ArrayList } from "uint8arraylist";
import { v4 as uuid } from "uuid";

import * as proto from "../../proto/light_push";

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

  static createRequest(
    message: proto.WakuMessage,
    pubSubTopic: string
  ): PushRPC {
    return new PushRPC({
      requestId: uuid(),
      request: {
        message: message,
        pubSubTopic: pubSubTopic,
      },
      response: undefined,
    });
  }

  static decode(bytes: Uint8ArrayList): PushRPC {
    const res = proto.PushRPC.decode(bytes);
    return new PushRPC(res);
  }

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

  get query(): proto.PushRequest | undefined {
    return this.proto.request;
  }

  get response(): proto.PushResponse | undefined {
    return this.proto.response;
  }
}