-
Notifications
You must be signed in to change notification settings - Fork 5
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(route): ✨ author
ShowHelper and DeleteHelper
- Loading branch information
Showing
4 changed files
with
182 additions
and
69 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,49 @@ | ||
| import { FastifyRedis } from '@fastify/redis' | ||
|
|
||
| import { AuthorDocument } from '#config/models/Author' | ||
| import PaprAudibleAuthorHelper from '#helpers/database/audible/PaprAudibleAuthorHelper' | ||
| import RedisHelper from '#helpers/database/RedisHelper' | ||
|
|
||
| export default class AuthorDeleteHelper { | ||
| asin: string | ||
| paprHelper: PaprAudibleAuthorHelper | ||
| redisHelper: RedisHelper | ||
| originalAuthor: AuthorDocument | null = null | ||
| constructor(asin: string, redis: FastifyRedis | null) { | ||
| this.asin = asin | ||
| this.paprHelper = new PaprAudibleAuthorHelper(this.asin, { | ||
| update: undefined | ||
| }) | ||
| this.redisHelper = new RedisHelper(redis, 'author', this.asin) | ||
| } | ||
|
|
||
| async getAuthorFromPapr(): Promise<AuthorDocument | null> { | ||
| return (await this.paprHelper.findOne()).data | ||
| } | ||
|
|
||
| /** | ||
| * Actions to run when a deletion is requested | ||
| */ | ||
| async deleteActions() { | ||
| // 1. Delete the author from cache | ||
| await this.redisHelper.deleteOne() | ||
|
|
||
| // 2. Delete the author from DB | ||
| return (await this.paprHelper.delete()).modified | ||
| } | ||
|
|
||
| /** | ||
| * Main handler for the author delete route | ||
| */ | ||
| async handler() { | ||
| this.originalAuthor = await this.getAuthorFromPapr() | ||
|
|
||
| // If the author is already present | ||
| if (this.originalAuthor) { | ||
| return this.deleteActions() | ||
| } | ||
|
|
||
| // If the author is not present | ||
| return false | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,121 @@ | ||
| import { FastifyRedis } from '@fastify/redis' | ||
|
|
||
| import type { AuthorDocument } from '#config/models/Author' | ||
| import { AuthorProfile } from '#config/typing/people' | ||
| import { RequestGeneric } from '#config/typing/requests' | ||
| import ScrapeHelper from '#helpers/authors/audible/ScrapeHelper' | ||
| import addTimestamps from '#helpers/database/addTimestamps' | ||
| import PaprAudibleAuthorHelper from '#helpers/database/audible/PaprAudibleAuthorHelper' | ||
| import RedisHelper from '#helpers/database/RedisHelper' | ||
| import SharedHelper from '#helpers/shared' | ||
|
|
||
| export default class AuthorShowHelper { | ||
| asin: string | ||
| authorInternal: AuthorProfile | undefined = undefined | ||
| commonHelpers: SharedHelper | ||
| paprHelper: PaprAudibleAuthorHelper | ||
| redisHelper: RedisHelper | ||
| options: RequestGeneric['Querystring'] | ||
| scrapeHelper: ScrapeHelper | ||
| originalAuthor: AuthorDocument | null = null | ||
| constructor(asin: string, options: RequestGeneric['Querystring'], redis: FastifyRedis | null) { | ||
| this.asin = asin | ||
| this.commonHelpers = new SharedHelper() | ||
| this.options = options | ||
| this.paprHelper = new PaprAudibleAuthorHelper(this.asin, this.options) | ||
| this.redisHelper = new RedisHelper(redis, 'book', this.asin) | ||
| this.scrapeHelper = new ScrapeHelper(this.asin) | ||
| } | ||
|
|
||
| async getAuthorFromPapr(): Promise<AuthorDocument | null> { | ||
| return (await this.paprHelper.findOne()).data | ||
| } | ||
|
|
||
| async getNewAuthorData() { | ||
| return this.scrapeHelper.process() | ||
| } | ||
|
|
||
| async createOrUpdateAuthor() { | ||
| // Place the new author data into the papr helper | ||
| this.paprHelper.setAuthorData(await this.getNewAuthorData()) | ||
| // Create or update the author | ||
| const authorToReturn = await this.paprHelper.createOrUpdate() | ||
| // Update or create the author in cache | ||
| await this.redisHelper.findOrCreate(authorToReturn.data) | ||
| // Return the author | ||
| return authorToReturn | ||
| } | ||
|
|
||
| /** | ||
| * Check if the author is updated recently by comparing the timestamps of updatedAt | ||
| */ | ||
| isUpdatedRecently() { | ||
| if (!this.originalAuthor) { | ||
| return false | ||
| } | ||
| return this.commonHelpers.checkIfRecentlyUpdated(this.originalAuthor) | ||
| } | ||
|
|
||
| /** | ||
| * Update the timestamps of the author when they are missing | ||
| */ | ||
| async updateAuthorTimestamps(): Promise<AuthorProfile> { | ||
| // Return if not present or already has timestamps | ||
| if (!this.originalAuthor || this.originalAuthor.createdAt) | ||
| return (await this.paprHelper.findOneWithProjection()).data | ||
|
|
||
| // Add timestamps | ||
| this.paprHelper.authorData = addTimestamps(this.originalAuthor) as AuthorDocument | ||
| // Update author in DB | ||
| try { | ||
| this.authorInternal = (await this.paprHelper.update()).data | ||
| } catch (err) { | ||
| throw new Error(`An error occurred while adding timestamps to author ${this.asin} in the DB`) | ||
| } | ||
| return this.authorInternal | ||
| } | ||
|
|
||
| /** | ||
| * Actions to run when an update is requested | ||
| */ | ||
| async updateActions(): Promise<AuthorProfile> { | ||
| // 1. Check if it is updated recently | ||
| if (this.isUpdatedRecently()) return this.originalAuthor as AuthorProfile | ||
|
|
||
| // 2. Get the new author and create or update it | ||
| const authorToReturn = await this.createOrUpdateAuthor() | ||
|
|
||
| // 3. Update author in cache | ||
| if (authorToReturn.modified) { | ||
| this.redisHelper.setOne(authorToReturn.data) | ||
| } | ||
|
|
||
| // 4. Return the author | ||
| return authorToReturn.data | ||
| } | ||
|
|
||
| /** | ||
| * Main handler for the author show route | ||
| */ | ||
| async handler() { | ||
| this.originalAuthor = await this.getAuthorFromPapr() | ||
|
|
||
| // If the author is already present | ||
| if (this.originalAuthor) { | ||
| // If an update is requested | ||
| if (this.options.update === '1') { | ||
| return this.updateActions() | ||
| } | ||
| // 1. Make sure it has timestamps | ||
| await this.updateAuthorTimestamps() | ||
| // 2. Check it it is cached | ||
| const redisAuthor = await this.redisHelper.findOrCreate(this.originalAuthor) | ||
| if (redisAuthor) return redisAuthor as AuthorProfile | ||
| // 3. Return the author from DB | ||
| return this.originalAuthor as AuthorProfile | ||
| } | ||
|
|
||
| // If the author is not present | ||
| return (await this.createOrUpdateAuthor()).data | ||
| } | ||
| } |