Better event logs

N2D4 · N2D4 · commit 3ae372010502 · 2024-08-11T15:25:45.000-07:00
diff --git a/apps/backend/src/lib/events.tsx b/apps/backend/src/lib/events.tsx
@@ -4,6 +4,7 @@ import * as yup from "yup";
 import { UnionToIntersection } from "@stackframe/stack-shared/dist/utils/types";
 import { StackAssertionError } from "@stackframe/stack-shared/dist/utils/errors";
 import { prismaClient } from "@/prisma-client";
+import posthog from "posthog-js";
 
 type EventType = {
   id: string,
@@ -124,7 +125,7 @@ export async function logEvent<T extends EventType[]>(
   }
 
 
-  // log event
+  // log event in DB
   await prismaClient.event.create({
     data: {
       systemEventTypeIds: [...allEventTypes].map(eventType => eventType.id),
@@ -134,4 +135,15 @@ export async function logEvent<T extends EventType[]>(
       eventEndedAt: timeRange.end,
     },
   });
+
+  // log event in PostHog
+  for (const eventType of allEventTypes) {
+    const postHogEventName = `stack_${eventType.id.replace(/^\$/, "system_").replace(/-/g, "_")}`;
+    posthog.capture(postHogEventName, {
+      data,
+      isWide,
+      eventStartedAt: timeRange.start,
+      eventEndedAt: timeRange.end,
+    });
+  }
 }
diff --git a/apps/backend/src/oauth/providers/base.tsx b/apps/backend/src/oauth/providers/base.tsx
@@ -10,13 +10,13 @@ export type TokenSet = {
   accessTokenExpiredAt: Date,
 };
 
-function processTokenSet(tokenSet: OIDCTokenSet): TokenSet {
+function processTokenSet(providerName: string, tokenSet: OIDCTokenSet): TokenSet {
   if (!tokenSet.access_token) {
     throw new StackAssertionError("No access token received", { tokenSet });
   }
 
   if (!tokenSet.expires_in) {
-    captureError("processTokenSet", "No expires_in received");
+    captureError("processTokenSet", new StackAssertionError(`No expires_in received from OAuth provider ${providerName}.`, { tokenSetKeys: Object.keys(tokenSet) }));
   }
 
   return {
@@ -123,7 +123,7 @@ export abstract class OAuthBaseProvider {
 
     }
 
-    tokenSet = processTokenSet(tokenSet);
+    tokenSet = processTokenSet(this.constructor.name, tokenSet);
 
     return {
       userInfo: await this.postProcessUserInfo(tokenSet),
@@ -136,7 +136,7 @@ export abstract class OAuthBaseProvider {
     scope?: string,
   }): Promise<TokenSet> {
     const tokenSet = await this.oauthClient.refresh(options.refreshToken, { exchangeBody: { scope: options.scope } });
-    return processTokenSet(tokenSet);
+    return processTokenSet(this.constructor.name, tokenSet);
   }
 
   abstract postProcessUserInfo(tokenSet: TokenSet): Promise<OAuthUserInfo>;
