// Copyright 2020 The Fuchsia 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 'package:fxtest/fxtest.dart';
import 'package:pedantic/pedantic.dart';
import 'package:test/test.dart';
import 'helpers.dart';

void main() {
  OutputBuffer buffer;
  OutputFormatter outputFormatter;
  StreamController<TestEvent> streamController;

  var testDefinition = TestDefinition.fromJson(
    {
      'environments': [],
      'test': {
        'cpu': 'x64',
        'label': '//scripts/lib:lib_tests(//build/toolchain:host_x64)',
        'name': 'lib_tests',
        'os': 'linux',
        'path': 'host_x64/lib_tests',
        'runtime_deps': 'host_x64/gen/scripts/lib/lib_tests.deps.json'
      }
    },
    buildDir: '/whatever',
    fx: '/whatever/fx',
  );

  setUp(() async {
    streamController = StreamController<TestEvent>();
    buffer = OutputBuffer.locMemIO();
  });

  tearDown(() async {
    unawaited(streamController.close());
  });

  group('output is collected correctly', () {
    test('for a passing test', () async {
      var testsConfig = TestsConfig.fromRawArgs(rawArgs: []);
      outputFormatter = OutputFormatter.fromConfig(
        testsConfig,
        buffer: buffer,
      );
      var runner = ScriptedTestRunner(scriptedOutput: [
        Output('test'),
        Output('test 2'),
        ErrOutput('test 3'),
      ]);
      var cmd = FuchsiaTestCommand.fromConfig(
        testsConfig,
        outputFormatter: outputFormatter,
        testRunnerBuilder: (TestsConfig config) => runner,
      );
      // Use the command's builder so we test how things are actually wired up,
      // instead of duplicating the wiring-up here
      var bundle = cmd.testBundleBuilder(testDefinition);
      await cmd.runTests([bundle]);
      expect(buffer.content, hasLength(1));
      // Output that the test passed. Note that the _test is running_ content
      // has been overwritten.
      expect(buffer.content.first, contains('✅'));
      expect(buffer.content.first, contains('/whatever/host_x64/lib_tests'));
    });
  });

  test('for a failing tests', () async {
    var testsConfig = TestsConfig.fromRawArgs(rawArgs: []);
    outputFormatter = OutputFormatter.fromConfig(
      testsConfig,
      buffer: buffer,
    );
    var runner = ScriptedTestRunner(exitCode: 2, scriptedOutput: [
      Output('test 1'),
      Output('test 2'),
      ErrOutput('test 3'),
    ]);
    var cmd = FuchsiaTestCommand.fromConfig(
      testsConfig,
      outputFormatter: outputFormatter,
      testRunnerBuilder: (TestsConfig config) => runner,
    );
    // Use the command's builder so we test how things are actually wired up,
    // instead of duplicating the wiring-up here
    var bundle = cmd.testBundleBuilder(testDefinition);
    await cmd.runTests([bundle]);
    var allOutput = buffer.content.join('\n');
    // All test output appears
    expect(allOutput, contains('test 1'));
    expect(allOutput, contains('test 2'));
    expect(allOutput, contains('test 3'));
    // Output that the test failed. Note that the _test is running_ content
    // has been overwritten.
    expect(allOutput, contains('❌'));
    expect(allOutput, contains('/whatever/host_x64/lib_tests'));
  });
}