[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 <set>
+#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"
+
+class Profile;
+
+namespace extensions {
+
+struct Event;
+class EventRouter;
+
+// 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<
+      bool(const std::string& extension_id, scoped_ptr<Event> event)>
+      DispatchEventImplCallback;
+
+  typedef base::Callback<
+      fileapi::FileSystemContext*(const std::string& extension_id,
+                                  Profile* profile)> GetContextImplCallback;
+
+  typedef base::Callback<void(std::vector<fileapi::FileSystemURL>)>
+      GetWatchedEntriesCallback;
+
+  explicit EntryWatcherService(Profile* profile);
+  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 SetGetContextImplForTesting(const GetContextImplCallback& callback);
+
+ private:
+  // Holds an information about an entry watcher.
+  struct EntryWatcher {
+   public:

[tzik, 2014/08/12 10:40:46]

not needed?

[mtomasz, 2014/08/13 03:08:44]

Done.

+    EntryWatcher();
+    EntryWatcher(const fileapi::FileSystemURL& url,
+                 bool directory,
+                 bool recursive);
+    ~EntryWatcher();
+
+    fileapi::FileSystemURL url;
+    bool directory;
+    bool recursive;
+  };
+
+  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);
+
+  Profile* profile_;

[tzik, 2014/08/12 10:40:46]

All usage of this |profile_| is as a BrowserContext. Can we change the type to
it?

[mtomasz, 2014/08/13 03:08:44]

Done.

+  WatcherMap watchers_;
+  DispatchEventImplCallback dispatch_event_impl_;
+  GetContextImplCallback get_context_impl_;
+  ScopedObserver<fileapi::WatcherManager, fileapi::WatcherManager::Observer>
+      observing_;
+  base::WeakPtrFactory<EntryWatcherService> weak_ptr_factory_;
+
+  DISALLOW_COPY_AND_ASSIGN(EntryWatcherService);
+};
+
+class EntryWatcherServiceFactory : public BrowserContextKeyedServiceFactory {
+ public:
+  // Returns a service instance singleton, after creating it (if necessary).
+  static EntryWatcherService* Get(content::BrowserContext* context);
+
+  // Returns a service instance for the context if exists. Otherwise, returns
+  // NULL.
+  static EntryWatcherService* FindExisting(content::BrowserContext* context);
+
+  // Gets a singleton instance of the factory.
+  static EntryWatcherServiceFactory* GetInstance();
+
+ private:
+  friend struct DefaultSingletonTraits<EntryWatcherServiceFactory>;
+
+  EntryWatcherServiceFactory();
+  virtual ~EntryWatcherServiceFactory();
+
+  // BrowserContextKeyedServiceFactory overrides:
+  virtual KeyedService* BuildServiceInstanceFor(
+      content::BrowserContext* profile) const OVERRIDE;
+  virtual bool ServiceIsCreatedWithBrowserContext() const OVERRIDE;
+
+  DISALLOW_COPY_AND_ASSIGN(EntryWatcherServiceFactory);
+};
+
+}  // namespace extensions
+
+#endif  // CHROME_BROWSER_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_