run method

Implementation

Future<CommandResult> run({
  required CommandToRun command,
  required bool showOutput,
  Duration? retryAfter,
  int maxAttempts = 3,
  FilterType? filter,
}) async {
  var cmd = command.command;

  if (command.envConfig case final EnvConfig config) {
    if (config.variables case final vars? when vars.isNotEmpty) {
      logger.detail('Setting environment variables: $vars');

      cmd = '\n$cmd';

      for (final entry in vars.entries.toList().reversed) {
        cmd = '''
export ${entry.key}=${entry.value}
$cmd''';
      }
    }

    if (config.files?.toList().reversed case final files?
        when files.isNotEmpty) {
      logger.detail('Sourcing env files: ${files.join('\n')}');

      for (final file in files) {
        logger.detail('Sourcing env file $file');
        final addToEnv = [
          r'''
while IFS='=' read -r key _; do
  if [[ $key =~ ^[A-Za-z_][A-Za-z0-9_]*$ ]]; then
    export "$key"
  fi
done < <(grep -vE '^\s*#' ''',
          file,
          " | grep -E '^[A-Za-z_][A-Za-z0-9_]*=')",
        ].join();

        cmd = '''
if [ -f $file ]; then
builtin source $file
$addToEnv
else
echo "ENV File $file not found"
exit 1
fi

$cmd''';
      }
    }
  }

  logger.detail('Setting directory to ${command.workingDirectory}');
  cmd = '''
cd ${command.workingDirectory} || exit 1

$cmd
''';

  var printOutput = showOutput;
  if (logger.level == Level.quiet) {
    printOutput = false;
  }

  if (filter case final filter?) {
    logger.detail('Filter type: $filter');
  }

  final runScript = bindings.runScript(
    cmd,
    showOutput: printOutput,
    filterType: filter,
    bail: command.bail,
  );

  CommandResult codeResult;
  if (retryAfter == null) {
    final result = await runScript;

    if (filter != null && showOutput) {
      logger.write('\n');
    }

    codeResult = result;
  } else {
    logger.detail('Retrying command after $retryAfter');
    var hasExited = false;
    var attempt = 0;

    while (!hasExited && attempt < maxAttempts) {
      attempt++;

      final controller = StreamController<CommandResult?>();

      final wait = retryAfter + (retryAfter * (.1 * attempt));

      logger.detail('Waiting $wait before attempt $attempt');

      final timer = Timer(wait, () => controller.add(null));

      runScript.then(controller.add).ignore();

      final exitCode = await controller.stream.first;

      timer.cancel();

      if (exitCode == null) {
        continue;
      }

      codeResult = exitCode;
      hasExited = true;
    }

    logger.detail(
      'Failed to exit after $maxAttempts attempts, '
      'running without retries',
    );

    final result = await runScript;

    if (filter case FilterType.flutterTest) {
      logger.write('\n');
    }

    codeResult = result;
  }

  logger.detail('Exited with ${codeResult.exitCode}');

  return codeResult;
}