task: Use Stripe PaymentIntents API for credit history

tomharmon · tomharmon · commit c52363af8db9 · 2025-09-08T16:57:47.000-07:00
diff --git a/web/.env.example b/web/.env.example
@@ -19,4 +19,8 @@ NEXT_PUBLIC_SUPABASE_ANON_KEY="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJz
 NEXT_PUBLIC_SUPABASE_URL="http://localhost:54321"
 SUPABASE_SERVICE_KEY="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJzdXBhYmFzZS1kZW1vIiwicm9sZSI6InNlcnZpY2Vfcm9sZSIsImV4cCI6MTk4MzgxMjk5Nn0.EGIM96RAZx35lJzdJsyH-qQwv8Hdp7fsn3W0YpN81IU"
 SUPABASE_URL="http://localhost:54321"
-NEXT_PUBLIC_BETTER_AUTH="false"
+NEXT_PUBLIC_BETTER_AUTH="false"
+
+# only required for pass through billing development
+STRIPE_CLOUD_GATEWAY_TOKEN_USAGE_PRODUCT="prod_"
+STRIPE_SECRET_KEY=""
diff --git a/web/pages/api/stripe/payment-intents/search.ts b/web/pages/api/stripe/payment-intents/search.ts
@@ -0,0 +1,70 @@
+import { NextApiRequest, NextApiResponse } from "next";
+import { stripeServer } from "../../../../utils/stripeServer";
+import { createServerSupabaseClient } from "@supabase/auth-helpers-nextjs";
+import { Database } from "../../../../db/database.types";
+
+export default async function handler(
+  req: NextApiRequest,
+  res: NextApiResponse,
+) {
+  if (req.method !== "GET") {
+    return res.status(405).json({ error: "Method not allowed" });
+  }
+
+  // Check authentication
+  const supabase = createServerSupabaseClient<Database>({
+    req,
+    res,
+  });
+
+  const {
+    data: { user },
+  } = await supabase.auth.getUser();
+
+  if (!user) {
+    return res.status(401).json({ error: "Unauthorized" });
+  }
+
+  try {
+    const { limit = "10", page } = req.query;
+    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 res.status(500).json({ error: "Stripe product ID not configured" });
+    }
+
+    const query = `metadata['productId']:'${productId}'`;
+
+    // Search payment intents using Stripe API
+    const searchParams: any = {
+      query,
+      limit: parseInt(limit as string, 10),
+    };
+    
+    // Add page parameter if provided (Stripe uses page token for search pagination)
+    if (page) {
+      searchParams.page = page as string;
+    }
+    
+    const paymentIntents = await stripeServer.paymentIntents.search(searchParams);
+
+    // Filter to only include succeeded payment intents
+    const filteredData = paymentIntents.data.filter(
+      (intent) => intent.status === "succeeded",
+    );
+
+    return res.status(200).json({
+      data: filteredData,
+      has_more: paymentIntents.has_more,
+      next_page: paymentIntents.next_page || null,
+      count: filteredData.length,
+    });
+  } catch (error: any) {
+    console.error("Error searching payment intents:", error);
+    return res.status(500).json({
+      error: "Failed to search payment intents",
+      message: error.message,
+    });
+  }
+}
diff --git a/web/pages/credits.tsx b/web/pages/credits.tsx
@@ -28,7 +28,8 @@ import { useFeatureFlag } from "@/services/hooks/admin";
 import { FeatureWaitlist } from "@/components/templates/waitlist/FeatureWaitlist";
 
 const Credits: NextPageWithLayout<void> = () => {
-  const [currentPage, setCurrentPage] = useState(0);
+  const [currentPageToken, setCurrentPageToken] = useState<string | null>(null);
+  const [pageTokenHistory, setPageTokenHistory] = useState<string[]>([]);
   const [pageSize, setPageSize] = useState(5);
   const [isPaymentModalOpen, setIsPaymentModalOpen] = useState(false);
 
@@ -49,15 +50,14 @@ const Credits: NextPageWithLayout<void> = () => {
     refetch: refetchTransactions,
     error: transactionsError,
   } = useCreditTransactions({
-    page: currentPage,
-    pageSize: pageSize,
+    limit: pageSize,
+    page: currentPageToken,
   });
 
   const transactions = transactionsData?.purchases || [];
-  const totalTransactions = transactionsData?.total || 0;
-  const totalPages = Math.ceil(totalTransactions / pageSize);
-  const hasMore = currentPage < totalPages - 1;
-  const hasPrevious = currentPage > 0;
+  const hasMore = transactionsData?.hasMore || false;
+  const hasPrevious = pageTokenHistory.length > 0;
+  const currentPageNumber = pageTokenHistory.length + 1;
 
   const hasAccess = hasCreditsFeatureFlag?.data;
 
@@ -330,7 +330,8 @@ const Credits: NextPageWithLayout<void> = () => {
                         onValueChange={(value) => {
                           setPageSize(Number(value));
                           // Reset pagination when changing page size
-                          setCurrentPage(0);
+                          setCurrentPageToken(null);
+                          setPageTokenHistory([]);
                         }}
                       >
                         <SelectTrigger className="h-8 w-[60px]">
@@ -423,23 +424,34 @@ const Credits: NextPageWithLayout<void> = () => {
                           onClick={() => {
                             // Go to previous page
                             if (hasPrevious) {
-                              setCurrentPage(currentPage - 1);
+                              const newHistory = [...pageTokenHistory];
+                              newHistory.pop();
+                              const previousToken =
+                                newHistory.length > 0
+                                  ? newHistory[newHistory.length - 1]
+                                  : null;
+                              setPageTokenHistory(newHistory);
+                              setCurrentPageToken(previousToken);
                             }
                           }}
                           disabled={!hasPrevious}
                         >
                           <ChevronLeft className="h-3 w-3" />
                         </Button>
                         <Badge variant="secondary" className="text-xs">
-                          Page {currentPage + 1} of {totalPages || 1}
+                          Page {currentPageNumber}
                         </Badge>
                         <Button
                           variant="ghost"
                           size="sm"
                           onClick={() => {
                             // Go to next page
-                            if (hasMore) {
-                              setCurrentPage(currentPage + 1);
+                            if (hasMore && transactionsData?.nextPage) {
+                              setPageTokenHistory([
+                                ...pageTokenHistory,
+                                currentPageToken || "",
+                              ]);
+                              setCurrentPageToken(transactionsData.nextPage);
                             }
                           }}
                           disabled={!hasMore}
diff --git a/web/services/hooks/useCredits.ts b/web/services/hooks/useCredits.ts
@@ -1,5 +1,6 @@
 import { useOrg } from "../../components/layout/org/organizationContext";
 import { $JAWN_API } from "../../lib/clients/jawn";
+import { useQuery } from "@tanstack/react-query";
 
 // Types matching the backend
 export interface PurchasedCredits {
@@ -12,8 +13,8 @@ export interface PurchasedCredits {
 export interface PaginatedPurchasedCredits {
   purchases: PurchasedCredits[];
   total: number;
-  page: number;
-  pageSize: number;
+  nextPage: string | null;
+  hasMore: boolean;
 }
 
 export interface CreditBalanceResponse {
@@ -24,14 +25,14 @@ export interface CreditBalanceResponse {
 // A hook for the user's credit balance in cents
 export const useCredits = () => {
   const org = useOrg();
-  
+
   const result = $JAWN_API.useQuery(
     "get",
     "/v1/credits/balance",
     {},
     {
       enabled: !!org?.currentOrg?.id,
-    }
+    },
   );
 
   return {
@@ -40,36 +41,73 @@ export const useCredits = () => {
   };
 };
 
+// Helper function to fetch payment intents from Stripe API
+const fetchStripePaymentIntents = async (
+  limit: number,
+  page?: string | null,
+) => {
+  const queryParams = new URLSearchParams();
+  queryParams.set("limit", limit.toString());
+  if (page) {
+    queryParams.set("page", page);
+  }
+
+  const url = `/api/stripe/payment-intents/search?${queryParams.toString()}`;
+  const response = await fetch(url);
+  
+  if (!response.ok) {
+    const errorText = await response.text();
+    throw new Error(`Failed to fetch payment intents: ${response.status} ${errorText}`);
+  }
+  
+  return response.json();
+};
+
 // A hook for fetching credit balance transactions with pagination
 export const useCreditTransactions = (params?: {
-  page?: number;
-  pageSize?: number;
+  limit?: number;
+  page?: string | null;
 }) => {
   const org = useOrg();
-  
-  const result = $JAWN_API.useQuery(
-    "get",
-    "/v1/credits/payments",
-    {
-      params: {
-        query: {
-          page: params?.page ?? 0,
-          pageSize: params?.pageSize ?? 10,
-        },
-      },
+
+  const result = useQuery({
+    queryKey: [
+      "credit-transactions",
+      org?.currentOrg?.id,
+      params?.limit,
+      params?.page,
+    ],
+    queryFn: async () => {
+      const data = await fetchStripePaymentIntents(
+        params?.limit ?? 10,
+        params?.page,
+      );
+
+      // Transform Stripe payment intents to our format
+      const purchases: PurchasedCredits[] = data.data.map((intent: any) => ({
+        id: intent.id,
+        createdAt: intent.created * 1000, // Convert from seconds to milliseconds
+        credits: intent.amount, // Amount is in cents
+        referenceId: intent.id,
+      }));
+
+      return {
+        purchases,
+        total: data.count || 0,
+        nextPage: data.next_page || null,
+        hasMore: data.has_more || false,
+      };
     },
-    {
-      enabled: !!org?.currentOrg?.id,
-    }
-  );
+    enabled: !!org?.currentOrg?.id,
+  });
 
   return {
     ...result,
-    data: result.data?.data || {
+    data: result.data || {
       purchases: [],
       total: 0,
-      page: 0,
-      pageSize: 10,
+      nextPage: null,
+      hasMore: false,
     },
   };
 };
@@ -86,4 +124,4 @@ export const useCreateCheckoutSession = () => {
       console.error("Failed to create checkout session:", error);
     },
   });
-};
+};
diff --git a/worker/src/lib/durable-objects/Wallet.ts b/worker/src/lib/durable-objects/Wallet.ts
@@ -185,44 +185,6 @@ export class Wallet extends DurableObject<Env> {
     });
   }
 
-  getCreditsPurchases(
-    page?: number,
-    pageSize?: number,
-  ): PaginatedPurchasedCredits {
-    return this.ctx.storage.transactionSync(() => {
-      const pageSizeValue = pageSize ?? 10;
-      const pageValue = page ?? 0;
-      const result = this.ctx.storage.sql.exec<{
-        id: string;
-        created_at: number;
-        credits: number;
-        reference_id: string;
-      }>(
-        "SELECT id, created_at, credits, reference_id FROM credit_purchases LIMIT ? OFFSET ?",
-        pageSizeValue,
-        pageValue * pageSizeValue
-      ).toArray();
-      const total = this.ctx.storage.sql.exec<{ total: number }>(
-        "SELECT COALESCE(COUNT(*), 0) as total FROM credit_purchases"
-      ).one().total;
-      let purchases: PurchasedCredits[] = [];
-      if (result.length > 0) {
-        purchases = result.map((row) => ({
-          id: row.id,
-          createdAt: row.created_at,
-          credits: row.credits / SCALE_FACTOR,
-          referenceId: row.reference_id,
-        }));
-      }
-      return {
-        purchases,
-        total,
-        page: pageValue,
-        pageSize: pageSizeValue,
-      } as PaginatedPurchasedCredits;
-    });
-  }
-
   getTotalCreditsPurchased(): TotalCreditsPurchased {
     const result = this.ctx.storage.sql.exec<{ totalCredits: number }>(
       "SELECT COALESCE(SUM(credits), 0) as totalCredits FROM credit_purchases"
diff --git a/worker/src/routers/api/apiRouter.ts b/worker/src/routers/api/apiRouter.ts
diff --git a/worker/wrangler.toml b/worker/wrangler.toml
