diff --git a/packages/core/src/lib/light_push/index.ts b/packages/core/src/lib/light_push/index.ts index 30a28072e5..05640d2cb6 100644 --- a/packages/core/src/lib/light_push/index.ts +++ b/packages/core/src/lib/light_push/index.ts @@ -18,7 +18,7 @@ import { Uint8ArrayList } from "uint8arraylist"; import { BaseProtocol } from "../base_protocol.js"; import { DefaultPubSubTopic } from "../constants.js"; -import { PushRPC } from "./push_rpc.js"; +import { PushRpc } from "./push_rpc.js"; const log = debug("waku:light-push"); @@ -54,7 +54,7 @@ class LightPush extends BaseProtocol implements ILightPush { log("Failed to encode to protoMessage, aborting push"); return { recipients }; } - const query = PushRPC.createRequest(protoMessage, pubSubTopic); + const query = PushRpc.createRequest(protoMessage, pubSubTopic); const res = await pipe( [query.encode()], lp.encode(), @@ -68,7 +68,7 @@ class LightPush extends BaseProtocol implements ILightPush { bytes.append(chunk); }); - const response = PushRPC.decode(bytes).response; + const response = PushRpc.decode(bytes).response; if (!response) { log("No response in PushRPC"); diff --git a/packages/core/src/lib/light_push/push_rpc.ts b/packages/core/src/lib/light_push/push_rpc.ts index 3d4621d236..00acebcab0 100644 --- a/packages/core/src/lib/light_push/push_rpc.ts +++ b/packages/core/src/lib/light_push/push_rpc.ts @@ -2,14 +2,14 @@ import { proto_lightpush as proto } from "@waku/proto"; import type { Uint8ArrayList } from "uint8arraylist"; import { v4 as uuid } from "uuid"; -export class PushRPC { +export class PushRpc { public constructor(public proto: proto.PushRpc) {} static createRequest( message: proto.WakuMessage, pubSubTopic: string - ): PushRPC { - return new PushRPC({ + ): PushRpc { + return new PushRpc({ requestId: uuid(), request: { message: message, @@ -19,9 +19,9 @@ export class PushRPC { }); } - static decode(bytes: Uint8ArrayList): PushRPC { + static decode(bytes: Uint8ArrayList): PushRpc { const res = proto.PushRpc.decode(bytes); - return new PushRPC(res); + return new PushRpc(res); } encode(): Uint8Array {