"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
/**
 * @license
 * Copyright Google Inc. All Rights Reserved.
 *
 * Use of this source code is governed by an MIT-style license that can be
 * found in the LICENSE file at https://angular.io/license
 */
const child_process_1 = require("child_process");
const fs = require("fs");
const path = require("path");
const semver = require("semver");
const schematic_command_1 = require("../models/schematic-command");
const install_package_1 = require("../tasks/install-package");
const package_manager_1 = require("../utilities/package-manager");
const package_metadata_1 = require("../utilities/package-metadata");
const package_tree_1 = require("../utilities/package-tree");
const npa = require('npm-package-arg');
const pickManifest = require('npm-pick-manifest');
const oldConfigFileNames = ['.angular-cli.json', 'angular-cli.json'];
class UpdateCommand extends schematic_command_1.SchematicCommand {
    constructor() {
        super(...arguments);
        this.allowMissingWorkspace = true;
        this.packageManager = package_manager_1.getPackageManager(this.workspace.root);
    }
    async parseArguments(_schematicOptions, _schema) {
        return {};
    }
    // tslint:disable-next-line:no-big-function
    async run(options) {
        // Check if the current installed CLI version is older than the latest version.
        if (await this.checkCLILatestVersion(options.verbose, options.next)) {
            this.logger.warn(`The installed Angular CLI version is older than the latest ${options.next ? 'pre-release' : 'stable'} version.\n` +
                'Installing a temporary version to perform the update.');
            return install_package_1.runTempPackageBin(`@angular/cli@${options.next ? 'next' : 'latest'}`, this.logger, this.packageManager, process.argv.slice(2));
        }
        const packages = [];
        for (const request of options['--'] || []) {
            try {
                const packageIdentifier = npa(request);
                // only registry identifiers are supported
                if (!packageIdentifier.registry) {
                    this.logger.error(`Package '${request}' is not a registry package identifer.`);
                    return 1;
                }
                if (packages.some(v => v.name === packageIdentifier.name)) {
                    this.logger.error(`Duplicate package '${packageIdentifier.name}' specified.`);
                    return 1;
                }
                // If next option is used and no specifier supplied, use next tag
                if (options.next && !packageIdentifier.rawSpec) {
                    packageIdentifier.fetchSpec = 'next';
                }
                packages.push(packageIdentifier);
            }
            catch (e) {
                this.logger.error(e.message);
                return 1;
            }
        }
        if (options.all && packages.length > 0) {
            this.logger.error('Cannot specify packages when using the "all" option.');
            return 1;
        }
        else if (options.all && options.migrateOnly) {
            this.logger.error('Cannot use "all" option with "migrate-only" option.');
            return 1;
        }
        else if (!options.migrateOnly && (options.from || options.to)) {
            this.logger.error('Can only use "from" or "to" options with "migrate-only" option.');
            return 1;
        }
        // If not asking for status then check for a clean git repository.
        // This allows the user to easily reset any changes from the update.
        const statusCheck = packages.length === 0 && !options.all;
        if (!statusCheck && !this.checkCleanGit()) {
            if (options.allowDirty) {
                this.logger.warn('Repository is not clean.  Update changes will be mixed with pre-existing changes.');
            }
            else {
                this.logger.error('Repository is not clean.  Please commit or stash any changes before updating.');
                return 2;
            }
        }
        this.logger.info(`Using package manager: '${this.packageManager}'`);
        // Special handling for Angular CLI 1.x migrations
        if (options.migrateOnly === undefined &&
            options.from === undefined &&
            !options.all &&
            packages.length === 1 &&
            packages[0].name === '@angular/cli' &&
            this.workspace.configFile &&
            oldConfigFileNames.includes(this.workspace.configFile)) {
            options.migrateOnly = true;
            options.from = '1.0.0';
        }
        this.logger.info('Collecting installed dependencies...');
        const packageTree = await package_tree_1.readPackageTree(this.workspace.root);
        const rootDependencies = package_tree_1.findNodeDependencies(packageTree);
        this.logger.info(`Found ${Object.keys(rootDependencies).length} dependencies.`);
        if (options.all || packages.length === 0) {
            // Either update all packages or show status
            return this.runSchematic({
                collectionName: '@schematics/update',
                schematicName: 'update',
                dryRun: !!options.dryRun,
                showNothingDone: false,
                additionalOptions: {
                    force: options.force || false,
                    next: options.next || false,
                    verbose: options.verbose || false,
                    packageManager: this.packageManager,
                    packages: options.all ? Object.keys(rootDependencies) : [],
                },
            });
        }
        if (options.migrateOnly) {
            if (!options.from) {
                this.logger.error('"from" option is required when using the "migrate-only" option.');
                return 1;
            }
            else if (packages.length !== 1) {
                this.logger.error('A single package must be specified when using the "migrate-only" option.');
                return 1;
            }
            if (options.next) {
                this.logger.warn('"next" option has no effect when using "migrate-only" option.');
            }
            const packageName = packages[0].name;
            const packageDependency = rootDependencies[packageName];
            let packageNode = packageDependency && packageDependency.node;
            if (packageDependency && !packageNode) {
                this.logger.error('Package found in package.json but is not installed.');
                return 1;
            }
            else if (!packageDependency) {
                // Allow running migrations on transitively installed dependencies
                // There can technically be nested multiple versions
                // TODO: If multiple, this should find all versions and ask which one to use
                const child = packageTree.children.find(c => c.name === packageName);
                if (child) {
                    packageNode = child;
                }
            }
            if (!packageNode) {
                this.logger.error('Package is not installed.');
                return 1;
            }
            const updateMetadata = packageNode.package['ng-update'];
            let migrations = updateMetadata && updateMetadata.migrations;
            if (migrations === undefined) {
                this.logger.error('Package does not provide migrations.');
                return 1;
            }
            else if (typeof migrations !== 'string') {
                this.logger.error('Package contains a malformed migrations field.');
                return 1;
            }
            else if (path.posix.isAbsolute(migrations) || path.win32.isAbsolute(migrations)) {
                this.logger.error('Package contains an invalid migrations field. Absolute paths are not permitted.');
                return 1;
            }
            // Normalize slashes
            migrations = migrations.replace(/\\/g, '/');
            if (migrations.startsWith('../')) {
                this.logger.error('Package contains an invalid migrations field. ' +
                    'Paths outside the package root are not permitted.');
                return 1;
            }
            // Check if it is a package-local location
            const localMigrations = path.join(packageNode.path, migrations);
            if (fs.existsSync(localMigrations)) {
                migrations = localMigrations;
            }
            else {
                // Try to resolve from package location.
                // This avoids issues with package hoisting.
                try {
                    migrations = require.resolve(migrations, { paths: [packageNode.path] });
                }
                catch (e) {
                    if (e.code === 'MODULE_NOT_FOUND') {
                        this.logger.error('Migrations for package were not found.');
                    }
                    else {
                        this.logger.error(`Unable to resolve migrations for package.  [${e.message}]`);
                    }
                    return 1;
                }
            }
            return this.runSchematic({
                collectionName: '@schematics/update',
                schematicName: 'migrate',
                dryRun: !!options.dryRun,
                force: false,
                showNothingDone: false,
                additionalOptions: {
                    package: packageName,
                    collection: migrations,
                    from: options.from,
                    verbose: options.verbose || false,
                    to: options.to || packageNode.package.version,
                },
            });
        }
        const requests = [];
        // Validate packages actually are part of the workspace
        for (const pkg of packages) {
            const node = rootDependencies[pkg.name] && rootDependencies[pkg.name].node;
            if (!node) {
                this.logger.error(`Package '${pkg.name}' is not a dependency.`);
                return 1;
            }
            // If a specific version is requested and matches the installed version, skip.
            if (pkg.type === 'version' && node.package.version === pkg.fetchSpec) {
                this.logger.info(`Package '${pkg.name}' is already at '${pkg.fetchSpec}'.`);
                continue;
            }
            requests.push({ identifier: pkg, node });
        }
        if (requests.length === 0) {
            return 0;
        }
        const packagesToUpdate = [];
        this.logger.info('Fetching dependency metadata from registry...');
        for (const { identifier: requestIdentifier, node } of requests) {
            const packageName = requestIdentifier.name;
            let metadata;
            try {
                // Metadata requests are internally cached; multiple requests for same name
                // does not result in additional network traffic
                metadata = await package_metadata_1.fetchPackageMetadata(packageName, this.logger, { verbose: options.verbose });
            }
            catch (e) {
                this.logger.error(`Error fetching metadata for '${packageName}': ` + e.message);
                return 1;
            }
            // Try to find a package version based on the user requested package specifier
            // registry specifier types are either version, range, or tag
            let manifest;
            if (requestIdentifier.type === 'version' ||
                requestIdentifier.type === 'range' ||
                requestIdentifier.type === 'tag') {
                try {
                    manifest = pickManifest(metadata, requestIdentifier.fetchSpec);
                }
                catch (e) {
                    if (e.code === 'ETARGET') {
                        // If not found and next was used and user did not provide a specifier, try latest.
                        // Package may not have a next tag.
                        if (requestIdentifier.type === 'tag' &&
                            requestIdentifier.fetchSpec === 'next' &&
                            !requestIdentifier.rawSpec) {
                            try {
                                manifest = pickManifest(metadata, 'latest');
                            }
                            catch (e) {
                                if (e.code !== 'ETARGET' && e.code !== 'ENOVERSIONS') {
                                    throw e;
                                }
                            }
                        }
                    }
                    else if (e.code !== 'ENOVERSIONS') {
                        throw e;
                    }
                }
            }
            if (!manifest) {
                this.logger.error(`Package specified by '${requestIdentifier.raw}' does not exist within the registry.`);
                return 1;
            }
            if (manifest.version === node.package.version) {
                this.logger.info(`Package '${packageName}' is already up to date.`);
                continue;
            }
            packagesToUpdate.push(requestIdentifier.toString());
        }
        if (packagesToUpdate.length === 0) {
            return 0;
        }
        return this.runSchematic({
            collectionName: '@schematics/update',
            schematicName: 'update',
            dryRun: !!options.dryRun,
            showNothingDone: false,
            additionalOptions: {
                verbose: options.verbose || false,
                force: options.force || false,
                packageManager: this.packageManager,
                packages: packagesToUpdate,
            },
        });
    }
    checkCleanGit() {
        try {
            const topLevel = child_process_1.execSync('git rev-parse --show-toplevel', { encoding: 'utf8', stdio: 'pipe' });
            const result = child_process_1.execSync('git status --porcelain', { encoding: 'utf8', stdio: 'pipe' });
            if (result.trim().length === 0) {
                return true;
            }
            // Only files inside the workspace root are relevant
            for (const entry of result.split('\n')) {
                const relativeEntry = path.relative(path.resolve(this.workspace.root), path.resolve(topLevel.trim(), entry.slice(3).trim()));
                if (!relativeEntry.startsWith('..') && !path.isAbsolute(relativeEntry)) {
                    return false;
                }
            }
        }
        catch (_a) { }
        return true;
    }
    /**
   * Checks if the current installed CLI version is older than the latest version.
   * @returns `true` when the installed version is older.
  */
    async checkCLILatestVersion(verbose = false, next = false) {
        const { version: installedCLIVersion } = require('../package.json');
        const LatestCLIManifest = await package_metadata_1.fetchPackageMetadata('@angular/cli', this.logger, {
            verbose,
            usingYarn: this.packageManager === 'yarn',
        });
        const latest = LatestCLIManifest.tags[next ? 'next' : 'latest'];
        if (!latest) {
            return false;
        }
        return semver.lt(installedCLIVersion, latest.version);
    }
}
exports.UpdateCommand = UpdateCommand;