Teach Stocks.apk how to load a skyx bundle

sky/shell/ui/engine.cc

 // 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.
 
 #include "sky/shell/ui/engine.h"
 
 #include "base/bind.h"
 #include "base/files/file_path.h"
 #include "base/threading/worker_pool.h"
 #include "base/trace_event/trace_event.h"
 #include "mojo/common/data_pipe_utils.h"
 #include "mojo/public/cpp/application/connect.h"
+#include "services/asset_bundle/asset_unpacker_job.h"
 #include "sky/engine/public/platform/WebInputEvent.h"
 #include "sky/engine/public/platform/sky_display_metrics.h"
 #include "sky/engine/public/platform/sky_display_metrics.h"
 #include "sky/engine/public/web/Sky.h"
 #include "sky/services/platform/platform_impl.h"
 #include "sky/shell/dart/dart_library_provider_files.h"
 #include "sky/shell/dart/dart_library_provider_network.h"
 #include "sky/shell/service_provider.h"
 #include "sky/shell/ui/animator.h"
 #include "sky/shell/ui/input_event_converter.h"
 #include "sky/shell/ui/internals.h"
 #include "third_party/skia/include/core/SkCanvas.h"
 #include "third_party/skia/include/core/SkPictureRecorder.h"
 
 namespace sky {
 namespace shell {
 
+const char kSnapshotKey[] = "snapshot_blob.bin";
+
 namespace {
 
 void Ignored(bool) {
 }
 
 mojo::ScopedDataPipeConsumerHandle Fetch(const base::FilePath& path) {
   mojo::DataPipe pipe;
   auto runner = base::WorkerPool::GetTaskRunner(true);
   mojo::common::CopyFromFile(base::FilePath(path), pipe.producer_handle.Pass(),
                              0, runner.get(), base::Bind(&Ignored));
   return pipe.consumer_handle.Pass();
 }
 
 PlatformImpl* g_platform_impl = nullptr;
 
-}
+}  // namespace
+
+using mojo::asset_bundle::AssetUnpackerJob;
 
 Engine::Config::Config() {
 }
 
 Engine::Config::~Config() {
 }
 
 Engine::Engine(const Config& config)
     : config_(config),
       animator_(new Animator(config, this)),
@@ skipping 87 matching lines @@
 void Engine::OnInputEvent(InputEventPtr event) {
   TRACE_EVENT0("sky", "Engine::OnInputEvent");
   scoped_ptr<blink::WebInputEvent> web_event =
       ConvertEvent(event, device_pixel_ratio_);
   if (!web_event)
     return;
   if (sky_view_)
     sky_view_->HandleInputEvent(*web_event);
 }
 
-void Engine::RunFromLibrary(const mojo::String& name) {
+void Engine::RunFromLibrary(const std::string& name) {
   sky_view_ = blink::SkyView::Create(this);
   sky_view_->RunFromLibrary(blink::WebString::fromUTF8(name),
                             dart_library_provider_.get());
   UpdateSkyViewSize();
 }
 
+void Engine::RunFromSnapshotStream(
+    const std::string& name,
+    mojo::ScopedDataPipeConsumerHandle snapshot) {
+  sky_view_ = blink::SkyView::Create(this);
+  sky_view_->RunFromSnapshot(blink::WebString::fromUTF8(name), snapshot.Pass());
+  UpdateSkyViewSize();
+}
+
 void Engine::RunFromNetwork(const mojo::String& url) {
   dart_library_provider_.reset(
       new DartLibraryProviderNetwork(g_platform_impl->networkService()));
   RunFromLibrary(url);
 }
 
 void Engine::RunFromFile(const mojo::String& main,
                          const mojo::String& package_root) {
   dart_library_provider_.reset(
       new DartLibraryProviderFiles(base::FilePath(package_root)));
   RunFromLibrary(main);
 }
 
 void Engine::RunFromSnapshot(const mojo::String& path) {
-  sky_view_ = blink::SkyView::Create(this);
-  sky_view_->RunFromSnapshot(blink::WebString::fromUTF8(path),
-                             Fetch(base::FilePath(path)));
-  UpdateSkyViewSize();
+  std::string path_str = path;
+  RunFromSnapshotStream(path_str, Fetch(base::FilePath(path_str)));
+}
+
+void Engine::RunFromBundle(const mojo::String& path) {
+  AssetUnpackerJob* unpacker = new AssetUnpackerJob(
+      mojo::GetProxy(&root_bundle_), base::WorkerPool::GetTaskRunner(true));
+  std::string path_str = path;
+  unpacker->Unpack(Fetch(base::FilePath(path_str)));
+  root_bundle_->GetAsStream(kSnapshotKey,
+                            base::Bind(&Engine::RunFromSnapshotStream,
+                                       weak_factory_.GetWeakPtr(), path_str));
 }
 
 void Engine::DidCreateIsolate(Dart_Isolate isolate) {
   Internals::Create(isolate,
                     CreateServiceProvider(config_.service_provider_context));
 }
 
 void Engine::ScheduleFrame() {
   animator_->RequestFrame();
 }
@@ skipping 12 matching lines @@
 
 void Engine::DidNavigateLocally(const mojo::String& url) {
 }
 
 void Engine::RequestNavigateHistory(int32_t delta) {
   NOTIMPLEMENTED();
 }
 
 }  // namespace shell
 }  // namespace sky