// Copyright 2014 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:io' as io;

import 'package:collection/collection.dart';
import 'package:test/test.dart';

import '../bin/engine_hash.dart' show GitRevisionStrategy, engineHash;

void main() {
  test('Produces an engine hash for merge-base', () async {
    final Future<io.ProcessResult> Function(List<String>) runProcess =
        _fakeProcesses(processes: <FakeProcess>[
      (
        exe: 'git',
        command: 'merge-base',
        rest: <String>['upstream/master', 'HEAD'],
        exitCode: 0,
        stdout: 'abcdef1234',
        stderr: null
      ),
      (
        exe: 'git',
        command: 'ls-tree',
        rest: <String>['-r', 'abcdef1234', 'engine', 'DEPS'],
        exitCode: 0,
        stdout: 'one\r\ntwo\r\n',
        stderr: null
      ),
    ]);

    final Future<String> result = engineHash(runProcess);

    expect(result, completion('c708d7ef841f7e1748436b8ef5670d0b2de1a227'));
  });

  test('Produces an engine hash for HEAD', () async {
    final Future<io.ProcessResult> Function(List<String>) runProcess =
        _fakeProcesses(
      processes: <FakeProcess>[
        (
          exe: 'git',
          command: 'ls-tree',
          rest: <String>['-r', 'HEAD', 'engine', 'DEPS'],
          exitCode: 0,
          stdout: 'one\ntwo\n',
          stderr: null
        ),
      ],
    );

    final Future<String> result =
        engineHash(runProcess, revisionStrategy: GitRevisionStrategy.head);

    expect(result, completion('c708d7ef841f7e1748436b8ef5670d0b2de1a227'));
  });

  test('Returns error in non-monorepo', () async {
    final Future<io.ProcessResult> Function(List<String>) runProcess =
        _fakeProcesses(processes: <FakeProcess>[
      (
        exe: 'git',
        command: 'ls-tree',
        rest: <String>['-r', 'HEAD', 'engine', 'DEPS'],
        exitCode: 0,
        stdout: '',
        stderr: null
      ),
    ]);

    final Future<String> result =
        engineHash(runProcess, revisionStrategy: GitRevisionStrategy.head);

    expect(result, throwsA('Not in a monorepo'));
  });
}

typedef FakeProcess = ({
  String exe,
  String command,
  List<String> rest,
  dynamic stdout,
  dynamic stderr,
  int exitCode
});

Future<io.ProcessResult> Function(List<String>) _fakeProcesses({
  required List<FakeProcess> processes,
}) =>
    (List<String> cmd) async {
      for (final FakeProcess process in processes) {
        if (process.exe.endsWith(cmd[0]) &&
            process.command.endsWith(cmd[1]) &&
            process.rest.equals(cmd.sublist(2))) {
          return io.ProcessResult(
              1, process.exitCode, process.stdout, process.stderr);
        }
      }
      return io.ProcessResult(1, -42, '', '404 command not found: $cmd');
    };