generated from coulomb/repo-seed
Bernd Worsch
ce42607fca
Convert all remaining `<- paramOrNothing / param / paramOrDefault /
currentUserOrNothing` monadic binds to `let` — these functions are pure
(ImplicitParams-based) in IHP v1.5, so `<-` is a type error in an IO
do-block.
Controllers fixed:
AgentDelegations, AiGovernancePolicies, Annotations, ApiConsumers,
CollectiveProposals, DecisionRecords, DeploymentRecords,
HubCapabilityManifests, HubRoutingRules, InstitutionalKnowledge,
OutcomeCorrelations, RequirementCandidates, TypeRegistries,
WebhookSubscriptions, Widgets,
Api/V2/{Annotations,InteractionEvents,Token}
WebhookSubscriptions: remove orphaned `Right () ->` case arm that was
left inside a bare `unless` block (structural parse error).
Also carries forward all in-progress fixes from the working tree:
helpers (AgentBridge, ApiRateLimit, BottleneckDetector,
CrossHubPropagation, FrictionScore),
views (CanSelect instances, HSX lambda extraction, formFor wrappers),
env/build (envrc GHCi perms, flake.nix Tailwind + GHC resource limits,
static/app.css additional Tailwind output).
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
88 lines
3.8 KiB
Haskell
88 lines
3.8 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 Application.Helper.AgentBridge
|
|
( callAgentWithBudget
|
|
, BridgeError(..)
|
|
, 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 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 }
|