Function Replay

internal/replay/replay.go:41–78

Replay reconstructs an AI request from the ledger and re-executes it.

(ctx context.Context, cfg *config.Config, store requests.Store, requestID string, mode Mode, deps Dependencies)

// Replay reconstructs an AI request from the ledger and re-executes it.
func Replay(ctx context.Context, cfg *config.Config, store requests.Store, requestID string, mode Mode, deps Dependencies) (types.AIResponse, error) {
	if store == nil {
		return types.AIResponse{}, errors.New("ledger store is nil")
	}
	row, err := store.GetRequest(ctx, requestID)
	if err != nil {
		return types.AIResponse{}, err
	}
	var req types.AIRequest
	if len(row.AIRequestJSON) > 0 {
		if err := json.Unmarshal(row.AIRequestJSON, &req); err != nil {
			return types.AIResponse{}, fmt.Errorf("decode ai_request_json: %w", err)
		}
	} else {
		if err := json.Unmarshal(row.InputJSON, &req.Input); err != nil {
			return types.AIResponse{}, fmt.Errorf("decode input: %w", err)
		}
		if err := json.Unmarshal(row.ContextJSON, &req.Context); err != nil {
			return types.AIResponse{}, fmt.Errorf("decode context: %w", err)
		}
	}
	req.RequestID = row.RequestID
	req.TenantID = row.TenantID
	req.TaskType = row.TaskType
	req.Priority = row.Priority
	req.RequestType = row.RequestType
	req.PipelineRef = row.PipelineRef
	req = types.NormalizeAIRequest(req)

	switch mode {
	case ModeExact:
		return replayExact(ctx, cfg, req, row, deps)
	case ModeCurrent:
		return replayCurrent(ctx, cfg, req, deps)
	default:
		return types.AIResponse{}, fmt.Errorf("unknown replay mode %q", mode)
	}
}

func replayExact(ctx context.Context, cfg *config.Config, req types.AIRequest, row requests.RequestRow, deps Dependencies) (types.AIResponse, error) {
	var snap types.PolicySnapshot