X-Git-Url: https://git.immae.eu/?a=blobdiff_plain;f=server%2Flib%2Factivitypub%2Fvideo-rates.ts;h=e246b1313c85b039fb330719bf26cb62170f3fd7;hb=92315d979c3f424d81f8fca3c8831d81e4e2a6d6;hp=581a2bca1d1f94dcccec032955112baa025d4c21;hpb=de94ac86a211dec657332d964693857ec235ce40;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 (