feat(codereview): add issue tracker integration #453

Introduce issue tracker support in code review, including new services, configuration dialogs, and related UI updates.

Author: phodal

mpp-core/src/androidMain/kotlin/cc/unitmesh/agent/platform/GitOperations.android.kt

@@ -45,4 +45,8 @@ actual class GitOperations actual constructor(private val projectPath: String) {
     actual suspend fun getDiff(base: String, target: String): GitDiffInfo? {
         return null
     }
+    
+    actual suspend fun getRemoteUrl(remoteName: String): String? {
+        return null
+    }
 }

mpp-core/src/commonMain/kotlin/cc/unitmesh/agent/platform/GitOperations.kt

@@ -60,4 +60,11 @@ expect class GitOperations(projectPath: String) {
      * @return true 表示支持，false 表示不支持
      */
     fun isSupported(): Boolean
+    
+    /**
+     * 获取 git remote URL
+     * @param remoteName remote 名称（默认为 "origin"）
+     * @return remote URL，如果获取失败返回 null
+     */
+    suspend fun getRemoteUrl(remoteName: String = "origin"): String?
 }

mpp-core/src/iosMain/kotlin/cc/unitmesh/agent/platform/GitOperations.ios.kt

@@ -39,5 +39,9 @@ actual class GitOperations actual constructor(private val projectPath: String) {
     }
 
     actual fun isSupported(): Boolean = false
+    
+    actual suspend fun getRemoteUrl(remoteName: String): String? {
+        return null
+    }
 }
 

mpp-core/src/jsMain/kotlin/cc/unitmesh/agent/platform/GitOperations.js.kt

@@ -153,6 +153,26 @@ actual class GitOperations actual constructor(private val projectPath: String) {
 
     actual fun isSupported(): Boolean = isNodeJs
 
+    actual suspend fun getRemoteUrl(remoteName: String): String? {
+        if (!isNodeJs) {
+            return null
+        }
+        
+        return try {
+            val output = execGitCommand("git remote get-url $remoteName")
+            val url = output.trim()
+            if (url.isNotBlank()) {
+                logger.info { "Remote '$remoteName' URL: $url" }
+                url
+            } else {
+                null
+            }
+        } catch (e: Throwable) {
+            logger.warn(e) { "Failed to get remote URL: ${e.message}" }
+            null
+        }
+    }
+    
     // Private helper methods
 
     private fun parseCommitLine(line: String): GitCommitInfo? {

mpp-core/src/jvmMain/kotlin/cc/unitmesh/agent/platform/GitOperations.jvm.kt

@@ -238,6 +238,31 @@ actual class GitOperations actual constructor(private val projectPath: String) {
 
     actual fun isSupported(): Boolean = true
 
+    actual suspend fun getRemoteUrl(remoteName: String): String? = withContext(Dispatchers.IO) {
+        try {
+            val command = listOf("git", "remote", "get-url", remoteName)
+            
+            val process = ProcessBuilder(command)
+                .directory(File(projectPath))
+                .redirectErrorStream(true)
+                .start()
+            
+            val output = process.inputStream.bufferedReader().readText().trim()
+            val exitCode = process.waitFor()
+            
+            if (exitCode != 0 || output.isBlank()) {
+                logger.debug { "No remote URL found for '$remoteName'" }
+                return@withContext null
+            }
+            
+            logger.info { "Remote '$remoteName' URL: $output" }
+            output
+        } catch (e: Exception) {
+            logger.warn(e) { "Failed to get remote URL: ${e.message}" }
+            null
+        }
+    }
+    
     // Private helper methods
 
     private fun parseCommitLine(line: String): GitCommitInfo? {

mpp-core/src/wasmJsMain/kotlin/cc/unitmesh/agent/platform/GitOperations.wasmJs.kt

@@ -377,6 +377,27 @@ actual class GitOperations actual constructor(private val projectPath: String) {
             false
         }
     }
+    
+    actual suspend fun getRemoteUrl(remoteName: String): String? {
+        initialize()
+        
+        val module = lg2Module ?: return null
+        
+        return try {
+            commandOutputBuffer.clear()
+            val exitCode = module.callMain(jsArrayOf("remote", "get-url", remoteName)).await<JsNumber>().toInt()
+            
+            if (exitCode != 0) {
+                WasmConsole.warn("git remote get-url failed with exit code: $exitCode")
+                return null
+            }
+            
+            commandOutputBuffer.firstOrNull()?.trim()?.takeIf { it.isNotBlank() }
+        } catch (e: Throwable) {
+            WasmConsole.error("Failed to get remote URL: ${e.message}")
+            null
+        }
+    }
 }
 
 fun debugObj(obj: LibGit2Module): Unit = js("console.log(obj)")

mpp-ui/src/androidMain/kotlin/cc/unitmesh/devins/ui/config/ConfigManager.android.kt

@@ -176,6 +176,19 @@ actual object ConfigManager {
         val wrapper = load()
         return wrapper.getLastWorkspace()
     }
+    
+    actual suspend fun saveIssueTracker(issueTracker: IssueTrackerConfig) {
+        val wrapper = load()
+        val configFile = wrapper.configFile
+        
+        val updatedConfigFile = configFile.copy(issueTracker = issueTracker)
+        save(updatedConfigFile)
+    }
+    
+    actual suspend fun getIssueTracker(): IssueTrackerConfig? {
+        val wrapper = load()
+        return wrapper.getIssueTracker()
+    }
 
     actual suspend fun loadToolConfig(): ToolConfigFile =
         withContext(Dispatchers.IO) {

mpp-ui/src/commonMain/kotlin/cc/unitmesh/devins/ui/compose/agent/codereview/CodeReviewModels.kt

@@ -3,6 +3,7 @@ package cc.unitmesh.devins.ui.compose.agent.codereview
 import cc.unitmesh.agent.linter.LintFileResult
 import cc.unitmesh.agent.diff.ChangeType
 import cc.unitmesh.agent.diff.DiffHunk
+import cc.unitmesh.agent.tracker.IssueInfo
 import kotlinx.serialization.Serializable
 
 /**
@@ -131,5 +132,7 @@ data class CommitInfo(
     val author: String,
     val timestamp: Long,
     val date: String,
-    val message: String
+    val message: String,
+    val issueInfo: IssueInfo? = null, // Issue information extracted from commit message
+    val isLoadingIssue: Boolean = false // Whether issue info is being loaded
 )

mpp-ui/src/commonMain/kotlin/cc/unitmesh/devins/ui/compose/agent/codereview/CodeReviewPage.kt

@@ -10,6 +10,7 @@ import cc.unitmesh.devins.ui.compose.icons.AutoDevComposeIcons
 import cc.unitmesh.devins.workspace.Workspace
 import cc.unitmesh.devins.workspace.WorkspaceManager
 import cc.unitmesh.llm.KoogLLMService
+import kotlinx.coroutines.launch
 
 /**
  * Code Review Page - Entry point for the Side-by-Side code review UI (redesigned)
@@ -47,6 +48,7 @@ fun CodeReviewPage(
                     onRefresh = { viewModel.refresh() },
                     workspace = currentWorkspace,
                     onBack = onBack,
+                    viewModel = viewModel
                 )
             },
             modifier = modifier,
@@ -76,8 +78,12 @@ fun CodeReviewPage(
 private fun CodeReviewTopBar(
     onRefresh: () -> Unit,
     workspace: Workspace?,
-    onBack: () -> Unit
+    onBack: () -> Unit,
+    viewModel: CodeReviewViewModel
 ) {
+    var showIssueTrackerDialog by remember { mutableStateOf(false) }
+    val scope = rememberCoroutineScope()
+    
     TopAppBar(
         title = {
             Column {
@@ -108,6 +114,15 @@ private fun CodeReviewTopBar(
             }
         },
         actions = {
+            // Issue Tracker Settings button
+            IconButton(onClick = { showIssueTrackerDialog = true }) {
+                Icon(
+                    imageVector = AutoDevComposeIcons.Settings,
+                    contentDescription = "Issue Tracker Settings",
+                    tint = MaterialTheme.colorScheme.onSurface
+                )
+            }
+            
             IconButton(onClick = onRefresh) {
                 Icon(
                     imageVector = AutoDevComposeIcons.Refresh,
@@ -121,4 +136,30 @@ private fun CodeReviewTopBar(
             titleContentColor = MaterialTheme.colorScheme.onSurface
         )
     )
+    
+    // Issue Tracker Configuration Dialog
+    if (showIssueTrackerDialog) {
+        val currentConfig = remember {
+            mutableStateOf<cc.unitmesh.devins.ui.config.IssueTrackerConfig?>(null)
+        }
+        
+        LaunchedEffect(Unit) {
+            currentConfig.value = cc.unitmesh.devins.ui.config.ConfigManager.getIssueTracker()
+        }
+        
+        IssueTrackerConfigDialog(
+            onDismiss = { showIssueTrackerDialog = false },
+            onConfigured = {
+                // Reload issue service when configuration changes
+                scope.launch {
+                    try {
+                        viewModel.reloadIssueService()
+                    } catch (e: Exception) {
+                        // Handle error
+                    }
+                }
+            },
+            initialConfig = currentConfig.value
+        )
+    }
 }

mpp-ui/src/commonMain/kotlin/cc/unitmesh/devins/ui/compose/agent/codereview/CodeReviewViewModel.kt

@@ -44,6 +44,9 @@ open class CodeReviewViewModel(
     // Non-AI analysis components (extracted for testability)
     private val codeAnalyzer = CodeAnalyzer(workspace)
     private val lintExecutor = LintExecutor()
+    
+    // Issue tracker service
+    private val issueService = IssueService(workspace.rootPath ?: "")
 
     // State
     private val _state = MutableStateFlow(CodeReviewState())
@@ -81,6 +84,8 @@ open class CodeReviewViewModel(
             CoroutineScope(Dispatchers.Default).launch {
                 try {
                     codeReviewAgent = initializeCodingAgent()
+                    // Initialize issue service
+                    issueService.initialize(if (gitOps.isSupported()) gitOps else null)
                     if (gitOps.isSupported()) {
                         loadCommitHistory()
                     } else {
@@ -146,6 +151,8 @@ open class CodeReviewViewModel(
 
             if (commits.isNotEmpty()) {
                 loadCommitDiffInternal(commits[0].hash)
+                // Load issue info for first commit asynchronously
+                loadIssueForCommit(0)
             }
 
         } catch (e: Exception) {
@@ -192,6 +199,12 @@ open class CodeReviewViewModel(
                     isLoadingMore = false
                 )
             }
+            
+            // Load issue info for newly loaded commits asynchronously
+            val startIndex = currentCount
+            additionalCommits.forEachIndexed { offset, _ ->
+                loadIssueForCommit(startIndex + offset)
+            }
 
         } catch (e: Exception) {
             updateState {
@@ -940,6 +953,82 @@ open class CodeReviewViewModel(
         }
     }
 
+    /**
+     * Load issue information for a specific commit asynchronously
+     * 
+     * @param commitIndex Index of the commit in commitHistory
+     */
+    private fun loadIssueForCommit(commitIndex: Int) {
+        val commit = currentState.commitHistory.getOrNull(commitIndex) ?: return
+        
+        // Skip if already loaded or loading
+        if (commit.issueInfo != null || commit.isLoadingIssue) {
+            return
+        }
+        
+        // Mark as loading
+        updateCommitAtIndex(commitIndex) { it.copy(isLoadingIssue = true) }
+        
+        // Load issue asynchronously
+        scope.launch {
+            try {
+                val issueDeferred = issueService.getIssueAsync(commit.hash, commit.message)
+                val issueInfo = issueDeferred.await()
+                
+                // Update commit with issue info
+                updateCommitAtIndex(commitIndex) { 
+                    it.copy(issueInfo = issueInfo, isLoadingIssue = false) 
+                }
+            } catch (e: Exception) {
+                AutoDevLogger.error("CodeReviewViewModel") {
+                    "Failed to load issue for commit ${commit.shortHash}: ${e.message}"
+                }
+                updateCommitAtIndex(commitIndex) { it.copy(isLoadingIssue = false) }
+            }
+        }
+    }
+    
+    /**
+     * Update a commit at a specific index
+     */
+    private fun updateCommitAtIndex(index: Int, update: (CommitInfo) -> CommitInfo) {
+        val commits = currentState.commitHistory
+        if (index !in commits.indices) return
+        
+        val updatedCommits = commits.toMutableList()
+        updatedCommits[index] = update(updatedCommits[index])
+        
+        updateState { it.copy(commitHistory = updatedCommits) }
+    }
+    
+    /**
+     * Reload issue service (called when configuration changes)
+     */
+    suspend fun reloadIssueService() {
+        try {
+            AutoDevLogger.info("CodeReviewViewModel") {
+                "Reloading issue service..."
+            }
+            issueService.reload(if (gitOps.isSupported()) gitOps else null)
+            
+            // Reload issues for all commits
+            currentState.commitHistory.forEachIndexed { index, commit ->
+                // Reset issue info
+                updateCommitAtIndex(index) { it.copy(issueInfo = null, isLoadingIssue = false) }
+                // Reload
+                loadIssueForCommit(index)
+            }
+            
+            AutoDevLogger.info("CodeReviewViewModel") {
+                "Issue service reloaded successfully"
+            }
+        } catch (e: Exception) {
+            AutoDevLogger.error("CodeReviewViewModel") {
+                "Failed to reload issue service: ${e.message}"
+            }
+        }
+    }
+    
     /**
      * Cleanup when ViewModel is disposed
      */