Refactor some of the duplicated code in the tests using a socket server

tests/standalone/src/EchoServerStreamTest.dart

 // Copyright (c) 2011, 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.
 //
 // Echo server test program to test socket streams.
 //
 // VMOptions=
 // VMOptions=--short_socket_read
 // VMOptions=--short_socket_write
 // VMOptions=--short_socket_read --short_socket_write
 
-class EchoServerStreamTest {
-
-  static void testMain() {
-    EchoServerGame echoServerGame = new EchoServerGame.start();
-  }
-}
+#source("TestingServer.dart");
 
 class EchoServerGame {
 
   static final MSGSIZE = 10;
-  static final SERVERINIT = 0;
-  static final SERVERSHUTDOWN = -1;
   static final MESSAGES = 100;
   static final FIRSTCHAR = 65;
 
   EchoServerGame.start()
       : _receivePort = new ReceivePort(),
         _sendPort = null,
         _buffer = new List<int>(MSGSIZE),
         _messages = 0 {
     for (int i = 0; i < MSGSIZE; i++) {
       _buffer[i] = FIRSTCHAR + i;
@@ skipping 71 matching lines @@
           break;
         case 3:
           stream.writeFrom(_buffer, len: _buffer.length ~/ 2);
           stream.writeFrom(_buffer, _buffer.length ~/ 2);
           break;
       }
       stream.close();
       dataSent();
     }
 
-    _socket = new Socket(EchoServer.HOST, _port);
+    _socket = new Socket(TestingServer.HOST, _port);
     if (_socket !== null) {
       _socket.connectHandler = connectHandler;
     } else {
       Expect.fail("socket creation failed");
     }
   }
 
   void start() {
     _receivePort.receive((var message, SendPort replyTo) {
       _port = message;
       sendData();
     });
-    _sendPort.send(SERVERINIT, _receivePort.toSendPort());
+    _sendPort.send(TestingServer.INIT, _receivePort.toSendPort());
   }
 
   void shutdown() {
-    _sendPort.send(SERVERSHUTDOWN, _receivePort.toSendPort());
+    _sendPort.send(TestingServer.SHUTDOWN, _receivePort.toSendPort());
     _receivePort.close();
   }
 
   int _port;
   ReceivePort _receivePort;
   SendPort _sendPort;
   Socket _socket;
   List<int> _buffer;
   int _messages;
 }
 
-class EchoServer extends Isolate {
 
-  static final HOST = "127.0.0.1";
+class EchoServer extends TestingServer {
+
   static final int MSGSIZE = EchoServerGame.MSGSIZE;
 
-  void main() {
+  void connectionHandler() {
+    Socket _client;
+    InputStream inputStream;
+    List<int> buffer = new List<int>(MSGSIZE);
+    int offset = 0;
 
-    void connectionHandler() {
-      Socket _client;
-      InputStream inputStream;
-      List<int> buffer = new List<int>(MSGSIZE);
-      int offset = 0;
-
-      void dataReceived() {
-        SocketOutputStream outputStream;
-        int bytesRead;
-        outputStream = _client.outputStream;
-        bytesRead = inputStream.readInto(buffer, offset, MSGSIZE - offset);
-        if (bytesRead > 0) {
-          offset += bytesRead;
-          for (int i = 0; i < offset; i++) {
-            Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]);
-          }
-          if (offset == MSGSIZE) {
-            outputStream.write(buffer);
-            outputStream.close();
-          }
+    void dataReceived() {
+      SocketOutputStream outputStream;
+      int bytesRead;
+      outputStream = _client.outputStream;
+      bytesRead = inputStream.readInto(buffer, offset, MSGSIZE - offset);
+      if (bytesRead > 0) {
+        offset += bytesRead;
+        for (int i = 0; i < offset; i++) {
+          Expect.equals(EchoServerGame.FIRSTCHAR + i, buffer[i]);
+        }
+        if (offset == MSGSIZE) {
+          outputStream.write(buffer);
+          outputStream.close();
         }
       }
-
-      void errorHandler() {
-        Expect.fail("Socket error");
-      }
-
-      _client = _server.accept();
-      inputStream = _client.inputStream;
-      inputStream.dataHandler = dataReceived;
-      _client.errorHandler = errorHandler;
     }
 
-    void errorHandlerServer() {
-      Expect.fail("Server socket error");
+    void errorHandler() {
+      Expect.fail("Socket error");
     }
 
-    this.port.receive((message, SendPort replyTo) {
-      if (message == EchoServerGame.SERVERINIT) {
-        _server = new ServerSocket(HOST, 0, 10);
-        Expect.equals(true, _server !== null);
-        _server.connectionHandler = connectionHandler;
-        _server.errorHandler = errorHandlerServer;
-        replyTo.send(_server.port, null);
-      } else if (message == EchoServerGame.SERVERSHUTDOWN) {
-        _server.close();
-        this.port.close();
-      }
-    });
+    _client = _server.accept();
+    inputStream = _client.inputStream;
+    inputStream.dataHandler = dataReceived;
+    _client.errorHandler = errorHandler;
   }
-
-  ServerSocket _server;
 }
 
 main() {
-  EchoServerStreamTest.testMain();
+  EchoServerGame echoServerGame = new EchoServerGame.start();
 }