MDS/openide
1
0
Fork 0
mirror of https://gitflic.ru/project/openide/openide.git synced 2026-09-27 10:03:11 +07:00
Code Issues Packages Projects Releases Wiki Activity

[tasks] IJPL-214046 Use coroutines to save task context asynchronously

Browse Source 
(cherry picked from commit 29b13650f3bb940bc9b9dddbaf7ef19854cc40e9)

IJ-CR-179796

GitOrigin-RevId: eba8aa03d06556711556e06fe3cec0b0a9e7cce8
This commit is contained in:
Piotr Tomiak
2025-10-27 22:20:43 +00:00
committed by intellij-monorepo-bot
parent 28a720007d
commit 7a1d0ac40b
3 changed files with 30 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
platform/tasks-platform-impl/resources/messages/TaskBundle.properties
+2 -1
View File
@@ -244,4 +244,5 @@ notification.group.tasks=Task server connection failed
notification.group.context.corrupted=Task context data corrupted
task.list.url.configuration.parameter.is.mandatory='Task list URL' configuration parameter is mandatory
do.not.associate.branch=Do &not associate branch
tasks.widget.accessible.name.prefix=Task
tasks.widget.accessible.name.prefix=Task
progress.title.saving.task.context=Saving task context\u2026
platform/vcs-api/src/com/intellij/openapi/vcs/checkin/CheckinHandler.java
+2
View File
@@ -11,6 +11,7 @@ import com.intellij.openapi.vcs.changes.CommitExecutor;
import com.intellij.openapi.vcs.changes.LocalCommitExecutor;
import com.intellij.openapi.vcs.ui.RefreshableOnComponent;
import com.intellij.util.PairConsumer;
import com.intellij.util.concurrency.annotations.RequiresEdt;
import org.jetbrains.annotations.Nullable;
import java.util.List;
@@ -96,6 +97,7 @@ public abstract class CheckinHandler {
* {@link BaseCheckinHandlerFactory#createHandler(CheckinProjectPanel, CommitContext)} to
* get information about the checked in files.
*/
@RequiresEdt
public void checkinSuccessful() {
}
plugins/tasks/tasks-core/src/com/intellij/tasks/impl/TaskCheckinHandlerFactory.kt
+26 -9
View File
@@ -1,15 +1,23 @@
// Copyright 2000-2024 JetBrains s.r.o. and contributors. Use of this source code is governed by the Apache 2.0 license.
package com.intellij.tasks.impl
import com.intellij.openapi.application.ApplicationManager
import com.intellij.openapi.components.Service
import com.intellij.openapi.components.service
import com.intellij.openapi.project.DumbAware
import com.intellij.openapi.vcs.CheckinProjectPanel
import com.intellij.openapi.vcs.changes.CommitContext
import com.intellij.openapi.vcs.checkin.CheckinHandler
import com.intellij.openapi.vcs.checkin.CheckinHandlerFactory
import com.intellij.platform.ide.progress.withBackgroundProgress
import com.intellij.tasks.Task
import com.intellij.tasks.TaskBundle
import com.intellij.tasks.TaskManager
import com.intellij.tasks.context.WorkingContextManager
import com.intellij.util.concurrency.annotations.RequiresEdt
import kotlinx.coroutines.CoroutineScope
import kotlinx.coroutines.Dispatchers
import kotlinx.coroutines.launch
import kotlinx.coroutines.withContext
import java.util.*
class TaskCheckinHandlerFactory : CheckinHandlerFactory() {
@@ -17,22 +25,31 @@ class TaskCheckinHandlerFactory : CheckinHandlerFactory() {
TaskCheckinHandler(panel)
private class TaskCheckinHandler(val panel: CheckinProjectPanel) : CheckinHandler(), DumbAware {
@RequiresEdt
override fun checkinSuccessful() {
val message = panel.getCommitMessage()
val project = panel.getProject()
val manager = TaskManager.getManager(project) as TaskManagerImpl
if (manager.getState().saveContextOnCommit) {
val task = findTaskInRepositories(message, manager)
?: manager.createLocalTask(message)
.also { (it as LocalTaskImpl).isClosed = true }
val localTask = manager.addTask(task)
localTask.setUpdated(Date())
ApplicationManager.getApplication().invokeLater(
{ WorkingContextManager.getInstance(project).saveContext(localTask) }, project.getDisposed())
project.service<CoroutineScopeHolder>().launch {
withBackgroundProgress(project, TaskBundle.message("progress.title.saving.task.context"), cancellable = true) {
val task = findTaskInRepositories(message, manager)
?: manager.createLocalTask(message)
.also { (it as LocalTaskImpl).isClosed = true }
val localTask = manager.addTask(task)
localTask.setUpdated(Date())
withContext(Dispatchers.Main) {
WorkingContextManager.getInstance(project).saveContext(localTask)
}
}
}
}
}
}
@Service(Service.Level.PROJECT)
private class CoroutineScopeHolder(private val cs: CoroutineScope) : CoroutineScope by cs
}
private fun findTaskInRepositories(message: String, manager: TaskManager): Task? {