blob: d159eb2228a92dc68ebeb2688c50fe9866b20761 [file] [log] [blame]
// 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';
import 'dart:convert';
import 'dart:io';
import 'package:flutter_devicelab/framework/framework.dart';
import 'package:flutter_devicelab/framework/task_result.dart';
import 'package:flutter_devicelab/framework/utils.dart';
import 'package:flutter_devicelab/versions/gallery.dart' show galleryVersion;
import 'package:path/path.dart' as path;
Future<void> main() async {
await task(const NewGalleryChromeRunTest().run);
/// After the gallery loads, a duration of [durationToWaitForError]
/// is waited, allowing any possible exceptions to be thrown.
const Duration durationToWaitForError = Duration(seconds: 5);
/// Flutter prints this string when an app is successfully loaded.
/// Used to check when the app is successfully loaded.
const String successfullyLoadedString = 'To hot restart';
/// Flutter prints this string when an exception is caught.
/// Used to check if there are any exceptions.
const String exceptionString = 'EXCEPTION CAUGHT';
/// Checks that the New Flutter Gallery runs successfully on Chrome.
class NewGalleryChromeRunTest {
const NewGalleryChromeRunTest();
/// Runs the test.
Future<TaskResult> run() async {
final Directory galleryParentDir =
final Directory galleryDir =
Directory(path.join(galleryParentDir.path, 'gallery'));
await getNewGallery(galleryVersion, galleryDir);
final TaskResult result = await inDirectory<TaskResult>(galleryDir, () async {
await flutter('doctor');
await flutter('packages', options: <String>['get']);
await flutter('build', options: <String>[
final List<String> options = <String>['-d', 'chrome', '--verbose', '--resident'];
final Process process = await startProcess(
path.join(flutterDirectory.path, 'bin', 'flutter'),
flutterCommandArgs('run', options),
final Completer<void> stdoutDone = Completer<void>();
final Completer<void> stderrDone = Completer<void>();
bool success = true;
.transform<String>(const LineSplitter())
.listen((String line) {
if (line.contains(successfullyLoadedString)) {
// Successfully started.
() {process.stdin.write('q');}
if (line.contains(exceptionString)) {
success = false;
print('stdout: $line');
}, onDone: () {
.transform<String>(const LineSplitter())
.listen((String line) {
print('stderr: $line');
}, onDone: () {
await Future.wait<void>(<Future<void>>[
await process.exitCode;
if (success) {
return TaskResult.success(<String, dynamic>{});
} else {
return TaskResult.failure('An exception was thrown.');
return result;