Native Workflow Support

internal/pipeline/compare.go

@@ -5,6 +5,7 @@ import (
 	"encoding/json"
 	"errors"
 	"fmt"
+	"io/fs"
 	"os"
 	"path/filepath"
 	"slices"
@@ -14,6 +15,7 @@ import (
 	"gitea.westgate.pw/ShadowsOverWestgate/sow-tools/internal/erf"
 	"gitea.westgate.pw/ShadowsOverWestgate/sow-tools/internal/gff"
 	"gitea.westgate.pw/ShadowsOverWestgate/sow-tools/internal/project"
+	"gitea.westgate.pw/ShadowsOverWestgate/sow-tools/internal/topdata"
 )
 
 type CompareResult struct {
@@ -112,6 +114,10 @@ func Compare(p *project.Project) (CompareResult, error) {
 
 func expectedResources(p *project.Project) (map[string]resourceExpectation, error) {
 	out := map[string]resourceExpectation{}
+	moduleHakOrder, err := plannedModuleHAKOrder(p)
+	if err != nil {
+		return nil, err
+	}
 
 	for _, rel := range p.Inventory.SourceFiles {
 		abs := filepath.Join(p.SourceDir(), filepath.FromSlash(rel))
@@ -128,6 +134,9 @@ func expectedResources(p *project.Project) (map[string]resourceExpectation, erro
 		if err := json.Unmarshal(raw, &document); err != nil {
 			return nil, fmt.Errorf("parse gff json %s: %w", abs, err)
 		}
+		if extension == ".ifo" && strings.EqualFold(name, "module") && len(moduleHakOrder) > 0 {
+			setModuleHAKList(&document, moduleHakOrder)
+		}
 
 		canonical, err := json.Marshal(document)
 		if err != nil {
@@ -195,6 +204,12 @@ func ensureBuildIsCurrent(p *project.Project, modulePath string, hakPaths []stri
 	archivePaths := make([]string, 0, 1+len(hakPaths))
 	archivePaths = append(archivePaths, modulePath)
 	archivePaths = append(archivePaths, hakPaths...)
+	if p.HasTopData() {
+		archivePaths = append(archivePaths,
+			filepath.Join(p.BuildDir(), topdata.PackageHAKFileName),
+			filepath.Join(p.BuildDir(), topdata.PackageTLKFileName),
+		)
+	}
 
 	oldestArchive := time.Time{}
 	for _, path := range archivePaths {
@@ -217,6 +232,13 @@ func ensureBuildIsCurrent(p *project.Project, modulePath string, hakPaths []stri
 	for _, rel := range p.Inventory.AssetFiles {
 		sourcePaths = append(sourcePaths, filepath.Join(p.AssetsDir(), filepath.FromSlash(rel)))
 	}
+	if p.HasTopData() {
+		topSources, err := topPackageSourcePaths(p)
+		if err != nil {
+			return err
+		}
+		sourcePaths = append(sourcePaths, topSources...)
+	}
 
 	newestSource := time.Time{}
 	newestPath := ""
@@ -308,6 +330,57 @@ func manifestHAKPaths(buildDir string) ([]string, error) {
 	if err != nil {
 		return nil, fmt.Errorf("scan hak archives: %w", err)
 	}
-	slices.Sort(paths)
+	filtered := make([]string, 0, len(paths))
+	for _, path := range paths {
+		if filepath.Base(path) == topdata.PackageHAKFileName {
+			continue
+		}
+		filtered = append(filtered, path)
+	}
+	slices.Sort(filtered)
+	return filtered, nil
+}
+
+func topPackageSourcePaths(p *project.Project) ([]string, error) {
+	sourceDir := p.TopDataSourceDir()
+	paths := make([]string, 0)
+	for _, candidate := range []string{
+		filepath.Join(sourceDir, ".tlk_state.json"),
+		filepath.Join(sourceDir, "base_dialog.json"),
+	} {
+		if _, err := os.Stat(candidate); err == nil {
+			paths = append(paths, candidate)
+		} else if err != nil && !errors.Is(err, os.ErrNotExist) {
+			return nil, fmt.Errorf("stat topdata source %s: %w", candidate, err)
+		}
+	}
+	for _, dir := range []string{
+		filepath.Join(sourceDir, "data"),
+		filepath.Join(sourceDir, "assets"),
+	} {
+		info, err := os.Stat(dir)
+		if err != nil {
+			if errors.Is(err, os.ErrNotExist) {
+				continue
+			}
+			return nil, fmt.Errorf("stat topdata path %s: %w", dir, err)
+		}
+		if !info.IsDir() {
+			continue
+		}
+		err = filepath.WalkDir(dir, func(path string, d fs.DirEntry, walkErr error) error {
+			if walkErr != nil {
+				return walkErr
+			}
+			if d.IsDir() {
+				return nil
+			}
+			paths = append(paths, path)
+			return nil
+		})
+		if err != nil {
+			return nil, fmt.Errorf("scan topdata path %s: %w", dir, err)
+		}
+	}
 	return paths, nil
 }