Add the ability to secure an already established raw socket connection

runtime/bin/socket_patch.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.
 
 patch class RawServerSocket  {
   /* patch */ static Future<RawServerSocket> bind([String address = "127.0.0.1",
                                                    int port = 0,
                                                    int backlog = 0]) {
     return _RawServerSocket.bind(address, port, backlog);
   }
@@ skipping 56 matching lines @@
 
   // Indicates if native interrupts can be activated.
   bool canActivateEvents = true;
 
   // The type flags for this socket.
   final int typeFlags;
 
   // Holds the port of the socket, null if not known.
   int localPort;
 
+  // Holds the host or address used to connect or bind the socket.
+  String localHost;
+
   // Native port for socket services.
   static SendPort socketService;
 
   static Future<_NativeSocket> connect(String host, int port) {
     var completer = new Completer();
     ensureSocketService();
     socketService.call([HOST_NAME_LOOKUP, host]).then((response) {
       if (isErrorResponse(response)) {
         completer.completeError(
             createError(response, "Failed host name lookup"));
       } else {
         var socket = new _NativeSocket.normal();
+        socket.localHost = host;
         var result = socket.nativeCreateConnect(response, port);
         if (result is OSError) {
           completer.completeError(createError(result, "Connection failed"));
         } else {
           // Setup handlers for receiving the first write event which
           // indicate that the socket is fully connected.
           socket.setHandlers(
               write: () {
                 socket.setListening(read: false, write: false);
                 completer.complete(socket);
               },
               error: (e) {
                 socket.close();
                 completer.completeError(createError(e, "Connection failed"));
               }
           );
           socket.setListening(read: false, write: true);
         }
       }
     });
     return completer.future;
   }
 
   static Future<_NativeSocket> bind(String address,
                                     int port,
                                     int backlog) {
     var socket = new _NativeSocket.listen();
+    socket.localHost = address;
     var result = socket.nativeCreateBindListen(address, port, backlog);
     if (result is OSError) {
       return new Future.immediateError(
           new SocketIOException("Failed to create server socket", result));
     }
     if (port != 0) socket.localPort = port;
     return new Future.immediate(socket);
   }
 
   _NativeSocket.normal() : typeFlags = TYPE_NORMAL_SOCKET {
@@ skipping 68 matching lines @@
 
   int get port {
     if (localPort != null) return localPort;
     return localPort = nativeGetPort();
   }
 
   int get remotePort {
     return nativeGetRemotePeer()[1];
   }
 
+  String get host => localHost;
+
   String get remoteHost {
     return nativeGetRemotePeer()[0];
   }
 
   // Multiplexes socket events to the socket handlers.
   void multiplex(int events) {
     canActivateEvents = false;
     for (int i = FIRST_EVENT; i <= LAST_EVENT; i++) {
       if (((events & (1 << i)) != 0)) {
         if (i == CLOSED_EVENT &&
@@ skipping 339 matching lines @@
       _socket.write(buffer, offset, count);
 
   void close() => _socket.close();
 
   void shutdown(SocketDirection direction) => _socket.shutdown(direction);
 
   int get port => _socket.port;
 
   int get remotePort => _socket.remotePort;
 
+  String get host => _socket.host;
+
   String get remoteHost => _socket.remoteHost;
 
   bool get readEventsEnabled => _readEventsEnabled;
   void set readEventsEnabled(bool value) {
     if (value != _readEventsEnabled) {
       _readEventsEnabled = value;
       if (!_controller.isPaused) _resume();
     }
   }
 
@@ skipping 372 matching lines @@
     _raw.onBadCertificate = callback;
   }
 
   X509Certificate get peerCertificate {
     if (_raw == null) {
      throw new StateError("peerCertificate called on destroyed SecureSocket");
     }
     return _raw.peerCertificate;
   }
 }