fix: resolve PR #316 issues [batch]

Author: pedronauck

engine/project/indexer.go

@@ -250,9 +250,10 @@ func (p *Config) indexProjectTools(
 			return fmt.Errorf("project tool at index %d missing id", i)
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceTool, ID: tool.ID}
-		value := tool
+		keyCopy := key
+		toolCopy := tool
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, toolCopy)
 		})
 	}
 	return nil
@@ -279,9 +280,10 @@ func (p *Config) indexProjectMemories(
 			return fmt.Errorf("memory '%s' validation failed: %w", memory.ID, err)
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceMemory, ID: memory.ID}
-		value := memory
+		keyCopy := key
+		mem := memory
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, mem)
 		})
 	}
 	return nil
@@ -301,9 +303,10 @@ func (p *Config) indexProjectSchemas(
 			continue
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceSchema, ID: sid}
-		value := schemaValue
+		keyCopy := key
+		schemaCopy := schemaValue
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, schemaCopy)
 		})
 	}
 	return nil
@@ -323,9 +326,10 @@ func (p *Config) indexProjectModels(
 		}
 		id := fmt.Sprintf("%s:%s", string(model.Provider), model.Model)
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceModel, ID: id}
-		value := model
+		keyCopy := key
+		modelCopy := model
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, modelCopy)
 		})
 	}
 	return nil
@@ -343,9 +347,10 @@ func (p *Config) indexProjectEmbedders(
 			return fmt.Errorf("project embedder at index %d missing id", i)
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceEmbedder, ID: embedder.ID}
-		value := embedder
+		keyCopy := key
+		embedderCopy := embedder
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, embedderCopy)
 		})
 	}
 	return nil
@@ -363,9 +368,10 @@ func (p *Config) indexProjectVectorDBs(
 			return fmt.Errorf("project vector_db at index %d missing id", i)
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceVectorDB, ID: vectorDB.ID}
-		value := vectorDB
+		keyCopy := key
+		vectorDBCopy := vectorDB
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, vectorDBCopy)
 		})
 	}
 	return nil
@@ -386,9 +392,10 @@ func (p *Config) indexProjectKnowledgeBases(
 			knowledgeBase.Ingest = knowledge.IngestManual
 		}
 		key := resources.ResourceKey{Project: p.Name, Type: resources.ResourceKnowledgeBase, ID: knowledgeBase.ID}
-		value := knowledgeBase
+		keyCopy := key
+		knowledgeBaseCopy := knowledgeBase
 		group.Go(func() error {
-			return p.putResourceWithMeta(ctx, store, metaSources, key, value)
+			return p.putResourceWithMeta(ctx, store, metaSources, keyCopy, knowledgeBaseCopy)
 		})
 	}
 	return nil

sdk/compozy/loader.go

@@ -16,6 +16,8 @@ import (
 
 var yamlExtensions = []string{".yaml", ".yml"}
 
+const defaultFilteredFilesCapacity = 8
+
 func requireContext(ctx context.Context) error {
 	if ctx == nil {
 		return fmt.Errorf("context is required")
@@ -43,28 +45,43 @@ type cwdSetter interface {
 
 func loadYAML[T any](ctx context.Context, engine *Engine, path string) (T, string, error) {
 	var zero T
+	log := logger.FromContext(ctx)
+	logFailure := func(target string, err error) {
+		if err == nil || log == nil {
+			return
+		}
+		log.Error("failed to load YAML", "path", target, "error", err)
+	}
+	requestedPath := strings.TrimSpace(path)
 	if err := requireContext(ctx); err != nil {
+		logFailure(requestedPath, err)
 		return zero, "", err
 	}
 	trimmed, cfg, err := prepareLoadContext(engine, path)
 	if err != nil {
+		logFailure(requestedPath, err)
 		return zero, "", err
 	}
 	if err := contextError(ctx); err != nil {
+		logFailure(trimmed, err)
 		return zero, "", err
 	}
 	data, abs, err := readYAMLFile(trimmed, cfg.Limits.MaxConfigFileSize)
 	if err != nil {
+		logFailure(trimmed, err)
 		return zero, "", err
 	}
 	if err := contextError(ctx); err != nil {
+		logFailure(trimmed, err)
 		return zero, "", err
 	}
 	value, err := decodeYAML[T](data, trimmed)
 	if err != nil {
+		logFailure(trimmed, err)
 		return zero, "", err
 	}
 	if err := contextError(ctx); err != nil {
+		logFailure(trimmed, err)
 		return zero, "", err
 	}
 	applyYAMLMetadata(engine.ctx, value, abs)
@@ -141,7 +158,11 @@ func filteredYAMLFiles(ctx context.Context, dir string) ([]string, error) {
 	if err != nil {
 		return nil, fmt.Errorf("read dir %s: %w", dir, err)
 	}
-	files := make([]string, 0, len(entries))
+	filesCap := len(entries)
+	if filesCap < defaultFilteredFilesCapacity {
+		filesCap = defaultFilteredFilesCapacity
+	}
+	files := make([]string, 0, filesCap)
 	for _, entry := range entries {
 		if err := contextError(ctx); err != nil {
 			return nil, err