feat(observer): enable AddDependencyAgentObserver and refactor message processing #259

- Enable AddDependencyAgentObserver in autodev-core.xml.
- Rename `preprocessMessages` to `processMessages` in AgentStateService.
- Add `dispose` method to AddDependencyAgentObserver for cleanup.
- Remove unused `resetMessages` method and add placeholder for `resolveIssue`.

Author: phodal

core/src/233/main/resources/META-INF/autodev-core.xml

@@ -278,7 +278,7 @@
 
         <agentObserver implementation="cc.unitmesh.devti.observer.TestAgentObserver" />
         <agentObserver implementation="cc.unitmesh.devti.observer.BuiltTaskAgentObserver" />
-<!--        <agentObserver implementation="cc.unitmesh.devti.observer.AddDependencyAgentObserver" />-->
+        <agentObserver implementation="cc.unitmesh.devti.observer.AddDependencyAgentObserver" />
 <!--        <agentObserver implementation="cc.unitmesh.devti.observer.ChangeListObserver" />-->
     </extensions>
 

core/src/main/kotlin/cc/unitmesh/devti/llms/custom/CustomLLMProvider.kt

@@ -84,7 +84,7 @@ class CustomLLMProvider(val project: Project, var llmConfig: LlmConfig = LlmConf
         }
 
         messages += Message("user", prompt)
-        val finalMsgs = agentService.preprocessMessages(messages)
+        val finalMsgs = agentService.processMessages(messages)
 
         val customRequest = CustomRequest(finalMsgs)
         val requestContent = customRequest.updateCustomFormat(requestFormat)

core/src/main/kotlin/cc/unitmesh/devti/observer/AddDependencyAgentObserver.kt

@@ -1,9 +1,32 @@
 package cc.unitmesh.devti.observer
 
 import cc.unitmesh.devti.provider.observer.AgentObserver
+import com.intellij.openapi.Disposable
+import com.intellij.openapi.externalSystem.service.project.manage.ProjectDataImportListener
 import com.intellij.openapi.project.Project
+import com.intellij.util.messages.MessageBusConnection
 
-class AddDependencyAgentObserver : AgentObserver {
+/**
+ * When test can use an unknown dependency, it will trigger the observer to store the error.
+ */
+class AddDependencyAgentObserver : AgentObserver, Disposable {
+    private var connection: MessageBusConnection? = null
     override fun onRegister(project: Project) {
+        connection = project.messageBus.connect()
+        connection?.subscribe(ProjectDataImportListener.TOPIC, object : ProjectDataImportListener {
+            override fun onImportFailed(projectPath: String?, t: Throwable) {
+                val prompt = """Help me fix follow dependency issue:
+                               |## ErrorMessage:
+                               |```
+                               |${t.message}
+                               |""".trimMargin()
+
+                sendErrorNotification(project, prompt)
+            }
+        })
+    }
+
+    override fun dispose() {
+        connection?.disconnect()
     }
-}
+}

core/src/main/kotlin/cc/unitmesh/devti/observer/TestAgentObserver.kt

@@ -135,7 +135,6 @@ class TestAgentObserver : AgentObserver, Disposable {
         }
     }
 
-
     private fun getConsoleView(executionConsole: ExecutionConsole): ConsoleViewImpl? {
         when (executionConsole) {
             is ConsoleViewImpl -> {
@@ -170,8 +169,6 @@ class TestAgentObserver : AgentObserver, Disposable {
         }
     }
 
-// ToolWindowManager.getInstance(project).getToolWindow(ToolWindowId.DEBUG)
-
     override fun dispose() {
         connection?.disconnect()
     }

core/src/main/kotlin/cc/unitmesh/devti/observer/agent/AgentStateService.kt

@@ -26,15 +26,16 @@ class AgentStateService {
         // todo changeList.add()
     }
 
-    fun resetMessages() {
-        state.messages = emptyList()
-    }
-
     /**
      * Call some LLM to compress it or use some other method to compress the history
      */
-    fun preprocessMessages(messages: List<Message>): List<Message> {
+    fun processMessages(messages: List<Message>): List<Message> {
         state.messages = messages
+        /// todo compress message in here
         return messages
     }
+
+    fun resolveIssue() {
+        // todo resolve issue
+    }
 }