moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cron: DRY updateTrendingTags

This commit is contained in:
Alex Gleason 2024-06-02 19:18:42 -05:00
parent 7e44368c08
commit b35090ef10
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 9 additions and 44 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

53
src/cron.ts
View File

@ -46,21 +46,21 @@ async function updateTrendingNotes() {
console.info('Trending notes updated.'); console.info('Trending notes updated.');
} }
async function updateTrendingHashtags() { async function updateTrendingTags(tagName: string, extra = '') {
console.info('Updating trending hashtags...'); console.info(`Updating trending #${tagName}...`);
const kysely = await DittoDB.getInstance(); const kysely = await DittoDB.getInstance();
const signal = AbortSignal.timeout(1000); const signal = AbortSignal.timeout(1000);
const yesterday = Math.floor((Date.now() - Time.days(1)) / 1000); const yesterday = Math.floor((Date.now() - Time.days(1)) / 1000);
const now = Math.floor(Date.now() / 1000); const now = Math.floor(Date.now() / 1000);
const hashtags = await getTrendingTagValues(kysely, 't', { const trends = await getTrendingTagValues(kysely, tagName, {
since: yesterday, since: yesterday,
until: now, until: now,
limit: 20, limit: 20,
}); });
if (!hashtags.length) { if (!trends.length) {
return; return;
} }
@ -71,54 +71,19 @@ async function updateTrendingHashtags() {
content: '', content: '',
tags: [ tags: [
['L', 'pub.ditto.trends'], ['L', 'pub.ditto.trends'],
['l', '#t', 'pub.ditto.trends'], ['l', `#${tagName}`, 'pub.ditto.trends'],
...hashtags.map(({ value, authors, uses }) => ['t', value, '', authors.toString(), uses.toString()]), ...trends.map(({ value, authors, uses }) => [tagName, value, extra, authors.toString(), uses.toString()]),
], ],
created_at: Math.floor(Date.now() / 1000), created_at: Math.floor(Date.now() / 1000),
}); });
await handleEvent(label, signal); await handleEvent(label, signal);
console.info('Trending hashtags updated.'); console.info(`Trending #${tagName} updated.`);
}
async function updateTrendingLinks() {
console.info('Updating trending links...');
const kysely = await DittoDB.getInstance();
const signal = AbortSignal.timeout(1000);
const yesterday = Math.floor((Date.now() - Time.days(1)) / 1000);
const now = Math.floor(Date.now() / 1000);
const links = await getTrendingTagValues(kysely, 'r', {
since: yesterday,
until: now,
limit: 20,
});
if (!links.length) {
return;
}
const signer = new AdminSigner();
const label = await signer.signEvent({
kind: 1985,
content: '',
tags: [
['L', 'pub.ditto.trends'],
['l', '#r', 'pub.ditto.trends'],
...links.map(({ value, authors, uses }) => ['r', value, '', authors.toString(), uses.toString()]),
],
created_at: Math.floor(Date.now() / 1000),
});
await handleEvent(label, signal);
console.info('Trending links updated.');
} }
/** Start cron jobs for the application. */ /** Start cron jobs for the application. */
export function cron() { export function cron() {
Deno.cron('update trending notes', '15 * * * *', updateTrendingNotes); Deno.cron('update trending notes', '15 * * * *', updateTrendingNotes);
Deno.cron('update trending hashtags', '30 * * * *', updateTrendingHashtags); Deno.cron('update trending hashtags', '30 * * * *', () => updateTrendingTags('t'));
Deno.cron('update trending links', '45 * * * *', updateTrendingLinks); Deno.cron('update trending links', '45 * * * *', () => updateTrendingTags('r'));
} }