Expose EventSchemas in Inngest instances

.changeset/mean-brooms-pull.md

@@ -0,0 +1,5 @@
+---
+"inngest": patch
+---
+
+Expose `EventSchemas` in `Inngest` instances

packages/inngest/src/components/EventSchemas.ts

@@ -248,6 +248,15 @@ export class EventSchemas<
     [internalEvents.ScheduledTimer]: ScheduledTimerEventPayload;
   }>,
 > {
+  protected runtimeSchemas: Record<string, unknown> = {};
+
+  private addRuntimeSchemas(schemas: Record<string, unknown>) {
+    this.runtimeSchemas = {
+      ...this.runtimeSchemas,
+      ...schemas,
+    };
+  }
+
   /**
    * Use generated Inngest types to type events.
    */
@@ -343,7 +352,6 @@ export class EventSchemas<
    * ```
    */
   public fromZod<T extends ZodEventSchemas | LiteralZodEventSchemas>(
-    // eslint-disable-next-line @typescript-eslint/no-unused-vars
     schemas: T
   ): EventSchemas<
     Combine<
@@ -353,6 +361,26 @@ export class EventSchemas<
       >
     >
   > {
+    let runtimeSchemas: Record<string, unknown>;
+
+    if (Array.isArray(schemas)) {
+      runtimeSchemas = schemas.reduce((acc, schema) => {
+        const {
+          name: { value: name },
+          ...rest
+        } = schema.shape;
+
+        return {
+          ...acc,
+          [name]: rest,
+        };
+      }, {});
+    } else {
+      runtimeSchemas = schemas;
+    }
+
+    this.addRuntimeSchemas(runtimeSchemas);
+
     return this;
   }
 }

packages/inngest/src/components/Inngest.ts

@@ -151,6 +151,8 @@ export class Inngest<TClientOpts extends ClientOptions = ClientOptions> {
    */
   private _mode!: Mode;
 
+  protected readonly schemas?: NonNullable<TClientOpts["schemas"]>;
+
   get apiBaseUrl(): string | undefined {
     return this._apiBaseUrl;
   }
@@ -192,6 +194,7 @@ export class Inngest<TClientOpts extends ClientOptions = ClientOptions> {
       logger = new DefaultLogger(),
       middleware,
       isDev,
+      schemas,
     } = this.options;
 
     if (!id) {
@@ -216,6 +219,7 @@ export class Inngest<TClientOpts extends ClientOptions = ClientOptions> {
       mode: this.mode,
     });
 
+    this.schemas = schemas;
     this.loadModeEnvVars();
 
     this.logger = logger;