m/umami
1
0
Fork 0
mirror of https://github.com/kremalicious/umami.git synced 2025-02-14 21:10:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

add redis calls to website delete/reset

Browse Source
This commit is contained in:
Francis Cao 2024-05-09 11:55:54 -07:00
parent 42b475b061
commit 4731c1cca3
1 changed files with 17 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/queries/admin/website.ts
View File

@ -1,4 +1,5 @@
import { Prisma, Website } from '@prisma/client'; import { Prisma, Website } from '@prisma/client';
import redis from '@umami/redis-client';
import prisma from 'lib/prisma'; import prisma from 'lib/prisma';
import { PageResult, PageParams } from 'lib/types'; import { PageResult, PageParams } from 'lib/types';
import WebsiteFindManyArgs = Prisma.WebsiteFindManyArgs; import WebsiteFindManyArgs = Prisma.WebsiteFindManyArgs;
@ -122,6 +123,7 @@ export async function resetWebsite(
websiteId: string, websiteId: string,
): Promise<[Prisma.BatchPayload, Prisma.BatchPayload, Website]> { ): Promise<[Prisma.BatchPayload, Prisma.BatchPayload, Website]> {
const { client, transaction } = prisma; const { client, transaction } = prisma;
const cloudMode = !!process.env.cloudMode;
return transaction([ return transaction([
client.eventData.deleteMany({ client.eventData.deleteMany({
@ -139,14 +141,20 @@ export async function resetWebsite(
resetAt: new Date(), resetAt: new Date(),
}, },
}), }),
]); ]).then(async data => {
if (cloudMode) {
await redis.client.set(`website:${websiteId}`, data[3]);
}
return data;
});
} }
export async function deleteWebsite( export async function deleteWebsite(
websiteId: string, websiteId: string,
): Promise<[Prisma.BatchPayload, Prisma.BatchPayload, Website]> { ): Promise<[Prisma.BatchPayload, Prisma.BatchPayload, Website]> {
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({ client.eventData.deleteMany({
@ -173,5 +181,11 @@ export async function deleteWebsite(
: client.website.delete({ : client.website.delete({
where: { id: websiteId }, where: { id: websiteId },
}), }),
]); ]).then(async data => {
if (cloudMode) {
await redis.client.del(`website:${websiteId}`);
}
return data;
});
} }