123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185 |
- "use strict";
- Object.defineProperty(exports, "__esModule", {
- value: true
- });
- exports.buildDependentProjects = buildDependentProjects;
- exports.buildProjectsClosure = buildProjectsClosure;
- exports.buildTeardownToSetupsMap = buildTeardownToSetupsMap;
- exports.collectFilesForProject = collectFilesForProject;
- exports.filterProjects = filterProjects;
- var _fs = _interopRequireDefault(require("fs"));
- var _path = _interopRequireDefault(require("path"));
- var _utilsBundle = require("playwright-core/lib/utilsBundle");
- var _util = require("util");
- var _util2 = require("../util");
- function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
- /**
- * Copyright Microsoft Corporation. All rights reserved.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
- const readFileAsync = (0, _util.promisify)(_fs.default.readFile);
- const readDirAsync = (0, _util.promisify)(_fs.default.readdir);
- function filterProjects(projects, projectNames) {
- if (!projectNames) return [...projects];
- const projectsToFind = new Set();
- const unknownProjects = new Map();
- projectNames.forEach(n => {
- const name = n.toLocaleLowerCase();
- projectsToFind.add(name);
- unknownProjects.set(name, n);
- });
- const result = projects.filter(project => {
- const name = project.project.name.toLocaleLowerCase();
- unknownProjects.delete(name);
- return projectsToFind.has(name);
- });
- if (unknownProjects.size) {
- const names = projects.map(p => p.project.name).filter(name => !!name);
- if (!names.length) throw new Error(`No named projects are specified in the configuration file`);
- const unknownProjectNames = Array.from(unknownProjects.values()).map(n => `"${n}"`).join(', ');
- throw new Error(`Project(s) ${unknownProjectNames} not found. Available named projects: ${names.map(name => `"${name}"`).join(', ')}`);
- }
- return result;
- }
- function buildTeardownToSetupsMap(projects) {
- const result = new Map();
- for (const project of projects) {
- if (project.teardown) {
- const setups = result.get(project.teardown) || [];
- setups.push(project);
- result.set(project.teardown, setups);
- }
- }
- return result;
- }
- function buildProjectsClosure(projects, hasTests) {
- const result = new Map();
- const visit = (depth, project) => {
- if (depth > 100) {
- const error = new Error('Circular dependency detected between projects.');
- error.stack = '';
- throw error;
- }
- if (depth === 0 && hasTests && !hasTests(project)) return;
- if (result.get(project) !== 'dependency') result.set(project, depth ? 'dependency' : 'top-level');
- for (const dep of project.deps) visit(depth + 1, dep);
- if (project.teardown) visit(depth + 1, project.teardown);
- };
- for (const p of projects) visit(0, p);
- return result;
- }
- function buildDependentProjects(forProjects, projects) {
- const reverseDeps = new Map(projects.map(p => [p, []]));
- for (const project of projects) {
- for (const dep of project.deps) reverseDeps.get(dep).push(project);
- }
- const result = new Set();
- const visit = (depth, project) => {
- if (depth > 100) {
- const error = new Error('Circular dependency detected between projects.');
- error.stack = '';
- throw error;
- }
- result.add(project);
- for (const reverseDep of reverseDeps.get(project)) visit(depth + 1, reverseDep);
- if (project.teardown) visit(depth + 1, project.teardown);
- };
- for (const forProject of forProjects) visit(0, forProject);
- return result;
- }
- async function collectFilesForProject(project, fsCache = new Map()) {
- const extensions = new Set(['.js', '.ts', '.mjs', '.mts', '.cjs', '.cts', '.jsx', '.tsx', '.mjsx', '.mtsx', '.cjsx', '.ctsx']);
- const testFileExtension = file => extensions.has(_path.default.extname(file));
- const allFiles = await cachedCollectFiles(project.project.testDir, project.respectGitIgnore, fsCache);
- const testMatch = (0, _util2.createFileMatcher)(project.project.testMatch);
- const testIgnore = (0, _util2.createFileMatcher)(project.project.testIgnore);
- const testFiles = allFiles.filter(file => {
- if (!testFileExtension(file)) return false;
- const isTest = !testIgnore(file) && testMatch(file);
- if (!isTest) return false;
- return true;
- });
- return testFiles;
- }
- async function cachedCollectFiles(testDir, respectGitIgnore, fsCache) {
- const key = testDir + ':' + respectGitIgnore;
- let result = fsCache.get(key);
- if (!result) {
- result = await collectFiles(testDir, respectGitIgnore);
- fsCache.set(key, result);
- }
- return result;
- }
- async function collectFiles(testDir, respectGitIgnore) {
- if (!_fs.default.existsSync(testDir)) return [];
- if (!_fs.default.statSync(testDir).isDirectory()) return [];
- const checkIgnores = (entryPath, rules, isDirectory, parentStatus) => {
- let status = parentStatus;
- for (const rule of rules) {
- const ruleIncludes = rule.negate;
- if (status === 'included' === ruleIncludes) continue;
- const relative = _path.default.relative(rule.dir, entryPath);
- if (rule.match('/' + relative) || rule.match(relative)) {
- // Matches "/dir/file" or "dir/file"
- status = ruleIncludes ? 'included' : 'ignored';
- } else if (isDirectory && (rule.match('/' + relative + '/') || rule.match(relative + '/'))) {
- // Matches "/dir/subdir/" or "dir/subdir/" for directories.
- status = ruleIncludes ? 'included' : 'ignored';
- } else if (isDirectory && ruleIncludes && (rule.match('/' + relative, true) || rule.match(relative, true))) {
- // Matches "/dir/donotskip/" when "/dir" is excluded, but "!/dir/donotskip/file" is included.
- status = 'ignored-but-recurse';
- }
- }
- return status;
- };
- const files = [];
- const visit = async (dir, rules, status) => {
- const entries = await readDirAsync(dir, {
- withFileTypes: true
- });
- entries.sort((a, b) => a.name.localeCompare(b.name));
- if (respectGitIgnore) {
- const gitignore = entries.find(e => e.isFile() && e.name === '.gitignore');
- if (gitignore) {
- const content = await readFileAsync(_path.default.join(dir, gitignore.name), 'utf8');
- const newRules = content.split(/\r?\n/).map(s => {
- s = s.trim();
- if (!s) return;
- // Use flipNegate, because we handle negation ourselves.
- const rule = new _utilsBundle.minimatch.Minimatch(s, {
- matchBase: true,
- dot: true,
- flipNegate: true
- });
- if (rule.comment) return;
- rule.dir = dir;
- return rule;
- }).filter(rule => !!rule);
- rules = [...rules, ...newRules];
- }
- }
- for (const entry of entries) {
- if (entry.name === '.' || entry.name === '..') continue;
- if (entry.isFile() && entry.name === '.gitignore') continue;
- if (entry.isDirectory() && entry.name === 'node_modules') continue;
- const entryPath = _path.default.join(dir, entry.name);
- const entryStatus = checkIgnores(entryPath, rules, entry.isDirectory(), status);
- if (entry.isDirectory() && entryStatus !== 'ignored') await visit(entryPath, rules, entryStatus);else if (entry.isFile() && entryStatus === 'included') files.push(entryPath);
- }
- };
- await visit(testDir, [], 'included');
- return files;
- }
|