1effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// Copyright 2014 The Chromium Authors. All rights reserved. 2effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// Use of this source code is governed by a BSD-style license that can be 3effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// found in the LICENSE file. 4effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 5effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "chrome/browser/extensions/api/webstore/webstore_api.h" 6effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 7effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "base/lazy_instance.h" 8effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "base/values.h" 9effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "chrome/browser/extensions/install_tracker.h" 10effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "chrome/browser/extensions/install_tracker_factory.h" 11effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "chrome/common/extensions/chrome_extension_messages.h" 12effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "extensions/browser/extension_system.h" 13effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "ipc/ipc_sender.h" 14effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 15effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochnamespace extensions { 16effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 17effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochnamespace { 18effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 19effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochbase::LazyInstance<BrowserContextKeyedAPIFactory<WebstoreAPI> > g_factory = 20effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch LAZY_INSTANCE_INITIALIZER; 21effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 22effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} // namespace 23effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 24effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochstruct WebstoreAPI::ObservedInstallInfo { 25effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(int routing_id, 26effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 27effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender); 28effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ~ObservedInstallInfo(); 29effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 30effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int routing_id; 31effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch std::string extension_id; 32effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender; 33effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch}; 34effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 35effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::ObservedInstallInfo::ObservedInstallInfo( 36effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int routing_id, 37effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 38effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender) 39effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch : routing_id(routing_id), 40effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch extension_id(extension_id), 41effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ipc_sender(ipc_sender) {} 42effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 43effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::ObservedInstallInfo::~ObservedInstallInfo() {} 44effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 45effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::WebstoreAPI(content::BrowserContext* browser_context) 46effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch : browser_context_(browser_context), 47effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_observer_( 48effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch new ScopedObserver<InstallTracker, InstallObserver>(this)) { 495f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) install_observer_->Add( 505f1c94371a64b3196d4be9466099bb892df9b88eTorne (Richard Coles) InstallTrackerFactory::GetForBrowserContext(browser_context)); 51effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 52effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 53effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::~WebstoreAPI() {} 54effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 55effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// static 56effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI* WebstoreAPI::Get(content::BrowserContext* browser_context) { 57effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return BrowserContextKeyedAPIFactory<WebstoreAPI>::Get(browser_context); 58effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 59effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 60effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnInlineInstallStart(int routing_id, 61effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender, 62effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 63effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int listeners_mask) { 64effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (listeners_mask & api::webstore::INSTALL_STAGE_LISTENER) { 65effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_stage_listeners_.push_back( 66effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(routing_id, extension_id, ipc_sender)); 67effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 68effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 69effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (listeners_mask & api::webstore::DOWNLOAD_PROGRESS_LISTENER) { 70effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch download_progress_listeners_.push_back( 71effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(routing_id, extension_id, ipc_sender)); 72effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 73effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 74effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 75effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnInlineInstallFinished(int routing_id, 76effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id) { 77effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch RemoveListeners(routing_id, extension_id, &download_progress_listeners_); 78effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch RemoveListeners(routing_id, extension_id, &install_stage_listeners_); 79effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 80effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 81effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnBeginExtensionDownload(const std::string& extension_id) { 82effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch SendInstallMessageIfObserved(extension_id, 83effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::INSTALL_STAGE_DOWNLOADING); 84effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 85effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 86effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnDownloadProgress(const std::string& extension_id, 87effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int percent_downloaded) { 88effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::const_iterator iter = 89effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch download_progress_listeners_.begin(); 90effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != download_progress_listeners_.end(); 91effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter) { 92effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id) { 93effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->ipc_sender->Send(new ExtensionMsg_InlineInstallDownloadProgress( 94effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->routing_id, percent_downloaded)); 95effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 96effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 97effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 98effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 99effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnBeginCrxInstall(const std::string& extension_id) { 100effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch SendInstallMessageIfObserved(extension_id, 101effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::INSTALL_STAGE_INSTALLING); 102effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 103effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 104effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnShutdown() { 105effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_observer_.reset(); 106effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 107effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 108effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::Shutdown() {} 109effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 110effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// static 111effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochBrowserContextKeyedAPIFactory<WebstoreAPI>* WebstoreAPI::GetFactoryInstance() { 112effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return g_factory.Pointer(); 113effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 114effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 115effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::SendInstallMessageIfObserved( 116effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 117effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::InstallStage install_stage) { 118effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::const_iterator iter = 119effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_stage_listeners_.begin(); 120effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != install_stage_listeners_.end(); 121effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter) { 122effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id) { 123effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->ipc_sender->Send(new ExtensionMsg_InlineInstallStageChanged( 124effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->routing_id, install_stage)); 125effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 126effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 127effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 128effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 129effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::RemoveListeners(int routing_id, 130effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 131effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfoList* listeners) { 132effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::iterator iter = listeners->begin(); 133effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != listeners->end();) { 134effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id && iter->routing_id == routing_id) 135effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter = listeners->erase(iter); 136effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch else 137effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter; 138effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 139effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 140effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 141effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} // namespace extensions 142