mirror of
https://github.com/flutter/flutter
synced 2024-10-13 19:52:53 +00:00
f5de6aadd4
Make it possible for all FlutterCommands to be global free, by moving instantiation to inside the Zone context. Additionally, provide VerboseLogger and NotifyLogger (daemon) at the top level and remove from command-specific overrides. This allows removing a work around where web devices needed to look up directly from the context in non-test code. Technically the output preferences are still zone injected, but these will be moved soon as they were not being used correctly by the top level command (the injection comes after ArgParser reads the overflow values, causing numerous wrap issues)
77 lines
2.7 KiB
Dart
77 lines
2.7 KiB
Dart
// 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:file/file.dart';
|
|
import 'package:flutter_tools/src/base/file_system.dart';
|
|
import 'package:flutter_tools/src/base/io.dart';
|
|
import 'package:flutter_tools/src/globals.dart' as globals;
|
|
import 'package:process/process.dart';
|
|
|
|
import '../src/common.dart';
|
|
import 'test_data/basic_project.dart';
|
|
import 'test_driver.dart';
|
|
import 'test_utils.dart';
|
|
|
|
void main() {
|
|
test('device.getDevices', () async {
|
|
final Directory tempDir = createResolvedTempDirectorySync('daemon_mode_test.');
|
|
|
|
final BasicProject _project = BasicProject();
|
|
await _project.setUpIn(tempDir);
|
|
|
|
final String flutterBin = globals.fs.path.join(getFlutterRoot(), 'bin', 'flutter');
|
|
|
|
const ProcessManager processManager = LocalProcessManager();
|
|
final Process process = await processManager.start(
|
|
<String>[flutterBin, '--show-test-device', 'daemon'],
|
|
workingDirectory: tempDir.path,
|
|
);
|
|
|
|
final StreamController<String> stdout = StreamController<String>.broadcast();
|
|
transformToLines(process.stdout).listen((String line) => stdout.add(line));
|
|
final Stream<Map<String, dynamic>> stream = stdout
|
|
.stream
|
|
.map<Map<String, dynamic>>(parseFlutterResponse)
|
|
.where((Map<String, dynamic> value) => value != null);
|
|
|
|
Map<String, dynamic> response = await stream.first;
|
|
expect(response['event'], 'daemon.connected');
|
|
|
|
// start listening for devices
|
|
process.stdin.writeln('[${jsonEncode(<String, dynamic>{
|
|
'id': 1,
|
|
'method': 'device.enable',
|
|
})}]');
|
|
response = await stream.firstWhere((Map<String, Object> json) => json['id'] == 1);
|
|
expect(response['id'], 1);
|
|
expect(response['error'], isNull);
|
|
|
|
// [{"event":"device.added","params":{"id":"flutter-tester","name":
|
|
// "Flutter test device","platform":"flutter-tester","emulator":false}}]
|
|
response = await stream.first;
|
|
expect(response['event'], 'device.added');
|
|
|
|
// get the list of all devices
|
|
process.stdin.writeln('[${jsonEncode(<String, dynamic>{
|
|
'id': 2,
|
|
'method': 'device.getDevices',
|
|
})}]');
|
|
// Skip other device.added events that may fire (desktop/web devices).
|
|
response = await stream.firstWhere((Map<String, dynamic> response) => response['event'] != 'device.added');
|
|
expect(response['id'], 2);
|
|
expect(response['error'], isNull);
|
|
|
|
final dynamic result = response['result'];
|
|
expect(result, isList);
|
|
expect(result, isNotEmpty);
|
|
|
|
tryToDelete(tempDir);
|
|
process.kill();
|
|
});
|
|
}
|