task: Use Stripe PaymentIntents API for credit history

Author: tomharmon

bifrost/lib/clients/jawnTypes/private.ts

@@ -16,6 +16,7 @@ import type { JawnAuthenticatedRequest } from "../../types/request";
 import { isError } from "../../packages/common/result";
 import express from "express";
 import { checkFeatureFlag } from "../../lib/utils/featureFlags";
+import Stripe from "stripe";
 
 export interface UpgradeToProRequest {
   addons?: {
@@ -36,6 +37,23 @@ export interface CreateCloudGatewayCheckoutSessionRequest {
   amount: number;
 }
 
+export enum PaymentIntentSearchKind {
+  CREDIT_PURCHASES = "credit_purchases",
+}
+
+export interface SearchPaymentIntentsRequest {
+  search_kind: PaymentIntentSearchKind;
+  limit?: number;
+  page?: string;
+}
+
+export interface StripePaymentIntentsResponse {
+  data: Stripe.PaymentIntent[];
+  has_more: boolean;
+  next_page: string | null;
+  count: number;
+}
+
 
 export interface LLMUsage {
   model: string;
@@ -363,6 +381,35 @@ export class StripeController extends Controller {
     const result = await stripeManager.migrateToPro();
   }
 
+  @Get("/payment-intents/search")
+  public async searchPaymentIntents(
+    @Request() request: JawnAuthenticatedRequest,
+    @Query() search_kind: string,
+    @Query() limit?: number,
+    @Query() page?: string
+  ): Promise<StripePaymentIntentsResponse> {
+    // Check if search_kind is valid
+    if (!Object.values(PaymentIntentSearchKind).includes(search_kind as PaymentIntentSearchKind)) {
+      this.setStatus(400);
+      throw new Error(`Invalid search_kind: ${search_kind}. Supported types: ${Object.values(PaymentIntentSearchKind).join(", ")}`);
+    }
+
+    const searchKind = search_kind as PaymentIntentSearchKind;
+    const stripeManager = new StripeManager(request.authParams);
+    const result = await stripeManager.searchPaymentIntents(
+      searchKind,
+      limit ?? 10,
+      page
+    );
+
+    if (isError(result)) {
+      this.setStatus(500);
+      throw new Error(result.error);
+    }
+
+    return result.data;
+  }
+
   @Get("/subscription")
   public async getSubscription(
     @Request() request: JawnAuthenticatedRequest

bifrost/lib/clients/jawnTypes/public.ts

@@ -3,6 +3,8 @@ import {
   LLMUsage,
   UpgradeToProRequest,
   UpgradeToTeamBundleRequest,
+  StripePaymentIntentsResponse,
+  PaymentIntentSearchKind,
 } from "../../controllers/public/stripeController";
 import { clickhouseDb } from "../../lib/db/ClickhouseWrapper";
 import { Database } from "../../lib/db/database.types";
@@ -1345,5 +1347,57 @@ WHERE (${builtFilter.filter})`,
       return err(`Error retrieving purchased seats: ${error.message}`);
     }
   }
+
+  public async searchPaymentIntents(
+    searchKind: PaymentIntentSearchKind,
+    limit: number = 10,
+    page?: string
+  ): Promise<Result<StripePaymentIntentsResponse, string>> {
+    try {
+      let query: string;
+
+      // Build query based on search kind
+      switch (searchKind) {
+        case PaymentIntentSearchKind.CREDIT_PURCHASES:
+          const productId = process.env.STRIPE_CLOUD_GATEWAY_TOKEN_USAGE_PRODUCT;
+          
+          if (!productId) {
+            console.error(
+              "[Stripe API] STRIPE_CLOUD_GATEWAY_TOKEN_USAGE_PRODUCT not configured"
+            );
+            return err("Stripe product ID not configured");
+          }
+          
+          query = `metadata['productId']:'${productId}' AND metadata['orgId']:'${this.authParams.organizationId}'`;
+          break;
+          
+        default:
+          return err(`Unsupported search kind: ${searchKind}`);
+      }
+
+      // Search payment intents using Stripe API
+      const searchParams: any = {
+        query,
+        limit,
+      };
+
+      // Add page parameter if provided (Stripe uses page token for search pagination)
+      if (page) {
+        searchParams.page = page;
+      }
+
+      const paymentIntents = await this.stripe.paymentIntents.search(searchParams);
+
+      return ok({
+        data: paymentIntents.data,
+        has_more: paymentIntents.has_more,
+        next_page: paymentIntents.next_page || null,
+        count: paymentIntents.data.length,
+      });
+    } catch (error: any) {
+      console.error("Error searching payment intents:", error);
+      return err("Failed to search payment intents");
+    }
+  }
 }