1 // Copyright (c) 2012 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 "chrome/browser/extensions/api/sync_file_system/extension_sync_event_observer.h"
6
7 #include "base/lazy_instance.h"
8 #include "chrome/browser/extensions/api/sync_file_system/sync_file_system_api_helpers.h"
9 #include "chrome/browser/sync_file_system/sync_event_observer.h"
10 #include "chrome/browser/sync_file_system/sync_file_system_service.h"
11 #include "chrome/browser/sync_file_system/sync_file_system_service_factory.h"
12 #include "chrome/browser/sync_file_system/syncable_file_system_util.h"
13 #include "chrome/common/extensions/api/sync_file_system.h"
14 #include "content/public/browser/browser_context.h"
15 #include "extensions/browser/event_router.h"
16 #include "extensions/browser/extension_registry.h"
17 #include "extensions/browser/extension_system_provider.h"
18 #include "extensions/browser/extensions_browser_client.h"
19 #include "extensions/common/extension_set.h"
20 #include "storage/browser/fileapi/file_system_url.h"
21 #include "storage/common/fileapi/file_system_util.h"
22
23 using sync_file_system::SyncEventObserver;
24
25 namespace extensions {
26
27 static base::LazyInstance<
28 BrowserContextKeyedAPIFactory<ExtensionSyncEventObserver> > g_factory =
29 LAZY_INSTANCE_INITIALIZER;
30
31 // static
32 BrowserContextKeyedAPIFactory<ExtensionSyncEventObserver>*
GetFactoryInstance()33 ExtensionSyncEventObserver::GetFactoryInstance() {
34 return g_factory.Pointer();
35 }
36
ExtensionSyncEventObserver(content::BrowserContext * context)37 ExtensionSyncEventObserver::ExtensionSyncEventObserver(
38 content::BrowserContext* context)
39 : browser_context_(context), sync_service_(NULL) {}
40
InitializeForService(sync_file_system::SyncFileSystemService * sync_service)41 void ExtensionSyncEventObserver::InitializeForService(
42 sync_file_system::SyncFileSystemService* sync_service) {
43 DCHECK(sync_service);
44 if (sync_service_ != NULL) {
45 DCHECK_EQ(sync_service_, sync_service);
46 return;
47 }
48 sync_service_ = sync_service;
49 sync_service_->AddSyncEventObserver(this);
50 }
51
~ExtensionSyncEventObserver()52 ExtensionSyncEventObserver::~ExtensionSyncEventObserver() {}
53
Shutdown()54 void ExtensionSyncEventObserver::Shutdown() {
55 if (sync_service_ != NULL)
56 sync_service_->RemoveSyncEventObserver(this);
57 }
58
GetExtensionId(const GURL & app_origin)59 std::string ExtensionSyncEventObserver::GetExtensionId(
60 const GURL& app_origin) {
61 const Extension* app = ExtensionRegistry::Get(browser_context_)
62 ->enabled_extensions().GetAppByURL(app_origin);
63 if (!app) {
64 // The app is uninstalled or disabled.
65 return std::string();
66 }
67 return app->id();
68 }
69
OnSyncStateUpdated(const GURL & app_origin,sync_file_system::SyncServiceState state,const std::string & description)70 void ExtensionSyncEventObserver::OnSyncStateUpdated(
71 const GURL& app_origin,
72 sync_file_system::SyncServiceState state,
73 const std::string& description) {
74 // Convert state and description into SyncState Object.
75 api::sync_file_system::ServiceInfo service_info;
76 service_info.state = SyncServiceStateToExtensionEnum(state);
77 service_info.description = description;
78 scoped_ptr<base::ListValue> params(
79 api::sync_file_system::OnServiceStatusChanged::Create(service_info));
80
81 BroadcastOrDispatchEvent(
82 app_origin,
83 api::sync_file_system::OnServiceStatusChanged::kEventName,
84 params.Pass());
85 }
86
OnFileSynced(const storage::FileSystemURL & url,sync_file_system::SyncFileStatus status,sync_file_system::SyncAction action,sync_file_system::SyncDirection direction)87 void ExtensionSyncEventObserver::OnFileSynced(
88 const storage::FileSystemURL& url,
89 sync_file_system::SyncFileStatus status,
90 sync_file_system::SyncAction action,
91 sync_file_system::SyncDirection direction) {
92 scoped_ptr<base::ListValue> params(new base::ListValue());
93
94 // For now we always assume events come only for files (not directories).
95 scoped_ptr<base::DictionaryValue> entry(
96 CreateDictionaryValueForFileSystemEntry(
97 url, sync_file_system::SYNC_FILE_TYPE_FILE));
98 if (!entry)
99 return;
100 params->Append(entry.release());
101
102 // Status, SyncAction and any optional notes to go here.
103 api::sync_file_system::FileStatus status_enum =
104 SyncFileStatusToExtensionEnum(status);
105 api::sync_file_system::SyncAction action_enum =
106 SyncActionToExtensionEnum(action);
107 api::sync_file_system::SyncDirection direction_enum =
108 SyncDirectionToExtensionEnum(direction);
109 params->AppendString(api::sync_file_system::ToString(status_enum));
110 params->AppendString(api::sync_file_system::ToString(action_enum));
111 params->AppendString(api::sync_file_system::ToString(direction_enum));
112
113 BroadcastOrDispatchEvent(
114 url.origin(),
115 api::sync_file_system::OnFileStatusChanged::kEventName,
116 params.Pass());
117 }
118
BroadcastOrDispatchEvent(const GURL & app_origin,const std::string & event_name,scoped_ptr<base::ListValue> values)119 void ExtensionSyncEventObserver::BroadcastOrDispatchEvent(
120 const GURL& app_origin,
121 const std::string& event_name,
122 scoped_ptr<base::ListValue> values) {
123 // Check to see whether the event should be broadcasted to all listening
124 // extensions or sent to a specific extension ID.
125 bool broadcast_mode = app_origin.is_empty();
126 EventRouter* event_router = EventRouter::Get(browser_context_);
127 DCHECK(event_router);
128
129 scoped_ptr<Event> event(new Event(event_name, values.Pass()));
130 event->restrict_to_browser_context = browser_context_;
131
132 // No app_origin, broadcast to all listening extensions for this event name.
133 if (broadcast_mode) {
134 event_router->BroadcastEvent(event.Pass());
135 return;
136 }
137
138 // Dispatch to single extension ID.
139 const std::string extension_id = GetExtensionId(app_origin);
140 if (extension_id.empty())
141 return;
142 event_router->DispatchEventToExtension(extension_id, event.Pass());
143 }
144
145 template <>
146 void BrowserContextKeyedAPIFactory<
DeclareFactoryDependencies()147 ExtensionSyncEventObserver>::DeclareFactoryDependencies() {
148 DependsOn(sync_file_system::SyncFileSystemServiceFactory::GetInstance());
149 DependsOn(ExtensionsBrowserClient::Get()->GetExtensionSystemFactory());
150 }
151
152 } // namespace extensions
153