generated from coulomb/repo-seed
Bernd Worsch
3737845e02
Fixes 46 compile errors across 18 controllers and views: - BridgeResponse missing from explicit import lists (Widgets, RequirementCandidates, DecisionRecords, AgentDelegations) — dot-notation HasField resolution fails without the type in scope under DuplicateRecordFields - unId not in IHP v1.5 — replaced all fmap (Id . unId) with fmap coerce - respondWith not in IHP — replaced with plain redirectTo in 5 controllers - [hubId] list param to sqlQuery — replaced with (Only hubId) tuple - deleteWhere not in IHP — replaced with query/filterWhere/fetch/deleteRecords - fill @'["label"] mismatch — field is label_ in generated types, not label - PersistUUID/toUUID (persistent-style) — replaced with (Only id) - intercalate + jsonArrayTexts ambiguity in GovernanceTemplates — hid Index import, removed local duplicates, added Data.Text (intercalate) - Int16 not in scope in AntifragilityDashboard — changed to Int (score :: Int) - typeArraySection type mismatch in HubCapabilityManifests/Edit — unified to [Text] - renderForm arity mismatch — added action param to DecisionRecords/New.renderForm - Missing qualified Data.Aeson import in AdaptiveThresholds - Missing ?request::Request constraint in Api/V2/WidgetPatterns.renderJsonWithStatus Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
90 lines
3.9 KiB
Haskell
90 lines
3.9 KiB
Haskell
module Web.Controller.AgentDelegations where
|
|
|
|
-- IHF Phase 11 — Advanced AI Federation (IHUB-WP-0012 T06)
|
|
-- Updated: delegation token budget enforced natively by llm-connect BudgetTracker (FR-4).
|
|
|
|
import Web.Controller.Prelude
|
|
import Web.View.AgentDelegations.Index
|
|
import Web.View.AgentDelegations.Show
|
|
import qualified Data.Aeson as A
|
|
import Application.Helper.AgentBridge
|
|
( callAgentWithBudget
|
|
, BridgeError(..)
|
|
, BridgeResponse
|
|
, bridgeErrorMessage
|
|
)
|
|
|
|
instance Controller AgentDelegationsController where
|
|
|
|
action AgentDelegationsAction = do
|
|
delegations <- query @AgentDelegation
|
|
|> orderByDesc #createdAt
|
|
|> fetch
|
|
render IndexView { .. }
|
|
|
|
action ShowAgentDelegationAction { agentDelegationId } = do
|
|
delegation <- fetch agentDelegationId
|
|
delegatingAgent <- fetch delegation.delegatingAgentId
|
|
receivingAgent <- fetch delegation.receivingAgentId
|
|
mParentProposal <- case delegation.parentProposalId of
|
|
Nothing -> pure Nothing
|
|
Just pid -> fetchOneOrNothing pid
|
|
render ShowView { .. }
|
|
|
|
action DelegateSubtaskAction { agentProposalId } = do
|
|
proposal <- fetch agentProposalId
|
|
let receivingAgentId = param @(Id AgentRegistration) "receivingAgentId"
|
|
scope = param @Text "scope"
|
|
tokenBudget = paramOrDefault @Int 1000 "tokenBudget"
|
|
delegatingAgentId <- case (proposal.agentRegistrationId :: Maybe (Id AgentRegistration)) of
|
|
Just aid -> pure aid
|
|
Nothing -> respondAndExit =<< renderNotFound
|
|
|
|
receivingAgent <- fetch receivingAgentId
|
|
|
|
delegation <- newRecord @AgentDelegation
|
|
|> set #delegatingAgentId delegatingAgentId
|
|
|> set #receivingAgentId receivingAgentId
|
|
|> set #parentProposalId (Just agentProposalId)
|
|
|> set #scope scope
|
|
|> set #tokenBudget tokenBudget
|
|
|> set #status "pending"
|
|
|> createRecord
|
|
|
|
-- FR-4: token budget passed to bridge → llm-connect BudgetTracker enforces it
|
|
-- natively, raising LLMBudgetExceededError if the call would exceed the cap.
|
|
result <- liftIO $ callAgentWithBudget receivingAgent scope tokenBudget 0
|
|
|
|
now <- getCurrentTime
|
|
case result of
|
|
Left BudgetExceededError { errorMessage, budgetTotal, budgetConsumed, budgetRequested } -> do
|
|
delegation
|
|
|> set #status "failed"
|
|
|> set #result (Just . A.toJSON $ A.object
|
|
[ "error" A..= errorMessage
|
|
, "budgetTotal" A..= budgetTotal
|
|
, "budgetConsumed" A..= budgetConsumed
|
|
, "budgetRequested" A..= budgetRequested
|
|
])
|
|
|> set #completedAt (Just now)
|
|
|> updateRecord
|
|
setErrorMessage ("Budget exceeded: requested " <> show budgetRequested
|
|
<> " tokens but only " <> show (budgetTotal - budgetConsumed) <> " remain")
|
|
Left err -> do
|
|
delegation
|
|
|> set #status "failed"
|
|
|> set #result (Just . A.toJSON $ A.object ["error" A..= bridgeErrorMessage err])
|
|
|> set #completedAt (Just now)
|
|
|> updateRecord
|
|
setErrorMessage ("Delegation failed: " <> bridgeErrorMessage err)
|
|
Right resp -> do
|
|
delegation
|
|
|> set #status "completed"
|
|
|> set #tokensUsed (Just resp.tokensOut)
|
|
|> set #result (Just . A.toJSON $ A.object ["content" A..= resp.content])
|
|
|> set #completedAt (Just now)
|
|
|> updateRecord
|
|
setSuccessMessage "Subtask delegated successfully"
|
|
|
|
redirectTo ShowAgentDelegationAction { agentDelegationId = delegation.id }
|