app_dart/integration_test/validate_test_ownership_test.dart

// Copyright 2021 The Flutter Authors. 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';

import 'package:github/github.dart';
import 'package:process/process.dart';
import 'package:test/test.dart';

import 'common.dart';

/// List of supported repositories with TESTOWNERS.
final List<SupportedConfig> configs = <SupportedConfig>[
  SupportedConfig(RepositorySlug('flutter', 'flutter')),
];

Future<void> main() async {
  for (final config in configs) {
    test('validate test ownership for $config', () async {
      const dart = 'dart';
      const taskExecutable = 'bin/validate_task_ownership.dart';
      final taskArgs = <String>[config.slug.name, config.branch];

      const ProcessManager processManager = LocalProcessManager();
      final process = await processManager.start(<String>[
        dart,
        taskExecutable,
        ...taskArgs,
      ], workingDirectory: Directory.current.path);

      final output = <String>[];
      final error = <String>[];

      process.stdout
          .transform<String>(const Utf8Decoder())
          .transform<String>(const LineSplitter())
          .listen((String line) {
            stdout.writeln('[STDOUT] $line');
            output.add(line);
          });

      process.stderr
          .transform<String>(const Utf8Decoder())
          .transform<String>(const LineSplitter())
          .listen((String line) {
            stderr.writeln('[STDERR] $line');
            error.add(line);
          });

      final exitCode = await process.exitCode;
      if (exitCode != 0) {
        for (var line in error) {
          print(line);
        }
        fail('An error has occurred.');
      }
    });
  }
}