packages/flutter_tools/test/daemon_test.dart

// 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.

import 'dart:async';

import 'package:mockito/mockito.dart';
import 'package:sky_tools/src/commands/daemon.dart';
import 'package:test/test.dart';

import 'src/mocks.dart';

main() => defineTests();

defineTests() {
  group('daemon', () {
    Daemon daemon;

    tearDown(() {
      if (daemon != null)
        return daemon.shutdown();
    });

    test('daemon.version', () async {
      StreamController<Map> commands = new StreamController();
      StreamController<Map> responses = new StreamController();
      daemon = new Daemon(
        commands.stream,
        (Map result) => responses.add(result)
      );
      commands.add({'id': 0, 'event': 'daemon.version'});
      Map response = await responses.stream.first;
      expect(response['id'], 0);
      expect(response['result'], isNotEmpty);
      expect(response['result'] is String, true);
    });

    test('daemon.shutdown', () async {
      StreamController<Map> commands = new StreamController();
      StreamController<Map> responses = new StreamController();
      daemon = new Daemon(
        commands.stream,
        (Map result) => responses.add(result)
      );
      commands.add({'id': 0, 'event': 'daemon.shutdown'});
      return daemon.onExit.then((int code) {
        expect(code, 0);
      });
    });

    test('daemon.stopAll', () async {
      DaemonCommand command = new DaemonCommand();
      applyMocksToCommand(command);

      StreamController<Map> commands = new StreamController();
      StreamController<Map> responses = new StreamController();
      daemon = new Daemon(
        commands.stream,
        (Map result) => responses.add(result),
        daemonCommand: command
      );

      MockDeviceStore mockDevices = command.devices;

      when(mockDevices.android.isConnected()).thenReturn(true);
      when(mockDevices.android.stopApp(any)).thenReturn(true);

      when(mockDevices.iOS.isConnected()).thenReturn(false);
      when(mockDevices.iOS.stopApp(any)).thenReturn(false);

      when(mockDevices.iOSSimulator.isConnected()).thenReturn(false);
      when(mockDevices.iOSSimulator.stopApp(any)).thenReturn(false);

      commands.add({'id': 0, 'event': 'app.stopAll'});
      Map response = await responses.stream.first;
      expect(response['id'], 0);
      expect(response['result'], true);
    });
  });
}