You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
181 lines
4.4 KiB
181 lines
4.4 KiB
'use strict'; |
|
const fs = require('fs'); |
|
const arrayUnion = require('array-union'); |
|
const merge2 = require('merge2'); |
|
const fastGlob = require('fast-glob'); |
|
const dirGlob = require('dir-glob'); |
|
const gitignore = require('./gitignore'); |
|
const {FilterStream, UniqueStream} = require('./stream-utils'); |
|
|
|
const DEFAULT_FILTER = () => false; |
|
|
|
const isNegative = pattern => pattern[0] === '!'; |
|
|
|
const assertPatternsInput = patterns => { |
|
if (!patterns.every(pattern => typeof pattern === 'string')) { |
|
throw new TypeError('Patterns must be a string or an array of strings'); |
|
} |
|
}; |
|
|
|
const checkCwdOption = (options = {}) => { |
|
if (!options.cwd) { |
|
return; |
|
} |
|
|
|
let stat; |
|
try { |
|
stat = fs.statSync(options.cwd); |
|
} catch { |
|
return; |
|
} |
|
|
|
if (!stat.isDirectory()) { |
|
throw new Error('The `cwd` option must be a path to a directory'); |
|
} |
|
}; |
|
|
|
const getPathString = p => p.stats instanceof fs.Stats ? p.path : p; |
|
|
|
const generateGlobTasks = (patterns, taskOptions) => { |
|
patterns = arrayUnion([].concat(patterns)); |
|
assertPatternsInput(patterns); |
|
checkCwdOption(taskOptions); |
|
|
|
const globTasks = []; |
|
|
|
taskOptions = { |
|
ignore: [], |
|
expandDirectories: true, |
|
...taskOptions |
|
}; |
|
|
|
for (const [index, pattern] of patterns.entries()) { |
|
if (isNegative(pattern)) { |
|
continue; |
|
} |
|
|
|
const ignore = patterns |
|
.slice(index) |
|
.filter(pattern => isNegative(pattern)) |
|
.map(pattern => pattern.slice(1)); |
|
|
|
const options = { |
|
...taskOptions, |
|
ignore: taskOptions.ignore.concat(ignore) |
|
}; |
|
|
|
globTasks.push({pattern, options}); |
|
} |
|
|
|
return globTasks; |
|
}; |
|
|
|
const globDirs = (task, fn) => { |
|
let options = {}; |
|
if (task.options.cwd) { |
|
options.cwd = task.options.cwd; |
|
} |
|
|
|
if (Array.isArray(task.options.expandDirectories)) { |
|
options = { |
|
...options, |
|
files: task.options.expandDirectories |
|
}; |
|
} else if (typeof task.options.expandDirectories === 'object') { |
|
options = { |
|
...options, |
|
...task.options.expandDirectories |
|
}; |
|
} |
|
|
|
return fn(task.pattern, options); |
|
}; |
|
|
|
const getPattern = (task, fn) => task.options.expandDirectories ? globDirs(task, fn) : [task.pattern]; |
|
|
|
const getFilterSync = options => { |
|
return options && options.gitignore ? |
|
gitignore.sync({cwd: options.cwd, ignore: options.ignore}) : |
|
DEFAULT_FILTER; |
|
}; |
|
|
|
const globToTask = task => glob => { |
|
const {options} = task; |
|
if (options.ignore && Array.isArray(options.ignore) && options.expandDirectories) { |
|
options.ignore = dirGlob.sync(options.ignore); |
|
} |
|
|
|
return { |
|
pattern: glob, |
|
options |
|
}; |
|
}; |
|
|
|
module.exports = async (patterns, options) => { |
|
const globTasks = generateGlobTasks(patterns, options); |
|
|
|
const getFilter = async () => { |
|
return options && options.gitignore ? |
|
gitignore({cwd: options.cwd, ignore: options.ignore}) : |
|
DEFAULT_FILTER; |
|
}; |
|
|
|
const getTasks = async () => { |
|
const tasks = await Promise.all(globTasks.map(async task => { |
|
const globs = await getPattern(task, dirGlob); |
|
return Promise.all(globs.map(globToTask(task))); |
|
})); |
|
|
|
return arrayUnion(...tasks); |
|
}; |
|
|
|
const [filter, tasks] = await Promise.all([getFilter(), getTasks()]); |
|
const paths = await Promise.all(tasks.map(task => fastGlob(task.pattern, task.options))); |
|
|
|
return arrayUnion(...paths).filter(path_ => !filter(getPathString(path_))); |
|
}; |
|
|
|
module.exports.sync = (patterns, options) => { |
|
const globTasks = generateGlobTasks(patterns, options); |
|
|
|
const tasks = []; |
|
for (const task of globTasks) { |
|
const newTask = getPattern(task, dirGlob.sync).map(globToTask(task)); |
|
tasks.push(...newTask); |
|
} |
|
|
|
const filter = getFilterSync(options); |
|
|
|
let matches = []; |
|
for (const task of tasks) { |
|
matches = arrayUnion(matches, fastGlob.sync(task.pattern, task.options)); |
|
} |
|
|
|
return matches.filter(path_ => !filter(path_)); |
|
}; |
|
|
|
module.exports.stream = (patterns, options) => { |
|
const globTasks = generateGlobTasks(patterns, options); |
|
|
|
const tasks = []; |
|
for (const task of globTasks) { |
|
const newTask = getPattern(task, dirGlob.sync).map(globToTask(task)); |
|
tasks.push(...newTask); |
|
} |
|
|
|
const filter = getFilterSync(options); |
|
const filterStream = new FilterStream(p => !filter(p)); |
|
const uniqueStream = new UniqueStream(); |
|
|
|
return merge2(tasks.map(task => fastGlob.stream(task.pattern, task.options))) |
|
.pipe(filterStream) |
|
.pipe(uniqueStream); |
|
}; |
|
|
|
module.exports.generateGlobTasks = generateGlobTasks; |
|
|
|
module.exports.hasMagic = (patterns, options) => [] |
|
.concat(patterns) |
|
.some(pattern => fastGlob.isDynamicPattern(pattern, options)); |
|
|
|
module.exports.gitignore = gitignore;
|
|
|