async.js 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336
  1. var fs = require('fs');
  2. var getHomedir = require('./homedir');
  3. var path = require('path');
  4. var caller = require('./caller');
  5. var nodeModulesPaths = require('./node-modules-paths');
  6. var normalizeOptions = require('./normalize-options');
  7. var isCore = require('is-core-module');
  8. var $Error = require('es-errors');
  9. var $TypeError = require('es-errors/type');
  10. var realpathFS = process.platform !== 'win32' && fs.realpath && typeof fs.realpath.native === 'function' ? fs.realpath.native : fs.realpath;
  11. var relativePathRegex = /^(?:\.\.?(?:\/|$)|\/|([A-Za-z]:)?[/\\])/;
  12. var windowsDriveRegex = /^\w:[/\\]*$/;
  13. var nodeModulesRegex = /[/\\]node_modules[/\\]*$/;
  14. var homedir = getHomedir();
  15. function defaultPaths() {
  16. if (!homedir) return [];
  17. return [
  18. path.join(homedir, '.node_modules'),
  19. path.join(homedir, '.node_libraries')
  20. ];
  21. }
  22. var defaultIsFile = function isFile(file, cb) {
  23. fs.stat(file, function (err, stat) {
  24. if (!err) {
  25. return cb(null, stat.isFile() || stat.isFIFO());
  26. }
  27. if (err.code === 'ENOENT' || err.code === 'ENOTDIR') return cb(null, false);
  28. return cb(err);
  29. });
  30. };
  31. var defaultIsDir = function isDirectory(dir, cb) {
  32. fs.stat(dir, function (err, stat) {
  33. if (!err) {
  34. return cb(null, stat.isDirectory());
  35. }
  36. if (err.code === 'ENOENT' || err.code === 'ENOTDIR') return cb(null, false);
  37. return cb(err);
  38. });
  39. };
  40. var defaultRealpath = function realpath(x, cb) {
  41. realpathFS(x, function (realpathErr, realPath) {
  42. if (realpathErr && realpathErr.code !== 'ENOENT') cb(realpathErr);
  43. else cb(null, realpathErr ? x : realPath);
  44. });
  45. };
  46. function maybeRealpath(realpath, x, opts, cb) {
  47. if (opts && opts.preserveSymlinks === false) {
  48. realpath(x, cb);
  49. } else {
  50. cb(null, x);
  51. }
  52. }
  53. function defaultReadPackage(readFile, pkgfile, cb) {
  54. readFile(pkgfile, function (readFileErr, body) {
  55. if (readFileErr) cb(readFileErr);
  56. else {
  57. try {
  58. var pkg = JSON.parse(body);
  59. cb(null, pkg);
  60. } catch (jsonErr) {
  61. cb(null);
  62. }
  63. }
  64. });
  65. }
  66. function getPackageCandidates(x, start, opts) {
  67. var dirs = nodeModulesPaths(start, opts, x);
  68. for (var i = 0; i < dirs.length; i++) {
  69. dirs[i] = path.join(dirs[i], x);
  70. }
  71. return dirs;
  72. }
  73. module.exports = function resolve(x, options, callback) {
  74. var cb = callback;
  75. var opts = options;
  76. if (typeof options === 'function') {
  77. cb = opts;
  78. opts = {};
  79. }
  80. if (typeof x !== 'string') {
  81. var err = new $TypeError('Path must be a string.');
  82. return process.nextTick(function () {
  83. cb(err);
  84. });
  85. }
  86. opts = normalizeOptions(x, opts);
  87. var isFile = opts.isFile || defaultIsFile;
  88. var isDirectory = opts.isDirectory || defaultIsDir;
  89. var readFile = opts.readFile || fs.readFile;
  90. var realpath = opts.realpath || defaultRealpath;
  91. var readPackage = opts.readPackage || defaultReadPackage;
  92. if (opts.readFile && opts.readPackage) {
  93. var conflictErr = new $TypeError('`readFile` and `readPackage` are mutually exclusive.');
  94. return process.nextTick(function () {
  95. cb(conflictErr);
  96. });
  97. }
  98. var packageIterator = opts.packageIterator;
  99. var extensions = opts.extensions || ['.js'];
  100. var includeCoreModules = opts.includeCoreModules !== false;
  101. var basedir = opts.basedir || path.dirname(caller());
  102. var parent = opts.filename || basedir;
  103. opts.paths = opts.paths || defaultPaths();
  104. // ensure that `basedir` is an absolute path at this point, resolving against the process' current working directory
  105. var absoluteStart = path.resolve(basedir);
  106. maybeRealpath(
  107. realpath,
  108. absoluteStart,
  109. opts,
  110. function (err, realStart) {
  111. if (err) cb(err);
  112. else init(realStart);
  113. }
  114. );
  115. var res;
  116. function init(basedir) {
  117. if (relativePathRegex.test(x)) {
  118. res = path.resolve(basedir, x);
  119. if (x === '.' || x === '..' || x.slice(-1) === '/') res += '/';
  120. if (x.slice(-1) === '/' && res === basedir) {
  121. loadAsDirectory(res, opts.package, onfile);
  122. } else loadAsFile(res, opts.package, onfile);
  123. } else if (includeCoreModules && isCore(x)) {
  124. return cb(null, x);
  125. } else loadNodeModules(x, basedir, function (err, n, pkg) {
  126. if (err) cb(err);
  127. else if (n) {
  128. return maybeRealpath(realpath, n, opts, function (err, realN) {
  129. if (err) {
  130. cb(err);
  131. } else {
  132. cb(null, realN, pkg);
  133. }
  134. });
  135. } else {
  136. var moduleError = new $Error("Cannot find module '" + x + "' from '" + parent + "'");
  137. moduleError.code = 'MODULE_NOT_FOUND';
  138. cb(moduleError);
  139. }
  140. });
  141. }
  142. function onfile(err, m, pkg) {
  143. if (err) cb(err);
  144. else if (m) cb(null, m, pkg);
  145. else loadAsDirectory(res, function (err, d, pkg) {
  146. if (err) cb(err);
  147. else if (d) {
  148. maybeRealpath(realpath, d, opts, function (err, realD) {
  149. if (err) {
  150. cb(err);
  151. } else {
  152. cb(null, realD, pkg);
  153. }
  154. });
  155. } else {
  156. var moduleError = new $Error("Cannot find module '" + x + "' from '" + parent + "'");
  157. moduleError.code = 'MODULE_NOT_FOUND';
  158. cb(moduleError);
  159. }
  160. });
  161. }
  162. function loadAsFile(x, thePackage, callback) {
  163. var loadAsFilePackage = thePackage;
  164. var cb = callback;
  165. if (typeof loadAsFilePackage === 'function') {
  166. cb = loadAsFilePackage;
  167. loadAsFilePackage = undefined;
  168. }
  169. var exts = [''].concat(extensions);
  170. load(exts, x, loadAsFilePackage);
  171. function load(exts, x, loadPackage) {
  172. if (exts.length === 0) return cb(null, undefined, loadPackage);
  173. var file = x + exts[0];
  174. var pkg = loadPackage;
  175. if (pkg) onpkg(null, pkg);
  176. else loadpkg(path.dirname(file), onpkg);
  177. function onpkg(err, pkg_, dir) {
  178. pkg = pkg_;
  179. if (err) return cb(err);
  180. if (dir && pkg && opts.pathFilter) {
  181. var rfile = path.relative(dir, file);
  182. var rel = rfile.slice(0, rfile.length - exts[0].length);
  183. var r = opts.pathFilter(pkg, x, rel);
  184. if (r) return load(
  185. [''].concat(extensions),
  186. path.resolve(dir, r),
  187. pkg
  188. );
  189. }
  190. isFile(file, onex);
  191. }
  192. function onex(err, ex) {
  193. if (err) return cb(err);
  194. if (ex) return cb(null, file, pkg);
  195. load(exts.slice(1), x, pkg);
  196. }
  197. }
  198. }
  199. function loadpkg(dir, cb) {
  200. if (dir === '' || dir === '/') return cb(null);
  201. if (process.platform === 'win32' && windowsDriveRegex.test(dir)) {
  202. return cb(null);
  203. }
  204. if (nodeModulesRegex.test(dir)) return cb(null);
  205. maybeRealpath(realpath, dir, opts, function (unwrapErr, pkgdir) {
  206. if (unwrapErr) return loadpkg(path.dirname(dir), cb);
  207. var pkgfile = path.join(pkgdir, 'package.json');
  208. isFile(pkgfile, function (err, ex) {
  209. // on err, ex is false
  210. if (!ex) return loadpkg(path.dirname(dir), cb);
  211. readPackage(readFile, pkgfile, function (err, pkgParam) {
  212. if (err) { return cb(err); }
  213. var pkg = pkgParam;
  214. if (pkg && opts.packageFilter) {
  215. pkg = opts.packageFilter(pkg, pkgfile);
  216. }
  217. cb(null, pkg, dir);
  218. });
  219. });
  220. });
  221. }
  222. function loadAsDirectory(x, loadAsDirectoryPackage, callback) {
  223. var cb = callback;
  224. var fpkg = loadAsDirectoryPackage;
  225. if (typeof fpkg === 'function') {
  226. cb = fpkg;
  227. fpkg = opts.package;
  228. }
  229. maybeRealpath(realpath, x, opts, function (unwrapErr, pkgdir) {
  230. if (unwrapErr) return cb(unwrapErr);
  231. var pkgfile = path.join(pkgdir, 'package.json');
  232. isFile(pkgfile, function (err, ex) {
  233. if (err) return cb(err);
  234. if (!ex) return loadAsFile(path.join(x, 'index'), fpkg, cb);
  235. readPackage(readFile, pkgfile, function (err, pkgParam) {
  236. if (err) return cb(err);
  237. var pkg = pkgParam;
  238. if (pkg && opts.packageFilter) {
  239. pkg = opts.packageFilter(pkg, pkgfile);
  240. }
  241. if (pkg && pkg.main) {
  242. if (typeof pkg.main !== 'string') {
  243. var mainError = new $TypeError('package “' + pkg.name + '” `main` must be a string');
  244. mainError.code = 'INVALID_PACKAGE_MAIN';
  245. return cb(mainError);
  246. }
  247. if (pkg.main === '.' || pkg.main === './') {
  248. pkg.main = 'index';
  249. }
  250. loadAsFile(path.resolve(x, pkg.main), pkg, function (err, m, pkg) {
  251. if (err) return cb(err);
  252. if (m) return cb(null, m, pkg);
  253. if (!pkg) return loadAsFile(path.join(x, 'index'), pkg, cb);
  254. var dir = path.resolve(x, pkg.main);
  255. loadAsDirectory(dir, pkg, function (err, n, pkg) {
  256. if (err) return cb(err);
  257. if (n) return cb(null, n, pkg);
  258. loadAsFile(path.join(x, 'index'), pkg, cb);
  259. });
  260. });
  261. return;
  262. }
  263. loadAsFile(path.join(x, '/index'), pkg, cb);
  264. });
  265. });
  266. });
  267. }
  268. function processDirs(cb, dirs) {
  269. if (dirs.length === 0) return cb(null, undefined);
  270. var dir = dirs[0];
  271. isDirectory(path.dirname(dir), isdir);
  272. function isdir(err, isdir) {
  273. if (err) return cb(err);
  274. if (!isdir) return processDirs(cb, dirs.slice(1));
  275. loadAsFile(dir, opts.package, onfile);
  276. }
  277. function onfile(err, m, pkg) {
  278. if (err) return cb(err);
  279. if (m) return cb(null, m, pkg);
  280. loadAsDirectory(dir, opts.package, ondir);
  281. }
  282. function ondir(err, n, pkg) {
  283. if (err) return cb(err);
  284. if (n) return cb(null, n, pkg);
  285. processDirs(cb, dirs.slice(1));
  286. }
  287. }
  288. function loadNodeModules(x, start, cb) {
  289. var thunk = function () { return getPackageCandidates(x, start, opts); };
  290. processDirs(
  291. cb,
  292. packageIterator ? packageIterator(x, start, thunk, opts) : thunk()
  293. );
  294. }
  295. };