daemon_client.dart 2.48 KB
Newer Older
Devon Carew's avatar
Devon Carew committed
1 2 3 4
// Copyright 2015 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

5
import 'dart:async';
Devon Carew's avatar
Devon Carew committed
6 7 8 9 10
import 'dart:convert';
import 'dart:io';

Process daemon;

11 12 13 14
// To use, start from the console and enter:
//   version: print version
//   shutdown: terminate the server
//   start: start an app
15
//   stop: stop a running app
16 17
//   devices: list devices

18
Future<Null> main() async {
19
  daemon = await Process.start('dart', <String>['bin/flutter_tools.dart', 'daemon']);
Devon Carew's avatar
Devon Carew committed
20 21 22 23 24
  print('daemon process started, pid: ${daemon.pid}');

  daemon.stdout
    .transform(UTF8.decoder)
    .transform(const LineSplitter())
25
    .listen((String line) => print('<== $line'));
26
  daemon.stderr.listen((dynamic data) => stderr.add(data));
Devon Carew's avatar
Devon Carew committed
27 28 29

  stdout.write('> ');
  stdin.transform(UTF8.decoder).transform(const LineSplitter()).listen((String line) {
30 31
    List<String> words = line.split(' ');

Devon Carew's avatar
Devon Carew committed
32
    if (line == 'version' || line == 'v') {
33
      _send(<String, dynamic>{'method': 'daemon.version'});
Devon Carew's avatar
Devon Carew committed
34
    } else if (line == 'shutdown' || line == 'q') {
35
      _send(<String, dynamic>{'method': 'daemon.shutdown'});
36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61
    } else if (words.first == 'start') {
      _send(<String, dynamic>{
        'method': 'app.start',
        'params': <String, dynamic> {
          'deviceId': words[1],
          'projectDirectory': words[2]
        }
      });
    } 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'});
      }
62
    } else if (line == 'devices') {
63
      _send(<String, dynamic>{'method': 'device.getDevices'});
64 65
    } else if (line == 'enable') {
      _send(<String, dynamic>{'method': 'device.enable'});
Devon Carew's avatar
Devon Carew committed
66
    } else {
67
      _send(<String, dynamic>{'method': line.trim()});
Devon Carew's avatar
Devon Carew committed
68 69 70 71 72
    }
    stdout.write('> ');
  });

  daemon.exitCode.then((int code) {
73
    print('daemon exiting ($code)');
Devon Carew's avatar
Devon Carew committed
74 75 76 77 78 79
    exit(code);
  });
}

int id = 0;

80
void _send(Map<String, dynamic> map) {
Devon Carew's avatar
Devon Carew committed
81 82 83
  map['id'] = id++;
  String str = '[${JSON.encode(map)}]';
  daemon.stdin.writeln(str);
84
  print('==> $str');
Devon Carew's avatar
Devon Carew committed
85
}