@chronark/zod-bird - npm Package Compare versions

Comparing version 0.3.1-canary.0 to 0.3.1-canary.1

dist/index.d.ts

@@ -87,6 +87,6 @@ import { z } from 'zod';
     }>;
-    buildIngestEndpoint<TEvent extends Record<string, unknown>>(req: {
+    buildIngestEndpoint<TOutput extends Record<string, unknown>, TInput = TOutput>(req: {
         datasource: string;
-        event: z.ZodSchema<TEvent, any, any>;
-    }): (events: TEvent | TEvent[]) => Promise<z.infer<typeof eventIngestReponseData>>;
+        event: z.ZodSchema<TOutput, z.ZodTypeDef, TInput>;
+    }): (events: TInput | TInput[]) => Promise<z.infer<typeof eventIngestReponseData>>;
 }
@@ -113,8 +113,8 @@
     }>;
-    buildIngestEndpoint<TEvent extends Record<string, unknown>>(req: {
+    buildIngestEndpoint<TOutput extends Record<string, unknown>, TInput = TOutput>(req: {
         datasource: string;
-        event: z.ZodSchema<TEvent, any, any>;
-    }): (events: TEvent | TEvent[]) => Promise<z.infer<typeof eventIngestReponseData>>;
+        event: z.ZodSchema<TOutput, z.ZodTypeDef, TInput>;
+    }): (events: TInput | TInput[]) => Promise<z.infer<typeof eventIngestReponseData>>;
 }
 
 export { NoopTinybird, Tinybird };

package.json

 {
   "name": "@chronark/zod-bird",
-  "version": "0.3.1-canary.0",
+  "version": "0.3.1-canary.1",
   "description": "",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/client.ts

@@ -83,8 +83,8 @@ import { type PipeErrorResponse, eventIngestReponseData, pipeResponseWithoutData } from "./util";
 
-  public buildIngestEndpoint<TEvent extends Record<string, unknown>,>(req: {
+  public buildIngestEndpoint<TOutput extends Record<string, unknown>, TInput = TOutput>(req: {
     datasource: string;
-    event: z.ZodSchema<TEvent, any, any>;
-  }): (events: TEvent | TEvent[]) => Promise<z.infer<typeof eventIngestReponseData>> {
-    return async (events: TEvent | TEvent[]) => {
-      let validatedEvents: typeof events | undefined = undefined;
+    event: z.ZodSchema<TOutput, z.ZodTypeDef, TInput>;
+  }): (events: TInput | TInput[]) => Promise<z.infer<typeof eventIngestReponseData>> {
+    return async (events: TInput | TInput[]) => {
+      let validatedEvents: TOutput | TOutput[] | undefined = undefined;
       if (req.event) {
@@ -91,0 +91,0 @@ const v = Array.isArray(events)

src/examples.ts

@@ -86,2 +86,12 @@ /**
 
+export const publishTransformedEvents = tb.buildIngestEndpoint({
+  datasource: "events__v1",
+  event: z.object({
+    actor: z
+      .object({ id: z.string(), name: z.string() })
+      .transform((val) => JSON.stringify(val)),
+  }),
+});
+
 // await publishEvents([{ id: "1" }, { id: "2" }])
+// await publishTransformedEvents({ actor: { id: "1", name: "John" } });

src/noop.ts

@@ -55,8 +55,8 @@ import { z } from "zod";
 
-  public buildIngestEndpoint<TEvent extends Record<string, unknown>,>(req: {
+  public buildIngestEndpoint<TOutput extends Record<string, unknown>, TInput = TOutput>(req: {
     datasource: string;
-    event: z.ZodSchema<TEvent, any, any>;
-  }): (events: TEvent | TEvent[]) => Promise<z.infer<typeof eventIngestReponseData>> {
-    return async (events: TEvent | TEvent[]) => {
-      let validatedEvents: typeof events | undefined = undefined;
+    event: z.ZodSchema<TOutput, z.ZodTypeDef, TInput>;
+  }): (events: TInput | TInput[]) => Promise<z.infer<typeof eventIngestReponseData>> {
+    return async (events: TInput | TInput[]) => {
+      let validatedEvents: TOutput | TOutput[] | undefined = undefined;
       if (req.event) {
@@ -63,0 +63,0 @@ const v = req.event.safeParse(events);

No alert changes

Improved metrics

Total package byte prevSize

68918

increased by0.87%

Lines of code

943

increased by0.96%

No dependency changes