summaryrefslogtreecommitdiff
path: root/packages/backend/src/server/ActivityPubServerService.ts
diff options
context:
space:
mode:
authormisskey-release-bot[bot] <157398866+misskey-release-bot[bot]@users.noreply.github.com>2025-06-16 02:33:18 +0000
committerGitHub <noreply@github.com>2025-06-16 02:33:18 +0000
commit830e2f0a5b5bada00bfbe036ef6e7ee8d84b83fd (patch)
treeb9ac1c4efb202a62fe34608fb3f42fd73297774b /packages/backend/src/server/ActivityPubServerService.ts
parentMerge pull request #16134 from misskey-dev/develop (diff)
parentRelease: 2025.6.1 (diff)
downloadmisskey-830e2f0a5b5bada00bfbe036ef6e7ee8d84b83fd.tar.gz
misskey-830e2f0a5b5bada00bfbe036ef6e7ee8d84b83fd.tar.bz2
misskey-830e2f0a5b5bada00bfbe036ef6e7ee8d84b83fd.zip
Merge pull request #16152 from misskey-dev/develop
Release: 2025.6.1
Diffstat (limited to 'packages/backend/src/server/ActivityPubServerService.ts')
-rw-r--r--packages/backend/src/server/ActivityPubServerService.ts27
1 files changed, 21 insertions, 6 deletions
diff --git a/packages/backend/src/server/ActivityPubServerService.ts b/packages/backend/src/server/ActivityPubServerService.ts
index f7b22c44c4..a5fb5b82e3 100644
--- a/packages/backend/src/server/ActivityPubServerService.ts
+++ b/packages/backend/src/server/ActivityPubServerService.ts
@@ -482,9 +482,19 @@ export class ActivityPubServerService {
return true;
},
dbFallback: async (untilId, sinceId, limit) => {
- return await this.getUserNotesFromDb(sinceId, untilId, limit, user.id);
+ return await this.getUserNotesFromDb({
+ untilId,
+ sinceId,
+ limit,
+ userId: user.id,
+ });
},
- }) : await this.getUserNotesFromDb(sinceId ?? null, untilId ?? null, limit, user.id);
+ }) : await this.getUserNotesFromDb({
+ untilId: untilId ?? null,
+ sinceId: sinceId ?? null,
+ limit,
+ userId: user.id,
+ });
if (sinceId) notes.reverse();
@@ -523,16 +533,21 @@ export class ActivityPubServerService {
}
@bindThis
- private async getUserNotesFromDb(untilId: string | null, sinceId: string | null, limit: number, userId: MiUser['id']) {
- return await this.queryService.makePaginationQuery(this.notesRepository.createQueryBuilder('note'), sinceId, untilId)
- .andWhere('note.userId = :userId', { userId })
+ private async getUserNotesFromDb(ps: {
+ untilId: string | null,
+ sinceId: string | null,
+ limit: number,
+ userId: MiUser['id'],
+ }) {
+ return await this.queryService.makePaginationQuery(this.notesRepository.createQueryBuilder('note'), ps.sinceId, ps.untilId)
+ .andWhere('note.userId = :userId', { userId: ps.userId })
.andWhere(new Brackets(qb => {
qb
.where('note.visibility = \'public\'')
.orWhere('note.visibility = \'home\'');
}))
.andWhere('note.localOnly = FALSE')
- .limit(limit)
+ .limit(ps.limit)
.getMany();
}