feat(effect): add type guards for Action, Message, and Actor

Author: IGassmann

rivetkit-typescript/packages/effect/src/Action.ts

@@ -1,8 +1,12 @@
 import { type Pipeable, pipeArguments } from "effect/Pipeable";
+import * as Predicate from "effect/Predicate";
 import * as Schema from "effect/Schema";
 
 const TypeId = "~@rivetkit/effect/Action";
 
+export const isAction = (u: unknown): u is Action<any, any, any, any> =>
+	Predicate.hasProperty(u, TypeId);
+
 /**
  * A Rivet Actor action: a synchronous request-response call dispatched
  * on the actor's main loop.

rivetkit-typescript/packages/effect/src/Actor.ts

@@ -2,6 +2,7 @@ import * as Context from "effect/Context";
 import type * as Effect from "effect/Effect";
 import * as Layer from "effect/Layer";
 import { type Pipeable, pipeArguments } from "effect/Pipeable";
+import * as Predicate from "effect/Predicate";
 import type * as PubSub from "effect/PubSub";
 import type * as Queue from "effect/Queue";
 import * as Schema from "effect/Schema";
@@ -13,6 +14,9 @@ import type * as Message from "./Message";
 
 const TypeId = "~@rivetkit/effect/Actor";
 
+export const isActor = (u: unknown): u is Actor<any, any, any, any, any> =>
+	Predicate.hasProperty(u, TypeId);
+
 /**
  * Schemas keyed by the event names an actor can publish.
  */
@@ -441,9 +445,6 @@ export type ServerServices<A> = A extends Actor<
 			| EventEncodeServices<_Events>
 	: never;
 
-export const isActor = (u: unknown): u is Any =>
-	typeof u === "object" && u !== null && TypeId in u;
-
 const identity = <A>(value: A): A => value;
 
 const Proto = {

rivetkit-typescript/packages/effect/src/Message.ts

@@ -1,10 +1,14 @@
 import { type Pipeable, pipeArguments } from "effect/Pipeable";
+import * as Predicate from "effect/Predicate";
 import * as Schema from "effect/Schema";
 
 const TypeId = "~@rivetkit/effect/Message";
 
 const EnvelopeTypeId = "~@rivetkit/effect/Message/Envelope";
 
+export const isMessage = (u: unknown): u is Message<any, any, any> =>
+	Predicate.hasProperty(u, TypeId);
+
 /**
  * A Rivet Actor message: a durable, queued operation that the actor
  * processes asynchronously on its main loop.