Function _installDownloadedTree

src/forceUpdate.js:499–651

(installRoot, tempTarget, requiredVersion, successLabel)

}

function _installDownloadedTree(installRoot, tempTarget, requiredVersion, successLabel) {
  var phase = 'parse';
  var backupRoot = null;
  var movedEntries = [];
  var copiedEntryNames = [];
  var committedIndex = false;
  var indexBackup = null;
  var packageBackup = null;
  try {
    var tmpPkg = JSON.parse(fs.readFileSync(path.join(tempTarget, 'package.json'), 'utf8'));
    if (!_isEvolverPackageName(tmpPkg && tmpPkg.name)) {
      return _fail(FORCE_UPDATE_FAIL_CODES.DOWNLOADED_PACKAGE_NAME_MISMATCH,
        'downloaded package.json name="' + (tmpPkg && tmpPkg.name) + '", expected "@evomap/evolver"');
    }
    if (!tmpPkg.version) {
      return _fail(FORCE_UPDATE_FAIL_CODES.DOWNLOAD_INCOMPLETE,
        'downloaded package.json has no version field');
    }
    if (tmpPkg.version !== requiredVersion) {
      return _fail(FORCE_UPDATE_FAIL_CODES.DOWNLOADED_VERSION_MISMATCH,
        'downloaded version=' + JSON.stringify(tmpPkg.version) + ', expected ' + requiredVersion);
    }
    try {
      if (!fs.statSync(path.join(tempTarget, 'index.js')).isFile()) {
        return _fail(FORCE_UPDATE_FAIL_CODES.DOWNLOAD_INCOMPLETE,
          'downloaded index.js is not a file');
      }
    } catch (indexReadErr) {
      return _fail(FORCE_UPDATE_FAIL_CODES.DOWNLOAD_INCOMPLETE,
        'missing/unreadable index.js in downloaded tree: ' + _errStr(indexReadErr));
    }

    phase = 'delete';
    var entries = fs.readdirSync(installRoot, { withFileTypes: true });
    backupRoot = fs.mkdtempSync(path.join(installRoot, FORCE_UPDATE_BACKUP_PREFIX));
    _writeForceUpdateRecoveryJournal(backupRoot, requiredVersion, _readInstallPackageVersion(installRoot));
    var indexSrc = path.join(tempTarget, 'index.js');
    var indexDst = path.join(installRoot, 'index.js');
    var indexTmp = indexDst + '.' + process.pid + '.evolver-tmp';
    indexBackup = path.join(backupRoot, 'index.js');
    try {
      phase = 'copy';
      _commitAtomicFileReplacement(indexSrc, indexDst, indexTmp, indexBackup);
      committedIndex = true;
    } catch (indexErr) {
      _restoreFileBackupIfPresent(indexBackup, indexDst);
      try { fs.rmSync(indexTmp, { force: true }); } catch (_) {}
      console.warn('[ForceUpdate] index.js commit (atomic replace) failed: ' + (indexErr.message || indexErr));
      try { indexErr._evolverEntry = 'index.js commit'; } catch (_) {}
      throw indexErr;
    }

    for (var ei = 0; ei < entries.length; ei++) {
      var eName = entries[ei].name;
      // package.json is the install's commit marker: keep the OLD one in
      // place through the entire delete+copy below and swap in the new one
      // atomically at the very end. index.js was already atomically replaced
      // after the recovery journal was written, before moving payload entries,