src/chrome/browser/extensions/api/sync_file_system/extension_sync_event_observer.cc

   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>*
  33 ExtensionSyncEventObserver::GetFactoryInstance() {
  34   return g_factory.Pointer();
  35 }
  36
  37 ExtensionSyncEventObserver::ExtensionSyncEventObserver(
  38     content::BrowserContext* context)
  39     : browser_context_(context), sync_service_(NULL) {}
  40
  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
  52 ExtensionSyncEventObserver::~ExtensionSyncEventObserver() {}
  53
  54 void ExtensionSyncEventObserver::Shutdown() {
  55   if (sync_service_ != NULL)
  56     sync_service_->RemoveSyncEventObserver(this);
  57 }
  58
  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
  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
  87 void ExtensionSyncEventObserver::OnFileSynced(
  88     const storage::FileSystemURL& url,
  89     sync_file_system::SyncFileType file_type,
  90     sync_file_system::SyncFileStatus status,
  91     sync_file_system::SyncAction action,
  92     sync_file_system::SyncDirection direction) {
  93   scoped_ptr<base::ListValue> params(new base::ListValue());
  94
  95   scoped_ptr<base::DictionaryValue> entry(
  96       CreateDictionaryValueForFileSystemEntry(url, file_type));
  97   if (!entry)
  98     return;
  99   params->Append(entry.release());
 100
 101   // Status, SyncAction and any optional notes to go here.
 102   api::sync_file_system::FileStatus status_enum =
 103       SyncFileStatusToExtensionEnum(status);
 104   api::sync_file_system::SyncAction action_enum =
 105       SyncActionToExtensionEnum(action);
 106   api::sync_file_system::SyncDirection direction_enum =
 107       SyncDirectionToExtensionEnum(direction);
 108   params->AppendString(api::sync_file_system::ToString(status_enum));
 109   params->AppendString(api::sync_file_system::ToString(action_enum));
 110   params->AppendString(api::sync_file_system::ToString(direction_enum));
 111
 112   BroadcastOrDispatchEvent(
 113       url.origin(),
 114       api::sync_file_system::OnFileStatusChanged::kEventName,
 115       params.Pass());
 116 }
 117
 118 void ExtensionSyncEventObserver::BroadcastOrDispatchEvent(
 119     const GURL& app_origin,
 120     const std::string& event_name,
 121     scoped_ptr<base::ListValue> values) {
 122   // Check to see whether the event should be broadcasted to all listening
 123   // extensions or sent to a specific extension ID.
 124   bool broadcast_mode = app_origin.is_empty();
 125   EventRouter* event_router = EventRouter::Get(browser_context_);
 126   DCHECK(event_router);
 127
 128   scoped_ptr<Event> event(new Event(event_name, values.Pass()));
 129   event->restrict_to_browser_context = browser_context_;
 130
 131   // No app_origin, broadcast to all listening extensions for this event name.
 132   if (broadcast_mode) {
 133     event_router->BroadcastEvent(event.Pass());
 134     return;
 135   }
 136
 137   // Dispatch to single extension ID.
 138   const std::string extension_id = GetExtensionId(app_origin);
 139   if (extension_id.empty())
 140     return;
 141   event_router->DispatchEventToExtension(extension_id, event.Pass());
 142 }
 143
 144 template <>
 145 void BrowserContextKeyedAPIFactory<
 146     ExtensionSyncEventObserver>::DeclareFactoryDependencies() {
 147   DependsOn(sync_file_system::SyncFileSystemServiceFactory::GetInstance());
 148   DependsOn(ExtensionsBrowserClient::Get()->GetExtensionSystemFactory());
 149 }
 150
 151 }  // namespace extensions