blob: 8e31d7f155263b85465e07f33137e80c6b8c70b0 [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:convert';
import 'dart:io';
import 'package:flutter_tools/src/base/common.dart';
late Process daemon;
// To use, start from the console and enter:
// version: print version
// shutdown: terminate the server
// start: start an app
// stop: stop a running app
// devices: list devices
// emulators: list emulators
// emulator-launch: launch an emulator, append the word coldBoot to cold boot the emulator.
Future<void> main() async {
daemon = await Process.start('dart', <String>['bin/flutter_tools.dart', 'daemon']);
print('daemon process started, pid: ${daemon.pid}');
daemon.stdout
.transform<String>(utf8.decoder)
.transform<String>(const LineSplitter())
.listen((String line) => print('<== $line'));
daemon.stderr.listen(stderr.add);
stdout.write('> ');
stdin.transform<String>(utf8.decoder).transform<String>(const LineSplitter()).listen((String line) {
final List<String> words = line.split(' ');
if (line == 'version' || line == 'v') {
_send(<String, dynamic>{'method': 'daemon.version'});
} else if (line == 'shutdown' || line == 'q') {
_send(<String, dynamic>{'method': 'daemon.shutdown'});
} else if (words.first == 'start') {
_send(<String, dynamic>{
'method': 'app.start',
'params': <String, dynamic>{
'deviceId': words[1],
'projectDirectory': words[2],
'launchMode': words[3],
},
});
} else if (words.first == 'stop') {
if (words.length > 1) {
_send(<String, dynamic>{
'method': 'app.stop',
'params': <String, dynamic>{'appId': words[1]},
});
} else {
_send(<String, dynamic>{'method': 'app.stop'});
}
} else if (words.first == 'restart') {
if (words.length > 1) {
_send(<String, dynamic>{
'method': 'app.restart',
'params': <String, dynamic>{'appId': words[1]},
});
} else {
_send(<String, dynamic>{'method': 'app.restart'});
}
} else if (line == 'devices') {
_send(<String, dynamic>{'method': 'device.getDevices'});
} else if (line == 'emulators') {
_send(<String, dynamic>{'method': 'emulator.getEmulators'});
} else if (words.first == 'emulator-launch') {
_send(<String, dynamic>{
'method': 'emulator.launch',
'params': <String, dynamic>{
'emulatorId': words[1],
if (words.contains('coldBoot'))
'coldBoot': true
},
});
} else if (line == 'enable') {
_send(<String, dynamic>{'method': 'device.enable'});
} else {
_send(<String, dynamic>{'method': line.trim()});
}
stdout.write('> ');
});
// Print in the callback can't fail.
unawaited(daemon.exitCode.then<int>((int code) {
print('daemon exiting ($code)');
exit(code);
}));
}
int id = 0;
void _send(Map<String, dynamic> map) {
map['id'] = id++;
final String str = '[${json.encode(map)}]';
daemon.stdin.writeln(str);
print('==> $str');
}