Index: mojo/fetcher/base_application_fetcher.cc |
diff --git a/mojo/fetcher/base_application_fetcher.cc b/mojo/fetcher/base_application_fetcher.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..68909b578f94a67efe93c62cdafe9223e8b28895 |
--- /dev/null |
+++ b/mojo/fetcher/base_application_fetcher.cc |
@@ -0,0 +1,99 @@ |
+// 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 "mojo/fetcher/base_application_fetcher.h" |
+ |
+#include "mojo/fetcher/about_fetcher.h" |
+#include "mojo/fetcher/local_fetcher.h" |
+#include "mojo/fetcher/network_fetcher.h" |
+#include "mojo/fetcher/switches.h" |
+#include "mojo/fetcher/update_fetcher.h" |
+#include "mojo/shell/application_manager.h" |
+#include "mojo/shell/query_util.h" |
+#include "mojo/util/filename_util.h" |
+#include "url/gurl.h" |
+ |
+namespace mojo { |
+namespace fetcher { |
+ |
+BaseApplicationFetcher::BaseApplicationFetcher( |
+ const base::FilePath& shell_file_root) |
+ : application_manager_(nullptr), |
+ disable_cache_(base::CommandLine::ForCurrentProcess()->HasSwitch( |
+ switches::kDisableCache)) { |
+ if (!shell_file_root.empty()) { |
+ GURL mojo_root_file_url = |
+ util::FilePathToFileURL(shell_file_root).Resolve(std::string()); |
+ url_resolver_.reset(new URLResolver(mojo_root_file_url)); |
+ } |
+} |
+ |
+BaseApplicationFetcher::~BaseApplicationFetcher() { |
+} |
+ |
+void BaseApplicationFetcher::SetApplicationManager( |
+ shell::ApplicationManager* manager) { |
+ application_manager_ = manager; |
+} |
+ |
+GURL BaseApplicationFetcher::ResolveURL(const GURL& url) { |
+ return url_resolver_.get() ? url_resolver_->ResolveMojoURL(url) : url; |
+} |
+ |
+void BaseApplicationFetcher::FetchRequest( |
+ URLRequestPtr request, |
+ const shell::Fetcher::FetchCallback& loader_callback) { |
+ GURL url(request->url); |
+ if (url.SchemeIs(AboutFetcher::kAboutScheme)) { |
+ AboutFetcher::Start(url, loader_callback); |
+ return; |
+ } |
+ |
+ GURL resolved_url = ResolveURL(url); |
+ |
+ if (resolved_url.SchemeIsFile()) { |
+ // LocalFetcher uses the network service to infer MIME types from URLs. |
+ // Skip this for mojo URLs to avoid recursively loading the network service. |
+ if (!network_service_ && !url.SchemeIs("mojo")) { |
+ application_manager_->ConnectToService(GURL("mojo:network_service"), |
+ &network_service_); |
+ } |
+ // Ownership of this object is transferred to |loader_callback|. |
+ // TODO(beng): this is eff'n weird. |
+ new LocalFetcher( |
+ network_service_.get(), resolved_url, |
+ shell::GetBaseURLAndQuery(resolved_url, nullptr), |
+ loader_callback); |
+ return; |
+ } |
+ |
+#if 0 |
+ // TODO(beng): figure out how this should be integrated now that mapped_url |
+ // is toast. |
+ // TODO(scottmg): to quote someone I know, if you liked this you shouldda put |
+ // a test on it. |
+ if (url.SchemeIs("mojo") && |
+ base::CommandLine::ForCurrentProcess()->HasSwitch( |
+ switches::kUseUpdater)) { |
+ application_manager_->ConnectToService(GURL("mojo:updater"), &updater_); |
+ // Ownership of this object is transferred to |loader_callback|. |
+ // TODO(beng): this is eff'n weird. |
+ new UpdateFetcher(url, updater_.get(), loader_callback); |
+ return; |
+ } |
+#endif |
+ |
+ if (!url_loader_factory_) { |
+ application_manager_->ConnectToService(GURL("mojo:network_service"), |
+ &url_loader_factory_); |
+ } |
+ |
+ // Ownership of this object is transferred to |loader_callback|. |
+ // TODO(beng): this is eff'n weird. |
+ new NetworkFetcher(disable_cache_, request.Pass(), url_loader_factory_.get(), |
+ loader_callback); |
+} |
+ |
+} // namespace fetcher |
+} // namespace mojo |