57 lines
1.3 KiB
TypeScript
57 lines
1.3 KiB
TypeScript
import { paginate, resolver } from "blitz";
|
|
import { z } from "zod";
|
|
|
|
import db from "db";
|
|
import { getPayments } from "integrations/paddle";
|
|
|
|
const Body = z.object({
|
|
skip: z.number().optional(),
|
|
take: z.number().optional(),
|
|
});
|
|
|
|
export default resolver.pipe(resolver.zod(Body), resolver.authorize(), async ({ skip, take }, { session }) => {
|
|
if (!session.orgId) {
|
|
return {
|
|
payments: [],
|
|
nextPage: null,
|
|
hasMore: false,
|
|
count: 0,
|
|
};
|
|
}
|
|
|
|
const subscriptions = await db.subscription.findMany({ where: { organizationId: session.orgId } });
|
|
if (subscriptions.length === 0) {
|
|
return {
|
|
payments: [],
|
|
nextPage: null,
|
|
hasMore: false,
|
|
count: 0,
|
|
};
|
|
}
|
|
|
|
const paymentsBySubscription = await Promise.all(
|
|
subscriptions.map((subscription) => getPayments({ subscriptionId: subscription.paddleSubscriptionId })),
|
|
);
|
|
const unsortedPayments = paymentsBySubscription.flat();
|
|
const allPayments = Array.from(unsortedPayments).sort((a, b) => b.payout_date.localeCompare(a.payout_date));
|
|
|
|
const {
|
|
items: payments,
|
|
hasMore,
|
|
nextPage,
|
|
count,
|
|
} = await paginate({
|
|
skip,
|
|
take,
|
|
count: () => Promise.resolve(allPayments.length),
|
|
query: ({ skip, take }) => Promise.resolve(allPayments.slice(skip, skip + take)),
|
|
});
|
|
|
|
return {
|
|
payments,
|
|
nextPage,
|
|
hasMore,
|
|
count,
|
|
};
|
|
});
|