(ctx context.Context, prompt string)
| 115 | |
| 116 | func (s *SubAgent) createSessionState(ctx context.Context, prompt string) *SubAgentSessionState { |
| 117 | abortCheck, _ := s.ExtraContext["abort_check"].(func() bool) |
| 118 | if abortCheck == nil { |
| 119 | abortCheck = func() bool { return false } |
| 120 | } |
| 121 | messages := s.buildInitialMessages(ctx, prompt) |
| 122 | return &SubAgentSessionState{ |
| 123 | Messages: messages, |
| 124 | SystemPrompt: s.buildSystemPrompt(), |
| 125 | SurfacedMemoryIDs: memory.RecalledMemoryIDs(messages), |
| 126 | ScopeID: stringFromContext(s.ExtraContext, "scope_id", ""), |
| 127 | CurrentTaskID: stringFromContext(s.ExtraContext, "current_task_id", ""), |
| 128 | AbortCheck: abortCheck, |
| 129 | } |
| 130 | } |
| 131 | |
| 132 | func (s *SubAgent) ExecuteOneRequest(ctx context.Context, prompt string, sessionState *SubAgentSessionState) SubAgentRequestResult { |
| 133 | if sessionState == nil { |
| 134 | sessionState = s.createSessionState(ctx, prompt) |
no test coverage detected