diff options
Diffstat (limited to 'server/lib/activitypub')
-rw-r--r-- | server/lib/activitypub/videos.ts | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/server/lib/activitypub/videos.ts b/server/lib/activitypub/videos.ts index cbbf23be1..096884776 100644 --- a/server/lib/activitypub/videos.ts +++ b/server/lib/activitypub/videos.ts | |||
@@ -68,6 +68,7 @@ import { ActorFollowScoreCache } from '../files-cache' | |||
68 | import { JobQueue } from '../job-queue' | 68 | import { JobQueue } from '../job-queue' |
69 | import { Notifier } from '../notifier' | 69 | import { Notifier } from '../notifier' |
70 | import { createPlaceholderThumbnail, createVideoMiniatureFromUrl } from '../thumbnail' | 70 | import { createPlaceholderThumbnail, createVideoMiniatureFromUrl } from '../thumbnail' |
71 | import { setVideoTags } from '../video' | ||
71 | import { autoBlacklistVideoIfNeeded } from '../video-blacklist' | 72 | import { autoBlacklistVideoIfNeeded } from '../video-blacklist' |
72 | import { getOrCreateActorAndServerAndModel } from './actor' | 73 | import { getOrCreateActorAndServerAndModel } from './actor' |
73 | import { crawlCollectionPage } from './crawl' | 74 | import { crawlCollectionPage } from './crawl' |
@@ -409,8 +410,7 @@ async function updateVideoFromAP (options: { | |||
409 | const tags = videoObject.tag | 410 | const tags = videoObject.tag |
410 | .filter(isAPHashTagObject) | 411 | .filter(isAPHashTagObject) |
411 | .map(tag => tag.name) | 412 | .map(tag => tag.name) |
412 | const tagInstances = await TagModel.findOrCreateTags(tags, t) | 413 | await setVideoTags({ video: videoUpdated, tags, transaction: t, defaultValue: videoUpdated.Tags }) |
413 | await videoUpdated.$set('Tags', tagInstances, sequelizeOptions) | ||
414 | } | 414 | } |
415 | 415 | ||
416 | { | 416 | { |
@@ -594,8 +594,7 @@ async function createVideo (videoObject: VideoTorrentObject, channel: MChannelAc | |||
594 | const tags = videoObject.tag | 594 | const tags = videoObject.tag |
595 | .filter(isAPHashTagObject) | 595 | .filter(isAPHashTagObject) |
596 | .map(t => t.name) | 596 | .map(t => t.name) |
597 | const tagInstances = await TagModel.findOrCreateTags(tags, t) | 597 | await setVideoTags({ video: videoCreated, tags, transaction: t }) |
598 | await videoCreated.$set('Tags', tagInstances, sequelizeOptions) | ||
599 | 598 | ||
600 | // Process captions | 599 | // Process captions |
601 | const videoCaptionsPromises = videoObject.subtitleLanguage.map(c => { | 600 | const videoCaptionsPromises = videoObject.subtitleLanguage.map(c => { |
@@ -604,7 +603,6 @@ async function createVideo (videoObject: VideoTorrentObject, channel: MChannelAc | |||
604 | await Promise.all(videoCaptionsPromises) | 603 | await Promise.all(videoCaptionsPromises) |
605 | 604 | ||
606 | videoCreated.VideoFiles = videoFiles | 605 | videoCreated.VideoFiles = videoFiles |
607 | videoCreated.Tags = tagInstances | ||
608 | 606 | ||
609 | const autoBlacklisted = await autoBlacklistVideoIfNeeded({ | 607 | const autoBlacklisted = await autoBlacklistVideoIfNeeded({ |
610 | video: videoCreated, | 608 | video: videoCreated, |