backend-plugin

Author: mustard-mh

components/ide/jetbrains/backend-plugin/src/main/kotlin/io/gitpod/jetbrains/remote/listeners/GradleSyncListener.kt

@@ -4,60 +4,53 @@
 
 package io.gitpod.jetbrains.remote.listeners
 
+import com.intellij.notification.Notification
+import com.intellij.notification.NotificationAction
+import com.intellij.notification.NotificationType
+import com.intellij.notification.Notifications
+import com.intellij.openapi.actionSystem.AnActionEvent
+import com.intellij.openapi.application.ApplicationManager
 import com.intellij.openapi.diagnostic.thisLogger
 import com.intellij.openapi.externalSystem.model.task.ExternalSystemTaskId
 import com.intellij.openapi.externalSystem.model.task.ExternalSystemTaskNotificationListener
-import com.intellij.openapi.externalSystem.model.task.ExternalSystemTaskNotificationListenerAdapter
 import com.intellij.openapi.externalSystem.model.task.ExternalSystemTaskType
-import com.intellij.openapi.progress.ProgressIndicator
-import com.intellij.openapi.progress.ProgressManager
-import com.intellij.openapi.progress.Task
-import kotlinx.coroutines.delay
-import java.util.concurrent.CompletableFuture
-import java.util.concurrent.TimeUnit
+import java.io.File
 
 class GradleSyncListener : ExternalSystemTaskNotificationListener {
     override fun onStart(id: ExternalSystemTaskId, workingDir: String?) {
-        thisLogger().warn("===========hwen.onStart.1 ${id.projectSystemId} ${id.type} ${workingDir}")
         if (id.projectSystemId.toString() != "GRADLE" || id.type != ExternalSystemTaskType.RESOLVE_PROJECT) {
             return
         }
-        thisLogger().warn("===========hwen.onStart.2 gradle")
-
-        Thread.sleep(90000L)
-        thisLogger().warn("===========hwen.onStart.3")
-
-        // 使用后台任务执行延迟
-        ProgressManager.getInstance().run(
-            object : Task.Backgroundable(null, "Waiting before Gradle sync", true) {
-                override fun run(indicator: ProgressIndicator) {
-                    try {
-                        indicator.isIndeterminate = false
-
-                        for (i in 1..10) {
-                            if (indicator.isCanceled) {
-                                thisLogger().warn("===========hwen.4 Delay was cancelled by user")
-                                return
-                            }
-
-                            indicator.fraction = i / 10.0
-                            indicator.text = "Waiting ${10 - i} seconds before Gradle sync..."
-
-                            CompletableFuture.delayedExecutor(1, TimeUnit.SECONDS)
-                                .execute {}.run {  }
-                        }
+        val lockFile = File("/tmp/gitpod-gradle.lock")
+        if (!lockFile.exists()) {
+            return
+        }
 
-                        thisLogger().warn("===========hwen.5 Delay completed, continuing with sync")
-                    } catch (e: Exception) {
-                        thisLogger().error("===========hwen.6 Error during delay", e)
-                    }
-                }
+        val notification = Notification(
+            "gitpod",
+            "Gitpod: Pause gradle sync",
+            "Pausing Gradle Sync, execute <code style='color: orange;'>gp jetbrains gradle resume</code> to unblock all builtin Gradle Sync",
+            NotificationType.INFORMATION
+        )
+        var isCancelled = false
+        notification.addAction(object : NotificationAction("Cancel") {
+            override fun actionPerformed(e: AnActionEvent, notification: Notification) {
+                isCancelled = true
+                notification.expire()
+            }
+        })
+        Notifications.Bus.notify(notification)
 
-                override fun onCancel() {
-                    thisLogger().warn("==============hwen.7 Delay was cancelled")
-                    super.onCancel()
-                }
+        while (lockFile.exists()) {
+            if (isCancelled) {
+                thisLogger().warn("gitpod: gradle sync pausing is cancelled")
+                break
             }
-        )
+            Thread.sleep(1000)
+        }
+        thisLogger().warn("gitpod: gradle sync pausing finished")
+        ApplicationManager.getApplication().invokeLater {
+            notification.expire()
+        }
     }
 }