Function dispatchDelta

internal/llm/llm.go:544–584

dispatchDelta forwards reasoning and content as events, then accumulates streamed tool-call fragments into index-keyed slots. Reasoning stays out of fullContent (must not round-trip into the assistant message) but is forwarded so the UI reflects thinking. Fragments key on the provider's `index`, not

(parent context.Context, d streamDelta, budget cloud.BudgetStatus, fullContent *strings.Builder, slots map[int]*toolSlot, order *[]int, out chan<- Event)

}

func (e *httpStatusError) Error() string { return fmt.Sprintf("%d: %s", e.status, e.msg) }

// retryable reports whether a pre-stream failure is worth resending: transport
// errors and the statuses that signal a transient server state. 404 is
// semantically permanent, but LiteLLM-style proxies emit it for transient
// upstream misses (the Agnes-AI freeze in issue #7), and the rising backoff
// bounds the cost of a truly permanent one. 401/402 arrive as typed sentinels
// the UI handles; 400 and other client errors fail identically on every
// resend.
func retryable(err error) bool {
	var un cloud.ErrUnreachable
	if errors.As(err, &un) {
		return true
	}
	var hs *httpStatusError
	if errors.As(err, &hs) {
		return hs.status == 404 || hs.status == 408 || hs.status == 429 || hs.status >= 500
	}
	return false
}

// errorMessageFromBody extracts the user-facing string from a non-2xx body.
// hamrpass wraps errors as `{"error":{"message":...,"provider_hint":...}}`; we
// prefer provider_hint (providers stash the human diagnostic there), fall back
// to message, then to the raw first line so non-hamrpass backends still surface
// whatever they emit.
func errorMessageFromBody(b []byte) string {
	var env struct {
		Error struct {
			Message      string `json:"message"`
			ProviderHint string `json:"provider_hint"`
		} `json:"error"`
	}
	if json.Unmarshal(b, &env) == nil {
		if env.Error.ProviderHint != "" {
			return env.Error.ProviderHint
		}
		if env.Error.Message != "" {
			return env.Error.Message
		}
	}
	return firstLine(string(b))
}