override suspend fun collect()

in intellij-plugin/educational-core/src/com/jetbrains/edu/learning/update/FrameworkTaskUpdater.kt [16:59]
32 lines of code
10 McCabe index (conditional complexity)

  override suspend fun collect(localItems: List<Task>, remoteItems: List<Task>): List<TaskUpdate> {
    // The first tasks in the lists must be the same
    if (!oneIsPrefixOfAnother(localItems, remoteItems)) {
      thisLogger().warn("Failed to update framework lesson \"${lesson.name}\" (id=${lesson.id}): old and new tasks do not match")
      return emptyList()
    }

    val prefixLength = min(localItems.size, remoteItems.size)

    val result = mutableListOf<TaskUpdate>()

    // deleted tasks
    if (localItems.size > prefixLength) {
      for (deletedTask in localItems.subList(prefixLength, localItems.size)) {
        result.add(TaskDeletionInfo(deletedTask))
      }
    }

    // created tasks
    if (remoteItems.size > prefixLength) {
      for (createdTask in remoteItems.subList(prefixLength, remoteItems.size)) {
        result.add(TaskCreationInfo(lesson, createdTask))
      }
    }

    val localLesson = localItems.firstOrNull()?.lesson as? FrameworkLesson ?: return result
    val remoteLesson = remoteItems.getOrNull(0)?.lesson as? FrameworkLesson ?: return result

    val propagateFilesOnNavigation = localLesson.propagateFilesOnNavigation
    if (propagateFilesOnNavigation != remoteLesson.propagateFilesOnNavigation) {
      thisLogger().error("Unable to update framework lesson \"${lesson.name}\": isTemplateBased flag is changed")
      return emptyList()
    }

    val taskHistory = FrameworkLessonHistory.create(project, localLesson, remoteLesson, propagateFilesOnNavigation)
    for ((localTask, remoteTask) in localItems.zip(remoteItems)) {
      // current task for non-template based FL should always be updated because the "task" folder could change because of propagation
      if (localTask.shouldBeUpdated(remoteTask) || localTask == lesson.currentTask()) {
        result.add(FrameworkTaskUpdateInfo(localTask, remoteTask, taskHistory))
      }
    }

    return result
  }