Version 0.8.10.5

dart/samples/dartiverse_search/web/client.dart

 // Copyright (c) 2013, the Dart project authors.  Please see the AUTHORS file
 // for details. 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:html';
-import 'dart:convert';
 
 
 class Client {
-  static const Duration CONNECT_DELAY = const Duration(milliseconds: 500);
+  static const Duration RECONNECT_DELAY = const Duration(milliseconds: 500);
 
   WebSocket webSocket;
   final DivElement log = new DivElement();
   SearchInputElement searchElement = querySelector('#q');
   DivElement statusElement = querySelector('#status');
   DivElement resultsElement = querySelector('#results');
 
   Client() {
-    onDisconnected();
     searchElement.onChange.listen((e) {
       search(searchElement.value);
       searchElement.value = '';
     });
+    connect();
   }
 
-  void onConnected() {
-    setStatus('');
-    searchElement.disabled = false;
-    searchElement.focus();
-    webSocket.onMessage.listen((e) {
-      onMessage(e.data);
-    });
-  }
-
-  void onDisconnected() {
-    searchElement.disabled = true;
-    setStatus('Disconnected');
+  void connect() {
     webSocket = new WebSocket('ws://${Uri.base.host}:${Uri.base.port}/ws');
     webSocket.onOpen.first.then((_) {
       onConnected();
       webSocket.onClose.first.then((_) {
         print("Connection disconnected to ${webSocket.url}");
         onDisconnected();
       });
     });
     webSocket.onError.first.then((_) {
-      print("Failed to connect to ${webSocket.url}");
+      print("Failed to connect to ${webSocket.url}. "
+            "Please run bin/server.dart and try again.");
       onDisconnected();
     });
   }
 
+  void onConnected() {
+    setStatus('');
+    searchElement.disabled = false;
+    searchElement.focus();
+    webSocket.onMessage.listen((e) {
+      onMessage(e.data);
+    });
+  }
+
+  void onDisconnected() {
+    searchElement.disabled = true;
+    setStatus('Disconnected - start \'bin/server.dart\' to continue');
+    new Timer(RECONNECT_DELAY, connect);
+  }
+
   void setStatus(String status) {
     statusElement.innerHtml = status;
   }
 
 
   void onMessage(data) {
     var json = JSON.decode(data);
     var response = json['response'];
     switch (response) {
       case 'searchResult':
@@ skipping 29 matching lines @@
       'input': input
     };
     webSocket.send(JSON.encode(request));
   }
 }
 
 
 void main() {
   var client = new Client();
 }