mirror of
https://github.com/tiennm99/goclaw.git
synced 2026-10-12 22:14:37 +00:00
viettranx
aadc4d6498
- Add TaskActionFlags context-based tracking for member tool calls (Completed, Reviewed, Escalated, Progressed, Commented, Claimed) - Replace aggressive auto-complete with flag-based switch/case: tool-completed → skip, reviewed → skip + renew lock, progress-only → renew lock (don't auto-complete), no flags → auto-complete (backward compat) - Fix executeReject to use RejectTask (strict in_review guard) with auto re-dispatch that preserves dependent task blocking - Add ticker Phase 4: mark in_review tasks stale after 4 hours - Add ticker Phase 5: fix orphaned blocked tasks (all blockers terminal) - Keep owner_agent_id during lock recovery for auto re-dispatch - Add RunKind="notification" to team notify inbound messages with mutation blocking in TeamTasksTool (read-only enforced) - Increase MessageBus buffer 500 → 1000 - Add ResetTaskStatus support for cancelled and in_review sources
44 lines
1.6 KiB
Go
44 lines
1.6 KiB
Go
package tools
|
|
|
|
import "context"
|
|
|
|
// TaskActionFlags tracks which team_tasks actions a member agent took during a turn.
|
|
// The consumer reads these flags post-turn to decide whether to auto-complete,
|
|
// skip, or re-dispatch the task.
|
|
//
|
|
// No mutex needed: a single goroutine writes (agent loop), and the consumer
|
|
// reads only after the turn ends (sequential).
|
|
type TaskActionFlags struct {
|
|
Completed bool // team_tasks(action="complete")
|
|
Reviewed bool // team_tasks(action="review")
|
|
Escalated bool // team_tasks(action="comment", type="blocker")
|
|
Progressed bool // team_tasks(action="progress")
|
|
Commented bool // team_tasks(action="comment")
|
|
Claimed bool // team_tasks(action="claim")
|
|
}
|
|
|
|
// HasAny returns true if the member interacted with the task system at all.
|
|
func (f *TaskActionFlags) HasAny() bool {
|
|
return f.Completed || f.Reviewed || f.Escalated || f.Progressed || f.Commented || f.Claimed
|
|
}
|
|
|
|
const ctxTaskActionFlags toolContextKey = "tool_task_action_flags"
|
|
|
|
// WithTaskActionFlags injects a TaskActionFlags into context.
|
|
func WithTaskActionFlags(ctx context.Context, flags *TaskActionFlags) context.Context {
|
|
return context.WithValue(ctx, ctxTaskActionFlags, flags)
|
|
}
|
|
|
|
// TaskActionFlagsFromCtx returns the TaskActionFlags from context, or nil.
|
|
func TaskActionFlagsFromCtx(ctx context.Context) *TaskActionFlags {
|
|
v, _ := ctx.Value(ctxTaskActionFlags).(*TaskActionFlags)
|
|
return v
|
|
}
|
|
|
|
// recordTaskAction is a helper that sets a flag if TaskActionFlags exist in context.
|
|
func recordTaskAction(ctx context.Context, setter func(*TaskActionFlags)) {
|
|
if flags := TaskActionFlagsFromCtx(ctx); flags != nil {
|
|
setter(flags)
|
|
}
|
|
}
|