nextcloud-ng_backup/lib/Job/TreeWalker.php

<?php

declare(strict_types=1);

// SPDX-FileCopyrightText: 2026 Dillard Blom
// SPDX-License-Identifier: AGPL-3.0-or-later

namespace OCA\NgBackup\Job;

/**
 * Walks one or more source roots in a stable depth-first order (entries of a directory sorted
 * by name, children right after their directory), yielding "<root>/<relative path>" for files.
 *
 * The same order is used for comparing paths (compare()), so a walk can resume after a cursor
 * and be merge-joined with the previous snapshot without holding any list in memory.
 */
final class TreeWalker {
	/**
	 * @param array<string, string> $roots name => absolute directory, walked in this order
	 * @param list<string> $exclude path prefixes ("<root>/<relative>") that are skipped entirely;
	 *                              a pattern with "*" matches one path segment (fnmatch, FNM_PATHNAME)
	 */
	public function __construct(
		private array $roots,
		private array $exclude = [],
		/** Called with the logical path of a directory that cannot be listed. */
		private ?\Closure $onUnreadable = null,
	) {
	}

	/** @return \Generator<string, string> logical path => absolute path, strictly after $after */
	public function walk(?string $after = null): \Generator {
		foreach ($this->roots as $name => $dir) {
			$name = (string)$name;
			if ($name !== '' && $after !== null && self::compare($name, self::firstSegment($after)) < 0) {
				continue; // whole root lies before the cursor
			}
			yield from $this->walkDir(rtrim($dir, '/'), $name, $after);
		}
	}

	/** Order used everywhere: segment by segment, byte-wise. */
	public static function compare(string $a, string $b): int {
		$sa = explode('/', $a);
		$sb = explode('/', $b);
		$n = min(count($sa), count($sb));
		for ($i = 0; $i < $n; $i++) {
			$c = strcmp($sa[$i], $sb[$i]);
			if ($c !== 0) {
				return $c < 0 ? -1 : 1;
			}
		}
		return count($sa) <=> count($sb);
	}

	private function walkDir(string $abs, string $logical, ?string $after): \Generator {
		if ($logical !== '' && $this->isExcluded($logical, true)) {
			return;
		}
		$names = @scandir($abs);
		if ($names === false) {
			if ($this->onUnreadable !== null) {
				($this->onUnreadable)($logical === '' ? '/' : $logical);
			}
			return;
		}
		$names = array_values(array_diff($names, ['.', '..']));
		sort($names, SORT_STRING);
		foreach ($names as $name) {
			$childLogical = $logical === '' ? $name : $logical . '/' . $name;
			$childAbs = $abs . '/' . $name;
			if (is_link($childAbs)) {
				continue; // never follow symlinks out of the data directory
			}
			if (is_dir($childAbs)) {
				// Skip a directory entirely if everything in it sorts before the cursor.
				if ($after !== null && self::compare($childLogical, $after) < 0 && !self::isPrefix($childLogical, $after)) {
					continue;
				}
				yield from $this->walkDir($childAbs, $childLogical, $after);
			} elseif (is_file($childAbs)) {
				if ($after !== null && self::compare($childLogical, $after) <= 0) {
					continue;
				}
				if (!$this->isExcluded($childLogical, false)) {
					yield $childLogical => $childAbs;
				}
			}
		}
	}

	private function isExcluded(string $logical, bool $isDir): bool {
		foreach ($this->exclude as $pattern) {
			if (str_contains($pattern, '*')) {
				if (fnmatch($pattern, $logical, FNM_PATHNAME)) {
					return true;
				}
			} elseif ($logical === $pattern || ($isDir && str_starts_with($logical, $pattern . '/'))) {
				return true;
			}
		}
		return false;
	}

	private static function isPrefix(string $dir, string $path): bool {
		return str_starts_with($path, $dir . '/');
	}

	private static function firstSegment(string $path): string {
		return explode('/', $path, 2)[0];
	}
}