X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;ds=sidebyside;f=server%2Flib%2Factivitypub%2Fvideo-rates.ts;h=e246b1313c85b039fb330719bf26cb62170f3fd7;hb=b49f22d8f9a52ab75fd38db2d377249eb58fa678;hp=581a2bca1d1f94dcccec032955112baa025d4c21;hpb=6c8c15f914cd375da1db5d0cd4d924a86c53d4c1;p=github%2FChocobozzz%2FPeerTube.git diff --git a/server/lib/activitypub/video-rates.ts b/server/lib/activitypub/video-rates.ts index 581a2bca1..e246b1313 100644 --- a/server/lib/activitypub/video-rates.ts +++ b/server/lib/activitypub/video-rates.ts @@ -13,8 +13,6 @@ import { sendDislike } from './send/send-dislike' import { MAccountActor, MActorUrl, MVideo, MVideoAccountLight, MVideoId } from '../../types/models' async function createRates (ratesUrl: string[], video: MVideo, rate: VideoRateType) { - let rateCounts = 0 - await Bluebird.map(ratesUrl, async rateUrl => { try { // Fetch url @@ -43,21 +41,12 @@ async function createRates (ratesUrl: string[], video: MVideo, rate: VideoRateTy url: body.id } - const created = await AccountVideoRateModel.upsert(entry) - - if (created) rateCounts += 1 + // Video "likes"/"dislikes" will be updated by the caller + await AccountVideoRateModel.upsert(entry) } catch (err) { logger.warn('Cannot add rate %s.', rateUrl, { err }) } }, { concurrency: CRAWL_REQUEST_CONCURRENCY }) - - logger.info('Adding %d %s to video %s.', rateCounts, rate, video.uuid) - - // This is "likes" and "dislikes" - if (rateCounts !== 0) { - const field = rate === 'like' ? 'likes' : 'dislikes' - await video.increment(field, { by: rateCounts }) - } } async function sendVideoRateChange (