Function replayCurrent

internal/replay/replay.go:114–149

(ctx context.Context, cfg *config.Config, req types.AIRequest, deps Dependencies)

}

func replayCurrent(ctx context.Context, cfg *config.Config, req types.AIRequest, deps Dependencies) (types.AIResponse, error) {
	pol, err := deps.Policy.Evaluate(ctx, req)
	if err != nil {
		return types.AIResponse{}, err
	}
	if !pol.Allowed {
		return types.AIResponse{}, fmt.Errorf("policy rejected: %s", pol.Reason)
	}
	req = pol.Normalized
	if req.RequestType == types.RequestTypeAgent {
		return types.AIResponse{}, errors.New("agent execution not implemented")
	}

	health := allHealthy(cfg)
	primary, err := deps.Router.SelectRoute(ctx, req, types.RuntimeState{
		QueueDepth:      0,
		BackendHealth:   health,
		OverloadDegrade: false,
	})
	if err != nil {
		return types.AIResponse{}, err
	}

	if req.RequestType == types.RequestTypeRAG {
		if err := runRAGRetrieve(ctx, cfg, &req, deps.Retrieval, deps.Rerank); err != nil {
			return types.AIResponse{}, err
		}
	}

	fallback := buildFallbackList(cfg, primary.BackendName, health)
	execRes, err := deps.Reliability.ExecuteWithFallback(ctx, req, primary, fallback)
	if err != nil {
		return types.AIResponse{}, err
	}
	return buildResponse(cfg, req, pol.Reason, primary, execRes, req.RequestID, ""), nil
}

func allHealthy(cfg *config.Config) map[string]bool {
	out := make(map[string]bool, len(cfg.Backends))