diff --git a/src/__test__/helper.ts b/src/__test__/helper.ts
index e86fc57..72fc208 100644
--- a/src/__test__/helper.ts
+++ b/src/__test__/helper.ts
@@ -28,17 +28,73 @@ export const faker = {
         }
     >
   ): EventPacket {
+    const message: Nostr.ToClientMessage.EVENT = [
+      "EVENT",
+      packetOrEvent?.subId ?? "*",
+      faker.event(packetOrEvent?.event ?? packetOrEvent),
+    ];
+
     return {
       from: packetOrEvent?.from ?? "*",
       subId: packetOrEvent?.subId ?? "*",
       event: faker.event(packetOrEvent?.event ?? packetOrEvent),
+      message,
+      type: "EVENT",
     };
   },
   messagePacket(message: Nostr.ToClientMessage.Any): MessagePacket {
-    return {
-      from: "*",
-      message,
-    };
+    const from = "*";
+    const type = message[0];
+
+    switch (type) {
+      case "EVENT":
+        return {
+          from,
+          type,
+          message,
+          subId: message[1],
+          event: message[2],
+        };
+      case "EOSE":
+        return {
+          from,
+          type,
+          message,
+          subId: message[1],
+        };
+      case "OK":
+        return {
+          from,
+          type,
+          message,
+          eventId: message[1],
+          id: message[1],
+          ok: message[2],
+          notice: message[3],
+        };
+      case "NOTICE":
+        return {
+          from,
+          type,
+          message,
+          notice: message[1],
+        };
+      case "AUTH":
+        return {
+          from,
+          type,
+          message,
+          challengeMessage: message[1],
+        };
+      case "COUNT":
+        return {
+          from,
+          type,
+          message,
+          subId: message[1],
+          count: message[2],
+        };
+    }
   },
 };
 
diff --git a/src/__test__/keep-alive.test.ts b/src/__test__/keep-alive.test.ts
index 5c3bfb2..954c9c1 100644
--- a/src/__test__/keep-alive.test.ts
+++ b/src/__test__/keep-alive.test.ts
@@ -2,7 +2,7 @@ import { afterEach, beforeEach, describe, expect, test } from "vitest";
 import { createMockRelay, type MockRelay } from "vitest-nostr";
 
 import { createRxForwardReq, createRxNostr, RxNostr } from "../index.js";
-import { disposeMockRelay, faker, spyEvent, stateWillBe } from "./helper.js";
+import { disposeMockRelay, faker, stateWillBe } from "./helper.js";
 
 describe("", () => {
   const DEFAULT_RELAY = "ws://localhost:1234";
diff --git a/src/__test__/operator.test.ts b/src/__test__/operator.test.ts
index 115737f..84c5abf 100644
--- a/src/__test__/operator.test.ts
+++ b/src/__test__/operator.test.ts
@@ -87,8 +87,8 @@ test("tie()", async () => {
       }))
     );
 
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
     expectObservable(packet$).toEqual(
+      // eslint-disable-next-line @typescript-eslint/no-explicit-any
       of<any[]>(
         {
           ...packets[0],
diff --git a/src/rx-nostr/utils.ts b/src/rx-nostr/utils.ts
index acce792..9c3986a 100644
--- a/src/rx-nostr/utils.ts
+++ b/src/rx-nostr/utils.ts
@@ -1,6 +1,4 @@
-import { filter, type OperatorFunction } from "rxjs";
-
-import type { LazyFilter, LazyREQ, MessagePacket } from "../packet.js";
+import type { LazyFilter, LazyREQ } from "../packet.js";
 import type { RxReq } from "../req.js";
 import type {
   AcceptableDefaultRelaysConfig,