add nodejs checks

src/host.ts

@@ -1,4 +1,4 @@
-import { extractMethods, generateId, getOriginFromURL } from "./helpers";
+import { extractMethods, generateId, getOriginFromURL, isNodeEnv } from "./helpers";
 import { registerLocalMethods, registerRemoteMethods } from "./rpc";
 import { actions, events, IConnection, IConnections, ISchema } from "./types";
 
@@ -25,14 +25,14 @@ function connect(guest: HTMLIFrameElement | Worker, schema: ISchema = {}): Promi
   if (!guest) throw new Error("a target is required");
 
   const guestIsWorker = (guest as Worker).onerror !== undefined && (guest as Worker).onmessage !== undefined;
-  const listeners = guestIsWorker ? guest : window;
+  const listeners = guestIsWorker || isNodeEnv() ? guest : window;
 
   return new Promise((resolve) => {
     const connectionID = generateId();
 
     // on handshake request
     function handleHandshake(event: any) {
-      if (!guestIsWorker && !isValidTarget(guest as HTMLIFrameElement, event)) return;
+      if (!guestIsWorker && !isNodeEnv() && !isValidTarget(guest as HTMLIFrameElement, event)) return;
       if (event.data.action !== actions.HANDSHAKE_REQUEST) return;
 
       // register local methods
@@ -41,7 +41,7 @@ function connect(guest: HTMLIFrameElement | Worker, schema: ISchema = {}): Promi
         schema,
         localMethods,
         connectionID,
-        guestIsWorker ? (guest as Worker) : undefined
+        guestIsWorker || isNodeEnv() ? (guest as Worker) : undefined
       );
 
       // register remote methods
@@ -50,7 +50,7 @@ function connect(guest: HTMLIFrameElement | Worker, schema: ISchema = {}): Promi
         event.data.methods,
         connectionID,
         event,
-        guestIsWorker ? (guest as Worker) : undefined
+        guestIsWorker || isNodeEnv() ? (guest as Worker) : undefined
       );
 
       const payload = {

src/rpc.ts

@@ -1,4 +1,4 @@
-import { generateId, get, isWorker, set } from "./helpers";
+import { generateId, get, isNodeEnv, isWorker, set } from "./helpers";
 import { actions, events, IRPCRequestPayload, IRPCResolvePayload, ISchema } from "./types";
 
 /**
@@ -105,12 +105,16 @@ export function createRPC(
         connectionID: _connectionID,
       };
 
-      if (guest) guest.addEventListener(events.MESSAGE, handleResponse);
-      else self.addEventListener(events.MESSAGE, handleResponse);
-      listeners.push(() => self.removeEventListener(events.MESSAGE, handleResponse));
+      if (guest || isNodeEnv()) {
+        guest?.addEventListener(events.MESSAGE, handleResponse);
+        listeners.push(() => guest?.removeEventListener(events.MESSAGE, handleResponse));
+      } else {
+        self.addEventListener(events.MESSAGE, handleResponse);
+        listeners.push(() => self.removeEventListener(events.MESSAGE, handleResponse));
+      }
 
       if (guest) guest.postMessage(payload);
-      else if (isWorker()) (self as any).postMessage(payload);
+      else if (isWorker() || isNodeEnv()) (self as any).postMessage(payload);
       else (event.source || event.target).postMessage(payload, event.origin);
     });
   };