Function ReadDirRecursive

pkg/util/fileutil/readdir.go:139–234

(path string, maxEntries int)

}

func ReadDirRecursive(path string, maxEntries int) (*ReadDirResult, error) {
	expandedPath, err := wavebase.ExpandHomeDir(path)
	if err != nil {
		return nil, fmt.Errorf("failed to expand path: %w", err)
	}

	fileInfo, err := os.Stat(expandedPath)
	if err != nil {
		return nil, fmt.Errorf("failed to stat path: %w", err)
	}

	if !fileInfo.IsDir() {
		return nil, fmt.Errorf("path is not a directory")
	}

	var allEntries []DirEntryOut
	isDirMap := make(map[string]bool)
	var truncated bool

	err = filepath.WalkDir(expandedPath, func(fullPath string, d fs.DirEntry, err error) error {
		if err != nil {
			return nil
		}

		if fullPath == expandedPath {
			return nil
		}

		if len(allEntries) >= maxEntries {
			truncated = true
			return fs.SkipAll
		}

		relativePath, _ := filepath.Rel(expandedPath, fullPath)

		isSymlink := d.Type()&fs.ModeSymlink != 0

		info, infoErr := d.Info()
		if infoErr != nil {
			return nil
		}

		isDir := d.IsDir()
		isDirMap[relativePath] = isDir

		entryData := DirEntryOut{
			Name:         relativePath,
			Dir:          isDir,
			Symlink:      isSymlink,
			Mode:         info.Mode().String(),
			Modified:     utilfn.FormatRelativeTime(info.ModTime()),
			ModifiedTime: info.ModTime().UTC().Format(time.RFC3339),
		}

		if !isDir {
			entryData.Size = info.Size()
		}