Teach sky_viewer about the new main.dart hotness

sky/engine/core/script/dart_loader.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/engine/config.h"
 #include "sky/engine/core/script/dart_loader.h"
 
 #include "base/callback.h"
 #include "base/trace_event/trace_event.h"
 #include "mojo/common/data_pipe_drainer.h"
@@ skipping 29 matching lines @@
 }
 
 }  // namespace
 
 // A DartLoader::Job represents a network load. It fetches data from the network
 // and buffers the data in Vector. To cancel the job, delete this object.
 class DartLoader::Job : public DartDependency,
                         public MojoFetcher::Client,
                         public DataPipeDrainer::Client {
  public:
-  Job(DartLoader* loader, const KURL& url)
-      : loader_(loader), url_(url), fetcher_(this, url) {}
+  Job(DartLoader* loader, const KURL& url, mojo::URLResponsePtr response)
+      : loader_(loader), url_(url)
+  {
+    if (!response) {
+      fetcher_ = adoptPtr(new MojoFetcher(this, url));
+    } else {
+      OnReceivedResponse(response.Pass());
+    }
+  }
 
   const KURL& url() const { return url_; }
 
  protected:
   DartLoader* loader_;
   // TODO(abarth): Should we be using SharedBuffer to buffer the data?
   Vector<uint8_t> buffer_;
 
  private:
   // MojoFetcher::Client
   void OnReceivedResponse(mojo::URLResponsePtr response) override {
     if (response->status_code != 200) {
       loader_->DidFailJob(this);
       return;
     }
     drainer_ = adoptPtr(new DataPipeDrainer(this, response->body.Pass()));
   }
 
   // DataPipeDrainer::Client
   void OnDataAvailable(const void* data, size_t num_bytes) override {
     buffer_.append(static_cast<const uint8_t*>(data), num_bytes);
   }
   // Subclasses must implement OnDataComplete.
 
   KURL url_;
-  MojoFetcher fetcher_;
+  OwnPtr<MojoFetcher> fetcher_;
   OwnPtr<DataPipeDrainer> drainer_;
 };
 
 class DartLoader::ImportJob : public Job {
  public:
-  ImportJob(DartLoader* loader, const KURL& url)
-    : Job(loader, url) {
+  ImportJob(DartLoader* loader, const KURL& url, mojo::URLResponsePtr response = nullptr)
+    : Job(loader, url, response.Pass()) {
     TRACE_EVENT_ASYNC_BEGIN1("sky", "DartLoader::ImportJob", this,
                              "url", url.string().ascii().toStdString());
   }
 
  private:
   // DataPipeDrainer::Client
   void OnDataComplete() override {
     TRACE_EVENT_ASYNC_END0("sky", "DartLoader::ImportJob", this);
     loader_->DidCompleteImportJob(this, buffer_);
   }
 };
 
 class DartLoader::SourceJob : public Job {
  public:
   SourceJob(DartLoader* loader, const KURL& url, Dart_Handle library)
-      : Job(loader, url), library_(loader->dart_state(), library) {
+      : Job(loader, url, nullptr), library_(loader->dart_state(), library) {
     TRACE_EVENT_ASYNC_BEGIN1("sky", "DartLoader::SourceJob", this,
                              "url", url.string().ascii().toStdString());
   }
 
   Dart_PersistentHandle library() const { return library_.value(); }
 
  private:
   // DataPipeDrainer::Client
   void OnDataComplete() override {
     TRACE_EVENT_ASYNC_END0("sky", "DartLoader::SourceJob", this);
@@ skipping 113 matching lines @@
 
 void DartLoader::WaitForDependencies(
     const HashSet<DartDependency*>& dependencies,
     const base::Closure& callback) {
   if (dependencies.isEmpty())
     return callback.Run();
   dependency_watchers_.add(
       adoptPtr(new DependencyWatcher(dependencies, callback)));
 }
 
-void DartLoader::LoadLibrary(const KURL& url) {
+void DartLoader::LoadLibrary(const KURL& url, mojo::URLResponsePtr response) {
   const auto& result = pending_libraries_.add(url.string(), nullptr);
   if (result.isNewEntry) {
     OwnPtr<Job> job = adoptPtr(new ImportJob(this, url));
     result.storedValue->value = job.get();
     jobs_.add(job.release());
   }
   if (dependency_catcher_)
     dependency_catcher_->AddDependency(result.storedValue->value);
 }
 
@@ skipping 51 matching lines @@
 
   WatcherSignaler watcher_signaler(*this, job);
 
   LOG(ERROR) << "Library Load failed: " << job->url().string().utf8().data();
   // TODO(eseidel): Call Dart_LibraryHandleError in the SourceJob case?
 
   jobs_.remove(job);
 }
 
 }  // namespace blink