Version 0.2.4

lib/entity_class/button_entity.class.dart

@@ -3,7 +3,7 @@ part of '../main.dart';
 class _ButtonEntityWidgetState extends _EntityWidgetState {
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
     eventBus.fire(new ServiceCallEvent(widget.entity.domain, "turn_on", widget.entity.entityId, null));
   }
 
@@ -11,7 +11,7 @@ class _ButtonEntityWidgetState extends _EntityWidgetState {
   Widget _buildActionWidget(bool inCard, BuildContext context) {
     return FlatButton(
       onPressed: (() {
-        sendNewState(null);
+        setNewState(null);
       }),
       child: Text(
         "EXECUTE",

lib/entity_class/datetime_entity.class.dart

@@ -28,7 +28,7 @@ class _DateTimeEntityWidgetState extends _EntityWidgetState {
   }
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
     eventBus.fire(new ServiceCallEvent(widget.entity.domain, "set_datetime", widget.entity.entityId,
         newValue));
   }
@@ -56,17 +56,17 @@ class _DateTimeEntityWidgetState extends _EntityWidgetState {
         if (date != null) {
           if (hasTime) {
             _showTimePicker(context).then((time){
-              sendNewState({"date": "${formatDate(date, [yyyy, '-', mm, '-', dd])}", "time": "${formatDate(DateTime(1970, 1, 1, time.hour, time.minute), [HH, ':', nn])}"});
+              setNewState({"date": "${formatDate(date, [yyyy, '-', mm, '-', dd])}", "time": "${formatDate(DateTime(1970, 1, 1, time.hour, time.minute), [HH, ':', nn])}"});
             });
           } else {
-            sendNewState({"date": "${formatDate(date, [yyyy, '-', mm, '-', dd])}"});
+            setNewState({"date": "${formatDate(date, [yyyy, '-', mm, '-', dd])}"});
           }
         }
       });
     } else if (hasTime) {
       _showTimePicker(context).then((time){
         if (time != null) {
-          sendNewState({"time": "${formatDate(DateTime(1970, 1, 1, time.hour, time.minute), [HH, ':', nn])}"});
+          setNewState({"time": "${formatDate(DateTime(1970, 1, 1, time.hour, time.minute), [HH, ':', nn])}"});
         }
       });
     } else {

lib/entity_class/entity.class.dart

@@ -22,6 +22,7 @@ class Entity {
   String _domain;
   String _entityId;
   String _state;
+  String assumedState;
   DateTime _lastUpdated;
 
   String get displayName =>
@@ -52,6 +53,7 @@ class Entity {
     _domain = rawData["entity_id"].split(".")[0];
     _entityId = rawData["entity_id"];
     _state = rawData["state"];
+    assumedState = _state;
     _lastUpdated = DateTime.tryParse(rawData["last_updated"]);
   }
 
@@ -104,7 +106,7 @@ class EntityWidget extends StatefulWidget {
   _EntityWidgetState createState() {
     switch (entity.domain) {
       case "automation":
-      case "input_boolean ":
+      case "input_boolean":
       case "switch":
       case "light": {
         return _SwitchEntityWidgetState();
@@ -179,7 +181,7 @@ class _EntityWidgetState extends State<EntityWidget> {
     eventBus.fire(new ShowEntityPageEvent(widget.entity));
   }
 
-  void sendNewState(newState) {
+  void setNewState(newState) {
     return;
   }
 

lib/entity_class/select_entity.class.dart

@@ -4,7 +4,7 @@ class _SelectEntityWidgetState extends _EntityWidgetState {
   List<String> _listOptions = [];
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
     eventBus.fire(new ServiceCallEvent(widget.entity.domain, "select_option", widget.entity.entityId,
         {"option": "$newValue"}));
   }
@@ -17,8 +17,8 @@ class _SelectEntityWidgetState extends _EntityWidgetState {
         _listOptions.add(value.toString());
       });
     }
-    return Container(
+    return Expanded(
-      width: Entity.INPUT_WIDTH,
+      //width: Entity.INPUT_WIDTH,
       child: DropdownButton<String>(
         value: widget.entity.state,
         items: this._listOptions.map((String value) {
@@ -28,7 +28,7 @@ class _SelectEntityWidgetState extends _EntityWidgetState {
           );
         }).toList(),
         onChanged: (_) {
-          sendNewState(_);
+          setNewState(_);
         },
       ),
     );

lib/entity_class/slider_entity.class.dart

@@ -14,7 +14,7 @@ class _SliderEntityWidgetState extends _EntityWidgetState {
   }
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
     eventBus.fire(new ServiceCallEvent(widget.entity.domain, "set_value", widget.entity.entityId,
         {"value": "${newValue.toString()}"}));
   }
@@ -26,8 +26,8 @@ class _SliderEntityWidgetState extends _EntityWidgetState {
     } else if (valueStep < 0.1) {
       _multiplier = 100;
     }
-    return Container(
+    return Expanded(
-      width: 200.0,
+      //width: 200.0,
       child: Row(
         children: <Widget>[
           Expanded(
@@ -46,7 +46,7 @@ class _SliderEntityWidgetState extends _EntityWidgetState {
                     (value.roundToDouble() / _multiplier).toString(), true));*/
               },
               onChangeEnd: (value) {
-                sendNewState(value.roundToDouble() / _multiplier);
+                setNewState(value.roundToDouble() / _multiplier);
               },
             ),
           ),

lib/entity_class/switch_entity.class.dart

@@ -8,7 +8,15 @@ class _SwitchEntityWidgetState extends _EntityWidgetState {
   }
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
+    setState(() {
+      widget.entity.assumedState = newValue ? 'on' : 'off';
+    });
+    Timer(Duration(seconds: 2), (){
+      setState(() {
+        widget.entity.assumedState = widget.entity.state;
+      });
+    });
     eventBus.fire(new ServiceCallEvent(
         widget.entity.domain, (newValue as bool) ? "turn_on" : "turn_off", widget.entity.entityId, null));
   }
@@ -16,10 +24,9 @@ class _SwitchEntityWidgetState extends _EntityWidgetState {
   @override
   Widget _buildActionWidget(bool inCard, BuildContext context) {
     return Switch(
-      value: widget.entity.isOn,
+      value: widget.entity.assumedState == 'on',
       onChanged: ((switchState) {
-        sendNewState(switchState);
+        setNewState(switchState);
-        widget.entity.state = switchState ? 'on' : 'off';
       }),
     );
   }

lib/entity_class/text_entity.class.dart

@@ -19,7 +19,7 @@ class _TextEntityWidgetState extends _EntityWidgetState {
   }
 
   @override
-  void sendNewState(newValue) {
+  void setNewState(newValue) {
     if (validate(newValue)) {
       eventBus.fire(new ServiceCallEvent(widget.entity.domain, "set_value", widget.entity.entityId,
           {"value": "$newValue"}));
@@ -43,7 +43,7 @@ class _TextEntityWidgetState extends _EntityWidgetState {
 
   void _focusListener() {
     if (!_focusNode.hasFocus && (_tmpValue != widget.entity.state)) {
-      sendNewState(_tmpValue);
+      setNewState(_tmpValue);
     }
   }
 
@@ -53,8 +53,8 @@ class _TextEntityWidgetState extends _EntityWidgetState {
       _tmpValue = widget.entity.state;
     }
     if (this.isTextField || this.isPasswordField) {
-      return Container(
+      return Expanded(
-        width: Entity.INPUT_WIDTH,
+        //width: Entity.INPUT_WIDTH,
         child: TextField(
             focusNode: _focusNode,
             obscureText: this.isPasswordField,

lib/home_assistant.class.dart

@@ -6,6 +6,7 @@ class HomeAssistant {
   String _hassioAuthType;
 
   IOWebSocketChannel _hassioChannel;
+  SendMessageQueue _messageQueue;
 
   int _currentMessageId = 0;
   int _statesMessageId = 0;
@@ -20,7 +21,15 @@ class HomeAssistant {
   Completer _statesCompleter;
   Completer _servicesCompleter;
   Completer _configCompleter;
-  Timer _fetchingTimer;
+  Completer _connectionCompleter;
+  Timer _connectionTimer;
+  Timer _fetchTimer;
+
+  StreamSubscription _socketSubscription;
+
+  int messageExpirationTime = 50; //seconds
+  Duration fetchTimeout = Duration(seconds: 45);
+  Duration connectTimeout = Duration(seconds: 15);
 
   String get locationName => _instanceConfig["location_name"] ?? "";
   int get viewsCount => _entities.viewList.length ?? 0;
@@ -28,25 +37,29 @@ class HomeAssistant {
 
   EntityCollection get entities => _entities;
 
-  HomeAssistant(String url, String password, String authType) {
+  HomeAssistant() {
+    _entities = EntityCollection();
+    _uiBuilder = UIBuilder();
+    _messageQueue = SendMessageQueue(messageExpirationTime);
+  }
+
+  void updateConnectionSettings(String url, String password, String authType) {
     _hassioAPIEndpoint = url;
     _hassioPassword = password;
     _hassioAuthType = authType;
-    _entities = EntityCollection();
-    _uiBuilder = UIBuilder();
   }
 
   Future fetch() {
     if ((_fetchCompleter != null) && (!_fetchCompleter.isCompleted)) {
       TheLogger.log("Warning","Previous fetch is not complited");
     } else {
-      //TODO: Fetch timeout timer. Should be removed after #21 fix
-      _fetchingTimer = Timer(Duration(seconds: 15), () {
-        closeConnection();
-        _fetchCompleter.completeError({"errorCode" : 1,"errorMessage": "Connection timeout"});
-      });
       _fetchCompleter = new Completer();
-      _reConnectSocket().then((r) {
+      _fetchTimer = Timer(fetchTimeout, () {
+        closeConnection();
+        TheLogger.log("Error", "Data fetching timeout");
+        _finishFetching({"errorCode" : 9,"errorMessage": "Couldn't get data from server"});
+      });
+      _connection().then((r) {
         _getData();
       }).catchError((e) {
         _finishFetching(e);
@@ -56,24 +69,46 @@ class HomeAssistant {
   }
 
   closeConnection() {
-    if (_hassioChannel?.closeCode == null) {
+    if (_socketSubscription != null) {
-      _hassioChannel?.sink?.close();
+      _socketSubscription.cancel();
+    }
+    if (_hassioChannel != null) {
+      if (_hassioChannel.closeCode == null) {
+        _hassioChannel.sink?.close();
       }
       _hassioChannel = null;
     }
+  }
 
-  Future _reConnectSocket() {
+  Future _connection() {
-    var _connectionCompleter = new Completer();
+    if ((_connectionCompleter != null) && (!_connectionCompleter.isCompleted)) {
-    if ((_hassioChannel == null) || (_hassioChannel.closeCode != null)) {
+      TheLogger.log("Debug","Previous connection is not complited");
-      TheLogger.log("Debug","Socket connecting...");
-      _hassioChannel = IOWebSocketChannel.connect(_hassioAPIEndpoint);
-      _hassioChannel.stream.handleError((e) {
-        TheLogger.log("Error","Unhandled socket error: ${e.toString()}");
-      });
-      _hassioChannel.stream.listen((message) =>
-          _handleMessage(_connectionCompleter, message));
     } else {
-      _connectionCompleter.complete();
+      if ((_hassioChannel == null) || (_hassioChannel.sink == null) || (_hassioChannel.closeCode != null)) {
+        closeConnection();
+        TheLogger.log("Debug", "Socket connecting...");
+        _connectionCompleter = new Completer();
+        _connectionTimer = Timer(connectTimeout, () {
+          closeConnection();
+          TheLogger.log("Error", "Socket connection timeout");
+          _finishConnecting({"errorCode" : 1,"errorMessage": "Couldn't connect to Home Assistant. Looks like a network issues"});
+        });
+        _hassioChannel = IOWebSocketChannel.connect(
+              _hassioAPIEndpoint, pingInterval: Duration(seconds: 30));
+        _hassioChannel.stream.handleError((e) {
+          TheLogger.log("Error", "Unhandled socket error: ${e.toString()}");
+        });
+        if (_socketSubscription != null) _socketSubscription.cancel();
+        _socketSubscription = _hassioChannel.stream.listen((message) =>
+            _handleMessage(_connectionCompleter, message));
+        _hassioChannel.sink.done.whenComplete(() {
+          TheLogger.log("Debug","Socket sink finished. Assuming it is closed.");
+          closeConnection();
+        });
+      } else {
+        //TheLogger.log("Debug","Socket looks connected...${_hassioChannel.protocol}, ${_hassioChannel.closeCode}, ${_hassioChannel.closeReason}");
+        _finishConnecting(null);
+      }
     }
     return _connectionCompleter.future;
   }
@@ -94,25 +129,39 @@ class HomeAssistant {
     });
   }
 
-  _finishFetching(error) {
+  void _finishFetching(error) {
-    _fetchingTimer.cancel();
+    _fetchTimer.cancel();
+    _finishConnecting(error);
     if (error != null) {
+      if (!_fetchCompleter.isCompleted)
         _fetchCompleter.completeError(error);
     } else {
+      if (!_fetchCompleter.isCompleted)
         _fetchCompleter.complete();
     }
   }
 
+  void _finishConnecting(error) {
+    _connectionTimer.cancel();
+    if (error != null) {
+      if (!_connectionCompleter.isCompleted)
+        _connectionCompleter.completeError(error);
+    } else {
+      if (!_connectionCompleter.isCompleted)
+        _connectionCompleter.complete();
+    }
+  }
+
   _handleMessage(Completer connectionCompleter, String message) {
     var data = json.decode(message);
     //TheLogger.log("Debug","[Received] => Message type: ${data['type']}");
     if (data["type"] == "auth_required") {
-      _sendMessageRaw('{"type": "auth","$_hassioAuthType": "$_hassioPassword"}');
+      _sendAuthMessageRaw('{"type": "auth","$_hassioAuthType": "$_hassioPassword"}');
     } else if (data["type"] == "auth_ok") {
+      _finishConnecting(null);
       _sendSubscribe();
-      connectionCompleter.complete();
     } else if (data["type"] == "auth_invalid") {
-      connectionCompleter.completeError({"errorCode": 6, "errorMessage": "${data["message"]}"});
+      _finishFetching({"errorCode": 6, "errorMessage": "${data["message"]}"});
     } else if (data["type"] == "result") {
       if (data["id"] == _configMessageId) {
         _parseConfig(data);
@@ -139,14 +188,14 @@ class HomeAssistant {
   void _sendSubscribe() {
     _incrementMessageId();
     _subscriptionMessageId = _currentMessageId;
-    _sendMessageRaw('{"id": $_subscriptionMessageId, "type": "subscribe_events", "event_type": "state_changed"}');
+    _sendMessageRaw('{"id": $_subscriptionMessageId, "type": "subscribe_events", "event_type": "state_changed"}', false);
   }
 
   Future _getConfig() {
     _configCompleter = new Completer();
     _incrementMessageId();
     _configMessageId = _currentMessageId;
-    _sendMessageRaw('{"id": $_configMessageId, "type": "get_config"}');
+    _sendMessageRaw('{"id": $_configMessageId, "type": "get_config"}', false);
 
     return _configCompleter.future;
   }
@@ -155,7 +204,7 @@ class HomeAssistant {
     _statesCompleter = new Completer();
     _incrementMessageId();
     _statesMessageId = _currentMessageId;
-    _sendMessageRaw('{"id": $_statesMessageId, "type": "get_states"}');
+    _sendMessageRaw('{"id": $_statesMessageId, "type": "get_states"}', false);
 
     return _statesCompleter.future;
   }
@@ -164,7 +213,7 @@ class HomeAssistant {
     _servicesCompleter = new Completer();
     _incrementMessageId();
     _servicesMessageId = _currentMessageId;
-    _sendMessageRaw('{"id": $_servicesMessageId, "type": "get_services"}');
+    _sendMessageRaw('{"id": $_servicesMessageId, "type": "get_services"}', false);
 
     return _servicesCompleter.future;
   }
@@ -173,17 +222,44 @@ class HomeAssistant {
     _currentMessageId += 1;
   }
 
-  _sendMessageRaw(String message) {
+  void _sendAuthMessageRaw(String message) {
-    if (message.indexOf('"type": "auth"') > 0) {
     TheLogger.log("Debug", "[Sending] ==> auth request");
-    } else {
-      TheLogger.log("Debug", "[Sending] ==> $message");
-    }
     _hassioChannel.sink.add(message);
   }
 
+  _sendMessageRaw(String message, bool queued) {
+    var sendCompleter = Completer();
+    if (queued) _messageQueue.add(message);
+    _connection().then((r) {
+      _messageQueue.getActualMessages().forEach((message){
+        TheLogger.log("Debug", "[Sending queued] ==> $message");
+        _hassioChannel.sink.add(message);
+      });
+      if (!queued) {
+        TheLogger.log("Debug", "[Sending] ==> $message");
+        _hassioChannel.sink.add(message);
+      }
+      sendCompleter.complete();
+    }).catchError((e){
+      sendCompleter.completeError(e);
+    });
+    return sendCompleter.future;
+  }
+
+  Future callService(String domain, String service, String entityId, Map<String, String> additionalParams) {
+    _incrementMessageId();
+    String message = '{"id": $_currentMessageId, "type": "call_service", "domain": "$domain", "service": "$service", "service_data": {"entity_id": "$entityId"';
+    if (additionalParams != null) {
+      additionalParams.forEach((name, value){
+        message += ', "$name" : "$value"';
+      });
+    }
+    message += '}}';
+    return _sendMessageRaw(message, true);
+  }
+
   void _handleEntityStateChange(Map eventData) {
-    TheLogger.log("Debug", "New state for ${eventData['entity_id']}");
+    //TheLogger.log("Debug", "New state for ${eventData['entity_id']}");
     _entities.updateState(eventData);
     eventBus.fire(new StateChangedEvent(eventData["entity_id"], null, false));
   }
@@ -232,29 +308,44 @@ class HomeAssistant {
     _uiBuilder.build(_entities);
     _statesCompleter.complete();
   }
+}
 
-  Future callService(String domain, String service, String entityId, Map<String, String> additionalParams) {
+class SendMessageQueue {
-    var sendCompleter = Completer();
+  int _messageTimeout;
-    //TODO: Send service call timeout timer. Should be removed after #21 fix
+  List<HAMessage> _queue = [];
-    Timer _sendTimer = Timer(Duration(seconds: 7), () {
+
-      sendCompleter.completeError({"errorCode" : 8,"errorMessage": "Connection timeout"});
+  SendMessageQueue(this._messageTimeout);
-    });
+
-    _reConnectSocket().then((r) {
+  void add(String message) {
-      _incrementMessageId();
+    _queue.add(HAMessage(_messageTimeout, message));
-      String message = '{"id": $_currentMessageId, "type": "call_service", "domain": "$domain", "service": "$service", "service_data": {"entity_id": "$entityId"';
-      if (additionalParams != null) {
-        additionalParams.forEach((name, value){
-          message += ', "$name" : "$value"';
-        });
   }
-      message += '}}';
+  
-      _sendMessageRaw(message);
+  List<String> getActualMessages() {
-      _sendTimer.cancel();
+    _queue.removeWhere((item) => item.isExpired());
-      sendCompleter.complete();
+    List<String> result = [];
-    }).catchError((e){
+    _queue.forEach((haMessage){
-      _sendTimer.cancel();
+      result.add(haMessage.message);
-      sendCompleter.completeError(e);
     });
-    return sendCompleter.future;
+    this.clear();
+    return result;
+  }
+  
+  void clear() {
+    _queue.clear();
+  }
+  
+}
+
+class HAMessage {
+  DateTime _timeStamp;
+  int _messageTimeout;
+  String message;
+  
+  HAMessage(this._messageTimeout, this.message) {
+    _timeStamp = DateTime.now();
+  }
+  
+  bool isExpired() {
+    return _timeStamp.difference(DateTime.now()).inSeconds > _messageTimeout;
   }
 }

lib/main.dart

@@ -34,7 +34,7 @@ part 'badge_class.dart';
 
 EventBus eventBus = new EventBus();
 const String appName = "HA Client";
-const appVersion = "0.2.2";
+const appVersion = "0.2.4";
 
 String homeAssistantWebHost;
 
@@ -88,6 +88,9 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
   HomeAssistant _homeAssistant;
   EntityCollection _entities;
   //Map _instanceConfig;
+  String _apiEndpoint;
+  String _apiPassword;
+  String _authType;
   int _uiViewsCount = 0;
   String _instanceHost;
   int _errorCodeToBeShown = 0;
@@ -107,14 +110,35 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
   void initState() {
     super.initState();
     WidgetsBinding.instance.addObserver(this);
+
+    _homeAssistant = HomeAssistant();
+
     _settingsSubscription = eventBus.on<SettingsChangedEvent>().listen((event) {
       TheLogger.log("Debug","Settings change event: reconnect=${event.reconnect}");
+      if (event.reconnect) {
+        _homeAssistant.closeConnection();
+        _initConnection().then((b){
           setState(() {
-        _errorCodeToBeShown = 0;
+            _homeAssistant.updateConnectionSettings(_apiEndpoint, _apiPassword, _authType);
+            _errorCodeToBeShown = 10;
+            _lastErrorMessage = "Connection settings was changed.";
+          });
+          }, onError: (_) {
+            setState(() {
+              _lastErrorMessage = _;
+              _errorCodeToBeShown = 5;
+            });
+          });
+      }
+    });
+    _initConnection().then((_){
+      _createConnection();
+    }, onError: (_) {
+      setState(() {
+        _lastErrorMessage = _;
+        _errorCodeToBeShown = 5;
       });
-      _initConnection();
     });
-    _initConnection();
   }
 
   @override
@@ -130,25 +154,19 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
     String domain = prefs.getString('hassio-domain');
     String port = prefs.getString('hassio-port');
     _instanceHost = "$domain:$port";
-    String apiEndpoint = "${prefs.getString('hassio-protocol')}://$domain:$port/api/websocket";
+    _apiEndpoint = "${prefs.getString('hassio-protocol')}://$domain:$port/api/websocket";
     homeAssistantWebHost = "${prefs.getString('hassio-res-protocol')}://$domain:$port";
-    String apiPassword = prefs.getString('hassio-password');
+    _apiPassword = prefs.getString('hassio-password');
-    String authType = prefs.getString('hassio-auth-type');
+    _authType = prefs.getString('hassio-auth-type');
-    if ((domain == null) || (port == null) || (apiPassword == null) ||
+    if ((domain == null) || (port == null) || (_apiPassword == null) ||
-        (domain.length == 0) || (port.length == 0) || (apiPassword.length == 0)) {
+        (domain.length == 0) || (port.length == 0) || (_apiPassword.length == 0)) {
-      setState(() {
+      throw("Check connection settings");
-        _errorCodeToBeShown = 5;
-      });
-    } else {
-      if (_homeAssistant != null) _homeAssistant.closeConnection();
-      _createConnection(apiEndpoint, apiPassword, authType);
     }
   }
 
-  _createConnection(String apiEndpoint, String apiPassword, String authType) {
+  _createConnection() {
-    _homeAssistant = HomeAssistant(apiEndpoint, apiPassword, authType);
     _refreshData();
-    if (_stateSubscription != null) _stateSubscription.cancel();
+    if (_stateSubscription == null) {
       _stateSubscription = eventBus.on<StateChangedEvent>().listen((event) {
         setState(() {
           if (event.localChange) {
@@ -158,23 +176,30 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
           }
         });
       });
-    if (_serviceCallSubscription != null) _serviceCallSubscription.cancel();
+    }
-    _serviceCallSubscription = eventBus.on<ServiceCallEvent>().listen((event) {
+    if (_serviceCallSubscription == null) {
-      _callService(event.domain, event.service, event.entityId, event.additionalParams);
+      _serviceCallSubscription =
-    });
+          eventBus.on<ServiceCallEvent>().listen((event) {
-
+            _callService(event.domain, event.service, event.entityId,
-    if (_showEntityPageSubscription != null) _showEntityPageSubscription.cancel();
+                event.additionalParams);
-    _showEntityPageSubscription = eventBus.on<ShowEntityPageEvent>().listen((event) {
-      _showEntityPage(event.entity);
           });
     }
 
+    if (_showEntityPageSubscription == null) {
+      _showEntityPageSubscription =
+          eventBus.on<ShowEntityPageEvent>().listen((event) {
+            _showEntityPage(event.entity);
+          });
+    }
+  }
+
   _refreshData() async {
+    _homeAssistant.updateConnectionSettings(_apiEndpoint, _apiPassword, _authType);
     setState(() {
       _isLoading = true;
     });
     _errorCodeToBeShown = 0;
-    if (_homeAssistant != null) {
+    _lastErrorMessage = "";
     await _homeAssistant.fetch().then((result) {
       setState(() {
         //_instanceConfig = _homeAssistant.instanceConfig;
@@ -186,7 +211,6 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
       _setErrorState(e);
     });
   }
-  }
 
   _setErrorState(e) {
     setState(() {
@@ -197,14 +221,7 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
   }
 
   void _callService(String domain, String service, String entityId, Map<String, String> additionalParams) {
-    setState(() {
+    _homeAssistant.callService(domain, service, entityId, additionalParams).catchError((e) => _setErrorState(e));
-      _isLoading = true;
-    });
-    _homeAssistant.callService(domain, service, entityId, additionalParams).then((r) {
-      setState(() {
-        _isLoading = false;
-      });
-    }).catchError((e) => _setErrorState(e));
   }
 
   void _showEntityPage(Entity entity) {
@@ -490,6 +507,25 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
               HAUtils.launchURL("https://github.com/estevez-dev/ha_client_pub/issues/new");
             },
           ),
+          Container(
+            height: 30.0,
+            decoration: new BoxDecoration(
+              border: new Border(
+                  top: BorderSide(
+                    width: 2.0,
+                    color: Colors.black26,
+                  )
+                ),
+              )
+          ),
+          new ListTile(
+            leading: Icon(MaterialDesignIcons.createIconDataFromIconName("mdi:coffee")),
+            title: Text("By me a coffee"),
+            onTap: () {
+              Navigator.of(context).pop();
+              HAUtils.launchURL("https://www.buymeacoffee.com/estevez");
+            },
+          ),
           new AboutListTile(
             applicationName: appName,
             applicationVersion: appVersion,
@@ -505,6 +541,9 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
       String message = _lastErrorMessage;
       SnackBarAction action;
       switch (_errorCodeToBeShown) {
+        case 9:
+        case 11:
+        case 7:
         case 1: {
             action = SnackBarAction(
                 label: "Retry",
@@ -539,9 +578,9 @@ class _MainPageState extends State<MainPage> with WidgetsBindingObserver {
           break;
         }
 
-        case 7: {
+        case 10: {
           action = SnackBarAction(
-            label: "Retry",
+            label: "Refresh",
             onPressed: () {
               _scaffoldKey?.currentState?.hideCurrentSnackBar();
               _refreshData();

lib/settings.page.dart

@@ -15,6 +15,7 @@ class _ConnectionSettingsPageState extends State<ConnectionSettingsPage> {
   String _hassioPassword = "";
   String _socketProtocol = "wss";
   String _authType = "access_token";
+  bool _connectionSettingsChanged = false;
 
   @override
   void initState() {
@@ -45,6 +46,7 @@ class _ConnectionSettingsPageState extends State<ConnectionSettingsPage> {
     prefs.setString("hassio-protocol", _socketProtocol);
     prefs.setString("hassio-res-protocol", _socketProtocol == "wss" ? "https" : "http");
     prefs.setString("hassio-auth-type", _authType);
+    _connectionSettingsChanged = true;
   }
 
   @override
@@ -52,12 +54,24 @@ class _ConnectionSettingsPageState extends State<ConnectionSettingsPage> {
     return new Scaffold(
       appBar: new AppBar(
         leading: IconButton(icon: Icon(Icons.arrow_back), onPressed: (){
-          _saveSettings().then((r){
           Navigator.pop(context);
-          });
-          eventBus.fire(SettingsChangedEvent(true));
         }),
         title: new Text(widget.title),
+        actions: <Widget>[
+          IconButton(
+            icon: Icon(Icons.check),
+            onPressed:(){
+              if (_connectionSettingsChanged) {
+                _saveSettings().then((r){
+                  Navigator.pop(context);
+                  eventBus.fire(SettingsChangedEvent(_connectionSettingsChanged));
+                });
+              } else {
+                Navigator.pop(context);
+              }
+            }
+          )
+        ],
       ),
       body: ListView(
         padding: const EdgeInsets.all(20.0),

pubspec.yaml

@@ -1,7 +1,7 @@
 name: hass_client
 description: Home Assistant Android Client
 
-version: 0.2.2+24
+version: 0.2.4+26
 
 environment:
   sdk: ">=2.0.0-dev.68.0 <3.0.0"