Support devFS writes via HTTP PUT

sdk/lib/vmservice/devfs.dart

 // Copyright (c) 2016, 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.
 
 part of dart._vmservice;
 
 String _encodeDevFSDisabledError(Message message) {
   return encodeRpcError(
       message, kFeatureDisabled,
       details: "DevFS is not supported by this Dart implementation");
@@ skipping 103 matching lines @@
         return _writeDevFSFiles(message);
       case '_listDevFSFiles':
         return _listDevFSFiles(message);
       default:
         return encodeRpcError(
             message, kInternalError,
             details: 'Unexpected rpc ${message.method}');
     }
   }
 
+  Future<String> handlePutStream(Object fsName,
+                                 Object path,
+                                 Stream<List<int>> bytes) async {
+    // A dummy Message for error message construction.
+    Message message = new Message.forMethod('_writeDevFSFile');
+    var writeStreamFile = VMServiceEmbedderHooks.writeStreamFile;
+    if (writeStreamFile == null) {
+      return _encodeDevFSDisabledError(message);
+    }
+    if (fsName == null) {
+      return encodeMissingParamError(message, 'fsName');
+    }
+    if (fsName is! String) {
+      return encodeInvalidParamError(message, 'fsName');
+    }
+    var fs = _fsMap[fsName];
+    if (fs == null) {
+      return _encodeFileSystemDoesNotExistError(message, fsName);
+    }
+    if (path == null) {
+      return encodeMissingParamError(message, 'path');
+    }
+    if (path is! String) {
+      return encodeInvalidParamError(message, 'path');
+    }
+    Uri uri = fs.resolvePath(path);
+    if (uri == null) {
+      return encodeInvalidParamError(message, 'path');
+    }
+    await writeStreamFile(uri, bytes);
+    return encodeSuccess(message);
+  }
+
   Future<String> _listDevFS(Message message) async {
     var result = {};
     result['type'] = 'FileSystemList';
     result['fsNames'] =  _fsMap.keys.toList();
     return encodeResult(message, result);
   }
 
   Future<String> _createDevFS(Message message) async {
     var createTempDir = VMServiceEmbedderHooks.createTempDir;
     if (createTempDir == null) {
@@ skipping 188 matching lines @@
     }
     var fileList = await listFiles(fs.uri);
     // Remove any url-encoding in the filenames.
     for (int i = 0; i < fileList.length; i++) {
       fileList[i]['name'] = Uri.decodeFull(fileList[i]['name']);
     }
     var result = { 'type': 'FSFileList', 'files': fileList };
     return encodeResult(message, result);
   }
 }