pkg/dartdev/lib/src/commands/analyze.dart - sdk.git - Git at Google

 // Copyright (c) 2020, the Dart project authors. Please see the AUTHORS file
 // for details. All rights reserved. Use of this source code is governed by a
 // BSD-style license that can be found in the LICENSE file.

 import 'dart:async';
 import 'dart:convert';
 import 'dart:io' as io;

 import 'package:cli_util/cli_logging.dart';
 import 'package:meta/meta.dart';
 import 'package:path/path.dart' as path;

 import '../analysis_server.dart';
 import '../core.dart';
 import '../sdk.dart';
 import '../utils.dart';

 class AnalyzeCommand extends DartdevCommand {
   static const String cmdName = 'analyze';

   /// The maximum length of any of the existing severity labels.
   static const int _severityWidth = 7;

   /// The number of spaces needed to indent follow-on lines (the body) under the
   /// message. The width left for the severity label plus the separator width.
   static const int _bodyIndentWidth = _severityWidth + 3;

   static final String _bodyIndent = ' ' * _bodyIndentWidth;

   static final int _pipeCodeUnit = '|'.codeUnitAt(0);

   static final int _slashCodeUnit = '\\'.codeUnitAt(0);

   static final int _newline = '\n'.codeUnitAt(0);

   static final int _return = '\r'.codeUnitAt(0);

   AnalyzeCommand({bool verbose = false})
       : super(cmdName, 'Analyze Dart code in a directory.', verbose) {
     argParser
       ..addFlag('fatal-infos',
           help: 'Treat info level issues as fatal.', negatable: false)
       ..addFlag('fatal-warnings',
           help: 'Treat warning level issues as fatal.', defaultsTo: true)

       // Options hidden by default.
       ..addOption(
         'format',
         valueHelp: 'value',
         help: 'Specifies the format to display errors.',
         allowed: ['default', 'json', 'machine'],
         allowedHelp: {
           'default':
               'The default output format. This format is intended to be user '
                   'consumable.\nThe format is not specified and can change '
                   'between releases.',
           'json': 'A machine readable output in a JSON format.',
           'machine': 'A machine readable output. The format is:\n\n'
               'SEVERITY|TYPE|ERROR_CODE|FILE_PATH|LINE|COLUMN|LENGTH|ERROR_MESSAGE\n\n'
               'Note that the pipe character is escaped with backslashes for '
               'the file path and error message fields.',
         },
         hide: !verbose,
       );
   }

   @override
   String get invocation => '${super.invocation} [<directory>]';

   @override
   FutureOr<int> run() async {
     // Find targets from the 'rest' params.
     final List<io.FileSystemEntity> targets = [];
     if (argResults.rest.isEmpty) {
       targets.add(io.Directory.current);
     } else {
       for (String targetPath in argResults.rest) {
         if (io.Directory(targetPath).existsSync()) {
           targets.add(io.Directory(targetPath));
         } else if (io.File(targetPath).existsSync()) {
           targets.add(io.File(targetPath));
         } else {
           usageException("Directory or file doesn't exist: $targetPath");
         }
       }
     }

     final List<AnalysisError> errors = <AnalysisError>[];

     final machineFormat = argResults['format'] == 'machine';
     final jsonFormat = argResults['format'] == 'json';

     final targetsNames =
         targets.map((entity) => path.basename(entity.path)).join(', ');

     var progress =
         machineFormat ? null : log.progress('Analyzing $targetsNames');

     final AnalysisServer server = AnalysisServer(
       io.Directory(sdk.sdkPath),
       targets,
       commandName: 'analyze',
       argResults: argResults,
     );

     server.onErrors.listen((FileAnalysisErrors fileErrors) {
       // Record the issues found (but filter out to do comments).
       errors.addAll(fileErrors.errors
           .where((AnalysisError error) => error.type != 'TODO'));
     });

     await server.start();

     bool analysisFinished = false;

     // ignore: unawaited_futures
     server.onExit.then((int exitCode) {
       if (!analysisFinished) {
         io.exitCode = exitCode;
       }
     });

     await server.analysisFinished;
     analysisFinished = true;

     await server.shutdown(timeout: Duration(milliseconds: 100));

     progress?.finish(showTiming: true);

     errors.sort();

     if (errors.isEmpty) {
       if (!machineFormat) {
         log.stdout('No issues found!');
       }
       return 0;
     }

     if (machineFormat) {
       emitMachineFormat(log, errors);
     } else if (jsonFormat) {
       emitJsonFormat(log, errors);
     } else {
       var relativeTo = targets.length == 1 ? targets.single : null;

       emitDefaultFormat(
         log,
         errors,
         relativeToDir: relativeTo is io.File ? relativeTo.parent : relativeTo,
         verbose: verbose,
       );
     }

     bool hasErrors = false;
     bool hasWarnings = false;
     bool hasInfos = false;

     for (final AnalysisError error in errors) {
       hasErrors |= error.isError;
       hasWarnings |= error.isWarning;
       hasInfos |= error.isInfo;
     }

     // Return an error code in the range [0-3] dependent on the severity of
     // the issue(s) found.
     if (hasErrors) {
       return 3;
     }

     bool fatalWarnings = argResults['fatal-warnings'];
     bool fatalInfos = argResults['fatal-infos'];

     if (fatalWarnings && hasWarnings) {
       return 2;
     } else if (fatalInfos && hasInfos) {
       return 1;
     } else {
       return 0;
     }
   }

   @visibleForTesting
   static void emitDefaultFormat(
     Logger log,
     List<AnalysisError> errors, {
     io.Directory relativeToDir,
     bool verbose = false,
   }) {
     final ansi = log.ansi;
     final bullet = ansi.bullet;

     log.stdout('');

     final wrapWidth = dartdevUsageLineLength == null
         ? null
         : (dartdevUsageLineLength - _bodyIndentWidth);

     for (final AnalysisError error in errors) {
       var severity = error.severity.toLowerCase().padLeft(_severityWidth);
       if (error.isError) {
         severity = ansi.error(severity);
       }
       var filePath = _relativePath(error.file, relativeToDir);
       var codeRef = error.code;
       // If we're in verbose mode, write any error urls instead of error codes.
       if (error.url != null && verbose) {
         codeRef = error.url;
       }

       // Emit "file:line:col * Error message. Correction (code)."
       var message = ansi.emphasized(error.message);
       if (error.correction != null) {
         message += ' ${error.correction}';
       }
       var location = '$filePath:${error.startLine}:${error.startColumn}';
       var output = '$location $bullet '
           '$message $bullet '
           '${ansi.green}$codeRef${ansi.none}';

       // TODO(devoncarew): We need to take into account ansi color codes when
       // performing line wrapping.
       output = wrapText(output, width: wrapWidth);
       log.stdout(
         '$severity $bullet '
         '${output.replaceAll('\n', '\n$_bodyIndent')}',
       );

       // Add any context messages as bullet list items.
       for (var message in error.contextMessages) {
         var contextPath = _relativePath(error.file, relativeToDir);
         var messageSentenceFragment = trimEnd(message.message, '.');

         log.stdout('$_bodyIndent'
             ' - $messageSentenceFragment at '
             '$contextPath:${message.line}:${message.column}.');
       }
     }

     log.stdout('');

     final errorCount = errors.length;
     log.stdout('$errorCount ${pluralize('issue', errorCount)} found.');
   }

   @visibleForTesting
   static void emitJsonFormat(Logger log, List<AnalysisError> errors) {
     Map<String, dynamic> location(
             String filePath, Map<String, dynamic> range) =>
         {
           'file': filePath,
           'range': range,
         };

     Map<String, dynamic> position(int offset, int line, int column) => {
           'offset': offset,
           'line': line,
           'column': column,
         };

     Map<String, dynamic> range(
             Map<String, dynamic> start, Map<String, dynamic> end) =>
         {
           'start': start,
           'end': end,
         };

     var diagnostics = <Map<String, dynamic>>[];
     for (final AnalysisError error in errors) {
       var contextMessages = [];
       for (var contextMessage in error.contextMessages) {
         var startOffset = contextMessage.offset;
         contextMessages.add({
           'location': location(
               contextMessage.filePath,
               range(
                   position(
                       startOffset, contextMessage.line, contextMessage.column),
                   position(startOffset + contextMessage.length,
                       contextMessage.endLine, contextMessage.endColumn))),
           'message': contextMessage.message,
         });
       }
       var startOffset = error.offset;
       diagnostics.add({
         'code': error.code,
         'severity': error.severity,
         'type': error.type,
         'location': location(
             error.file,
             range(
                 position(startOffset, error.startLine, error.startColumn),
                 position(startOffset + error.length, error.endLine,
                     error.endColumn))),
         'problemMessage': error.message,
         if (error.correction != null) 'correctionMessage': error.correction,
         if (contextMessages.isNotEmpty) 'contextMessages': contextMessages,
         if (error.url != null) 'documentation': error.url,
       });
     }
     log.stdout(json.encode({
       'version': 1,
       'diagnostics': diagnostics,
     }));
   }

   /// Return a relative path if it is a shorter reference than the given dir.
   static String _relativePath(String givenPath, io.Directory fromDir) {
     String fromPath = fromDir?.absolute?.resolveSymbolicLinksSync();
     String relative = path.relative(givenPath, from: fromPath);
     return relative.length <= givenPath.length ? relative : givenPath;
   }

   @visibleForTesting
   static void emitMachineFormat(Logger log, List<AnalysisError> errors) {
     for (final AnalysisError error in errors) {
       log.stdout([
         error.severity,
         error.type,
         error.code.toUpperCase(),
         _escapeForMachineMode(error.file),
         error.startLine.toString(),
         error.startColumn.toString(),
         error.length.toString(),
         _escapeForMachineMode(error.message),
       ].join('|'));
     }
   }

   static String _escapeForMachineMode(String input) {
     var result = StringBuffer();
     for (var c in input.codeUnits) {
       if (c == _newline) {
         result.write(r'\n');
       } else if (c == _return) {
         result.write(r'\r');
       } else {
         if (c == _slashCodeUnit || c == _pipeCodeUnit) {
           result.write('\\');
         }
         result.writeCharCode(c);
       }
     }
     return result.toString();
   }
 }
	// Copyright (c) 2020, the Dart project authors. Please see the AUTHORS file
	// for details. All rights reserved. Use of this source code is governed by a
	// BSD-style license that can be found in the LICENSE file.

	import 'dart:async';
	import 'dart:convert';
	import 'dart:io' as io;

	import 'package:cli_util/cli_logging.dart';
	import 'package:meta/meta.dart';
	import 'package:path/path.dart' as path;

	import '../analysis_server.dart';
	import '../core.dart';
	import '../sdk.dart';
	import '../utils.dart';

	class AnalyzeCommand extends DartdevCommand {
	static const String cmdName = 'analyze';

	/// The maximum length of any of the existing severity labels.
	static const int _severityWidth = 7;

	/// The number of spaces needed to indent follow-on lines (the body) under the
	/// message. The width left for the severity label plus the separator width.
	static const int _bodyIndentWidth = _severityWidth + 3;

	static final String _bodyIndent = ' ' * _bodyIndentWidth;

	static final int _pipeCodeUnit = '\|'.codeUnitAt(0);

	static final int _slashCodeUnit = '\\'.codeUnitAt(0);

	static final int _newline = '\n'.codeUnitAt(0);

	static final int _return = '\r'.codeUnitAt(0);

	AnalyzeCommand({bool verbose = false})
	: super(cmdName, 'Analyze Dart code in a directory.', verbose) {
	argParser
	..addFlag('fatal-infos',
	help: 'Treat info level issues as fatal.', negatable: false)
	..addFlag('fatal-warnings',
	help: 'Treat warning level issues as fatal.', defaultsTo: true)

	// Options hidden by default.
	..addOption(
	'format',
	valueHelp: 'value',
	help: 'Specifies the format to display errors.',
	allowed: ['default', 'json', 'machine'],
	allowedHelp: {
	'default':
	'The default output format. This format is intended to be user '
	'consumable.\nThe format is not specified and can change '
	'between releases.',
	'json': 'A machine readable output in a JSON format.',
	'machine': 'A machine readable output. The format is:\n\n'
	'SEVERITY\|TYPE\|ERROR_CODE\|FILE_PATH\|LINE\|COLUMN\|LENGTH\|ERROR_MESSAGE\n\n'
	'Note that the pipe character is escaped with backslashes for '
	'the file path and error message fields.',
	},
	hide: !verbose,
	);
	}

	@override
	String get invocation => '${super.invocation} [<directory>]';

	@override
	FutureOr<int> run() async {
	// Find targets from the 'rest' params.
	final List<io.FileSystemEntity> targets = [];
	if (argResults.rest.isEmpty) {
	targets.add(io.Directory.current);
	} else {
	for (String targetPath in argResults.rest) {
	if (io.Directory(targetPath).existsSync()) {
	targets.add(io.Directory(targetPath));
	} else if (io.File(targetPath).existsSync()) {
	targets.add(io.File(targetPath));
	} else {
	usageException("Directory or file doesn't exist: $targetPath");
	}
	}
	}

	final List<AnalysisError> errors = <AnalysisError>[];

	final machineFormat = argResults['format'] == 'machine';
	final jsonFormat = argResults['format'] == 'json';

	final targetsNames =
	targets.map((entity) => path.basename(entity.path)).join(', ');

	var progress =
	machineFormat ? null : log.progress('Analyzing $targetsNames');

	final AnalysisServer server = AnalysisServer(
	io.Directory(sdk.sdkPath),
	targets,
	commandName: 'analyze',
	argResults: argResults,
	);

	server.onErrors.listen((FileAnalysisErrors fileErrors) {
	// Record the issues found (but filter out to do comments).
	errors.addAll(fileErrors.errors
	.where((AnalysisError error) => error.type != 'TODO'));
	});

	await server.start();

	bool analysisFinished = false;

	// ignore: unawaited_futures
	server.onExit.then((int exitCode) {
	if (!analysisFinished) {
	io.exitCode = exitCode;
	}
	});

	await server.analysisFinished;
	analysisFinished = true;

	await server.shutdown(timeout: Duration(milliseconds: 100));

	progress?.finish(showTiming: true);

	errors.sort();

	if (errors.isEmpty) {
	if (!machineFormat) {
	log.stdout('No issues found!');
	}
	return 0;
	}

	if (machineFormat) {
	emitMachineFormat(log, errors);
	} else if (jsonFormat) {
	emitJsonFormat(log, errors);
	} else {
	var relativeTo = targets.length == 1 ? targets.single : null;

	emitDefaultFormat(
	log,
	errors,
	relativeToDir: relativeTo is io.File ? relativeTo.parent : relativeTo,
	verbose: verbose,
	);
	}

	bool hasErrors = false;
	bool hasWarnings = false;
	bool hasInfos = false;

	for (final AnalysisError error in errors) {
	hasErrors \|= error.isError;
	hasWarnings \|= error.isWarning;
	hasInfos \|= error.isInfo;
	}

	// Return an error code in the range [0-3] dependent on the severity of
	// the issue(s) found.
	if (hasErrors) {
	return 3;
	}

	bool fatalWarnings = argResults['fatal-warnings'];
	bool fatalInfos = argResults['fatal-infos'];

	if (fatalWarnings && hasWarnings) {
	return 2;
	} else if (fatalInfos && hasInfos) {
	return 1;
	} else {
	return 0;
	}
	}

	@visibleForTesting
	static void emitDefaultFormat(
	Logger log,
	List<AnalysisError> errors, {
	io.Directory relativeToDir,
	bool verbose = false,
	}) {
	final ansi = log.ansi;
	final bullet = ansi.bullet;

	log.stdout('');

	final wrapWidth = dartdevUsageLineLength == null
	? null
	: (dartdevUsageLineLength - _bodyIndentWidth);

	for (final AnalysisError error in errors) {
	var severity = error.severity.toLowerCase().padLeft(_severityWidth);
	if (error.isError) {
	severity = ansi.error(severity);
	}
	var filePath = _relativePath(error.file, relativeToDir);
	var codeRef = error.code;
	// If we're in verbose mode, write any error urls instead of error codes.
	if (error.url != null && verbose) {
	codeRef = error.url;
	}

	// Emit "file:line:col * Error message. Correction (code)."
	var message = ansi.emphasized(error.message);
	if (error.correction != null) {
	message += ' ${error.correction}';
	}
	var location = '$filePath:${error.startLine}:${error.startColumn}';
	var output = '$location $bullet '
	'$message $bullet '
	'${ansi.green}$codeRef${ansi.none}';

	// TODO(devoncarew): We need to take into account ansi color codes when
	// performing line wrapping.
	output = wrapText(output, width: wrapWidth);
	log.stdout(
	'$severity $bullet '
	'${output.replaceAll('\n', '\n$_bodyIndent')}',
	);

	// Add any context messages as bullet list items.
	for (var message in error.contextMessages) {
	var contextPath = _relativePath(error.file, relativeToDir);
	var messageSentenceFragment = trimEnd(message.message, '.');

	log.stdout('$_bodyIndent'
	' - $messageSentenceFragment at '
	'$contextPath:${message.line}:${message.column}.');
	}
	}

	log.stdout('');

	final errorCount = errors.length;
	log.stdout('$errorCount ${pluralize('issue', errorCount)} found.');
	}

	@visibleForTesting
	static void emitJsonFormat(Logger log, List<AnalysisError> errors) {
	Map<String, dynamic> location(
	String filePath, Map<String, dynamic> range) =>
	{
	'file': filePath,
	'range': range,
	};

	Map<String, dynamic> position(int offset, int line, int column) => {
	'offset': offset,
	'line': line,
	'column': column,
	};

	Map<String, dynamic> range(
	Map<String, dynamic> start, Map<String, dynamic> end) =>
	{
	'start': start,
	'end': end,
	};

	var diagnostics = <Map<String, dynamic>>[];
	for (final AnalysisError error in errors) {
	var contextMessages = [];
	for (var contextMessage in error.contextMessages) {
	var startOffset = contextMessage.offset;
	contextMessages.add({
	'location': location(
	contextMessage.filePath,
	range(
	position(
	startOffset, contextMessage.line, contextMessage.column),
	position(startOffset + contextMessage.length,
	contextMessage.endLine, contextMessage.endColumn))),
	'message': contextMessage.message,
	});
	}
	var startOffset = error.offset;
	diagnostics.add({
	'code': error.code,
	'severity': error.severity,
	'type': error.type,
	'location': location(
	error.file,
	range(
	position(startOffset, error.startLine, error.startColumn),
	position(startOffset + error.length, error.endLine,
	error.endColumn))),
	'problemMessage': error.message,
	if (error.correction != null) 'correctionMessage': error.correction,
	if (contextMessages.isNotEmpty) 'contextMessages': contextMessages,
	if (error.url != null) 'documentation': error.url,
	});
	}
	log.stdout(json.encode({
	'version': 1,
	'diagnostics': diagnostics,
	}));
	}

	/// Return a relative path if it is a shorter reference than the given dir.
	static String _relativePath(String givenPath, io.Directory fromDir) {
	String fromPath = fromDir?.absolute?.resolveSymbolicLinksSync();
	String relative = path.relative(givenPath, from: fromPath);
	return relative.length <= givenPath.length ? relative : givenPath;
	}

	@visibleForTesting
	static void emitMachineFormat(Logger log, List<AnalysisError> errors) {
	for (final AnalysisError error in errors) {
	log.stdout([
	error.severity,
	error.type,
	error.code.toUpperCase(),
	_escapeForMachineMode(error.file),
	error.startLine.toString(),
	error.startColumn.toString(),
	error.length.toString(),
	_escapeForMachineMode(error.message),
	].join('\|'));
	}
	}

	static String _escapeForMachineMode(String input) {
	var result = StringBuffer();
	for (var c in input.codeUnits) {
	if (c == _newline) {
	result.write(r'\n');
	} else if (c == _return) {
	result.write(r'\r');
	} else {
	if (c == _slashCodeUnit \|\| c == _pipeCodeUnit) {
	result.write('\\');
	}
	result.writeCharCode(c);
	}
	}
	return result.toString();
	}
	}