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

Merge branch 'trends-limits' into 'main' 

Set trending statuses default limit to 20

See merge request soapbox-pub/ditto!300
This commit is contained in:
Alex Gleason 2024-05-22 18:10:49 +00:00
parent ca4f6ccb5c 9c7a650d1f
commit dfb0b0b874
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/controllers/api/trends.ts
View File

@ -14,8 +14,6 @@ import { TrendsWorker } from '@/workers/trends.ts';
await TrendsWorker.open('data/trends.sqlite3'); await TrendsWorker.open('data/trends.sqlite3');
const limitSchema = z.coerce.number().catch(10).transform((value) => Math.min(Math.max(value, 0), 20));
let trendingHashtagsCache = getTrendingHashtags(); let trendingHashtagsCache = getTrendingHashtags();
Deno.cron('update trends cache', { minute: { every: 15 } }, async () => { Deno.cron('update trends cache', { minute: { every: 15 } }, async () => {
@ -23,8 +21,12 @@ Deno.cron('update trends cache', { minute: { every: 15 } }, async () => {
trendingHashtagsCache = Promise.resolve(trends); trendingHashtagsCache = Promise.resolve(trends);
}); });
const trendingTagsQuerySchema = z.object({
limit: z.coerce.number().catch(10).transform((value) => Math.min(Math.max(value, 0), 20)),
});
const trendingTagsController: AppController = async (c) => { const trendingTagsController: AppController = async (c) => {
const limit = limitSchema.parse(c.req.query('limit')); const { limit } = trendingTagsQuerySchema.parse(c.req.query());
const trends = await trendingHashtagsCache; const trends = await trendingHashtagsCache;
return c.json(trends.slice(0, limit)); return c.json(trends.slice(0, limit));
}; };
@ -75,9 +77,13 @@ Deno.cron('update trending notes cache', { minute: { every: 15 } }, async () =>
trendingNotesCache = Promise.resolve(events); trendingNotesCache = Promise.resolve(events);
}); });
const trendingStatusesQuerySchema = z.object({
limit: z.coerce.number().catch(20).transform((value) => Math.min(Math.max(value, 0), 40)),
});
const trendingStatusesController: AppController = async (c) => { const trendingStatusesController: AppController = async (c) => {
const store = await Storages.db(); const store = await Storages.db();
const limit = limitSchema.parse(c.req.query('limit')); const { limit } = trendingStatusesQuerySchema.parse(c.req.query());
const events = await trendingNotesCache const events = await trendingNotesCache
.then((events) => events.slice(0, limit)) .then((events) => events.slice(0, limit))