Remove old web socket API.

sdk/lib/_internal/pub/lib/src/barback/barback_server.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.
 
 library pub.barback.server;
 
 import 'dart:async';
 import 'dart:io';
 
 import 'package:barback/barback.dart';
 import 'package:mime/mime.dart';
 import 'package:path/path.dart' as path;
 import 'package:stack_trace/stack_trace.dart';
 
 import '../barback.dart';
 import '../log.dart' as log;
 import '../utils.dart';
 import 'base_server.dart';
 import 'build_environment.dart';
-import 'old_web_socket_api.dart';
 
 /// Callback for determining if an asset with [id] should be served or not.
 typedef bool AllowAsset(AssetId id);
 
 /// A server that serves assets transformed by barback.
 class BarbackServer extends BaseServer<BarbackServerResult> {
   /// The directory in the root which will serve as the root of this server as
   /// a native platform path.
   ///
   /// This may be `null` in which case no files in the root package can be
@@ skipping 57 matching lines @@
 
     // Strip the leading "/" from the URL.
     if (parts.isNotEmpty && parts.first == "/") parts = parts.skip(1);
 
     var relativePath = path.url.join(rootDirectory, path.url.joinAll(parts));
     return new AssetId(environment.rootPackage.name, relativePath);
   }
 
   /// Handles an HTTP request.
   void handleRequest(HttpRequest request) {
-    // TODO(rnystrom): Remove this when the Editor is using the admin server.
-    // port. See #17640.
-    if (WebSocketTransformer.isUpgradeRequest(request)) {
-      _handleWebSocket(request);
-      return;
-    }
-
     if (request.method != "GET" && request.method != "HEAD") {
       methodNotAllowed(request);
       return;
     }
 
     var id;
     try {
       id = urlToId(request.uri);
     } on FormatException catch (ex) {
       // If we got here, we had a path like "/packages" which is a special
@@ skipping 40 matching lines @@
         addError(error, trace);
         close();
         return;
       }
 
       addResult(new BarbackServerResult._failure(request.uri, id, error));
       notFound(request, asset: id);
     });
   }
 
-  // TODO(rnystrom): Remove this when the Editor is using the admin server.
-  // port. See #17640.
-  /// Creates a web socket for [request] which should be an upgrade request.
-  void _handleWebSocket(HttpRequest request) {
-    Chain.track(WebSocketTransformer.upgrade(request)).then((socket) {
-      _webSockets.add(socket);
-      var api = new OldWebSocketApi(socket, environment);
-
-      return api.listen().whenComplete(() {
-        _webSockets.remove(api);
-      });
-    }).catchError(addError);
-  }
-
   /// Serves the body of [asset] on [request]'s response stream.
   ///
   /// Returns a future that completes when the response has been succesfully
   /// written.
   Future _serveAsset(HttpRequest request, Asset asset) {
     return validateStream(asset.read()).then((stream) {
       addResult(new BarbackServerResult._success(request.uri, asset.id));
       var mimeType = lookupMimeType(asset.id.path);
       if (mimeType != null) {
         request.response.headers.add('content-type', mimeType);
@@ skipping 49 matching lines @@
   bool get isSuccess => error == null;
 
   /// Whether the request was served unsuccessfully.
   bool get isFailure => !isSuccess;
 
   BarbackServerResult._success(this.url, this.id)
       : error = null;
 
   BarbackServerResult._failure(this.url, this.id, this.error);
 }