feat: onError callback for event consumers

examples/ai-token-stream-expr-usage.ts

@@ -33,7 +33,13 @@ async function* tokenUsageFromAIStream(): AsyncGenerator<AITokenUsagePayload> {
 
 async function main() {
   const response = await scrawn.aiTokenStreamConsumer(tokenUsageFromAIStream());
-  console.log(`Streamed ${response.getEventsprocessed()} token usage events with expression pricing`);
+  if (!response) {
+    console.log("No token events were processed due to an error");
+    return;
+  }
+  console.log(
+    `Streamed ${response.getEventsprocessed()} token usage events with expression pricing`
+  );
 }
 
 main().catch(console.error);

examples/ai-token-stream-usage.ts

@@ -40,6 +40,11 @@ async function fireAndForgetExample() {
 
   const response = await scrawn.aiTokenStreamConsumer(tokenUsageFromAIStream());
 
+  if (!response) {
+    console.log("No token events were processed due to an error");
+    return;
+  }
+
   console.log(`Streamed ${response.getEventsprocessed()} token usage events`);
 }
 
@@ -51,7 +56,9 @@ async function returnModeExample() {
 
   const { response, stream } = await scrawn.aiTokenStreamConsumer(
     tokenUsageFromAIStream(),
-    { return: true }
+    {
+      return: true,
+    }
   );
 
   // Stream tokens to user while billing happens in background
@@ -64,6 +71,10 @@ async function returnModeExample() {
 
   // Billing completes after stream is consumed
   const result = await response;
+  if (!result) {
+    console.log("Billing failed before processing events");
+    return;
+  }
   console.log(`Billing complete: ${result.getEventsprocessed()} events processed`);
 }
 

examples/sdkcall-expr-usage.ts

@@ -8,20 +8,26 @@ async function main() {
     baseURL: process.env.SCRAWN_BASE_URL || "http://localhost:8069",
   });
 
-  await scrawn.sdkCallEventConsumer({
-    userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
-    debitExpr: tag("PREMIUM_FEATURE"),
-  });
+  await scrawn.sdkCallEventConsumer(
+    {
+      userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
+      debitExpr: tag("PREMIUM_FEATURE"),
+    }
+  );
 
-  await scrawn.sdkCallEventConsumer({
-    userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
-    debitExpr: mul(tag("PER_CALL"), 3),
-  });
+  await scrawn.sdkCallEventConsumer(
+    {
+      userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
+      debitExpr: mul(tag("PER_CALL"), 3),
+    }
+  );
 
-  await scrawn.sdkCallEventConsumer({
-    userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
-    debitExpr: add(mul(tag("BASE_RATE"), 5), tag("SURCHARGE"), 100),
-  });
+  await scrawn.sdkCallEventConsumer(
+    {
+      userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
+      debitExpr: add(mul(tag("BASE_RATE"), 5), tag("SURCHARGE"), 100),
+    }
+  );
 
   console.log("SDK call expression events consumed successfully");
 }

examples/sdkcall-usage.ts

@@ -8,15 +8,19 @@ async function main() {
     baseURL: process.env.SCRAWN_BASE_URL || "http://localhost:8069",
   });
 
-  await scrawn.sdkCallEventConsumer({
-    userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
-    debitAmount: 3000,
-  });
+  await scrawn.sdkCallEventConsumer(
+    {
+      userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
+      debitAmount: 3000,
+    }
+  );
 
-  await scrawn.sdkCallEventConsumer({
-    userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
-    debitTag: "PREMIUM_FEATURE",
-  });
+  await scrawn.sdkCallEventConsumer(
+    {
+      userId: "c0971bcb-b901-4c3e-a191-c9a97871c39f",
+      debitTag: "PREMIUM_FEATURE",
+    }
+  );
 
   console.log("SDK call events consumed successfully");