Ryan/documenso
1
0
Fork 1
mirror of https://github.com/documenso/documenso.git synced 2025-11-17 18:21:32 +10:00
Code Issues Packages Projects Releases Wiki Activity

chore: wip1

Browse Source
This commit is contained in:
Ephraim Atta-Duncan
2025-02-25 10:41:28 +00:00
parent 87f66edd95
commit 6f930ece4e
1 changed files with 37 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
packages/lib/server-only/admin/get-signing-volume.ts
View File

@ -53,14 +53,9 @@ export const getSigningVolume = async ({
}, },
}); });
const uniqueEntities = new Map(); const subscriptionData = activeSubscriptions.map((subscription) => {
activeSubscriptions.forEach((subscription) => {
const isTeam = !!subscription.teamId; const isTeam = !!subscription.teamId;
const entityId = isTeam ? `team-${subscription.teamId}` : `user-${subscription.userId}`; return {
if (!uniqueEntities.has(entityId)) {
uniqueEntities.set(entityId, {
id: subscription.id, id: subscription.id,
planId: subscription.planId, planId: subscription.planId,
userId: subscription.userId, userId: subscription.userId,
@ -71,11 +66,8 @@ export const getSigningVolume = async ({
: subscription.user?.email || '', : subscription.user?.email || '',
createdAt: isTeam ? subscription.team?.createdAt : subscription.user?.createdAt, createdAt: isTeam ? subscription.team?.createdAt : subscription.user?.createdAt,
isTeam, isTeam,
};
}); });
}
});
const subscriptionData = Array.from(uniqueEntities.values());
const filteredSubscriptions = search const filteredSubscriptions = search
? subscriptionData.filter((sub) => { ? subscriptionData.filter((sub) => {
@ -91,16 +83,38 @@ export const getSigningVolume = async ({
filteredSubscriptions.map(async (subscription) => { filteredSubscriptions.map(async (subscription) => {
let signingVolume = 0; let signingVolume = 0;
if (subscription.userId && !subscription.isTeam) { if (subscription.userId) {
const personalCount = await prisma.document.count({ const personalCount = await prisma.document.count({
where: { where: {
userId: subscription.userId, userId: subscription.userId,
teamId: null,
status: DocumentStatus.COMPLETED, status: DocumentStatus.COMPLETED,
}, },
}); });
signingVolume += personalCount; signingVolume += personalCount;
const userTeams = await prisma.teamMember.findMany({
where: {
userId: subscription.userId,
},
select: {
teamId: true,
},
});
if (userTeams.length > 0) {
const teamIds = userTeams.map((team) => team.teamId);
const teamCount = await prisma.document.count({
where: {
teamId: {
in: teamIds,
},
status: DocumentStatus.COMPLETED,
},
});
signingVolume += teamCount;
}
} }
if (subscription.teamId) { if (subscription.teamId) {