introduce rate limiting to delay didChangeDependencyPaths events

liumofei-amazon · liumofei-amazon · commit f4ae22edca98 · 2025-07-09T16:46:28.000-07:00
diff --git a/plugins/amazonq/shared/jetbrains-community/src/software/aws/toolkits/jetbrains/services/amazonq/lsp/dependencies/DefaultModuleDependenciesService.kt b/plugins/amazonq/shared/jetbrains-community/src/software/aws/toolkits/jetbrains/services/amazonq/lsp/dependencies/DefaultModuleDependenciesService.kt
@@ -9,6 +9,7 @@ import com.intellij.openapi.project.Project
 import com.intellij.openapi.roots.ModuleRootEvent
 import com.intellij.openapi.roots.ModuleRootListener
 import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.delay
 import kotlinx.coroutines.launch
 import software.aws.toolkits.jetbrains.services.amazonq.lsp.AmazonQLspService
 import software.aws.toolkits.jetbrains.services.amazonq.lsp.dependencies.ModuleDependencyProvider.Companion.EP_NAME
@@ -66,7 +67,12 @@ class DefaultModuleDependenciesService(
             }
         }
 
-        paramsMap.values.forEach { didChangeDependencyPaths(it) }
+        paramsMap.values.chunked(10).forEachIndexed { index, chunk ->
+            cs.launch {
+                delay(index * 1000L)
+                chunk.forEach { didChangeDependencyPaths(it) }
+            }
+        }
     }
 
     override fun dispose() {

Original file line number	Diff line number	Diff line change
`@@ -9,6 +9,7 @@ import com.intellij.openapi.project.Project`
`9`	`9`	`import com.intellij.openapi.roots.ModuleRootEvent`
`10`	`10`	`import com.intellij.openapi.roots.ModuleRootListener`
`11`	`11`	`import kotlinx.coroutines.CoroutineScope`
	`12`	`+import kotlinx.coroutines.delay`
`12`	`13`	`import kotlinx.coroutines.launch`
`13`	`14`	`import software.aws.toolkits.jetbrains.services.amazonq.lsp.AmazonQLspService`
`14`	`15`	`import software.aws.toolkits.jetbrains.services.amazonq.lsp.dependencies.ModuleDependencyProvider.Companion.EP_NAME`
`@@ -66,7 +67,12 @@ class DefaultModuleDependenciesService(`
`66`	`67`	`}`
`67`	`68`	`}`
`68`	`69`
`69`		`- paramsMap.values.forEach { didChangeDependencyPaths(it) }`
	`70`	`+ paramsMap.values.chunked(10).forEachIndexed { index, chunk ->`
	`71`	`+ cs.launch {`
	`72`	`+ delay(index * 1000L)`
	`73`	`+ chunk.forEach { didChangeDependencyPaths(it) }`
	`74`	`+ }`
	`75`	`+ }`
`70`	`76`	`}`
`71`	`77`
`72`	`78`	`override fun dispose() {`