[ew] Add basic classes.

chrome/browser/file_system/entry_watcher_service.h

+// 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 CHROME_BROWSER_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_
+#define CHROME_BROWSER_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_
+
+#include <map>
+#include <string>
+#include <vector>
+
+#include "base/memory/singleton.h"
+#include "base/memory/weak_ptr.h"
+#include "base/scoped_observer.h"
+#include "components/keyed_service/content/browser_context_keyed_service_factory.h"
+#include "components/keyed_service/core/keyed_service.h"
+#include "webkit/browser/fileapi/file_system_url.h"
+#include "webkit/browser/fileapi/watcher_manager.h"
+
+namespace content {
+class BrowserContext;
+}  // namespace content
+
+namespace extensions {
+struct Event;
+class EventRouter;
+}  // namespace extensions
+
+// Watches entries (files and directories) for changes. Created per profile.
+// TODO(mtomasz): Add support for watching files.
+class EntryWatcherService : public KeyedService,
+                            public fileapi::WatcherManager::Observer {
+ public:
+  typedef base::Callback<void(const std::string& extension_id,
+                              scoped_ptr<extensions::Event> event)>
+      DispatchEventImplCallback;
+
+  typedef base::Callback<fileapi::FileSystemContext*(
+      const std::string& extension_id,
+      content::BrowserContext* context)> GetFileSystemContextImplCallback;
+
+  typedef base::Callback<void(std::vector<fileapi::FileSystemURL>)>
+      GetWatchedEntriesCallback;
+
+  explicit EntryWatcherService(content::BrowserContext* context);
+  virtual ~EntryWatcherService();
+
+  // Watches a directory. Only one watcher can be set per the same |url| and
+  // |extension_id|.
+  void WatchDirectory(const std::string& extension_id,
+                      const fileapi::FileSystemURL& url,
+                      bool recursive,
+                      const fileapi::WatcherManager::StatusCallback& callback);
+
+  // Unwatches an entry (file or directory).
+  void UnwatchEntry(const std::string& extension_id,
+                    const fileapi::FileSystemURL& url,
+                    const fileapi::WatcherManager::StatusCallback& callback);
+
+  std::vector<fileapi::FileSystemURL> GetWatchedEntries(
+      const std::string& extension_id);
+
+  // fileapi::WatcherManager::Observer overrides.
+  virtual void OnEntryChanged(const fileapi::FileSystemURL& url) OVERRIDE;
+  virtual void OnEntryRemoved(const fileapi::FileSystemURL& url) OVERRIDE;
+
+  // Sets a custom dispatcher for tests in order to be able to verify dispatched
+  // events.
+  void SetDispatchEventImplForTesting(
+      const DispatchEventImplCallback& callback);
+
+  // Sets a custom context getter for tests in order to inject a testing
+  // file system context implementation.
+  void SetGetFileSystemContextImplForTesting(
+      const GetFileSystemContextImplCallback& callback);
+
+ private:
+  // Holds information about an entry watcher.
+  struct EntryWatcher {
+    EntryWatcher();
+    EntryWatcher(const fileapi::FileSystemURL& url,
+                 bool directory,
+                 bool recursive);
+    ~EntryWatcher();
+
+    fileapi::FileSystemURL url;
+    bool directory;
+    bool recursive;
+  };
+
+  // Map from a file system url to a map from an extension id to an entry
+  // watcher descriptor. Note, that GURL is used instead of fileapi::
+  // FileSystemURL, since the second one doesn't work well with stl containers.
+  typedef std::map<GURL, std::map<std::string, EntryWatcher> > WatcherMap;
+
+  // Called when adding a directory watcher is completed with either a success
+  // or an error.
+  void OnWatchDirectoryCompleted(
+      const std::string& extension_id,
+      const fileapi::FileSystemURL& url,
+      bool recursive,
+      const fileapi::WatcherManager::StatusCallback& callback,
+      base::File::Error result);
+
+  // Called when removing a watcher is completed with either a success or an
+  // error.
+  void OnUnwatchEntryCompleted(
+      const std::string& extension_id,
+      const fileapi::FileSystemURL& url,
+      const fileapi::WatcherManager::StatusCallback& callback,
+      base::File::Error result);
+
+  content::BrowserContext* context_;
+  WatcherMap watchers_;
+  DispatchEventImplCallback dispatch_event_impl_;
+  GetFileSystemContextImplCallback get_file_system_context_impl_;
+  ScopedObserver<fileapi::WatcherManager, fileapi::WatcherManager::Observer>
+      observing_;
+  base::WeakPtrFactory<EntryWatcherService> weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(EntryWatcherService);
+};
+
+#endif  // CHROME_BROWSER_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_