diff options
Diffstat (limited to 'server/models')
-rw-r--r-- | server/models/activitypub/actor-follow.ts | 6 | ||||
-rw-r--r-- | server/models/utils.ts | 14 |
2 files changed, 17 insertions, 3 deletions
diff --git a/server/models/activitypub/actor-follow.ts b/server/models/activitypub/actor-follow.ts index c3c4d61ab..c65b975d2 100644 --- a/server/models/activitypub/actor-follow.ts +++ b/server/models/activitypub/actor-follow.ts | |||
@@ -23,7 +23,7 @@ import { logger } from '../../helpers/logger' | |||
23 | import { getServerActor } from '../../helpers/utils' | 23 | import { getServerActor } from '../../helpers/utils' |
24 | import { ACTOR_FOLLOW_SCORE, FOLLOW_STATES, SERVER_ACTOR_NAME } from '../../initializers/constants' | 24 | import { ACTOR_FOLLOW_SCORE, FOLLOW_STATES, SERVER_ACTOR_NAME } from '../../initializers/constants' |
25 | import { ServerModel } from '../server/server' | 25 | import { ServerModel } from '../server/server' |
26 | import { createSafeIn, getSort } from '../utils' | 26 | import { createSafeIn, getSort, getFollowsSort } from '../utils' |
27 | import { ActorModel, unusedActorAttributesForAPI } from './actor' | 27 | import { ActorModel, unusedActorAttributesForAPI } from './actor' |
28 | import { VideoChannelModel } from '../video/video-channel' | 28 | import { VideoChannelModel } from '../video/video-channel' |
29 | import { AccountModel } from '../account/account' | 29 | import { AccountModel } from '../account/account' |
@@ -324,7 +324,7 @@ export class ActorFollowModel extends Model<ActorFollowModel> { | |||
324 | distinct: true, | 324 | distinct: true, |
325 | offset: start, | 325 | offset: start, |
326 | limit: count, | 326 | limit: count, |
327 | order: getSort(sort), | 327 | order: getFollowsSort(sort), |
328 | where: followWhere, | 328 | where: followWhere, |
329 | include: [ | 329 | include: [ |
330 | { | 330 | { |
@@ -391,7 +391,7 @@ export class ActorFollowModel extends Model<ActorFollowModel> { | |||
391 | distinct: true, | 391 | distinct: true, |
392 | offset: start, | 392 | offset: start, |
393 | limit: count, | 393 | limit: count, |
394 | order: getSort(sort), | 394 | order: getFollowsSort(sort), |
395 | where: followWhere, | 395 | where: followWhere, |
396 | include: [ | 396 | include: [ |
397 | { | 397 | { |
diff --git a/server/models/utils.ts b/server/models/utils.ts index ccdbcd1cf..b53a52a05 100644 --- a/server/models/utils.ts +++ b/server/models/utils.ts | |||
@@ -58,6 +58,19 @@ function getBlacklistSort (model: any, value: string, lastSort: OrderItem = [ 'i | |||
58 | return [ firstSort, lastSort ] | 58 | return [ firstSort, lastSort ] |
59 | } | 59 | } |
60 | 60 | ||
61 | function getFollowsSort (value: string, lastSort: OrderItem = [ 'id', 'ASC' ]): OrderItem[] { | ||
62 | const { direction, field } = buildDirectionAndField(value) | ||
63 | |||
64 | if (field === 'redundancyAllowed') { | ||
65 | return [ | ||
66 | [ 'ActorFollowing', 'Server', 'redundancyAllowed', direction ], | ||
67 | lastSort | ||
68 | ] | ||
69 | } | ||
70 | |||
71 | return getSort(value, lastSort) | ||
72 | } | ||
73 | |||
61 | function isOutdated (model: { createdAt: Date, updatedAt: Date }, refreshInterval: number) { | 74 | function isOutdated (model: { createdAt: Date, updatedAt: Date }, refreshInterval: number) { |
62 | const now = Date.now() | 75 | const now = Date.now() |
63 | const createdAtTime = model.createdAt.getTime() | 76 | const createdAtTime = model.createdAt.getTime() |
@@ -163,6 +176,7 @@ export { | |||
163 | buildWhereIdOrUUID, | 176 | buildWhereIdOrUUID, |
164 | isOutdated, | 177 | isOutdated, |
165 | parseAggregateResult, | 178 | parseAggregateResult, |
179 | getFollowsSort, | ||
166 | createSafeIn | 180 | createSafeIn |
167 | } | 181 | } |
168 | 182 | ||