errors

var (
	ErrAgentNotFound       = errors.New("agent not found")
	ErrAgentTimeout        = errors.New("agent execution timeout")
	ErrAgentPanic          = errors.New("agent internal panic")
	ErrTaskQueueFull       = errors.New("task queue is full")
	ErrDependencyCycle     = errors.New("task dependency cycle detected")
	ErrAgentNotReady       = errors.New("agent not ready")
	ErrAgentBusy           = errors.New("agent is busy")
	ErrAgentAlreadyStarted = errors.New("agent already started")
	ErrAgentNotRunning     = errors.New("agent not running")
	ErrQueueNotInitialized = errors.New("message queue not initialized")
	ErrToolNotFound        = errors.New("tool not found")
	ErrMaxStepsExceeded    = errors.New("agent max steps exceeded")
)

var (
	ErrInvalidMessage  = errors.New("invalid message format")
	ErrMessageTimeout  = errors.New("message send timeout")
	ErrHeartbeatMissed = errors.New("heartbeat missed")
	ErrQueueFull       = errors.New("message queue is full")
	ErrQueueEmpty      = errors.New("message queue is empty")
	ErrQueueClosed     = errors.New("message queue is closed")
)

var (
	ErrDBConnectionFailed = errors.New("database connection failed")
	ErrQueryFailed        = errors.New("query execution failed")
	ErrVectorSearchFailed = errors.New("vector search failed")
	ErrRecordNotFound     = errors.New("record not found")
	ErrTransactionFailed  = errors.New("transaction failed")
	ErrNoTransaction      = errors.New("no active transaction")
	ErrInvalidArgument    = errors.New("invalid argument provided")
	ErrCircuitBreakerOpen = errors.New("circuit breaker is open")
	ErrServiceUnavailable = errors.New("service is temporarily unavailable")
	ErrInvalidState       = errors.New("invalid state")
	ErrSecretExpired      = errors.New("secret has expired")
	ErrNotImplemented     = errors.New("feature not implemented yet")
	ErrBufferFull         = errors.New("write buffer is full")
)

var (
	ErrLLMRequestFailed    = errors.New("LLM request failed")
	ErrLLMTimeout          = errors.New("LLM response timeout")
	ErrLLMQuotaExceeded    = errors.New("LLM quota exceeded")
	ErrLLMInvalidResponse  = errors.New("LLM invalid response")
	ErrLLMParserFailed     = errors.New("LLM output parsing failed")
	ErrLLMValidationFailed = errors.New("LLM output validation failed")
)

var (
	ErrRateLimitExceeded = errors.New("rate limit exceeded")
	ErrDBTimeout         = errors.New("database operation timeout")
)

var (
	ErrInvalidUserID = errors.New("invalid user ID")
	ErrInvalidAge    = errors.New("invalid age")
	ErrInvalidBudget = errors.New("invalid budget range")
	ErrInvalidInput  = errors.New("invalid input parameter")
	ErrNilPointer    = errors.New("nil pointer error")
)

var (
	ErrProfileParsingFailed        = errors.New("profile parsing failed")
	ErrProfileValidationFailed     = errors.New("profile validation failed")
	ErrMaxRetriesExceeded          = errors.New("max retries exceeded")
	ErrTaskExecutionFailed         = errors.New("task execution failed")
	ErrPromptRenderFailed          = errors.New("prompt render failed")
	ErrLLMGenerateFailed           = errors.New("LLM generate failed")
	ErrTaskPlannerNotInitialized   = errors.New("task planner not initialized")
	ErrProfileParserNotInitialized = errors.New("profile parser not initialized")
	ErrDispatchNotInitialized      = errors.New("task dispatcher not initialized")
	ErrResultAggNotInitialized     = errors.New("result aggregator not initialized")
	ErrDispatchFailed              = errors.New("task dispatch failed")
)

var (
	ErrWorkflowNotFound     = errors.New("workflow not found")
	ErrWorkflowLoadFailed   = errors.New("workflow load failed")
	ErrWorkflowCyclicDAG    = errors.New("workflow has cyclic dependency")
	ErrWorkflowInvalidPhase = errors.New("invalid workflow phase")
)

var (
	ErrBackpressureTriggered = errors.New("backpressure triggered")
	ErrTokenBucketExhausted  = errors.New("token bucket exhausted")
)

var DefaultErrorStrategiesConfig = ConfigFile{
	Version: "1.0",
	Strategies: map[string]ErrorStrategy{

		"01-002": {Backoff: 5 * time.Second, MaxRetries: 3, DLQEnabled: true, AlertEnabled: false},
		"01-003": {Backoff: 10 * time.Second, MaxRetries: 2, DLQEnabled: true, AlertEnabled: true, AlertMessage: "Agent panic detected"},
		"01-004": {Backoff: 1 * time.Second, MaxRetries: 5, DLQEnabled: false, AlertEnabled: true, AlertMessage: "Task queue full"},

		"02-002": {Backoff: 3 * time.Second, MaxRetries: 3, DLQEnabled: false, AlertEnabled: false},
		"02-003": {Backoff: 5 * time.Second, MaxRetries: 5, DLQEnabled: true, AlertEnabled: true, AlertMessage: "Heartbeat missed"},

		"03-001": {Backoff: 2 * time.Second, MaxRetries: 3, DLQEnabled: false, AlertEnabled: true, AlertMessage: "DB connection failed"},
		"03-002": {Backoff: 1 * time.Second, MaxRetries: 2, DLQEnabled: false, AlertEnabled: false},
		"03-003": {Backoff: 2 * time.Second, MaxRetries: 2, DLQEnabled: false, AlertEnabled: false},

		"04-001": {Backoff: 3 * time.Second, MaxRetries: 3, DLQEnabled: false, AlertEnabled: true, AlertMessage: "LLM request failed"},
		"04-002": {Backoff: 5 * time.Second, MaxRetries: 2, DLQEnabled: false, AlertEnabled: false},
		"04-003": {Backoff: 0, MaxRetries: 0, DLQEnabled: false, AlertEnabled: true, AlertMessage: "LLM quota exceeded"},
		"04-005": {Backoff: 1 * time.Second, MaxRetries: 3, DLQEnabled: false, AlertEnabled: false},
		"04-006": {Backoff: 0, MaxRetries: 0, DLQEnabled: false, AlertEnabled: true, AlertMessage: "LLM validation failed"},
		"04-007": {Backoff: 0, MaxRetries: 0, DLQEnabled: false, AlertEnabled: true, AlertMessage: "LLM authentication failed (401) - check API key"},
	},
}

var DefaultStrategy = ErrorStrategy{
	Backoff:      1 * time.Second,
	MaxRetries:   1,
	DLQEnabled:   false,
	AlertEnabled: false,
}

var ModelValidationErrors = map[string]error{
	"ErrInvalidUserID": ErrInvalidUserID,
	"ErrInvalidAge":    ErrInvalidAge,
	"ErrInvalidBudget": ErrInvalidBudget,
	"ErrInvalidInput":  ErrInvalidInput,
	"ErrNilPointer":    ErrNilPointer,
}