mirror of https://github.com/Chocobozzz/PeerTube
				
				
				
			
		
			
				
	
	
		
			52 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			TypeScript
		
	
	
			
		
		
	
	
			52 lines
		
	
	
		
			1.8 KiB
		
	
	
	
		
			TypeScript
		
	
	
import { Transaction } from 'sequelize'
 | 
						|
import { ActivityAnnounce, ActivityAudience } from '../../../../shared/models/activitypub'
 | 
						|
import { broadcastToFollowers } from './utils'
 | 
						|
import { audiencify, getActorsInvolvedInVideo, getAudience, getAudienceFromFollowersOf } from '../audience'
 | 
						|
import { logger } from '../../../helpers/logger'
 | 
						|
import { MActorLight, MVideo } from '../../../types/models'
 | 
						|
import { MVideoShare } from '../../../types/models/video'
 | 
						|
 | 
						|
async function buildAnnounceWithVideoAudience (
 | 
						|
  byActor: MActorLight,
 | 
						|
  videoShare: MVideoShare,
 | 
						|
  video: MVideo,
 | 
						|
  t: Transaction
 | 
						|
) {
 | 
						|
  const announcedObject = video.url
 | 
						|
 | 
						|
  const actorsInvolvedInVideo = await getActorsInvolvedInVideo(video, t)
 | 
						|
  const audience = getAudienceFromFollowersOf(actorsInvolvedInVideo)
 | 
						|
 | 
						|
  const activity = buildAnnounceActivity(videoShare.url, byActor, announcedObject, audience)
 | 
						|
 | 
						|
  return { activity, actorsInvolvedInVideo }
 | 
						|
}
 | 
						|
 | 
						|
async function sendVideoAnnounce (byActor: MActorLight, videoShare: MVideoShare, video: MVideo, t: Transaction) {
 | 
						|
  const { activity, actorsInvolvedInVideo } = await buildAnnounceWithVideoAudience(byActor, videoShare, video, t)
 | 
						|
 | 
						|
  logger.info('Creating job to send announce %s.', videoShare.url)
 | 
						|
 | 
						|
  const followersException = [ byActor ]
 | 
						|
  return broadcastToFollowers(activity, byActor, actorsInvolvedInVideo, t, followersException, 'Announce')
 | 
						|
}
 | 
						|
 | 
						|
function buildAnnounceActivity (url: string, byActor: MActorLight, object: string, audience?: ActivityAudience): ActivityAnnounce {
 | 
						|
  if (!audience) audience = getAudience(byActor)
 | 
						|
 | 
						|
  return audiencify({
 | 
						|
    type: 'Announce' as 'Announce',
 | 
						|
    id: url,
 | 
						|
    actor: byActor.url,
 | 
						|
    object
 | 
						|
  }, audience)
 | 
						|
}
 | 
						|
 | 
						|
// ---------------------------------------------------------------------------
 | 
						|
 | 
						|
export {
 | 
						|
  sendVideoAnnounce,
 | 
						|
  buildAnnounceActivity,
 | 
						|
  buildAnnounceWithVideoAudience
 | 
						|
}
 |