| OLD | NEW |
| (Empty) |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #ifndef CHROME_BROWSER_EXTENSIONS_API_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_ | |
| 6 #define CHROME_BROWSER_EXTENSIONS_API_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_ | |
| 7 | |
| 8 #include <map> | |
| 9 #include <string> | |
| 10 #include <vector> | |
| 11 | |
| 12 #include "base/memory/singleton.h" | |
| 13 #include "base/memory/weak_ptr.h" | |
| 14 #include "base/scoped_observer.h" | |
| 15 #include "components/keyed_service/content/browser_context_keyed_service_factory
.h" | |
| 16 #include "components/keyed_service/core/keyed_service.h" | |
| 17 #include "storage/browser/fileapi/file_system_url.h" | |
| 18 #include "storage/browser/fileapi/watcher_manager.h" | |
| 19 | |
| 20 namespace content { | |
| 21 class BrowserContext; | |
| 22 } // namespace content | |
| 23 | |
| 24 namespace storage { | |
| 25 class FileSystemContext; | |
| 26 } // namespace storage | |
| 27 | |
| 28 namespace extensions { | |
| 29 struct Event; | |
| 30 class EventRouter; | |
| 31 | |
| 32 // Watches entries (files and directories) for changes. Created per profile. | |
| 33 // TODO(mtomasz): Add support for watching files. | |
| 34 class EntryWatcherService : public KeyedService, | |
| 35 public storage::WatcherManager::Observer { | |
| 36 public: | |
| 37 typedef base::Callback< | |
| 38 void(const std::string& extension_id, scoped_ptr<Event> event)> | |
| 39 DispatchEventImplCallback; | |
| 40 | |
| 41 typedef base::Callback<storage::FileSystemContext*( | |
| 42 const std::string& extension_id, | |
| 43 content::BrowserContext* context)> GetFileSystemContextImplCallback; | |
| 44 | |
| 45 explicit EntryWatcherService(content::BrowserContext* context); | |
| 46 virtual ~EntryWatcherService(); | |
| 47 | |
| 48 // Watches a directory. Only one watcher can be set per the same |url| and | |
| 49 // |extension_id|. | |
| 50 void WatchDirectory(const std::string& extension_id, | |
| 51 const storage::FileSystemURL& url, | |
| 52 bool recursive, | |
| 53 const storage::WatcherManager::StatusCallback& callback); | |
| 54 | |
| 55 // Unwatches an entry (file or directory). | |
| 56 void UnwatchEntry(const std::string& extension_id, | |
| 57 const storage::FileSystemURL& url, | |
| 58 const storage::WatcherManager::StatusCallback& callback); | |
| 59 | |
| 60 std::vector<storage::FileSystemURL> GetWatchedEntries( | |
| 61 const std::string& extension_id); | |
| 62 | |
| 63 // storage::WatcherManager::Observer overrides. | |
| 64 virtual void OnEntryChanged(const storage::FileSystemURL& url) override; | |
| 65 virtual void OnEntryRemoved(const storage::FileSystemURL& url) override; | |
| 66 | |
| 67 // Sets a custom dispatcher for tests in order to be able to verify dispatched | |
| 68 // events. | |
| 69 void SetDispatchEventImplForTesting( | |
| 70 const DispatchEventImplCallback& callback); | |
| 71 | |
| 72 // Sets a custom context getter for tests in order to inject a testing | |
| 73 // file system context implementation. | |
| 74 void SetGetFileSystemContextImplForTesting( | |
| 75 const GetFileSystemContextImplCallback& callback); | |
| 76 | |
| 77 private: | |
| 78 // Holds information about an active entry watcher. | |
| 79 struct EntryWatcher { | |
| 80 EntryWatcher(); | |
| 81 EntryWatcher(const storage::FileSystemURL& url, | |
| 82 bool directory, | |
| 83 bool recursive); | |
| 84 ~EntryWatcher(); | |
| 85 | |
| 86 storage::FileSystemURL url; | |
| 87 bool directory; | |
| 88 bool recursive; | |
| 89 }; | |
| 90 | |
| 91 // Map from a file system url to a map from an extension id to an entry | |
| 92 // watcher descriptor. | |
| 93 typedef std::map<storage::FileSystemURL, | |
| 94 std::map<std::string, EntryWatcher>, | |
| 95 storage::FileSystemURL::Comparator> WatcherMap; | |
| 96 | |
| 97 // Called when adding a directory watcher is completed with either a success | |
| 98 // or an error. | |
| 99 void OnWatchDirectoryCompleted( | |
| 100 storage::WatcherManager* watcher_manager, | |
| 101 const std::string& extension_id, | |
| 102 const storage::FileSystemURL& url, | |
| 103 bool recursive, | |
| 104 const storage::WatcherManager::StatusCallback& callback, | |
| 105 base::File::Error result); | |
| 106 | |
| 107 // Called when removing a watcher is completed with either a success or an | |
| 108 // error. | |
| 109 void OnUnwatchEntryCompleted( | |
| 110 const std::string& extension_id, | |
| 111 const storage::FileSystemURL& url, | |
| 112 const storage::WatcherManager::StatusCallback& callback, | |
| 113 base::File::Error result); | |
| 114 | |
| 115 content::BrowserContext* context_; | |
| 116 WatcherMap watchers_; | |
| 117 DispatchEventImplCallback dispatch_event_impl_; | |
| 118 GetFileSystemContextImplCallback get_file_system_context_impl_; | |
| 119 ScopedObserver<storage::WatcherManager, storage::WatcherManager::Observer> | |
| 120 observing_; | |
| 121 base::WeakPtrFactory<EntryWatcherService> weak_ptr_factory_; | |
| 122 | |
| 123 DISALLOW_COPY_AND_ASSIGN(EntryWatcherService); | |
| 124 }; | |
| 125 | |
| 126 } // namespace extensions | |
| 127 | |
| 128 #endif // CHROME_BROWSER_EXTENSIONS_API_FILE_SYSTEM_ENTRY_WATCHER_SERVICE_H_ | |
| OLD | NEW |