limepotato/jormungandr-bite
1
0
Fork 0
mirror of https://iceshrimp.dev/limepotato/jormungandr-bite.git synced 2024-11-22 18:07:31 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions

[mastodon-client] Improve query performance

Browse source
This commit is contained in:
Laura Hausmann 2023-10-04 23:16:52 +02:00
parent f87712040d
commit c90161189f
No known key found for this signature in database
GPG key ID: D044E84C5BE01605
1 changed files with 1 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
packages/backend/src/server/api/mastodon/helpers/pagination.ts
View file

@ -43,27 +43,7 @@ export class PaginationHelpers {
* @param reverse whether the result needs to be .reverse()'d. Set this to true when the parameter minId is not undefined in the original request. * @param reverse whether the result needs to be .reverse()'d. Set this to true when the parameter minId is not undefined in the original request.
*/ */
public static async execQuery<T extends ObjectLiteral>(query: SelectQueryBuilder<T>, limit: number, reverse: boolean): Promise<T[]> { public static async execQuery<T extends ObjectLiteral>(query: SelectQueryBuilder<T>, limit: number, reverse: boolean): Promise<T[]> {
// We fetch more than requested because some may be filtered out, and if there's less than return query.take(limit).getMany().then(found => reverse ? found.reverse() : found);
// requested, the pagination stops.
const found = [];
const take = Math.floor(limit * 1.5);
let skip = 0;
try {
while (found.length < limit) {
const notes = await query.take(take).skip(skip).getMany();
found.push(...notes);
skip += take;
if (notes.length < take) break;
}
} catch (error) {
return [];
}
if (found.length > limit) {
found.length = limit;
}
return reverse ? found.reverse() : found;
} }
public static appendLinkPaginationHeader(args: any, ctx: any, res: any, defaultLimit: number): void { public static appendLinkPaginationHeader(args: any, ctx: any, res: any, defaultLimit: number): void {