Function processVideo has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

async function processVideo (videoId: number) {
  const video = await VideoModel.loadWithFiles(videoId)

  const hls = video.getHLSPlaylist()
  if (video.isLive || !hls || hls.playlistFilename !== 'master.m3u8' || hls.VideoFiles.length === 0) {

• Read up
  Read up

Function run has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

async function run () {
  await initDatabaseModels(true)

  JobQueue.Instance.init()

• Read up
  Read up

Function isPackageJSONValid has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

function isPackageJSONValid (packageJSON: PluginPackageJSON, pluginType: PluginType_Type) {
  let result = true
  const badFields: string[] = []

  if (!isNpmPluginNameValid(packageJSON.name)) {

• Read up
  Read up

Function generateVideoCaptionValidator has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  async (req: express.Request, res: express.Response, next: express.NextFunction) => {
    if (areValidationErrors(req, res)) return

    if (CONFIG.VIDEO_TRANSCRIPTION.ENABLED !== true) {
      return res.fail({

• Read up
  Read up

Function makeAvailableFactory has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  private async makeAvailableFactory <T> (options: {
    createMethods: MakeAvailableCreateMethod[]
    cbContext: MakeAvailableMultipleCB<T>
  }) {
    const { cbContext, createMethods } = options

• Read up
  Read up

Function updateObjectIfNeeded has a Cognitive Complexity of 11 (exceeds 5 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> }

• Read up
  Read up

Function crawlCollectionPage has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

async function crawlCollectionPage <T> (argUrl: string, handler: HandlerFunction<T>, cleaner?: CleanerFunction) {
  let url = argUrl

  logger.info('Crawling ActivityPub data on %s.', url)

• Read up
  Read up

Function buildMetadataFromVideo has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

function buildMetadataFromVideo (video: MVideoThumbnail, type: ThumbnailType_Type, size?: ImageSize) {
  const existingThumbnail = Array.isArray(video.Thumbnails)
    ? video.Thumbnails.find(t => t.type === type)
    : undefined

• Read up
  Read up

Function resolveRemoteParentComment has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

async function resolveRemoteParentComment (params: ResolveThreadParams) {
  const { url, comments } = params

  if (comments.length > ACTIVITY_PUB.MAX_RECURSION_COMMENTS) {
    throw new Error('Recursion limit reached when resolving a thread')

• Read up
  Read up

Function tryToResolveThreadFromVideo has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

async function tryToResolveThreadFromVideo (params: ResolveThreadParams) {
  const { url, comments, commentCreated } = params

  // Maybe it's a reply to a video?
  // If yes, it's done: we resolved all the thread

• Read up
  Read up

Function getP2PMediaLoaderOptions has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  private getP2PMediaLoaderOptions (options: {
    redundancyUrlManager: RedundancyUrlManager | null
    segmentValidator: SegmentValidator | null
  }): HlsJsEngineSettings {
    const { redundancyUrlManager, segmentValidator } = options

• Read up
  Read up

Function loadVideo has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  private loadVideo (options: {
    videoId: string
    forceAutoplay: boolean
    liveRefresh?: boolean
    videoPassword?: string

• Read up
  Read up

Function sendPendingChunks has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

  private async sendPendingChunks (): Promise<any> {
    if (this.ended) return Promise.resolve()

    const parallelPromises: Promise<any>[] = []

• Read up
  Read up

Function up has 31 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 whereSearch has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  private whereSearch (search?: string) {
    if (!search) {
      this.attributes.push('0 as similarity')
      return
    }

Function getVideoAttributes has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  getVideoAttributes () {
    return [
      'id',
      'uuid',
      'name',

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

Open

async function up (utils: {
  transaction: Sequelize.Transaction
  queryInterface: Sequelize.QueryInterface
  sequelize: Sequelize.Sequelize
}): Promise<void> {

Function createOAuthAdminIfNotExist has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

async function createOAuthAdminIfNotExist () {
  const exist = await usersExist()
  // Nothing to do, users already exist
  if (exist === true) return undefined

Function buildPlayerURLQuery has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function buildPlayerURLQuery (inputQueryUrl: string) {
  const allowedParameters = new Set([
    'start',
    'stop',
    'loop',

Function getPluginValidator has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

const getPluginValidator = (pluginType: PluginType_Type, withVersion = true) => {
  const validators: (ValidationChain | express.Handler)[] = [
    param('pluginName')
      .custom(isPluginNameValid)
  ]