Skip to content
This repository has been archived by the owner on Jan 31, 2024. It is now read-only.

Commit

Permalink
upd: remove unused function, fix logger message
Browse files Browse the repository at this point in the history
  • Loading branch information
Mar0xy committed Nov 12, 2023
1 parent bc25b28 commit 486a2ad
Showing 1 changed file with 2 additions and 10 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,14 +42,6 @@ export class ImportNotesProcessorService {
) {
this.logger = this.queueLoggerService.logger.createSubLogger('import-notes');
}
@bindThis
private async _keepTweet(tweet: any) {
if (!tweet.created_at.endsWith(new Date().getFullYear())) {
return false;
}

return !tweet.full_text.startsWith('@');
}

@bindThis
private async uploadFiles(dir: any, user: any) {
Expand Down Expand Up @@ -84,7 +76,7 @@ export class ImportNotesProcessorService {

@bindThis
public async process(job: Bull.Job<DbNoteImportJobData>): Promise<void> {
this.logger.info(`Importing following of ${job.data.user.id} ...`);
this.logger.info(`Starting note import of ${job.data.user.id} ...`);

const user = await this.usersRepository.findOneBy({ id: job.data.user.id });
if (user == null) {
Expand Down Expand Up @@ -135,7 +127,7 @@ export class ImportNotesProcessorService {
script.runInContext(context);
const tweets = Object.keys(fakeWindow.window.YTD.tweets.part0).reduce((m, key, i, obj) => {
return m.concat(fakeWindow.window.YTD.tweets.part0[key].tweet);
}, []).filter(this._keepTweet);
}, []);
this.queueService.createImportTweetsToDbJob(job.data.user, tweets);
} finally {
cleanup();
Expand Down

0 comments on commit 486a2ad

Please sign in to comment.