Chocobozzz/PeerTube

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    const body = await unwrapBody<{ videoChannel: VideoChannelCreateResult }>(this.postBodyRequest({
      ...options,

      path,
      fields: attributes,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    muxingSession.on('duration-exceeded', ({ videoUUID }) => {
      logger.info('Stopping session of %s: max duration exceeded.', videoUUID, localLTags)

      this.stopSessionOfVideo({ videoUUID, error: LiveVideoError.DURATION_EXCEEDED })
    })

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

      it('Should accept the registration', async function () {
        await loginPage.loginAsRootUser()

        await adminRegistrationPage.navigateToRegistratonsList()
        await adminRegistrationPage.accept('user_2', 'moderation response')

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    const body = await unwrapBody<{ videoPlaylistElement: VideoPlaylistElementCreateResult }>(this.postBodyRequest({
      ...options,

      path,
      fields: attributes,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  static loadByIdAndPopulateVideoAndAccountAndReply (id: number, transaction?: Transaction): Promise<MCommentOwnerVideoReply> {
    const query = {
      where: {
        id
      },

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  toFormattedJSON (): VideoPassword {
    return {
      id: this.id,
      password: this.password,
      videoId: this.videoId,

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

  addUser (userCreate: UserCreate) {
    return this.authHttp.post(UserService.BASE_USERS_URL, userCreate)
               .pipe(catchError(err => this.restExtractor.handleError(err)))
  }

• Read up
  Read up

Function up has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function up (utils: {
  transaction: Sequelize.Transaction
  queryInterface: Sequelize.QueryInterface
  sequelize: Sequelize.Sequelize
  db: any

Function acceptRunnerJob has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function acceptRunnerJob (req: express.Request, res: express.Response) {
  const runner = res.locals.runner
  const runnerJob = res.locals.runnerJob

  const newRunnerJob = await retryTransactionWrapper(() => {

Function handleToken has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function handleToken (req: express.Request, res: express.Response, next: express.NextFunction) {
  const grantType = req.body.grant_type

  try {
    const bypassLogin = await buildByPassLogin(req, grantType)

Function reorderVideosPlaylist has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function reorderVideosPlaylist (req: express.Request, res: express.Response) {
  const videoPlaylist = res.locals.videoPlaylistFull
  const body: VideoPlaylistReorder = req.body

  const start: number = body.startPosition

Function updateObjectIfNeeded has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function updateObjectIfNeeded <T> (options: {
  url: string
  bodyValidator: (body: any) => boolean
  updater: (url: string, newUrl: string) => Promise<T>
  deleter: (url: string) => Promise<T> }

Function processVideosViewsStats has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function processVideosViewsStats () {
  const lastHour = new Date()

  // In test mode, we run this function multiple times per hour, so we don't want the values of the previous hour
  if (!isTestOrDevInstance()) lastHour.setHours(lastHour.getHours() - 1)

Function buildNewFile has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export async function buildNewFile (options: {
  path: string
  mode: 'web-video' | 'hls'
  ffprobe?: FfprobeData
}): Promise<MVideoFile> {

Function createElements has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private async createElements (playlist: MVideoPlaylistThumbnail, playlistImportData: SanitizedObject) {
    const elementsToCreate: { videoId: number, startTimestamp: number, stopTimestamp: number }[] = []

    for (const element of playlistImportData.elements.slice(0, USER_IMPORT.MAX_PLAYLIST_ELEMENTS)) {
      const video = await loadOrCreateVideoIfAllowedForUser(element.videoUrl)

Function updateSha256VODSegments has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function updateSha256VODSegments (video: MVideo, playlistArg: MStreamingPlaylist): Promise<MStreamingPlaylistFilesVideo> {
  return playlistFilesQueue.add(async () => {
    const json: { [filename: string]: { [range: string]: string } } = {}

    const playlist = await VideoStreamingPlaylistModel.loadWithVideoAndFiles(playlistArg.id)

Function validate has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async validate (segment: Segment, _method: string, _peerId: string, retry = 1) {
    if (this.destroyed) return

    this.loadSha256SegmentsPromiseIfNeeded()

Function create has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async create () {
    logger.debug('Adding remote video %s.', this.videoObject.id, this.lTags())

    const channelActor = await this.getOrCreateVideoChannelFromVideoObject()
    const channel = channelActor.VideoChannel

Function _notifyVideoQualities has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private _notifyVideoQualities () {
    if (!this.metadata) return

    const resolutions: PeerTubeResolution[] = []

Function signup has 34 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  async signup () {
    this.signupError = undefined

    const termsForm = this.formStepTerms.value
    const userForm = this.formStepUser.value