Get mojo_shell building inside chromium checkout.

mojo/shell/application_manager/application_manager.h

Index: mojo/shell/application_manager/application_manager.h
diff --git a/mojo/shell/application_manager/application_manager.h b/mojo/shell/application_manager/application_manager.h
new file mode 100644
index 0000000000000000000000000000000000000000..d0d3a40d44c8a1a164c75c1d36b3850ed960ece4
--- /dev/null
+++ b/mojo/shell/application_manager/application_manager.h
@@ -0,0 +1,239 @@
+// Copyright 2014 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.
+
+#ifndef SHELL_APPLICATION_MANAGER_APPLICATION_MANAGER_H_
+#define SHELL_APPLICATION_MANAGER_APPLICATION_MANAGER_H_
+
+#include <map>
+
+#include "base/macros.h"
+#include "base/memory/scoped_ptr.h"
+#include "base/memory/scoped_vector.h"
+#include "base/memory/weak_ptr.h"
+#include "mojo/public/cpp/bindings/interface_request.h"
+#include "mojo/public/interfaces/application/application.mojom.h"
+#include "mojo/public/interfaces/application/service_provider.mojom.h"
+#include "mojo/services/network/public/interfaces/network_service.mojom.h"
+#include "mojo/shell/application_manager/application_loader.h"
+#include "mojo/shell/application_manager/identity.h"
+#include "mojo/shell/application_manager/native_runner.h"
+#include "mojo/shell/native_application_support.h"
+#include "url/gurl.h"
+
+namespace base {
+class FilePath;
+class SequencedWorkerPool;
+}
+
+namespace mojo {
+namespace shell {
+
+class Fetcher;
+class ShellImpl;
+
+class ApplicationManager {
+ public:
+  class Delegate {
+   public:
+    virtual ~Delegate();
+    virtual GURL ResolveURL(const GURL& url);
+    virtual GURL ResolveMappings(const GURL& url);
+  };
+
+  // API for testing.
+  class TestAPI {
+   public:
+    explicit TestAPI(ApplicationManager* manager);
+    ~TestAPI();
+
+    // Returns true if the shared instance has been created.
+    static bool HasCreatedInstance();
+    // Returns true if there is a ShellImpl for this URL.
+    bool HasFactoryForURL(const GURL& url) const;
+
+   private:
+    ApplicationManager* manager_;
+
+    DISALLOW_COPY_AND_ASSIGN(TestAPI);
+  };
+
+  explicit ApplicationManager(Delegate* delegate);
+  ~ApplicationManager();
+
+  // Loads a service if necessary and establishes a new client connection.
+  void ConnectToApplication(const GURL& application_url,
+                            const GURL& requestor_url,
+                            InterfaceRequest<ServiceProvider> services,
+                            ServiceProviderPtr exposed_services,
+                            const base::Closure& on_application_end);
+
+  template <typename Interface>
+  inline void ConnectToService(const GURL& application_url,
+                               InterfacePtr<Interface>* ptr) {
+    ScopedMessagePipeHandle service_handle =
+        ConnectToServiceByName(application_url, Interface::Name_);
+    ptr->Bind(service_handle.Pass());
+  }
+
+  ScopedMessagePipeHandle ConnectToServiceByName(
+      const GURL& application_url,
+      const std::string& interface_name);
+
+  void RegisterContentHandler(const std::string& mime_type,
+                              const GURL& content_handler_url);
+
+  void RegisterExternalApplication(const GURL& application_url,
+                                   const std::vector<std::string>& args,
+                                   ApplicationPtr application);
+
+  // Sets the default Loader to be used if not overridden by SetLoaderForURL()
+  // or SetLoaderForScheme().
+  void set_default_loader(scoped_ptr<ApplicationLoader> loader) {
+    default_loader_ = loader.Pass();
+  }
+  void set_native_runner_factory(
+      scoped_ptr<NativeRunnerFactory> runner_factory) {
+    native_runner_factory_ = runner_factory.Pass();
+  }
+  void set_blocking_pool(base::SequencedWorkerPool* blocking_pool) {
+    blocking_pool_ = blocking_pool;
+  }
+  void set_disable_cache(bool disable_cache) { disable_cache_ = disable_cache; }
+  // Sets a Loader to be used for a specific url.
+  void SetLoaderForURL(scoped_ptr<ApplicationLoader> loader, const GURL& url);
+  // Sets a Loader to be used for a specific url scheme.
+  void SetLoaderForScheme(scoped_ptr<ApplicationLoader> loader,
+                          const std::string& scheme);
+  // These strings will be passed to the Initialize() method when an Application
+  // is instantiated.
+  // TODO(vtl): Maybe we should store/compare resolved URLs, like
+  // SetNativeOptionsForURL() below?
+  void SetArgsForURL(const std::vector<std::string>& args, const GURL& url);
+  // These options will be used in running any native application at |url|
+  // (which shouldn't contain a query string). (|url| will be mapped and
+  // resolved, and any application whose base resolved URL matches it will have
+  // |options| applied.)
+  // TODO(vtl): This may not do what's desired if the resolved URL results in an
+  // HTTP redirect. Really, we want options to be identified with a particular
+  // implementation, maybe via a signed manifest or something like that.
+  void SetNativeOptionsForURL(const NativeRunnerFactory::Options& options,
+                              const GURL& url);
+
+  // Destroys all Shell-ends of connections established with Applications.
+  // Applications connected by this ApplicationManager will observe pipe errors
+  // and have a chance to shutdown.
+  void TerminateShellConnections();
+
+  // Removes a ShellImpl when it encounters an error.
+  void OnShellImplError(ShellImpl* shell_impl);
+
+ private:
+  class ContentHandlerConnection;
+
+  typedef std::map<std::string, ApplicationLoader*> SchemeToLoaderMap;
+  typedef std::map<GURL, ApplicationLoader*> URLToLoaderMap;
+  typedef std::map<Identity, ShellImpl*> IdentityToShellImplMap;
+  typedef std::map<GURL, ContentHandlerConnection*> URLToContentHandlerMap;
+  typedef std::map<GURL, std::vector<std::string>> URLToArgsMap;
+  typedef std::map<std::string, GURL> MimeTypeToURLMap;
+  typedef std::map<GURL, NativeRunnerFactory::Options> URLToNativeOptionsMap;
+
+  void ConnectToApplicationWithParameters(
+      const GURL& application_url,
+      const GURL& requestor_url,
+      InterfaceRequest<ServiceProvider> services,
+      ServiceProviderPtr exposed_services,
+      const base::Closure& on_application_end,
+      const std::vector<std::string>& pre_redirect_parameters);
+
+  bool ConnectToRunningApplication(const GURL& resolved_url,
+                                   const GURL& requestor_url,
+                                   InterfaceRequest<ServiceProvider>* services,
+                                   ServiceProviderPtr* exposed_services);
+
+  bool ConnectToApplicationWithLoader(
+      const GURL& resolved_url,
+      const GURL& requestor_url,
+      InterfaceRequest<ServiceProvider>* services,
+      ServiceProviderPtr* exposed_services,
+      const base::Closure& on_application_end,
+      const std::vector<std::string>& parameters,
+      ApplicationLoader* loader);
+
+  InterfaceRequest<Application> RegisterShell(
+      // The URL after resolution and redirects, including the querystring.
+      const GURL& resolved_url,
+      const GURL& requestor_url,
+      InterfaceRequest<ServiceProvider> services,
+      ServiceProviderPtr exposed_services,
+      const base::Closure& on_application_end,
+      const std::vector<std::string>& parameters);
+
+  ShellImpl* GetShellImpl(const GURL& url);
+
+  void ConnectToClient(ShellImpl* shell_impl,
+                       const GURL& resolved_url,
+                       const GURL& requestor_url,
+                       InterfaceRequest<ServiceProvider> services,
+                       ServiceProviderPtr exposed_services);
+
+  void HandleFetchCallback(const GURL& requestor_url,
+                           InterfaceRequest<ServiceProvider> services,
+                           ServiceProviderPtr exposed_services,
+                           const base::Closure& on_application_end,
+                           const std::vector<std::string>& parameters,
+                           NativeApplicationCleanup cleanup,
+                           scoped_ptr<Fetcher> fetcher);
+
+  void RunNativeApplication(InterfaceRequest<Application> application_request,
+                            const NativeRunnerFactory::Options& options,
+                            NativeApplicationCleanup cleanup,
+                            scoped_ptr<Fetcher> fetcher,
+                            const base::FilePath& file_path,
+                            bool path_exists);
+
+  void LoadWithContentHandler(const GURL& content_handler_url,
+                              InterfaceRequest<Application> application_request,
+                              URLResponsePtr url_response);
+
+  // Returns the appropriate loader for |url|, or null if there is no loader
+  // configured for the URL.
+  ApplicationLoader* GetLoaderForURL(const GURL& url);
+
+  // Removes a ContentHandler when it encounters an error.
+  void OnContentHandlerError(ContentHandlerConnection* content_handler);
+
+  // Returns the arguments for the given url.
+  std::vector<std::string> GetArgsForURL(const GURL& url);
+
+  void CleanupRunner(NativeRunner* runner);
+
+  Delegate* const delegate_;
+  // Loader management.
+  // Loaders are chosen in the order they are listed here.
+  URLToLoaderMap url_to_loader_;
+  SchemeToLoaderMap scheme_to_loader_;
+  scoped_ptr<ApplicationLoader> default_loader_;
+  scoped_ptr<NativeRunnerFactory> native_runner_factory_;
+
+  IdentityToShellImplMap identity_to_shell_impl_;
+  URLToContentHandlerMap url_to_content_handler_;
+  URLToArgsMap url_to_args_;
+  // Note: The keys are URLs after mapping and resolving.
+  URLToNativeOptionsMap url_to_native_options_;
+
+  base::SequencedWorkerPool* blocking_pool_;
+  NetworkServicePtr network_service_;
+  MimeTypeToURLMap mime_type_to_url_;
+  ScopedVector<NativeRunner> native_runners_;
+  bool disable_cache_;
+  base::WeakPtrFactory<ApplicationManager> weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(ApplicationManager);
+};
+
+}  // namespace shell
+}  // namespace mojo
+
+#endif  // SHELL_APPLICATION_MANAGER_APPLICATION_MANAGER_H_