aboutsummaryrefslogtreecommitdiffhomepage
path: root/server/models/video/video-comment.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/models/video/video-comment.ts')
-rw-r--r--server/models/video/video-comment.ts76
1 files changed, 56 insertions, 20 deletions
diff --git a/server/models/video/video-comment.ts b/server/models/video/video-comment.ts
index dfeb1c4e7..ba09522cc 100644
--- a/server/models/video/video-comment.ts
+++ b/server/models/video/video-comment.ts
@@ -21,7 +21,8 @@ import {
21 MCommentOwnerReplyVideoLight, 21 MCommentOwnerReplyVideoLight,
22 MCommentOwnerVideo, 22 MCommentOwnerVideo,
23 MCommentOwnerVideoFeed, 23 MCommentOwnerVideoFeed,
24 MCommentOwnerVideoReply 24 MCommentOwnerVideoReply,
25 MVideoImmutable
25} from '../../typings/models/video' 26} from '../../typings/models/video'
26import { AccountModel } from '../account/account' 27import { AccountModel } from '../account/account'
27import { ActorModel, unusedActorAttributesForAPI } from '../activitypub/actor' 28import { ActorModel, unusedActorAttributesForAPI } from '../activitypub/actor'
@@ -38,14 +39,14 @@ enum ScopeNames {
38} 39}
39 40
40@Scopes(() => ({ 41@Scopes(() => ({
41 [ScopeNames.ATTRIBUTES_FOR_API]: (serverAccountId: number, userAccountId?: number) => { 42 [ScopeNames.ATTRIBUTES_FOR_API]: (blockerAccountIds: number[]) => {
42 return { 43 return {
43 attributes: { 44 attributes: {
44 include: [ 45 include: [
45 [ 46 [
46 Sequelize.literal( 47 Sequelize.literal(
47 '(' + 48 '(' +
48 'WITH "blocklist" AS (' + buildBlockedAccountSQL(serverAccountId, userAccountId) + ')' + 49 'WITH "blocklist" AS (' + buildBlockedAccountSQL(blockerAccountIds) + ')' +
49 'SELECT COUNT("replies"."id") - (' + 50 'SELECT COUNT("replies"."id") - (' +
50 'SELECT COUNT("replies"."id") ' + 51 'SELECT COUNT("replies"."id") ' +
51 'FROM "videoComment" AS "replies" ' + 52 'FROM "videoComment" AS "replies" ' +
@@ -276,16 +277,15 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
276 277
277 static async listThreadsForApi (parameters: { 278 static async listThreadsForApi (parameters: {
278 videoId: number 279 videoId: number
280 isVideoOwned: boolean
279 start: number 281 start: number
280 count: number 282 count: number
281 sort: string 283 sort: string
282 user?: MUserAccountId 284 user?: MUserAccountId
283 }) { 285 }) {
284 const { videoId, start, count, sort, user } = parameters 286 const { videoId, isVideoOwned, start, count, sort, user } = parameters
285 287
286 const serverActor = await getServerActor() 288 const blockerAccountIds = await VideoCommentModel.buildBlockerAccountIds({ videoId, user, isVideoOwned })
287 const serverAccountId = serverActor.Account.id
288 const userAccountId = user ? user.Account.id : undefined
289 289
290 const query = { 290 const query = {
291 offset: start, 291 offset: start,
@@ -304,7 +304,7 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
304 { 304 {
305 accountId: { 305 accountId: {
306 [Op.notIn]: Sequelize.literal( 306 [Op.notIn]: Sequelize.literal(
307 '(' + buildBlockedAccountSQL(serverAccountId, userAccountId) + ')' 307 '(' + buildBlockedAccountSQL(blockerAccountIds) + ')'
308 ) 308 )
309 } 309 }
310 }, 310 },
@@ -320,7 +320,7 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
320 const scopes: (string | ScopeOptions)[] = [ 320 const scopes: (string | ScopeOptions)[] = [
321 ScopeNames.WITH_ACCOUNT_FOR_API, 321 ScopeNames.WITH_ACCOUNT_FOR_API,
322 { 322 {
323 method: [ ScopeNames.ATTRIBUTES_FOR_API, serverAccountId, userAccountId ] 323 method: [ ScopeNames.ATTRIBUTES_FOR_API, blockerAccountIds ]
324 } 324 }
325 ] 325 ]
326 326
@@ -334,14 +334,13 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
334 334
335 static async listThreadCommentsForApi (parameters: { 335 static async listThreadCommentsForApi (parameters: {
336 videoId: number 336 videoId: number
337 isVideoOwned: boolean
337 threadId: number 338 threadId: number
338 user?: MUserAccountId 339 user?: MUserAccountId
339 }) { 340 }) {
340 const { videoId, threadId, user } = parameters 341 const { videoId, threadId, user, isVideoOwned } = parameters
341 342
342 const serverActor = await getServerActor() 343 const blockerAccountIds = await VideoCommentModel.buildBlockerAccountIds({ videoId, user, isVideoOwned })
343 const serverAccountId = serverActor.Account.id
344 const userAccountId = user ? user.Account.id : undefined
345 344
346 const query = { 345 const query = {
347 order: [ [ 'createdAt', 'ASC' ], [ 'updatedAt', 'ASC' ] ] as Order, 346 order: [ [ 'createdAt', 'ASC' ], [ 'updatedAt', 'ASC' ] ] as Order,
@@ -353,7 +352,7 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
353 ], 352 ],
354 accountId: { 353 accountId: {
355 [Op.notIn]: Sequelize.literal( 354 [Op.notIn]: Sequelize.literal(
356 '(' + buildBlockedAccountSQL(serverAccountId, userAccountId) + ')' 355 '(' + buildBlockedAccountSQL(blockerAccountIds) + ')'
357 ) 356 )
358 } 357 }
359 } 358 }
@@ -362,7 +361,7 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
362 const scopes: any[] = [ 361 const scopes: any[] = [
363 ScopeNames.WITH_ACCOUNT_FOR_API, 362 ScopeNames.WITH_ACCOUNT_FOR_API,
364 { 363 {
365 method: [ ScopeNames.ATTRIBUTES_FOR_API, serverAccountId, userAccountId ] 364 method: [ ScopeNames.ATTRIBUTES_FOR_API, blockerAccountIds ]
366 } 365 }
367 ] 366 ]
368 367
@@ -399,13 +398,23 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
399 .findAll(query) 398 .findAll(query)
400 } 399 }
401 400
402 static listAndCountByVideoId (videoId: number, start: number, count: number, t?: Transaction, order: 'ASC' | 'DESC' = 'ASC') { 401 static async listAndCountByVideoForAP (video: MVideoImmutable, start: number, count: number, t?: Transaction) {
402 const blockerAccountIds = await VideoCommentModel.buildBlockerAccountIds({
403 videoId: video.id,
404 isVideoOwned: video.isOwned()
405 })
406
403 const query = { 407 const query = {
404 order: [ [ 'createdAt', order ] ] as Order, 408 order: [ [ 'createdAt', 'ASC' ] ] as Order,
405 offset: start, 409 offset: start,
406 limit: count, 410 limit: count,
407 where: { 411 where: {
408 videoId 412 videoId: video.id,
413 accountId: {
414 [Op.notIn]: Sequelize.literal(
415 '(' + buildBlockedAccountSQL(blockerAccountIds) + ')'
416 )
417 }
409 }, 418 },
410 transaction: t 419 transaction: t
411 } 420 }
@@ -424,7 +433,7 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
424 deletedAt: null, 433 deletedAt: null,
425 accountId: { 434 accountId: {
426 [Op.notIn]: Sequelize.literal( 435 [Op.notIn]: Sequelize.literal(
427 '(' + buildBlockedAccountSQL(serverActor.Account.id) + ')' 436 '(' + buildBlockedAccountSQL([ serverActor.Account.id, '"Video->VideoChannel"."accountId"' ]) + ')'
428 ) 437 )
429 } 438 }
430 }, 439 },
@@ -435,7 +444,14 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
435 required: true, 444 required: true,
436 where: { 445 where: {
437 privacy: VideoPrivacy.PUBLIC 446 privacy: VideoPrivacy.PUBLIC
438 } 447 },
448 include: [
449 {
450 attributes: [ 'accountId' ],
451 model: VideoChannelModel.unscoped(),
452 required: true
453 }
454 ]
439 } 455 }
440 ] 456 ]
441 } 457 }
@@ -650,4 +666,24 @@ export class VideoCommentModel extends Model<VideoCommentModel> {
650 tag 666 tag
651 } 667 }
652 } 668 }
669
670 private static async buildBlockerAccountIds (options: {
671 videoId: number
672 isVideoOwned: boolean
673 user?: MUserAccountId
674 }) {
675 const { videoId, user, isVideoOwned } = options
676
677 const serverActor = await getServerActor()
678 const blockerAccountIds = [ serverActor.Account.id ]
679
680 if (user) blockerAccountIds.push(user.Account.id)
681
682 if (isVideoOwned) {
683 const videoOwnerAccount = await AccountModel.loadAccountIdFromVideo(videoId)
684 blockerAccountIds.push(videoOwnerAccount.id)
685 }
686
687 return blockerAccountIds
688 }
653} 689}