1 files changed, 44 insertions, 0 deletions
diff --git a/Omni/Task/Core.hs b/Omni/Task/Core.hs
index 4e65581..3a71900 100644
--- a/Omni/Task/Core.hs
+++ b/Omni/Task/Core.hs
@@ -1026,3 +1026,47 @@ getActivitiesForTask tid =
   where
     readStage :: Text -> ActivityStage
     readStage s = fromMaybe Claiming (readMaybe (T.unpack s))
+
+-- | Get tasks with unmet blocking dependencies (not ready, not done)
+getBlockedTasks :: IO [Task]
+getBlockedTasks = do
+  allTasks <- loadTasks
+  readyTasks <- getReadyTasks
+  let readyIds = map taskId readyTasks
+      doneIds = [taskId t | t <- allTasks, taskStatus t == Done]
+      isBlocked task =
+        taskStatus task
+          `elem` [Open, InProgress]
+          && taskId task
+          `notElem` readyIds
+          && taskId task
+          `notElem` doneIds
+  pure [t | t <- allTasks, isBlocked t]
+
+-- | Get tasks that have failed 3+ times and need human intervention
+getInterventionTasks :: IO [Task]
+getInterventionTasks = do
+  allTasks <- loadTasks
+  retryContexts <- getAllRetryContexts
+  let highRetryIds = [retryTaskId ctx | ctx <- retryContexts, retryAttempt ctx >= 3]
+  pure [t | t <- allTasks, taskId t `elem` highRetryIds]
+
+-- | Get all retry contexts from the database
+getAllRetryContexts :: IO [RetryContext]
+getAllRetryContexts =
+  withDb <| \conn -> do
+    rows <-
+      SQL.query_
+        conn
+        "SELECT task_id, original_commit, conflict_files, attempt, reason FROM retry_context" ::
+        IO [(Text, Text, Text, Int, Text)]
+    pure
+      [ RetryContext
+          { retryTaskId = tid,
+            retryOriginalCommit = commit,
+            retryConflictFiles = fromMaybe [] (decode (BLC.pack (T.unpack filesJson))),
+            retryAttempt = attempt,
+            retryReason = reason
+          }
+        | (tid, commit, filesJson, attempt, reason) <- rows
+      ]