logos-delivery-js/src/lib/waku_light_push/push_rpc.ts

import { v4 as uuid } from "uuid";

import * as proto from "../../proto/light_push";
import { WakuMessage } from "../waku_message";

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

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

  static decode(bytes: Uint8Array): 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;
  }
}