sirtimbly/bewcloud
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update dependencies, add more logging to crons

Browse Source
This commit is contained in:
Bruno Bernardino
2024-04-17 14:01:06 +01:00
parent bcf54f148e
commit 7fd29ba7bf
9 changed files with 20 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
crons/cleanup.ts
View File

@@ -6,6 +6,8 @@ export async function cleanupSessions() {
const yesterday = new Date(new Date().setUTCDate(new Date().getUTCDate() - 1));
try {
console.info('Will cleanup user sessions');
const result = await db.query<{ count: number }>(
sql`WITH "deleted" AS (
DELETE FROM "bewcloud_user_sessions" WHERE "expires_at" <= $1 RETURNING *
@@ -16,8 +18,8 @@ export async function cleanupSessions() {
],
);
console.log('Deleted', result[0].count, 'user sessions');
console.info('Deleted', result[0].count, 'user sessions');
} catch (error) {
console.log(error);
console.error(error);
}
}

2
crons/index.ts
View File

@@ -1,4 +1,4 @@
import { Cron } from 'https://deno.land/x/croner@7.0.1/dist/croner.js';
import { Cron } from 'https://deno.land/x/croner@8.0.1/dist/croner.js';
import { cleanupSessions } from './cleanup.ts';
import { fetchNewArticles } from './news.ts';

6
crons/news.ts
View File

@@ -16,10 +16,12 @@ export async function fetchNewArticles(forceFetch = false) {
],
);
console.info('Will crawl', feedsToCrawl.length, 'news feeds');
await concurrentPromises(feedsToCrawl.map((newsFeed) => () => crawlNewsFeed(newsFeed)), 3);
console.log('Crawled', feedsToCrawl.length, 'news feeds');
console.info('Crawled', feedsToCrawl.length, 'news feeds');
} catch (error) {
console.log(error);
console.error(error);
}
}