version 0.1.1

android/app/build.gradle

@@ -39,8 +39,8 @@ android {
         applicationId "com.keyboardcrumbs.haclient"
         minSdkVersion 21
         targetSdkVersion 27
-        versionCode 17
-        versionName "0.0.12-alpha"
+        versionCode 19
+        versionName "0.1.1-alpha"
         testInstrumentationRunner "android.support.test.runner.AndroidJUnitRunner"
     }
 

lib/data_model.dart

@@ -17,7 +17,7 @@ class HassioDataModel {
   String _hassioPassword;
   String _hassioAuthType;
   IOWebSocketChannel _hassioChannel;
-  int _currentMssageId = 0;
+  int _currentMessageId = 0;
   int _statesMessageId = 0;
   int _servicesMessageId = 0;
   int _subscriptionMessageId = 0;
@@ -46,10 +46,10 @@ class HassioDataModel {
 
   Future fetch() {
     if ((_fetchCompleter != null) && (!_fetchCompleter.isCompleted)) {
-      debugPrint("Previous fetch is not complited");
+      TheLogger.log("Warning","Previous fetch is not complited");
     } else {
       //TODO: Fetch timeout timer. Should be removed after #21 fix
-      _fetchingTimer = Timer(Duration(seconds: 10), () {
+      _fetchingTimer = Timer(Duration(seconds: 15), () {
         closeConnection();
         _fetchCompleter.completeError({"errorCode" : 1,"errorMessage": "Connection timeout"});
       });
@@ -73,10 +73,10 @@ class HassioDataModel {
   Future _reConnectSocket() {
     var _connectionCompleter = new Completer();
     if ((_hassioChannel == null) || (_hassioChannel.closeCode != null)) {
-      debugPrint("Socket connecting...");
+      TheLogger.log("Debug","Socket connecting...");
       _hassioChannel = IOWebSocketChannel.connect(_hassioAPIEndpoint);
       _hassioChannel.stream.handleError((e) {
-        debugPrint("Unhandled socket error: ${e.toString()}");
+        TheLogger.log("Error","Unhandled socket error: ${e.toString()}");
       });
       _hassioChannel.stream.listen((message) =>
           _handleMessage(_connectionCompleter, message));
@@ -113,7 +113,7 @@ class HassioDataModel {
 
   _handleMessage(Completer connectionCompleter, String message) {
     var data = json.decode(message);
-    debugPrint("[Received]Message type: ${data['type']}");
+    TheLogger.log("Debug","[Received] => Message type: ${data['type']}");
     if (data["type"] == "auth_required") {
       _sendMessageRaw('{"type": "auth","$_hassioAuthType": "$_hassioPassword"}');
     } else if (data["type"] == "auth_ok") {
@@ -128,36 +128,32 @@ class HassioDataModel {
         _parseEntities(data);
       } else if (data["id"] == _servicesMessageId) {
         _parseServices(data);
-      } else if (data["id"] == _currentMssageId) {
-        debugPrint("Request id:$_currentMssageId was successful");
-      } else {
-        debugPrint("Skipped message due to messageId:");
-        debugPrint(message);
+      } else if (data["id"] == _currentMessageId) {
+        TheLogger.log("Debug","Request id:$_currentMessageId was successful");
       }
     } else if (data["type"] == "event") {
       if ((data["event"] != null) && (data["event"]["event_type"] == "state_changed")) {
         _handleEntityStateChange(data["event"]["data"]);
       } else if (data["event"] != null) {
-        debugPrint("Unhandled event type: ${data["event"]["event_type"]}");
+        TheLogger.log("Warning","Unhandled event type: ${data["event"]["event_type"]}");
       } else {
-        debugPrint("Event is null");
+        TheLogger.log("Error","Event is null: $message");
       }
     } else {
-      debugPrint("Unknown message type");
-      debugPrint(message);
+      TheLogger.log("Warning","Unknown message type: $message");
     }
   }
 
   void _sendSubscribe() {
     _incrementMessageId();
-    _subscriptionMessageId = _currentMssageId;
+    _subscriptionMessageId = _currentMessageId;
     _sendMessageRaw('{"id": $_subscriptionMessageId, "type": "subscribe_events", "event_type": "state_changed"}');
   }
 
   Future _getConfig() {
     _configCompleter = new Completer();
     _incrementMessageId();
-    _configMessageId = _currentMssageId;
+    _configMessageId = _currentMessageId;
     _sendMessageRaw('{"id": $_configMessageId, "type": "get_config"}');
 
     return _configCompleter.future;
@@ -166,7 +162,7 @@ class HassioDataModel {
   Future _getStates() {
     _statesCompleter = new Completer();
     _incrementMessageId();
-    _statesMessageId = _currentMssageId;
+    _statesMessageId = _currentMessageId;
     _sendMessageRaw('{"id": $_statesMessageId, "type": "get_states"}');
 
     return _statesCompleter.future;
@@ -175,28 +171,38 @@ class HassioDataModel {
   Future _getServices() {
     _servicesCompleter = new Completer();
     _incrementMessageId();
-    _servicesMessageId = _currentMssageId;
+    _servicesMessageId = _currentMessageId;
     _sendMessageRaw('{"id": $_servicesMessageId, "type": "get_services"}');
 
     return _servicesCompleter.future;
   }
 
   _incrementMessageId() {
-    _currentMssageId += 1;
+    _currentMessageId += 1;
   }
 
-  _sendMessageRaw(message) {
-    debugPrint("[Sent]$message");
+  _sendMessageRaw(String message) {
+    if (message.indexOf('"type": "auth"') > 0) {
+      TheLogger.log("Debug", "[Sending] ==> auth request");
+    } else {
+      TheLogger.log("Debug", "[Sending] ==> $message");
+    }
     _hassioChannel.sink.add(message);
   }
 
   void _handleEntityStateChange(Map eventData) {
-    String entityId = eventData["entity_id"];
-    if (_entitiesData[entityId] != null) {
-      _entitiesData[entityId].addAll(eventData["new_state"]);
-      eventBus.fire(new StateChangedEvent(eventData["entity_id"]));
+    TheLogger.log("Debug", "Parsing new state for ${eventData['entity_id']}");
+    if (eventData["new_state"] == null) {
+      TheLogger.log("Error", "No new_state found");
     } else {
-      debugPrint("Unknown enity $entityId");
+      var parsedEntityData = _parseEntity(eventData["new_state"]);
+      String entityId = parsedEntityData["entity_id"];
+      if (_entitiesData[entityId] == null) {
+        _entitiesData[entityId] = parsedEntityData;
+      } else {
+        _entitiesData[entityId].addAll(parsedEntityData);
+      }
+      eventBus.fire(new StateChangedEvent(eventData["entity_id"]));
     }
   }
 
@@ -214,12 +220,13 @@ class HassioDataModel {
       _servicesCompleter.completeError({"errorCode": 4, "errorMessage": response["error"]["message"]});
       return;
     }
+    try {
       Map data = response["result"];
       Map result = {};
-    debugPrint("Parsing ${data.length} Home Assistant service domains");
-    data.forEach((domain, services){
+      TheLogger.log("Debug","Parsing ${data.length} Home Assistant service domains");
+      data.forEach((domain, services) {
         result[domain] = Map.from(services);
-      services.forEach((serviceName, serviceData){
+        services.forEach((serviceName, serviceData) {
           if (_entitiesData["$domain.$serviceName"] != null) {
             result[domain].remove(serviceName);
           }
@@ -227,66 +234,59 @@ class HassioDataModel {
       });
       _servicesData = result;
       _servicesCompleter.complete();
+    } catch (e) {
+      //TODO hadle it properly
+      TheLogger.log("Error","Error parsing services. But they are not used :-)");
+      _servicesCompleter.complete();
+    }
   }
 
   void _parseEntities(response) async {
+    _entitiesData.clear();
+    _uiStructure.clear();
     if (response["success"] == false) {
       _statesCompleter.completeError({"errorCode": 3, "errorMessage": response["error"]["message"]});
       return;
     }
     List data = response["result"];
-    debugPrint("Parsing ${data.length} Home Assistant entities");
+    TheLogger.log("Debug","Parsing ${data.length} Home Assistant entities");
     List<String> uiGroups = [];
     data.forEach((entity) {
-      var composedEntity = Map.from(entity);
-      String entityDomain = entity["entity_id"].split(".")[0];
-      String entityId = entity["entity_id"];
-
-      composedEntity["display_name"] = "${entity["attributes"]!=null ? entity["attributes"]["friendly_name"] ?? entity["attributes"]["name"] : "_"}";
-      composedEntity["domain"] = entityDomain;
-
-      if ((entityDomain == "automation") || (entityDomain == "switch") || (entityDomain == "light")) {
-        composedEntity["actionType"] = "switch";
-      } else if ((entityDomain == "script") || (entityDomain == "scene")) {
-        composedEntity["actionType"] = "statelessIcon";
-      } else {
-        composedEntity["actionType"] = "stateText";
-      }
+      try {
+        var composedEntity = _parseEntity(entity);
 
         if (composedEntity["attributes"] != null) {
-        if ((entityDomain == "group")&&(composedEntity["attributes"]["view"] == true)) {
-          uiGroups.add(entityId);
-        }
-      }
-
-
-      if (entityDomain == "group") {
-        if ((composedEntity["attributes"] != null) &&
+          if ((composedEntity["domain"] == "group") &&
               (composedEntity["attributes"]["view"] == true)) {
-
+            uiGroups.add(composedEntity["entity_id"]);
           }
         }
-
-      _entitiesData[entityId] = Map.from(composedEntity);
+        _entitiesData[entity["entity_id"]] = composedEntity;
+      } catch (error) {
+        TheLogger.log("Error","Error parsing entity: ${entity['entity_id']}");
+      }
     });
 
     //Gethering information for UI
-    debugPrint("Gethering views");
+    TheLogger.log("Debug","Gethering views");
     int viewCounter = 0;
     uiGroups.forEach((viewId) { //Each view
-      viewCounter +=1;
-      var viewGroup = _entitiesData[viewId];
+      try {
         Map viewGroupStructure = {};
+        viewCounter += 1;
+        var viewGroup = _entitiesData[viewId];
         if (viewGroup != null) {
-        viewGroupStructure["standalone"] = {};
           viewGroupStructure["groups"] = {};
           viewGroupStructure["state"] = "on";
           viewGroupStructure["entity_id"] = viewGroup["entity_id"];
           viewGroupStructure["badges"] = {"children": []};
-        viewGroupStructure["attributes"] = viewGroup["attributes"] != null ? {"icon": viewGroup["attributes"]["icon"]} : {"icon": "none"};
+          viewGroupStructure["attributes"] = viewGroup["attributes"] != null ? {
+            "icon": viewGroup["attributes"]["icon"]
+          } : {"icon": "none"};
 
 
-        viewGroup["attributes"]["entity_id"].forEach((entityId) { //Each entity or group in view
+          viewGroup["attributes"]["entity_id"].forEach((
+              entityId) { //Each entity or group in view
             Map newGroup = {};
             String domain = _entitiesData[entityId]["domain"];
             if (domain != "group") {
@@ -310,7 +310,8 @@ class HassioDataModel {
               newGroup["entity_id"] = entityId;
               newGroup["friendly_name"] =
               (_entitiesData[entityId]['attributes'] != null)
-                ? (_entitiesData[entityId]['attributes']['friendly_name'] ?? "")
+                  ? (_entitiesData[entityId]['attributes']['friendly_name'] ??
+                  "")
                   : "";
               newGroup["children"] = List<String>();
               _entitiesData[entityId]["attributes"]["entity_id"].forEach((
@@ -320,12 +321,23 @@ class HassioDataModel {
               viewGroupStructure["groups"]["$entityId"] = Map.from(newGroup);
             }
           });
+        }
         _uiStructure[viewId.split(".")[1]] = viewGroupStructure;
+      } catch (error) {
+        TheLogger.log("Error","Error parsing view: $viewId");
       }
     });
     _statesCompleter.complete();
   }
 
+  Map _parseEntity(rawData) {
+    var composedEntity = Map.from(rawData);
+    String entityDomain = rawData["entity_id"].split(".")[0];
+    composedEntity["display_name"] = "${rawData["attributes"]!=null ? rawData["attributes"]["friendly_name"] ?? rawData["attributes"]["name"] : "_"}";
+    composedEntity["domain"] = entityDomain;
+    return composedEntity;
+  }
+
   Future callService(String domain, String service, String entity_id) {
     var sendCompleter = Completer();
     //TODO: Send service call timeout timer. Should be removed after #21 fix
@@ -334,7 +346,7 @@ class HassioDataModel {
     });
     _reConnectSocket().then((r) {
       _incrementMessageId();
-      _sendMessageRaw('{"id": $_currentMssageId, "type": "call_service", "domain": "$domain", "service": "$service", "service_data": {"entity_id": "$entity_id"}}');
+      _sendMessageRaw('{"id": $_currentMessageId, "type": "call_service", "domain": "$domain", "service": "$service", "service_data": {"entity_id": "$entity_id"}}');
       _sendTimer.cancel();
       sendCompleter.complete();
     }).catchError((e){

lib/logPage.dart

@@ -0,0 +1,49 @@
+part of 'main.dart';
+
+class LogViewPage extends StatefulWidget {
+  LogViewPage({Key key, this.title}) : super(key: key);
+
+  final String title;
+
+  @override
+  _LogViewPageState createState() => new _LogViewPageState();
+}
+
+class _LogViewPageState extends State<LogViewPage> {
+  String _hassioDomain = "";
+  String _hassioPort = "8123";
+  String _hassioPassword = "";
+  String _socketProtocol = "wss";
+  String _authType = "access_token";
+
+  @override
+  void initState() {
+    super.initState();
+    _loadLog();
+  }
+
+  _loadLog() async {
+    //
+  }
+
+  @override
+  Widget build(BuildContext context) {
+    return new Scaffold(
+      appBar: new AppBar(
+        leading: IconButton(icon: Icon(Icons.arrow_back), onPressed: (){
+          Navigator.pop(context);
+        }),
+        // Here we take the value from the MyHomePage object that was created by
+        // the App.build method, and use it to set our appbar title.
+        title: new Text(widget.title),
+      ),
+      body: TextField(
+        maxLines: null,
+
+        controller: TextEditingController(
+            text: TheLogger.getLog()
+        ),
+      )
+    );
+  }
+}

lib/main.dart

@@ -9,15 +9,46 @@ import 'package:event_bus/event_bus.dart';
 import 'package:flutter/widgets.dart';
 import 'package:cached_network_image/cached_network_image.dart';
 
-part 'settings.dart';
+part 'settingsPage.dart';
 part 'data_model.dart';
+part 'logPage.dart';
 
 EventBus eventBus = new EventBus();
 const String appName = "HA Client";
-const appVersion = "0.0.12-alpha";
+const appVersion = "0.1.1-alpha";
 
 String homeAssistantWebHost;
 
+class TheLogger {
+
+  static List<String> _log = [];
+
+  static String getLog() {
+    String res = '';
+    _log.forEach((line) {
+      res += "$line\n\n";
+    });
+    return res;
+  }
+
+  static bool get isInDebugMode {
+    bool inDebugMode = false;
+
+    assert(inDebugMode = true);
+
+    return inDebugMode;
+  }
+
+  static void log(String level, String message) {
+    debugPrint('$message');
+    _log.add("[$level] :  $message");
+    if (_log.length > 50) {
+      _log.removeAt(0);
+    }
+  }
+
+}
+
 void main() => runApp(new HassClientApp());
 
 class HassClientApp extends StatelessWidget {
@@ -32,7 +63,8 @@ class HassClientApp extends StatelessWidget {
       initialRoute: "/",
       routes: {
         "/": (context) => MainPage(title: 'Hass Client'),
-        "/connection-settings": (context) => ConnectionSettingsPage(title: "Connection Settings")
+        "/connection-settings": (context) => ConnectionSettingsPage(title: "Connection Settings"),
+        "/log-view": (context) => LogViewPage(title: "Log")
       },
     );
   }
@@ -59,20 +91,24 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
   StreamSubscription _stateSubscription;
   StreamSubscription _settingsSubscription;
   bool _isLoading = true;
-  Map _stateIconColors = {
+  Map<String, Color> _stateIconColors = {
     "on": Colors.amber,
-    "off": Colors.blueGrey,
+    "off": Color.fromRGBO(68, 115, 158, 1.0),
     "unavailable": Colors.black12,
     "unknown": Colors.black12,
     "playing": Colors.amber
   };
+  Map<String, Color> _badgeColors = {
+    "default": Color.fromRGBO(223, 76, 30, 1.0),
+    "binary_sensor": Color.fromRGBO(3, 155, 229, 1.0)
+  };
 
   @override
   void initState() {
     super.initState();
     WidgetsBinding.instance.addObserver(this);
     _settingsSubscription = eventBus.on<SettingsChangedEvent>().listen((event) {
-      debugPrint("Settings change event: reconnect=${event.reconnect}");
+      TheLogger.log("Debug","Settings change event: reconnect=${event.reconnect}");
       setState(() {
         _errorCodeToBeShown = 0;
       });
@@ -83,7 +119,7 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
 
   @override
   void didChangeAppLifecycleState(AppLifecycleState state) {
-    debugPrint("$state");
+    TheLogger.log("Debug","$state");
     if (state == AppLifecycleState.resumed) {
       _refreshData();
     }
@@ -114,7 +150,6 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
     _refreshData();
     if (_stateSubscription != null) _stateSubscription.cancel();
     _stateSubscription = eventBus.on<StateChangedEvent>().listen((event) {
-      debugPrint("State change event for ${event.entityId}");
       setState(() {
         _entitiesData = _dataModel.entities;
       });
@@ -208,9 +243,7 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
     List<Widget> result = [];
     ids.forEach((entityId) {
       var data = _entitiesData[entityId];
-      if (data == null) {
-        debugPrint("Hiding unknown entity from badges: $entityId");
-      } else {
+      if (data != null) {
         result.add(
           _buildSingleBadge(data)
         );
@@ -220,11 +253,21 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
   }
 
   Widget _buildSingleBadge(data) {
+    double iconSize = 26.0;
     Widget badgeIcon;
     String badgeTextValue;
+    Color iconColor = _badgeColors[data["domain"]] ?? _badgeColors["default"];
     switch (data["domain"]) {
       case "sun": {
-        badgeIcon = data["state"] == "below_horizon" ? Icon(MaterialDesignIcons.createIconDataFromIconCode(0xf0dc)) : Icon(MaterialDesignIcons.createIconDataFromIconCode(0xf5a8));
+        badgeIcon = data["state"] == "below_horizon" ?
+          Icon(
+            MaterialDesignIcons.createIconDataFromIconCode(0xf0dc),
+            size: iconSize,
+          ) :
+          Icon(
+            MaterialDesignIcons.createIconDataFromIconCode(0xf5a8),
+            size: iconSize,
+          );
         break;
       }
       case "sensor": {
@@ -241,12 +284,12 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
         break;
       }
       case "device_tracker": {
-        badgeIcon = MaterialDesignIcons.createIconFromEntityData(data, 50.0,Colors.black);
+        badgeIcon = MaterialDesignIcons.createIconFromEntityData(data, iconSize,Colors.black);
         badgeTextValue = data["state"];
         break;
       }
       default: {
-       badgeIcon = MaterialDesignIcons.createIconFromEntityData(data, 50.0,Colors.black);
+       badgeIcon = MaterialDesignIcons.createIconFromEntityData(data, iconSize,Colors.black);
       }
     }
     Widget badgeText;
@@ -261,7 +304,7 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
           decoration: new BoxDecoration(
             // Circle shape
             //shape: BoxShape.circle,
-            color: Colors.redAccent,
+            color: iconColor,
             borderRadius: BorderRadius.circular(9.0),
           )
       );
@@ -279,7 +322,7 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
             // The border you want
             border: new Border.all(
               width: 2.0,
-              color: Colors.redAccent,
+              color: iconColor,
             ),
           ),
           child: Stack(
@@ -349,13 +392,11 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
     List<Widget> entities = [];
     ids.forEach((id) {
       var data = _entitiesData[id];
-      if (data == null) {
-        debugPrint("Hiding unknown entity from card: $id");
-      } else {
+      if (data != null) {
         entities.add(new ListTile(
           leading: MaterialDesignIcons.createIconFromEntityData(data, 28.0, _stateIconColors[data["state"]] ?? Colors.blueGrey),
           //subtitle: Text("${data['entity_id']}"),
-          trailing: _buildEntityStateWidget(data),
+          trailing: _buildEntityActionWidget(data),
           title: Text(
             "${data["display_name"]}",
             overflow: TextOverflow.fade,
@@ -367,10 +408,13 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
     return entities;
   }
 
-  Widget _buildEntityStateWidget(data) {
+  Widget _buildEntityActionWidget(data) {
     String entityId = data["entity_id"];
     Widget result;
-    if (data["actionType"] == "switch") {
+    switch (data["domain"]) {
+      case "automation":
+      case "switch":
+      case "light": {
         result = Switch(
           value: (data["state"] == "on"),
           onChanged: ((state) {
@@ -381,7 +425,11 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
             });
           }),
         );
-    } else if (data["actionType"] == "statelessIcon") {
+        break;
+      }
+
+      case "script":
+      case "scene": {
         result = SizedBox(
           width: 60.0,
           child: FlatButton(
@@ -393,8 +441,12 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
               textAlign: TextAlign.right,
               style: new TextStyle(fontSize: 16.0, color: Colors.blue),
             ),
-          ));
-    } else {
+          )
+        );
+        break;
+      }
+
+      default: {
         result = Padding(
           padding: EdgeInsets.fromLTRB(0.0, 0.0, 16.0, 0.0),
           child: Text(
@@ -402,8 +454,12 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
             textAlign: TextAlign.right,
             style: new TextStyle(
               fontSize: 16.0,
-              )));
+            )
+          )
+        );
       }
+    }
+
     /*return SizedBox(
       width: 60.0,
       // height: double.infinity,
@@ -458,6 +514,13 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
               Navigator.pushNamed(context, '/connection-settings');
             },
           ),
+          new ListTile(
+            leading: Icon(Icons.insert_drive_file),
+            title: Text("Log"),
+            onTap: () {
+              Navigator.pushNamed(context, '/log-view');
+            },
+          ),
           new AboutListTile(
             applicationName: appName,
             applicationVersion: appVersion,

lib/settingsPage.dart

@@ -35,6 +35,9 @@ class _ConnectionSettingsPageState extends State<ConnectionSettingsPage> {
   }
 
   _saveSettings() async {
+    if (_hassioDomain.indexOf("http") == 0 && _hassioDomain.indexOf("//") > 0) {
+      _hassioDomain = _hassioDomain.split("//")[1];
+    }
     SharedPreferences prefs = await SharedPreferences.getInstance();
     prefs.setString("hassio-domain", _hassioDomain);
     prefs.setString("hassio-port", _hassioPort);

pubspec.yaml

@@ -1,7 +1,7 @@
 name: hass_client
 description: Home Assistant Android Client
 
-version: 0.0.12-alpha
+version: 0.1.1-alpha
 
 environment:
   sdk: ">=2.0.0-dev.68.0 <3.0.0"