Support (de)serialization from command-line

pkg/compiler/lib/src/apiimpl.dart

 // Copyright (c) 2012, 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 leg_apiimpl;
 
 import 'dart:async';
 import 'dart:convert';
 
 import 'package:package_config/packages.dart';
 import 'package:package_config/packages_file.dart' as pkgs;
 import 'package:package_config/src/packages_impl.dart'
     show MapPackages, NonFilePackagesDirectoryPackages;
 import 'package:package_config/src/util.dart' show checkValidPackageUri;
 
 import '../compiler_new.dart' as api;
 import 'common/tasks.dart' show GenericTask, Measurer;
 import 'common.dart';
 import 'common/backend_api.dart' show Backend;
 import 'compiler.dart';
 import 'diagnostics/messages.dart' show Message;
 import 'elements/elements.dart' as elements;
 import 'environment.dart';
 import 'io/source_file.dart';
 import 'options.dart' show CompilerOptions;
 import 'platform_configuration.dart' as platform_configuration;
 import 'resolved_uri_translator.dart';
 import 'script.dart';
+import 'serialization/system.dart';
 
 /// Implements the [Compiler] using a [api.CompilerInput] for supplying the
 /// sources.
 class CompilerImpl extends Compiler {
   api.CompilerInput provider;
   api.CompilerDiagnostics handler;
   Packages packages;
 
   bool get mockableLibraryUsed => resolvedUriTranslator.isSet
       ? resolvedUriTranslator.mockableLibraryUsed
@@ skipping 66 matching lines @@
         reporter.withCurrentElement(element, () {
           reporter.reportErrorMessage(node, MessageKind.DART_EXT_NOT_SUPPORTED);
         });
       }
       return _synthesizeScript(readableUri);
     }
 
     // TODO(johnniwinther): Wrap the result from [provider] in a specialized
     // [Future] to ensure that we never execute an asynchronous action without
     // setting up the current element of the compiler.
-    return new Future.sync(() => callUserProvider(resourceUri)).then((data) {
-      SourceFile sourceFile;
-      if (data is List<int>) {
-        sourceFile = new Utf8BytesSourceFile(resourceUri, data);
-      } else if (data is String) {
-        sourceFile = new StringSourceFile.fromUri(resourceUri, data);
-      } else {
-        String message = "Expected a 'String' or a 'List<int>' from the input "
-            "provider, but got: ${Error.safeToString(data)}.";
-        reportReadError(message);
-      }
+    return new Future.sync(() => callUserProvider(resourceUri))
+        .then((SourceFile sourceFile) {
       // We use [readableUri] as the URI for the script since need to preserve
       // the scheme in the script because [Script.uri] is used for resolving
       // relative URIs mentioned in the script. See the comment on
       // [LibraryLoader] for more details.
       return new Script(readableUri, resourceUri, sourceFile);
     }).catchError((error) {
       reportReadError(error);
       return _synthesizeScript(readableUri);
     });
   }
@@ skipping 39 matching lines @@
           .analyzeUri(uri, skipLibraryWithPartOfTag: skipLibraryWithPartOfTag);
     });
   }
 
   Future setupPackages(Uri uri) {
     if (options.packageRoot != null) {
       // Use "non-file" packages because the file version requires a [Directory]
       // and we can't depend on 'dart:io' classes.
       packages = new NonFilePackagesDirectoryPackages(options.packageRoot);
     } else if (options.packageConfig != null) {
-      return callUserProvider(options.packageConfig).then((configContents) {
-        if (configContents is String) {
-          configContents = UTF8.encode(configContents);
-        }
+      return callUserProvider(options.packageConfig)
+          .then((SourceFile sourceFile) {
+        List<int> configContents = sourceFile.slowUtf8ZeroTerminatedBytes();
         // The input provider may put a trailing 0 byte when it reads a source
         // file, which confuses the package config parser.
         if (configContents.length > 0 && configContents.last == 0) {
           configContents = configContents.sublist(0, configContents.length - 1);
         }
         packages =
             new MapPackages(pkgs.parse(configContents, options.packageConfig));
       }).catchError((error) {
         reporter.reportErrorMessage(
             NO_LOCATION_SPANNABLE,
             MessageKind.INVALID_PACKAGE_CONFIG,
             {'uri': options.packageConfig, 'exception': error});
         packages = Packages.noPackages;
       });
     } else {
       if (options.packagesDiscoveryProvider == null) {
         packages = Packages.noPackages;
       } else {
         return callUserPackagesDiscovery(uri).then((p) {
           packages = p;
         });
       }
     }
     return new Future.value();
   }
 
   Future<Null> setupSdk() {
+    Future future = new Future.value(null);
+    if (options.serializationSource != null) {
+      reporter
+          .log('Reading serialized data from ${options.serializationSource}');
+      future = callUserProvider(options.serializationSource)
+          .then((SourceFile sourceFile) {
+        serialization.deserializeFromText(sourceFile.slowText());
+      });
+    }
     if (resolvedUriTranslator.isNotSet) {
-      return platform_configuration
-          .load(options.platformConfigUri, provider)
-          .then((Map<String, Uri> mapping) {
-        resolvedUriTranslator.resolvedUriTranslator =
-            new ResolvedUriTranslator(mapping, reporter);
+      future = future.then((_) {
+        return platform_configuration
+            .load(options.platformConfigUri, provider)
+            .then((Map<String, Uri> mapping) {
+          resolvedUriTranslator.resolvedUriTranslator =
+              new ResolvedUriTranslator(mapping, reporter);
+        });
       });
-    } else {
-      // The incremental compiler sets up the sdk before run.
-      // Therefore this will be called a second time.
-      return new Future.value(null);
     }
+    // The incremental compiler sets up the sdk before run.
+    // Therefore this will be called a second time.
+    return future;
   }
 
   Future<bool> run(Uri uri) {
     Duration setupDuration = measurer.wallClock.elapsed;
     return selfTask.measureSubtask("CompilerImpl.run", () {
       log('Using platform configuration at ${options.platformConfigUri}');
 
       return setupSdk().then((_) => setupPackages(uri)).then((_) {
         assert(resolvedUriTranslator.isSet);
         assert(packages != null);
@@ skipping 71 matching lines @@
     try {
       userHandlerTask.measure(() {
         handler.report(message, uri, begin, end, text, kind);
       });
     } catch (ex, s) {
       reportCrashInUserCode('Uncaught exception in diagnostic handler', ex, s);
       rethrow;
     }
   }
 
-  Future callUserProvider(Uri uri) {
+  Future<SourceFile> callUserProvider(Uri uri) {
     try {
-      return userProviderTask.measureIo(() => provider.readFromUri(uri));
+      return userProviderTask
+          .measureIo(() => provider.readFromUri(uri))
+          .then((data) {
+        SourceFile sourceFile;
+        if (data is List<int>) {
+          sourceFile = new Utf8BytesSourceFile(uri, data);
+        } else if (data is String) {
+          sourceFile = new StringSourceFile.fromUri(uri, data);
+        } else {
+          throw "Expected a 'String' or a 'List<int>' from the input "
+              "provider, but got: ${Error.safeToString(data)}.";
+        }
+        return sourceFile;
+      });
     } catch (ex, s) {
       reportCrashInUserCode('Uncaught exception in input provider', ex, s);
       rethrow;
     }
   }
 
   Future<Packages> callUserPackagesDiscovery(Uri uri) {
     try {
       return userPackagesDiscoveryTask
           .measureIo(() => options.packagesDiscoveryProvider(uri));
@@ skipping 45 matching lines @@
   }
 }
 
 /// For every 'dart:' library, a corresponding environment variable is set
 /// to "true". The environment variable's name is the concatenation of
 /// this prefix and the name (without the 'dart:'.
 ///
 /// For example 'dart:html' has the environment variable 'dart.library.html' set
 /// to "true".
 const String _dartLibraryEnvironmentPrefix = 'dart.library.';