watson/umami
1
0
Fork 0
mirror of https://github.com/umami-software/umami.git synced 2025-12-06 01:18:00 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge remote-tracking branch 'origin/dev' into dev

Browse source
This commit is contained in:
Mike Cao 2025-12-02 13:47:01 -08:00
commit e7cb613cec
1 changed files with 41 additions and 29 deletions
Download patch file Download diff file Expand all files Collapse all files

70
src/queries/prisma/website.ts
View file

@ -137,6 +137,9 @@ export async function resetWebsite(websiteId: string) {
return transaction( return transaction(
[ [
client.revenue.deleteMany({
where: { websiteId },
}),
client.eventData.deleteMany({ client.eventData.deleteMany({
where: { websiteId }, where: { websiteId },
}), }),
@ -175,35 +178,44 @@ export async function deleteWebsite(websiteId: string) {
const { client, transaction } = prisma; const { client, transaction } = prisma;
const cloudMode = !!process.env.CLOUD_MODE; const cloudMode = !!process.env.CLOUD_MODE;
return transaction([ return transaction(
client.eventData.deleteMany({ [
where: { websiteId }, client.revenue.deleteMany({
}), where: { websiteId },
client.sessionData.deleteMany({ }),
where: { websiteId }, client.eventData.deleteMany({
}), where: { websiteId },
client.websiteEvent.deleteMany({ }),
where: { websiteId }, client.sessionData.deleteMany({
}), where: { websiteId },
client.session.deleteMany({ }),
where: { websiteId }, client.websiteEvent.deleteMany({
}), where: { websiteId },
client.report.deleteMany({ }),
where: { client.session.deleteMany({
websiteId, where: { websiteId },
}, }),
}), client.report.deleteMany({
cloudMode where: { websiteId },
? client.website.update({ }),
data: { client.segment.deleteMany({
deletedAt: new Date(), where: { websiteId },
}, }),
where: { id: websiteId }, cloudMode
}) ? client.website.update({
: client.website.delete({ data: {
where: { id: websiteId }, deletedAt: new Date(),
}), },
]).then(async data => { where: { id: websiteId },
})
: client.website.delete({
where: { id: websiteId },
}),
],
{
timeout: 30000,
},
).then(async data => {
if (cloudMode) { if (cloudMode) {
await redis.client.del(`website:${websiteId}`); await redis.client.del(`website:${websiteId}`);
} }