(parentState *AgentState, permissionMode string)
| 1534 | } |
| 1535 | } |
| 1536 | |
| 1537 | func (e *CoreExecutionEngine) apiErrorEvent(msg string, metadata map[string]any) StreamEvent { |
| 1538 | return NewStreamEvent("error", fmt.Sprintf("API error after %d retries: %s. The request may be malformed. Try /clear to start a fresh session.", MaxAPIErrorRetries, msg), metadata) |
| 1539 | } |
| 1540 | |
| 1541 | func (e *CoreExecutionEngine) isAborted() bool { |
| 1542 | e.mu.Lock() |
| 1543 | defer e.mu.Unlock() |
| 1544 | return e.aborted |
| 1545 | } |
| 1546 | |
| 1547 | func (e *CoreExecutionEngine) clearAbort() { |
| 1548 | e.mu.Lock() |
no test coverage detected