mdtest/lib/src/mobile/device.dart

// Copyright 2016 The Vanadium 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 'key_provider.dart';
import 'android.dart';

class Device implements ClusterKeyProvider {
  Device({
    this.properties
  });

  Map<String, String> properties;

  String get id => properties['device-id'];
  String get modelName => properties['model-name'];
  String get screenSize => properties['screen-size'];

  @override
  String clusterKey() {
    return id;
  }

  @override
  String toString()
    => '<id: $id, model-name: $modelName, screen-size: $screenSize>';
}

Future<List<Device>> getDevices() async {
  List<Device> devices = <Device>[];
  await _getDeviceIDs().then((List<String> ids) async {
    for(String id in ids) {
      devices.add(await _collectDeviceProps(id));
    }
  });
  return devices;
}

/// Run "flutter devices -v" to collect device ids from the output
Future<List<String>> _getDeviceIDs() async {
  List<String> deviceIDs = <String>[];
  Process process = await Process.start('flutter', ['devices', '-v']);
  Stream lineStream = process.stdout
                             .transform(new Utf8Decoder())
                             .transform(new LineSplitter());
  bool startReading = false;
  RegExp startPattern = new RegExp(r'List of devices attached');
  RegExp deviceIDPattern = new RegExp(r'\s+(\w+)\s+.*');
  RegExp stopPattern = new RegExp(r'\d+ connected devices?|No devices detected');
  await for (var line in lineStream) {
    if (!startReading && startPattern.hasMatch(line.toString())) {
      startReading = true;
      continue;
    }

    if (stopPattern.hasMatch(line.toString()))
      break;

    if (startReading) {
      Match idMatch = deviceIDPattern.firstMatch(line.toString());
      if (idMatch != null) {
        String deviceID = idMatch.group(1);
        deviceIDs.add(deviceID);
      }
    }
  }

  process.stderr.drain();

  return deviceIDs;
}

Future<Device> _collectDeviceProps(String deviceID) async {
  return new Device(
    properties: <String, String> {
      'device-id': deviceID,
      'model-name': await getProperty(deviceID, 'ro.product.model'),
      'screen-size': await getScreenSize(deviceID)
    }
  );
}