// 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:async' show Completer, StreamSubscription;
import 'dart:io' show Directory, Process;

import 'package:flutter_devicelab/framework/devices.dart'
    show Device, DeviceOperatingSystem, deviceOperatingSystem, devices;
import 'package:flutter_devicelab/framework/framework.dart' show task;
import 'package:flutter_devicelab/framework/task_result.dart' show TaskResult;
import 'package:flutter_devicelab/framework/utils.dart'
    show dir, flutter, flutterDirectory, inDirectory, startFlutter;
import 'package:path/path.dart' as path;

Future<TaskResult> run() async {
  deviceOperatingSystem = DeviceOperatingSystem.android;
  final Device device = await devices.workingDevice;
  await device.unlock();
  final Directory appDir = dir(path.join(flutterDirectory.path, 'examples/hello_world'));

  bool isUsingValidationLayers = false;
  bool hasValidationErrors = false;
  int invalidBackendCount = 0;
  final Completer<void> didReceiveBackendMessage = Completer<void>();

  await inDirectory(appDir, () async {
    await flutter('packages', options: <String>['get']);
    const String validationLayersMessage =
        'Using the Impeller rendering backend (Vulkan with Validation Layers)';
    final StreamSubscription<String> adb = device.logcat.listen((String data) {
      if (data.contains('Using the Impeller rendering backend')) {
        // Sometimes more than one of these will be printed out if there is a
        // fallback.
        if (!data.contains(validationLayersMessage)) {
          invalidBackendCount += 1;
        }
        if (!didReceiveBackendMessage.isCompleted) {
          didReceiveBackendMessage.complete();
        }
      }
      if (data.contains(validationLayersMessage)) {
        isUsingValidationLayers = true;
      }
      // "ImpellerValidationBreak" comes from the engine:
      // https://github.com/flutter/engine/blob/4160ebacdae2081d6f3160432f5f0dd87dbebec1/impeller/base/validation.cc#L40
      if (data.contains('ImpellerValidationBreak')) {
        hasValidationErrors = true;
      }
    });

    final Process process = await startFlutter(
      'run',
      options: <String>['--enable-impeller', '--enable-vulkan-validation', '-d', device.deviceId],
    );

    await didReceiveBackendMessage.future;
    // Since we are waiting for the lack of errors, there is no determinate
    // amount of time we can wait.
    await Future<void>.delayed(const Duration(seconds: 30));
    process.stdin.write('q');
    await adb.cancel();
  });

  if (!isUsingValidationLayers || invalidBackendCount != 0) {
    return TaskResult.failure('Not using Vulkan validation layers.');
  }
  if (hasValidationErrors) {
    return TaskResult.failure('Impeller validation errors detected.');
  }
  return TaskResult.success(null);
}

Future<void> main() async {
  await task(run);
}