hexclave
diff --git a/‎apps/backend/prisma/migrations/20250917193043_store_price_id/migration.sql‎
Lines changed: 5 additions & 0 deletions b/‎apps/backend/prisma/migrations/20250917193043_store_price_id/migration.sql‎
Lines changed: 5 additions & 0 deletions
diff --git a/‎apps/backend/prisma/migrations/20250918005821_item_quantity_change_customer_type/migration.sql‎
Lines changed: 27 additions & 0 deletions b/‎apps/backend/prisma/migrations/20250918005821_item_quantity_change_customer_type/migration.sql‎
Lines changed: 27 additions & 0 deletions
diff --git a/‎apps/backend/prisma/schema.prisma‎
Lines changed: 22 additions & 19 deletions b/‎apps/backend/prisma/schema.prisma‎
Lines changed: 22 additions & 19 deletions
diff --git a/‎apps/backend/src/app/api/latest/integrations/stripe/webhooks/route.tsx‎
Lines changed: 2 additions & 1 deletion b/‎apps/backend/src/app/api/latest/integrations/stripe/webhooks/route.tsx‎
Lines changed: 2 additions & 1 deletion
diff --git a/‎apps/backend/src/app/api/latest/internal/payments/test-mode-purchase-session/route.tsx‎
Lines changed: 2 additions & 0 deletions b/‎apps/backend/src/app/api/latest/internal/payments/test-mode-purchase-session/route.tsx‎
Lines changed: 2 additions & 0 deletions
diff --git a/‎apps/backend/src/app/api/latest/internal/payments/transactions/route.tsx‎
Lines changed: 206 additions & 0 deletions b/‎apps/backend/src/app/api/latest/internal/payments/transactions/route.tsx‎
Lines changed: 206 additions & 0 deletions
diff --git a/‎apps/backend/src/app/api/latest/payments/items/[customer_type]/[customer_id]/[item_id]/update-quantity/route.ts‎
Lines changed: 1 addition & 0 deletions b/‎apps/backend/src/app/api/latest/payments/items/[customer_type]/[customer_id]/[item_id]/update-quantity/route.ts‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎apps/backend/src/app/api/latest/payments/purchases/purchase-session/route.tsx‎
Lines changed: 3 additions & 0 deletions b/‎apps/backend/src/app/api/latest/payments/purchases/purchase-session/route.tsx‎
Lines changed: 3 additions & 0 deletions
@@ -0,0 +1,5 @@
+-- AlterTable
+ALTER TABLE "OneTimePurchase" ADD COLUMN     "priceId" TEXT;
+
+-- AlterTable
+ALTER TABLE "Subscription" ADD COLUMN     "priceId" TEXT;
@@ -0,0 +1,27 @@
+/*
+  Warnings:
+
+  - Added the required column `customerType` to the `ItemQuantityChange` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "ItemQuantityChange" ADD COLUMN "customerType" "CustomerType";
+
+UPDATE "ItemQuantityChange" AS iqc
+SET "customerType" = 'USER'
+FROM "ProjectUser" AS pu
+WHERE iqc."tenancyId" = pu."tenancyId"
+  AND iqc."customerId" = pu."projectUserId"::text;
+
+UPDATE "ItemQuantityChange" AS iqc
+SET "customerType" = 'TEAM'
+FROM "Team" AS t
+WHERE iqc."customerType" IS NULL
+  AND iqc."tenancyId" = t."tenancyId"
+  AND iqc."customerId" = t."teamId"::text;
+
+UPDATE "ItemQuantityChange"
+SET "customerType" = 'CUSTOM'
+WHERE "customerType" IS NULL;
+
+ALTER TABLE "ItemQuantityChange" ALTER COLUMN "customerType" SET NOT NULL;
@@ -764,6 +764,7 @@ model Subscription {
   customerId   String
   customerType CustomerType
   offerId      String?
+  priceId      String?
   offer        Json
   quantity     Int          @default(1)
 
@@ -774,38 +775,40 @@ model Subscription {
   cancelAtPeriodEnd    Boolean
 
   creationSource PurchaseCreationSource
-  createdAt      DateTime                   @default(now())
-  updatedAt      DateTime                   @updatedAt
+  createdAt      DateTime               @default(now())
+  updatedAt      DateTime               @updatedAt
 
@@id([tenancyId, id])
@@unique([tenancyId, stripeSubscriptionId])
 }
 
 model ItemQuantityChange {
-  id          String    @default(uuid()) @db.Uuid
-  tenancyId   String    @db.Uuid
-  customerId  String
-  itemId      String
-  quantity    Int
-  description String?
-  expiresAt   DateTime?
-  createdAt   DateTime  @default(now())
+  id           String       @default(uuid()) @db.Uuid
+  tenancyId    String       @db.Uuid
+  customerId   String
+  customerType CustomerType
+  itemId       String
+  quantity     Int
+  description  String?
+  expiresAt    DateTime?
+  createdAt    DateTime     @default(now())
 
@@id([tenancyId, id])
@@index([tenancyId, customerId, expiresAt])
 }
 
 model OneTimePurchase {
-  id String @default(uuid()) @db.Uuid
-  tenancyId String @db.Uuid
-  customerId String
-  customerType CustomerType
-  offerId String?
-  offer Json
-  quantity Int
+  id                    String                 @default(uuid()) @db.Uuid
+  tenancyId             String                 @db.Uuid
+  customerId            String
+  customerType          CustomerType
+  offerId               String?
+  priceId               String?
+  offer                 Json
+  quantity              Int
   stripePaymentIntentId String?
-  createdAt DateTime @default(now())
-  creationSource PurchaseCreationSource
+  createdAt             DateTime               @default(now())
+  creationSource        PurchaseCreationSource
 
@@id([tenancyId, id])
@@unique([tenancyId, stripePaymentIntentId])
 
@@ -42,7 +42,6 @@ async function processStripeWebhookEvent(event: Stripe.Event): Promise<void> {
     if (!accountId) {
       throw new StackAssertionError("Stripe webhook account id missing", { event });
     }
-    console.log("Processing1", mockData);
     const stripe = getStackStripe(mockData);
     const account = await stripe.accounts.retrieve(accountId);
     const tenancyId = account.metadata?.tenancyId;
@@ -75,13 +74,15 @@ async function processStripeWebhookEvent(event: Stripe.Event): Promise<void> {
         customerId: metadata.customerId,
         customerType: typedToUppercase(metadata.customerType),
         offerId: metadata.offerId || null,
+        priceId: metadata.priceId || null,
         stripePaymentIntentId,
         offer,
         quantity: qty,
         creationSource: "PURCHASE_PAGE",
       },
       update: {
         offerId: metadata.offerId || null,
+        priceId: metadata.priceId || null,
         offer,
         quantity: qty,
       }
 
@@ -55,6 +55,7 @@ export const POST = createSmartRouteHandler({
           customerId: data.customerId,
           customerType: typedToUppercase(data.offer.customerType),
           offerId: data.offerId,
+          priceId: price_id,
           offer: data.offer,
           quantity,
           creationSource: "TEST_MODE",
@@ -87,6 +88,7 @@ export const POST = createSmartRouteHandler({
           customerType: typedToUppercase(data.offer.customerType),
           status: "active",
           offerId: data.offerId,
+          priceId: price_id,
           offer: data.offer,
           quantity,
           currentPeriodStart: new Date(),
 
@@ -0,0 +1,206 @@
+import { getPrismaClientForTenancy } from "@/prisma-client";
+import { createSmartRouteHandler } from "@/route-handlers/smart-route-handler";
+import { Prisma } from "@prisma/client";
+import { AdminTransaction, adminTransaction } from "@stackframe/stack-shared/dist/interface/crud/transactions";
+import { adaptSchema, adminAuthTypeSchema, yupArray, yupNumber, yupObject, yupString } from "@stackframe/stack-shared/dist/schema-fields";
+import { getOrUndefined } from "@stackframe/stack-shared/dist/utils/objects";
+import { typedToLowercase, typedToUppercase } from "@stackframe/stack-shared/dist/utils/strings";
+
+
+type SelectedPrice = NonNullable<AdminTransaction['price']>;
+type OfferWithPrices = {
+  displayName?: string,
+  prices?: Record<string, SelectedPrice & { serverOnly?: unknown, freeTrial?: unknown }> | "include-by-default",
+} | null | undefined;
+
+function resolveSelectedPriceFromOffer(offer: OfferWithPrices, priceId?: string | null): SelectedPrice | null {
+  if (!offer) return null;
+  if (!priceId) return null;
+  const prices = offer.prices;
+  if (!prices || prices === "include-by-default") return null;
+  const selected = prices[priceId as keyof typeof prices] as (SelectedPrice & { serverOnly?: unknown, freeTrial?: unknown }) | undefined;
+  if (!selected) return null;
+  const { serverOnly: _serverOnly, freeTrial: _freeTrial, ...rest } = selected as any;
+  return rest as SelectedPrice;
+}
+
+function getOfferDisplayName(offer: OfferWithPrices): string | null {
+  return offer?.displayName ?? null;
+}
+
+
+export const GET = createSmartRouteHandler({
+  metadata: {
+    hidden: true,
+  },
+  request: yupObject({
+    auth: yupObject({
+      type: adminAuthTypeSchema.defined(),
+      project: adaptSchema.defined(),
+      tenancy: adaptSchema.defined(),
+    }).defined(),
+    query: yupObject({
+      cursor: yupString().optional(),
+      limit: yupString().optional(),
+      type: yupString().oneOf(['subscription', 'one_time', 'item_quantity_change']).optional(),
+      customer_type: yupString().oneOf(['user', 'team', 'custom']).optional(),
+    }).optional(),
+  }),
+  response: yupObject({
+    statusCode: yupNumber().oneOf([200]).defined(),
+    bodyType: yupString().oneOf(["json"]).defined(),
+    body: yupObject({
+      transactions: yupArray(adminTransaction).defined(),
+      next_cursor: yupString().nullable().defined(),
+    }).defined(),
+  }),
+  handler: async ({ auth, query }) => {
+    const prisma = await getPrismaClientForTenancy(auth.tenancy);
+
+    const rawLimit = query.limit ?? "50";
+    const parsedLimit = Number.parseInt(rawLimit, 10);
+    const limit = Math.max(1, Math.min(200, Number.isFinite(parsedLimit) ? parsedLimit : 50));
+    const cursorStr = query.cursor ?? "";
+    const [subCursor, iqcCursor, otpCursor] = (cursorStr.split("|") as [string?, string?, string?]);
+
+    const paginateWhere = async <T extends "subscription" | "itemQuantityChange" | "oneTimePurchase">(
+      table: T,
+      cursorId?: string
+    ): Promise<
+      T extends "subscription"
+      ? Prisma.SubscriptionWhereInput | undefined
+      : T extends "itemQuantityChange"
+      ? Prisma.ItemQuantityChangeWhereInput | undefined
+      : Prisma.OneTimePurchaseWhereInput | undefined
+    > => {
+      if (!cursorId) return undefined as any;
+      let pivot: { createdAt: Date } | null = null;
+      if (table === "subscription") {
+        pivot = await prisma.subscription.findUnique({
+          where: { tenancyId_id: { tenancyId: auth.tenancy.id, id: cursorId } },
+          select: { createdAt: true },
+        });
+      } else if (table === "itemQuantityChange") {
+        pivot = await prisma.itemQuantityChange.findUnique({
+          where: { tenancyId_id: { tenancyId: auth.tenancy.id, id: cursorId } },
+          select: { createdAt: true },
+        });
+      } else {
+        pivot = await prisma.oneTimePurchase.findUnique({
+          where: { tenancyId_id: { tenancyId: auth.tenancy.id, id: cursorId } },
+          select: { createdAt: true },
+        });
+      }
+      if (!pivot) return undefined as any;
+      return {
+        OR: [
+          { createdAt: { lt: pivot.createdAt } },
+          { AND: [{ createdAt: { equals: pivot.createdAt } }, { id: { lt: cursorId } }] },
+        ],
+      } as any;
+    };
+
+    const [subWhere, iqcWhere, otpWhere] = await Promise.all([
+      paginateWhere("subscription", subCursor),
+      paginateWhere("itemQuantityChange", iqcCursor),
+      paginateWhere("oneTimePurchase", otpCursor),
+    ]);
+
+    const baseOrder = [{ createdAt: "desc" as const }, { id: "desc" as const }];
+    const customerTypeFilter = query.customer_type ? { customerType: typedToUppercase(query.customer_type) } : {};
+
+    let merged: AdminTransaction[] = [];
+
+    const [subs, iqcs, otps] = await Promise.all([
+      (query.type === "subscription" || !query.type) ? prisma.subscription.findMany({
+        where: { tenancyId: auth.tenancy.id, ...(subWhere ?? {}), ...customerTypeFilter },
+        orderBy: baseOrder,
+        take: limit,
+      }) : [],
+      (query.type === "item_quantity_change" || !query.type) ? prisma.itemQuantityChange.findMany({
+        where: { tenancyId: auth.tenancy.id, ...(iqcWhere ?? {}), ...customerTypeFilter },
+        orderBy: baseOrder,
+        take: limit,
+      }) : [],
+      (query.type === "one_time" || !query.type) ? prisma.oneTimePurchase.findMany({
+        where: { tenancyId: auth.tenancy.id, ...(otpWhere ?? {}), ...customerTypeFilter },
+        orderBy: baseOrder,
+        take: limit,
+      }) : [],
+    ]);
+
+    const subRows: AdminTransaction[] = subs.map((s) => ({
+      id: s.id,
+      type: 'subscription',
+      created_at_millis: s.createdAt.getTime(),
+      customer_type: typedToLowercase(s.customerType),
+      customer_id: s.customerId,
+      quantity: s.quantity,
+      test_mode: s.creationSource === 'TEST_MODE',
+      offer_display_name: getOfferDisplayName(s.offer as OfferWithPrices),
+      price: resolveSelectedPriceFromOffer(s.offer as OfferWithPrices, s.priceId ?? null),
+      status: s.status,
+    }));
+
+    const iqcRows: AdminTransaction[] = iqcs.map((i) => {
+      const itemCfg = getOrUndefined(auth.tenancy.config.payments.items, i.itemId) as { customerType?: 'user' | 'team' | 'custom' } | undefined;
+      const customerType = (itemCfg && itemCfg.customerType) ? itemCfg.customerType : 'custom';
+      return {
+        id: i.id,
+        type: 'item_quantity_change',
+        created_at_millis: i.createdAt.getTime(),
+        customer_type: customerType,
+        customer_id: i.customerId,
+        quantity: i.quantity,
+        test_mode: false,
+        offer_display_name: null,
+        price: null,
+        status: null,
+        item_id: i.itemId,
+        description: i.description ?? null,
+        expires_at_millis: i.expiresAt ? i.expiresAt.getTime() : null,
+      } as const;
+    });
+
+    const otpRows: AdminTransaction[] = otps.map((o) => ({
+      id: o.id,
+      type: 'one_time',
+      created_at_millis: o.createdAt.getTime(),
+      customer_type: typedToLowercase(o.customerType),
+      customer_id: o.customerId,
+      quantity: o.quantity,
+      test_mode: o.creationSource === 'TEST_MODE',
+      offer_display_name: getOfferDisplayName(o.offer as OfferWithPrices),
+      price: resolveSelectedPriceFromOffer(o.offer as OfferWithPrices, o.priceId ?? null),
+      status: null,
+    }));
+
+    merged = [...subRows, ...iqcRows, ...otpRows]
+      .sort((a, b) => (a.created_at_millis === b.created_at_millis ? (a.id < b.id ? 1 : -1) : (a.created_at_millis < b.created_at_millis ? 1 : -1)));
+
+    const page = merged.slice(0, limit);
+    let lastSubId = "";
+    let lastIqcId = "";
+    let lastOtpId = "";
+    for (const r of page) {
+      if (r.type === 'subscription') lastSubId = r.id;
+      if (r.type === 'item_quantity_change') lastIqcId = r.id;
+      if (r.type === 'one_time') lastOtpId = r.id;
+    }
+
+    const nextCursor = page.length === limit
+      ? [lastSubId, lastIqcId, lastOtpId].join('|')
+      : null;
+
+    return {
+      statusCode: 200,
+      bodyType: "json",
+      body: {
+        transactions: page,
+        next_cursor: nextCursor,
+      },
+    };
+  },
+});
+
+
@@ -72,6 +72,7 @@ export const POST = createSmartRouteHandler({
         data: {
           tenancyId: tenancy.id,
           customerId: req.params.customer_id,
+          customerType: typedToUppercase(req.params.customer_type),
           itemId: req.params.item_id,
           quantity: req.body.delta,
           description: req.body.description,
 
@@ -73,6 +73,7 @@ export const POST = createSmartRouteHandler({
             metadata: {
               offerId: data.offerId ?? null,
               offer: JSON.stringify(data.offer),
+              priceId: price_id,
             },
           });
           const clientSecretUpdated = getClientSecretFromStripeSubscription(updated);
@@ -114,6 +115,7 @@ export const POST = createSmartRouteHandler({
           purchaseQuantity: String(quantity),
           purchaseKind: "ONE_TIME",
           tenancyId: data.tenancyId,
+          priceId: price_id,
         },
       });
       const clientSecret = paymentIntent.client_secret;
@@ -147,6 +149,7 @@ export const POST = createSmartRouteHandler({
       metadata: {
         offerId: data.offerId ?? null,
         offer: JSON.stringify(data.offer),
+        priceId: price_id,
       },
     });
     const clientSecret = getClientSecretFromStripeSubscription(created);