Ryan/Reactive-Resume
1
0
Fork 0
mirror of https://github.com/AmruthPillai/Reactive-Resume.git synced 2025-11-14 00:32:35 +10:00
Code Issues Packages Projects Releases Wiki Activity

remove caching from resumes

Browse Source
This commit is contained in:
Amruth Pillai
2024-03-10 10:00:51 +01:00
parent 359c7f1c80
commit 783af5070d
6 changed files with 62 additions and 83 deletions
Download Patch File Download Diff File Expand all files Collapse all files

68
apps/server/src/printer/printer.service.ts
View File

@ -48,52 +48,42 @@ export class PrinterService {
}
async printResume(resume: ResumeDto) {
return this.utils.getCachedOrSet(
`user:${resume.userId}:storage:resumes:${resume.id}`,
async () => {
const start = performance.now();
const start = performance.now();
const url = await retry(() => this.generateResume(resume), {
retries: 3,
randomize: true,
onRetry: (_, attempt) => {
this.logger.log(`Retrying to print resume #${resume.id}, attempt #${attempt}`);
},
});
const duration = Number(performance.now() - start).toFixed(0);
const numPages = resume.data.metadata.layout.length;
this.logger.debug(`Chrome took ${duration}ms to print ${numPages} page(s)`);
return url;
const url = await retry(() => this.generateResume(resume), {
retries: 3,
randomize: true,
onRetry: (_, attempt) => {
this.logger.log(`Retrying to print resume #${resume.id}, attempt #${attempt}`);
},
);
});
const duration = Number(performance.now() - start).toFixed(0);
const numPages = resume.data.metadata.layout.length;
this.logger.debug(`Chrome took ${duration}ms to print ${numPages} page(s)`);
return url;
}
async printPreview(resume: ResumeDto) {
return this.utils.getCachedOrSet(
`user:${resume.userId}:storage:previews:${resume.id}`,
async () => {
const start = performance.now();
const start = performance.now();
const url = await retry(() => this.generatePreview(resume), {
retries: 3,
randomize: true,
onRetry: (_, attempt) => {
this.logger.log(
`Retrying to generate preview of resume #${resume.id}, attempt #${attempt}`,
);
},
});
const duration = Number(performance.now() - start).toFixed(0);
this.logger.debug(`Chrome took ${duration}ms to generate preview`);
return url;
const url = await retry(() => this.generatePreview(resume), {
retries: 3,
randomize: true,
onRetry: (_, attempt) => {
this.logger.log(
`Retrying to generate preview of resume #${resume.id}, attempt #${attempt}`,
);
},
);
});
const duration = Number(performance.now() - start).toFixed(0);
this.logger.debug(`Chrome took ${duration}ms to generate preview`);
return url;
}
async generateResume(resume: ResumeDto) {

2
apps/server/src/resume/resume.controller.ts
View File

@ -115,7 +115,7 @@ export class ResumeController {
@Patch(":id/lock")
@UseGuards(TwoFactorGuard)
lock(@User() user: UserEntity, @Param("id") id: string, @Body("set") set: boolean = true) {
lock(@User() user: UserEntity, @Param("id") id: string, @Body("set") set = true) {
return this.resumeService.lock(user.id, id, set);
}

59
apps/server/src/resume/resume.service.ts
View File

@ -54,10 +54,10 @@ export class ResumeService {
},
});
await Promise.all([
this.redis.del(`user:${userId}:resumes`),
this.redis.set(`user:${userId}:resume:${resume.id}`, JSON.stringify(resume)),
]);
// await Promise.all([
// this.redis.del(`user:${userId}:resumes`),
// this.redis.set(`user:${userId}:resume:${resume.id}`, JSON.stringify(resume)),
// ]);
return resume;
}
@ -75,37 +75,24 @@ export class ResumeService {
},
});
await Promise.all([
this.redis.del(`user:${userId}:resumes`),
this.redis.set(`user:${userId}:resume:${resume.id}`, JSON.stringify(resume)),
]);
// await Promise.all([
// this.redis.del(`user:${userId}:resumes`),
// this.redis.set(`user:${userId}:resume:${resume.id}`, JSON.stringify(resume)),
// ]);
return resume;
}
findAll(userId: string) {
return this.utils.getCachedOrSet(`user:${userId}:resumes`, () =>
this.prisma.resume.findMany({
where: { userId },
orderBy: { updatedAt: "desc" },
}),
);
return this.prisma.resume.findMany({ where: { userId }, orderBy: { updatedAt: "desc" } });
}
findOne(id: string, userId?: string) {
if (userId) {
return this.utils.getCachedOrSet(`user:${userId}:resume:${id}`, () =>
this.prisma.resume.findUniqueOrThrow({
where: { userId_id: { userId, id } },
}),
);
return this.prisma.resume.findUniqueOrThrow({ where: { userId_id: { userId, id } } });
}
return this.utils.getCachedOrSet(`user:public:resume:${id}`, () =>
this.prisma.resume.findUniqueOrThrow({
where: { id },
}),
);
return this.prisma.resume.findUniqueOrThrow({ where: { id } });
}
async findOneStatistics(userId: string, id: string) {
@ -149,12 +136,12 @@ export class ResumeService {
where: { userId_id: { userId, id } },
});
await Promise.all([
this.redis.set(`user:${userId}:resume:${id}`, JSON.stringify(resume)),
this.redis.del(`user:${userId}:resumes`),
this.redis.del(`user:${userId}:storage:resumes:${id}`),
this.redis.del(`user:${userId}:storage:previews:${id}`),
]);
// await Promise.all([
// this.redis.set(`user:${userId}:resume:${id}`, JSON.stringify(resume)),
// this.redis.del(`user:${userId}:resumes`),
// this.redis.del(`user:${userId}:storage:resumes:${id}`),
// this.redis.del(`user:${userId}:storage:previews:${id}`),
// ]);
return resume;
} catch (error) {
@ -171,10 +158,10 @@ export class ResumeService {
where: { userId_id: { userId, id } },
});
await Promise.all([
this.redis.set(`user:${userId}:resume:${id}`, JSON.stringify(resume)),
this.redis.del(`user:${userId}:resumes`),
]);
// await Promise.all([
// this.redis.set(`user:${userId}:resume:${id}`, JSON.stringify(resume)),
// this.redis.del(`user:${userId}:resumes`),
// ]);
return resume;
}
@ -182,8 +169,8 @@ export class ResumeService {
async remove(userId: string, id: string) {
await Promise.all([
// Remove cached keys
this.redis.del(`user:${userId}:resumes`),
this.redis.del(`user:${userId}:resume:${id}`),
// this.redis.del(`user:${userId}:resumes`),
// this.redis.del(`user:${userId}:resume:${id}`),
// Remove files in storage, and their cached keys
this.storageService.deleteObject(userId, "resumes", id),