| 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 #include "apps/app_window_geometry_cache.h" | |
| 6 | |
| 7 #include "base/bind.h" | |
| 8 #include "base/stl_util.h" | |
| 9 #include "base/strings/string_number_conversions.h" | |
| 10 #include "components/keyed_service/content/browser_context_dependency_manager.h" | |
| 11 #include "extensions/browser/extension_prefs.h" | |
| 12 #include "extensions/browser/extension_prefs_factory.h" | |
| 13 #include "extensions/browser/extension_registry.h" | |
| 14 #include "extensions/browser/extensions_browser_client.h" | |
| 15 #include "extensions/common/extension.h" | |
| 16 | |
| 17 namespace { | |
| 18 | |
| 19 // The timeout in milliseconds before we'll persist window geometry to the | |
| 20 // StateStore. | |
| 21 const int kSyncTimeoutMilliseconds = 1000; | |
| 22 | |
| 23 } // namespace | |
| 24 | |
| 25 namespace apps { | |
| 26 | |
| 27 AppWindowGeometryCache::AppWindowGeometryCache( | |
| 28 content::BrowserContext* context, | |
| 29 extensions::ExtensionPrefs* prefs) | |
| 30 : prefs_(prefs), | |
| 31 sync_delay_(base::TimeDelta::FromMilliseconds(kSyncTimeoutMilliseconds)), | |
| 32 extension_registry_observer_(this) { | |
| 33 extension_registry_observer_.Add(extensions::ExtensionRegistry::Get(context)); | |
| 34 } | |
| 35 | |
| 36 AppWindowGeometryCache::~AppWindowGeometryCache() {} | |
| 37 | |
| 38 // static | |
| 39 AppWindowGeometryCache* AppWindowGeometryCache::Get( | |
| 40 content::BrowserContext* context) { | |
| 41 return Factory::GetForContext(context, true /* create */); | |
| 42 } | |
| 43 | |
| 44 void AppWindowGeometryCache::SaveGeometry(const std::string& extension_id, | |
| 45 const std::string& window_id, | |
| 46 const gfx::Rect& bounds, | |
| 47 const gfx::Rect& screen_bounds, | |
| 48 ui::WindowShowState window_state) { | |
| 49 ExtensionData& extension_data = cache_[extension_id]; | |
| 50 | |
| 51 // If we don't have any unsynced changes and this is a duplicate of what's | |
| 52 // already in the cache, just ignore it. | |
| 53 if (extension_data[window_id].bounds == bounds && | |
| 54 extension_data[window_id].window_state == window_state && | |
| 55 extension_data[window_id].screen_bounds == screen_bounds && | |
| 56 !ContainsKey(unsynced_extensions_, extension_id)) | |
| 57 return; | |
| 58 | |
| 59 base::Time now = base::Time::Now(); | |
| 60 | |
| 61 extension_data[window_id].bounds = bounds; | |
| 62 extension_data[window_id].screen_bounds = screen_bounds; | |
| 63 extension_data[window_id].window_state = window_state; | |
| 64 extension_data[window_id].last_change = now; | |
| 65 | |
| 66 if (extension_data.size() > kMaxCachedWindows) { | |
| 67 ExtensionData::iterator oldest = extension_data.end(); | |
| 68 // Too many windows in the cache, find the oldest one to remove. | |
| 69 for (ExtensionData::iterator it = extension_data.begin(); | |
| 70 it != extension_data.end(); | |
| 71 ++it) { | |
| 72 // Don't expunge the window that was just added. | |
| 73 if (it->first == window_id) | |
| 74 continue; | |
| 75 | |
| 76 // If time is in the future, reset it to now to minimize weirdness. | |
| 77 if (it->second.last_change > now) | |
| 78 it->second.last_change = now; | |
| 79 | |
| 80 if (oldest == extension_data.end() || | |
| 81 it->second.last_change < oldest->second.last_change) | |
| 82 oldest = it; | |
| 83 } | |
| 84 extension_data.erase(oldest); | |
| 85 } | |
| 86 | |
| 87 unsynced_extensions_.insert(extension_id); | |
| 88 | |
| 89 // We don't use Reset() because the timer may not yet be running. | |
| 90 // (In that case Stop() is a no-op.) | |
| 91 sync_timer_.Stop(); | |
| 92 sync_timer_.Start( | |
| 93 FROM_HERE, sync_delay_, this, &AppWindowGeometryCache::SyncToStorage); | |
| 94 } | |
| 95 | |
| 96 void AppWindowGeometryCache::SyncToStorage() { | |
| 97 std::set<std::string> tosync; | |
| 98 tosync.swap(unsynced_extensions_); | |
| 99 for (std::set<std::string>::const_iterator it = tosync.begin(), | |
| 100 eit = tosync.end(); | |
| 101 it != eit; | |
| 102 ++it) { | |
| 103 const std::string& extension_id = *it; | |
| 104 const ExtensionData& extension_data = cache_[extension_id]; | |
| 105 | |
| 106 scoped_ptr<base::DictionaryValue> dict(new base::DictionaryValue); | |
| 107 for (ExtensionData::const_iterator it = extension_data.begin(), | |
| 108 eit = extension_data.end(); | |
| 109 it != eit; | |
| 110 ++it) { | |
| 111 base::DictionaryValue* value = new base::DictionaryValue; | |
| 112 const gfx::Rect& bounds = it->second.bounds; | |
| 113 const gfx::Rect& screen_bounds = it->second.screen_bounds; | |
| 114 DCHECK(!bounds.IsEmpty()); | |
| 115 DCHECK(!screen_bounds.IsEmpty()); | |
| 116 DCHECK(it->second.window_state != ui::SHOW_STATE_DEFAULT); | |
| 117 value->SetInteger("x", bounds.x()); | |
| 118 value->SetInteger("y", bounds.y()); | |
| 119 value->SetInteger("w", bounds.width()); | |
| 120 value->SetInteger("h", bounds.height()); | |
| 121 value->SetInteger("screen_bounds_x", screen_bounds.x()); | |
| 122 value->SetInteger("screen_bounds_y", screen_bounds.y()); | |
| 123 value->SetInteger("screen_bounds_w", screen_bounds.width()); | |
| 124 value->SetInteger("screen_bounds_h", screen_bounds.height()); | |
| 125 value->SetInteger("state", it->second.window_state); | |
| 126 value->SetString( | |
| 127 "ts", base::Int64ToString(it->second.last_change.ToInternalValue())); | |
| 128 dict->SetWithoutPathExpansion(it->first, value); | |
| 129 | |
| 130 FOR_EACH_OBSERVER( | |
| 131 Observer, | |
| 132 observers_, | |
| 133 OnGeometryCacheChanged(extension_id, it->first, bounds)); | |
| 134 } | |
| 135 | |
| 136 prefs_->SetGeometryCache(extension_id, dict.Pass()); | |
| 137 } | |
| 138 } | |
| 139 | |
| 140 bool AppWindowGeometryCache::GetGeometry(const std::string& extension_id, | |
| 141 const std::string& window_id, | |
| 142 gfx::Rect* bounds, | |
| 143 gfx::Rect* screen_bounds, | |
| 144 ui::WindowShowState* window_state) { | |
| 145 std::map<std::string, ExtensionData>::const_iterator extension_data_it = | |
| 146 cache_.find(extension_id); | |
| 147 | |
| 148 // Not in the map means loading data for the extension didn't finish yet or | |
| 149 // the cache was not constructed until after the extension was loaded. | |
| 150 // Attempt to load from sync to address the latter case. | |
| 151 if (extension_data_it == cache_.end()) { | |
| 152 LoadGeometryFromStorage(extension_id); | |
| 153 extension_data_it = cache_.find(extension_id); | |
| 154 DCHECK(extension_data_it != cache_.end()); | |
| 155 } | |
| 156 | |
| 157 ExtensionData::const_iterator window_data_it = | |
| 158 extension_data_it->second.find(window_id); | |
| 159 | |
| 160 if (window_data_it == extension_data_it->second.end()) | |
| 161 return false; | |
| 162 | |
| 163 const WindowData& window_data = window_data_it->second; | |
| 164 | |
| 165 // Check for and do not return corrupt data. | |
| 166 if ((bounds && window_data.bounds.IsEmpty()) || | |
| 167 (screen_bounds && window_data.screen_bounds.IsEmpty()) || | |
| 168 (window_state && window_data.window_state == ui::SHOW_STATE_DEFAULT)) | |
| 169 return false; | |
| 170 | |
| 171 if (bounds) | |
| 172 *bounds = window_data.bounds; | |
| 173 if (screen_bounds) | |
| 174 *screen_bounds = window_data.screen_bounds; | |
| 175 if (window_state) | |
| 176 *window_state = window_data.window_state; | |
| 177 return true; | |
| 178 } | |
| 179 | |
| 180 void AppWindowGeometryCache::Shutdown() { SyncToStorage(); } | |
| 181 | |
| 182 AppWindowGeometryCache::WindowData::WindowData() | |
| 183 : window_state(ui::SHOW_STATE_DEFAULT) {} | |
| 184 | |
| 185 AppWindowGeometryCache::WindowData::~WindowData() {} | |
| 186 | |
| 187 void AppWindowGeometryCache::OnExtensionLoaded( | |
| 188 content::BrowserContext* browser_context, | |
| 189 const extensions::Extension* extension) { | |
| 190 LoadGeometryFromStorage(extension->id()); | |
| 191 } | |
| 192 | |
| 193 void AppWindowGeometryCache::OnExtensionUnloaded( | |
| 194 content::BrowserContext* browser_context, | |
| 195 const extensions::Extension* extension, | |
| 196 extensions::UnloadedExtensionInfo::Reason reason) { | |
| 197 SyncToStorage(); | |
| 198 cache_.erase(extension->id()); | |
| 199 } | |
| 200 | |
| 201 void AppWindowGeometryCache::SetSyncDelayForTests(int timeout_ms) { | |
| 202 sync_delay_ = base::TimeDelta::FromMilliseconds(timeout_ms); | |
| 203 } | |
| 204 | |
| 205 void AppWindowGeometryCache::LoadGeometryFromStorage( | |
| 206 const std::string& extension_id) { | |
| 207 ExtensionData& extension_data = cache_[extension_id]; | |
| 208 | |
| 209 const base::DictionaryValue* stored_windows = | |
| 210 prefs_->GetGeometryCache(extension_id); | |
| 211 if (!stored_windows) | |
| 212 return; | |
| 213 | |
| 214 for (base::DictionaryValue::Iterator it(*stored_windows); !it.IsAtEnd(); | |
| 215 it.Advance()) { | |
| 216 // If the cache already contains geometry for this window, don't | |
| 217 // overwrite that information since it is probably the result of an | |
| 218 // application starting up very quickly. | |
| 219 const std::string& window_id = it.key(); | |
| 220 ExtensionData::iterator cached_window = extension_data.find(window_id); | |
| 221 if (cached_window == extension_data.end()) { | |
| 222 const base::DictionaryValue* stored_window; | |
| 223 if (it.value().GetAsDictionary(&stored_window)) { | |
| 224 WindowData& window_data = extension_data[it.key()]; | |
| 225 | |
| 226 int i; | |
| 227 if (stored_window->GetInteger("x", &i)) | |
| 228 window_data.bounds.set_x(i); | |
| 229 if (stored_window->GetInteger("y", &i)) | |
| 230 window_data.bounds.set_y(i); | |
| 231 if (stored_window->GetInteger("w", &i)) | |
| 232 window_data.bounds.set_width(i); | |
| 233 if (stored_window->GetInteger("h", &i)) | |
| 234 window_data.bounds.set_height(i); | |
| 235 if (stored_window->GetInteger("screen_bounds_x", &i)) | |
| 236 window_data.screen_bounds.set_x(i); | |
| 237 if (stored_window->GetInteger("screen_bounds_y", &i)) | |
| 238 window_data.screen_bounds.set_y(i); | |
| 239 if (stored_window->GetInteger("screen_bounds_w", &i)) | |
| 240 window_data.screen_bounds.set_width(i); | |
| 241 if (stored_window->GetInteger("screen_bounds_h", &i)) | |
| 242 window_data.screen_bounds.set_height(i); | |
| 243 if (stored_window->GetInteger("state", &i)) { | |
| 244 window_data.window_state = static_cast<ui::WindowShowState>(i); | |
| 245 } | |
| 246 std::string ts_as_string; | |
| 247 if (stored_window->GetString("ts", &ts_as_string)) { | |
| 248 int64 ts; | |
| 249 if (base::StringToInt64(ts_as_string, &ts)) { | |
| 250 window_data.last_change = base::Time::FromInternalValue(ts); | |
| 251 } | |
| 252 } | |
| 253 } | |
| 254 } | |
| 255 } | |
| 256 } | |
| 257 | |
| 258 /////////////////////////////////////////////////////////////////////////////// | |
| 259 // Factory boilerplate | |
| 260 | |
| 261 // static | |
| 262 AppWindowGeometryCache* AppWindowGeometryCache::Factory::GetForContext( | |
| 263 content::BrowserContext* context, | |
| 264 bool create) { | |
| 265 return static_cast<AppWindowGeometryCache*>( | |
| 266 GetInstance()->GetServiceForBrowserContext(context, create)); | |
| 267 } | |
| 268 | |
| 269 AppWindowGeometryCache::Factory* | |
| 270 AppWindowGeometryCache::Factory::GetInstance() { | |
| 271 return Singleton<AppWindowGeometryCache::Factory>::get(); | |
| 272 } | |
| 273 | |
| 274 AppWindowGeometryCache::Factory::Factory() | |
| 275 : BrowserContextKeyedServiceFactory( | |
| 276 "AppWindowGeometryCache", | |
| 277 BrowserContextDependencyManager::GetInstance()) { | |
| 278 DependsOn(extensions::ExtensionPrefsFactory::GetInstance()); | |
| 279 } | |
| 280 | |
| 281 AppWindowGeometryCache::Factory::~Factory() {} | |
| 282 | |
| 283 KeyedService* AppWindowGeometryCache::Factory::BuildServiceInstanceFor( | |
| 284 content::BrowserContext* context) const { | |
| 285 return new AppWindowGeometryCache(context, | |
| 286 extensions::ExtensionPrefs::Get(context)); | |
| 287 } | |
| 288 | |
| 289 bool AppWindowGeometryCache::Factory::ServiceIsNULLWhileTesting() const { | |
| 290 return false; | |
| 291 } | |
| 292 | |
| 293 content::BrowserContext* | |
| 294 AppWindowGeometryCache::Factory::GetBrowserContextToUse( | |
| 295 content::BrowserContext* context) const { | |
| 296 return extensions::ExtensionsBrowserClient::Get()->GetOriginalContext( | |
| 297 context); | |
| 298 } | |
| 299 | |
| 300 void AppWindowGeometryCache::AddObserver(Observer* observer) { | |
| 301 observers_.AddObserver(observer); | |
| 302 } | |
| 303 | |
| 304 void AppWindowGeometryCache::RemoveObserver(Observer* observer) { | |
| 305 observers_.RemoveObserver(observer); | |
| 306 } | |
| 307 | |
| 308 } // namespace apps | |
| OLD | NEW |