Support some file operations in dart:io under mojo

mojo/dart/embedder/io/mojo_patch.dart

 // Copyright 2015 The Chromium Authors. 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:_mojo/application.dart';
 import 'dart:_mojo/bindings.dart';
 import 'dart:_mojo/core.dart';
 import 'dart:_mojo/mojo/network_error.mojom.dart';
 import 'dart:_mojo_services/mojo/host_resolver.mojom.dart';
 import 'dart:_mojo_services/mojo/net_address.mojom.dart';
 import 'dart:_mojo_services/mojo/network_service.mojom.dart';
 import 'dart:_mojo_services/mojo/tcp_bound_socket.mojom.dart';
 import 'dart:_mojo_services/mojo/tcp_connected_socket.mojom.dart';
 import 'dart:_mojo_services/mojo/tcp_server_socket.mojom.dart';
 import 'dart:_mojo_services/mojo/files/file.mojom.dart';
 import 'dart:_mojo_services/mojo/files/files.mojom.dart';
 import 'dart:_mojo_services/mojo/files/directory.mojom.dart';
 import 'dart:_mojo_services/mojo/files/ioctl.mojom.dart';
-import 'dart:_mojo_services/mojo/files/types.mojom.dart';
+import 'dart:_mojo_services/mojo/files/types.mojom.dart' as types;
+
+// When developing, set fileSystemDeveloper to true and the file system will
+// persist under ~/MojoAppPersistentCaches/.
+const bool fileSystemDeveloper = false;
+const String fileSystemName =
+    fileSystemDeveloper ? 'app_persistent_cache' : null;
+
+// System temp path relative to the root directory.
+const String systemTempPath = 'tmp';
 
 //
 // Mojo objects and helper functions used by the 'dart:io' library.
 //
 int _networkServiceHandle;
 int _filesServiceHandle;
 NetworkServiceProxy _networkService;
 HostResolverProxy _hostResolver;
 FilesProxy _files;
+DirectoryProxy _rootDirectory;
+DirectoryProxy _systemTempDirectory;
 
 void _initialize(int networkServiceHandle, int filesServiceHandle) {
   if (networkServiceHandle != MojoHandle.INVALID) {
     _networkServiceHandle = networkServiceHandle;
   }
   if (filesServiceHandle != MojoHandle.INVALID) {
     _filesServiceHandle = filesServiceHandle;
   }
 }
 
@@ skipping 21 matching lines @@
     _networkService = null;
   }
   if (_hostResolver != null) {
     _hostResolver.close(immediate: true);
     _hostResolver = null;
   }
   if (_files != null) {
     _files.close(immediate: true);
     _files = null;
   }
+  if (_rootDirectory != null) {
+    _rootDirectory.close(immediate: true);
+    _rootDirectory = null;
+  }
+  if (_systemTempDirectory != null) {
+    _systemTempDirectory.close(immediate: true);
+    _systemTempDirectory = null;
+  }
 }
 
 /// Get the singleton NetworkServiceProxy.
 NetworkServiceProxy _getNetworkService() {
   if (_networkService != null) {
     return _networkService;
   }
   _networkService = new NetworkServiceProxy.fromHandle(
       new MojoHandle(_networkServiceHandle).pass());
   _networkServiceHandle = null;
@@ skipping 21 matching lines @@
 FilesProxy _getFiles() {
   if (_files != null) {
     return _files;
   }
   _files = new FilesProxy.fromHandle(
       new MojoHandle(_filesServiceHandle).pass());
   _filesServiceHandle = null;
   return _files;
 }
 
+/// Get the singleton DirectoryProxy for the root directory.
+Future<DirectoryProxy> _getRootDirectory() async {
+  if (_rootDirectory != null) {
+    return _rootDirectory;
+  }
+  FilesProxy files = _getFiles();
+  assert(files != null);
+  _rootDirectory = new DirectoryProxy.unbound();
+  var response =
+      await files.ptr.openFileSystem(fileSystemName, _rootDirectory);
+  // Remove the root directory's handle from the open set because it is not
+  // under application control and does not affect isolate shutdown.
+  _rootDirectory.impl.endpoint.handle.pass();
+
+  // Ensure system temporary directory exists before returning the root
+  // directory.
+  await _getSystemTempDirectory();
+  return _rootDirectory;
+}
+
+/// Get the singleton DirectoryProxy for the system temp directory.
+Future<DirectoryProxy> _getSystemTempDirectory() async {
+  if (_systemTempDirectory != null) {
+    return _systempTempDirectory;
+  }
+  DirectoryProxy rootDirectory = await _getRootDirectory();
+  int flags = types.kOpenFlagRead |
+              types.kOpenFlagWrite |
+              types.kOpenFlagCreate;
+  _systemTempDirectory = new DirectoryProxy.unbound();
+  var response =
+      await rootDirectory.ptr.openDirectory(systemTempPath,
+                                            _systemTempDirectory,
+                                            flags);
+  assert(response.error == types.Error.ok);
+  // Remove the system temp directory's handle from the open set because it
+  // is not under application control and does not affect isolate shutdown.
+  _systemTempDirectory.impl.endpoint.handle.pass();
+  return _systemTempDirectory;
+}
+
 /// Static utility methods for converting between 'dart:io' and
 /// 'mojo:network_service' structs.
 class _NetworkServiceCodec {
   /// Returns a string representation of an ip address encoded in [address].
   /// Supports both IPv4 and IPv6.
   static String _addressToString(List<int> address) {
     String r = '';
     if (address == null) {
       return r;
     }
@@ skipping 108 matching lines @@
   }
 
   static _throwOnError(NetworkError error) {
     if (_okay(error)) {
       return;
     }
     throw new OSError(error.description, error.code);
   }
 }