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 ~EntryWatcherService() override; | |
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 void OnEntryChanged(const storage::FileSystemURL& url) override; | |
65 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 |