[github/Chocobozzz/PeerTube.git] / follows.ts

import { waitJobs } from './jobs'
import { ServerInfo } from './servers'

async function doubleFollow (server1: ServerInfo, server2: ServerInfo) {
  await Promise.all([
    server1.followsCommand.follow({ targets: [ server2.url ] }),
    server2.followsCommand.follow({ targets: [ server1.url ] })
  ])

  // Wait request propagation
  await waitJobs([ server1, server2 ])

  return true
}

// ---------------------------------------------------------------------------

export {
  doubleFollow
}
Commit	Line	Data
	1	import { waitJobs } from './jobs'
	2	import { ServerInfo } from './servers'
	3
	4	async function doubleFollow (server1: ServerInfo, server2: ServerInfo) {
	5	await Promise.all([
	6	server1.followsCommand.follow({ targets: [ server2.url ] }),
	7	server2.followsCommand.follow({ targets: [ server1.url ] })
	8	])
	9
	10	// Wait request propagation
	11	await waitJobs([ server1, server2 ])
	12
	13	return true
	14	}
	15
	16	// ---------------------------------------------------------------------------
	17
	18	export {
	19	doubleFollow
	20	}