feat: remove all credit usage logging (#5428)

* chore: remove `unneeded` fields from `checkAndDeductOrganizationCredits` call

* feat: remove all credit `usage` logging

* chore: delete unnecessary `transactions` and drop `credit_transactions`

Author: Jabolol

apps/frontend/app/api/v1/chat/completions/route.ts

@@ -46,8 +46,6 @@ export const POST = withPostHogTracking(async (req: NextRequest) => {
         orgId,
         TransactionType.AGENT_QUERY,
         tracker,
-        "/api/v1/chat/completions",
-        { message: getLatestMessage(body.messages) },
       );
     } catch (error) {
       if (error instanceof InsufficientCreditsError) {

apps/frontend/app/api/v1/chat/route.ts

@@ -62,8 +62,6 @@ export const POST = withPostHogTracking(async (req: NextRequest) => {
       org.id,
       TransactionType.CHAT_QUERY,
       tracker,
-      "/api/v1/chat",
-      { message: getLatestMessage(prompt.messages) },
     );
   } catch (error) {
     if (error instanceof InsufficientCreditsError) {

apps/frontend/app/api/v1/graphql/route.ts

@@ -140,21 +140,11 @@ const customHandler = async (req: NextRequest) => {
   const requestClone = req.clone();
   const tracker = trackServerEvent(user);
 
-  let operation = "unknown";
   let query = "";
 
   try {
     const body = await requestClone.json();
     query = body.query || "";
-
-    // TODO(jabolo): Use a real parser to extract operation type and name
-    if (query.includes("query")) {
-      operation = "query";
-    } else if (query.includes("mutation")) {
-      operation = "mutation";
-    } else if (query.includes("subscription")) {
-      operation = "subscription";
-    }
   } catch (error) {
     logger.error("Error parsing GraphQL request body:", error);
   }
@@ -179,8 +169,6 @@ const customHandler = async (req: NextRequest) => {
       user.orgId,
       TransactionType.GRAPHQL_QUERY,
       tracker,
-      "/api/v1/graphql",
-      { operation, query },
     );
   } catch (error) {
     if (error instanceof InsufficientCreditsError) {

apps/frontend/app/api/v1/responses/route.ts

@@ -46,8 +46,6 @@ export const POST = withPostHogTracking(async (req: NextRequest) => {
         orgId,
         TransactionType.AGENT_QUERY,
         tracker,
-        "/api/v1/chat/responses",
-        { message: getLatestMessage(body.messages) },
       );
     } catch (error) {
       if (error instanceof InsufficientCreditsError) {

apps/frontend/app/api/v1/sql/route.ts

@@ -114,8 +114,6 @@ export const POST = withPostHogTracking(async (request: NextRequest) => {
       user.orgId,
       TransactionType.SQL_QUERY,
       tracker,
-      "/api/v1/sql",
-      { query },
     );
   } catch (error) {
     if (error instanceof InsufficientCreditsError) {

apps/frontend/app/api/v1/text2sql/route.ts

@@ -46,8 +46,6 @@ export const POST = withPostHogTracking(async (req: NextRequest) => {
         orgId,
         TransactionType.TEXT2SQL,
         tracker,
-        "/api/v1/text2sql",
-        { message: getLatestMessage(prompt.messages) },
       );
     } catch (error) {
       if (error instanceof InsufficientCreditsError) {

apps/frontend/lib/services/credits.test.ts

@@ -165,7 +165,6 @@ describe("CreditsService", () => {
         TEST_ORG_ID,
         TransactionType.AGENT_QUERY,
         mockTracker,
-        "/api/test",
       );
 
       expect(result).toBeDefined();
@@ -178,18 +177,6 @@ describe("CreditsService", () => {
         .single();
 
       expect(credits?.credits_balance).toBe(100 - FREE_PLAN_COST);
-
-      const { data: transactions } = await adminSupabase
-        .from("organization_credit_transactions")
-        .select("*")
-        .eq("org_id", TEST_ORG_ID)
-        .order("created_at", { ascending: false })
-        .limit(1);
-
-      expect(transactions?.[0]?.amount).toBe(-FREE_PLAN_COST);
-      expect(transactions?.[0]?.transaction_type).toBe(
-        TransactionType.AGENT_QUERY,
-      );
     });
 
     it("should throw InsufficientCreditsError when balance too low", async () => {
@@ -215,56 +202,12 @@ describe("CreditsService", () => {
           TEST_ORG_ID,
           TransactionType.AGENT_QUERY,
           mockTracker,
-          "/api/test",
         ),
       ).rejects.toThrow(InsufficientCreditsError);
 
       expect(mockTracker.track).toHaveBeenCalled();
     });
 
-    it("should log failed transaction when insufficient credits", async () => {
-      await adminSupabase
-        .from("organization_credits")
-        .update({ credits_balance: 0 })
-        .eq("org_id", TEST_ORG_ID);
-
-      const user: OrgUser = {
-        userId: TEST_USER_ID,
-        role: "user",
-        orgId: TEST_ORG_ID,
-        orgName: "test",
-        orgRole: "admin",
-        name: "Test User",
-        keyName: "test-key",
-        host: null,
-      };
-
-      try {
-        await CreditsService.checkAndDeductOrganizationCredits(
-          user,
-          TEST_ORG_ID,
-          TransactionType.AGENT_QUERY,
-          mockTracker,
-          "/api/test",
-        );
-      } catch (err) {
-        void err;
-      }
-
-      const { data: transactions } = await adminSupabase
-        .from("organization_credit_transactions")
-        .select("*")
-        .eq("org_id", TEST_ORG_ID)
-        .order("created_at", { ascending: false })
-        .limit(1);
-
-      expect(transactions).toHaveLength(1);
-      expect(transactions?.[0]?.amount).toBeLessThan(0);
-      expect(transactions?.[0]?.transaction_type).toBe(
-        TransactionType.AGENT_QUERY,
-      );
-    });
-
     it("should return null for anonymous users", async () => {
       const anonUser: OrgUser = { role: "anonymous" as const, host: null };
 
@@ -273,7 +216,6 @@ describe("CreditsService", () => {
         TEST_ORG_ID,
         TransactionType.AGENT_QUERY,
         mockTracker,
-        "/api/test",
       );
 
       expect(result).toBeNull();
@@ -309,7 +251,6 @@ describe("CreditsService", () => {
         TEST_ORG_ID,
         TransactionType.AGENT_QUERY,
         mockTracker,
-        "/api/test",
       );
 
       const { data: credits } = await adminSupabase
@@ -367,7 +308,6 @@ describe("CreditsService", () => {
         TEST_ORG_ID,
         TransactionType.AGENT_QUERY,
         mockTracker,
-        "/api/test",
       );
 
       const { data: credits } = await adminSupabase

apps/frontend/lib/services/credits.ts

@@ -88,53 +88,11 @@ export class InsufficientCreditsError extends Error {
   }
 }
 
-interface TransactionLogParams {
-  orgId: string;
-  userId: string;
-  amount: number;
-  transactionType: TransactionType;
-  apiEndpoint?: string;
-  metadata?: Record<string, any>;
-  error?: {
-    type: "insufficient_credits" | "transaction_failed";
-    details?: Record<string, any>;
-  };
-}
-
 export class CreditsService {
   static isAnonymousUser(user: OrgUser | User): user is AnonUser {
     return user.role === "anonymous";
   }
 
-  private static async logTransaction(
-    client: SupabaseClient,
-    params: TransactionLogParams,
-  ): Promise<void> {
-    const {
-      orgId,
-      userId,
-      amount,
-      transactionType,
-      apiEndpoint,
-      metadata,
-      error,
-    } = params;
-
-    const finalMetadata = error
-      ? { error: error.type, ...error.details, ...metadata }
-      : metadata;
-
-    await client.from("organization_credit_transactions").insert({
-      org_id: orgId,
-      user_id: userId,
-      amount,
-      transaction_type: transactionType,
-      api_endpoint: apiEndpoint,
-      metadata: finalMetadata,
-      created_at: new Date().toISOString(),
-    });
-  }
-
   private static async validateUserAccess(
     client: SupabaseClient,
     actingUserId: string,
@@ -454,8 +412,6 @@ export class CreditsService {
     orgId: string,
     transactionType: TransactionType,
     tracker: PostHogTracker,
-    apiEndpoint?: string,
-    metadata?: Record<string, any>,
   ): Promise<OrganizationPlan | null> {
     if (CreditsService.isAnonymousUser(user)) {
       return null;
@@ -482,22 +438,6 @@ export class CreditsService {
       );
 
       if (!deductionResult.success) {
-        await CreditsService.logTransaction(client, {
-          orgId,
-          userId: user.userId,
-          amount: -costPerCall,
-          transactionType,
-          apiEndpoint,
-          metadata,
-          error: {
-            type: "insufficient_credits",
-            details: {
-              attempted_amount: costPerCall,
-              current_balance: deductionResult.currentBalance,
-            },
-          },
-        });
-
         await CreditsService.handleInsufficientCredits(
           client,
           orgId,
@@ -506,32 +446,8 @@ export class CreditsService {
         );
       }
 
-      await CreditsService.logTransaction(client, {
-        orgId,
-        userId: user.userId,
-        amount: -costPerCall,
-        transactionType,
-        apiEndpoint,
-        metadata,
-      });
-
       return orgPlan;
     } catch (error) {
-      await CreditsService.logTransaction(client, {
-        orgId,
-        userId: user.userId,
-        amount: -costPerCall,
-        transactionType,
-        apiEndpoint,
-        metadata,
-        error: {
-          type: "transaction_failed",
-          details: {
-            sql_error: error instanceof Error ? error.message : String(error),
-          },
-        },
-      });
-
       logger.error("Exception in checkAndDeductOrganizationCredits:", error);
       throw error;
     }

apps/frontend/supabase/migrations/20251018000000_drop_credit_usage_tracking.sql

@@ -0,0 +1,10 @@
+DROP TABLE IF EXISTS public.credit_transactions CASCADE;
+
+DELETE FROM public.organization_credit_transactions
+WHERE transaction_type IN (
+    'sql_query',
+    'graphql_query',
+    'chat_query',
+    'text2sql',
+    'agent_query'
+);