webstore_api.cc revision effb81e5f8246d0db0270817048dc992db66e9fb
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/browser/profiles/profile.h" 12effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "chrome/common/extensions/chrome_extension_messages.h" 13effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "extensions/browser/extension_system.h" 14effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch#include "ipc/ipc_sender.h" 15effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 16effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochnamespace extensions { 17effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 18effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochnamespace { 19effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 20effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochbase::LazyInstance<BrowserContextKeyedAPIFactory<WebstoreAPI> > g_factory = 21effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch LAZY_INSTANCE_INITIALIZER; 22effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 23effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} // namespace 24effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 25effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochstruct WebstoreAPI::ObservedInstallInfo { 26effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(int routing_id, 27effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 28effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender); 29effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ~ObservedInstallInfo(); 30effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 31effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int routing_id; 32effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch std::string extension_id; 33effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender; 34effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch}; 35effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 36effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::ObservedInstallInfo::ObservedInstallInfo( 37effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int routing_id, 38effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 39effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender) 40effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch : routing_id(routing_id), 41effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch extension_id(extension_id), 42effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ipc_sender(ipc_sender) {} 43effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 44effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::ObservedInstallInfo::~ObservedInstallInfo() {} 45effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 46effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::WebstoreAPI(content::BrowserContext* browser_context) 47effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch : browser_context_(browser_context), 48effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_observer_( 49effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch new ScopedObserver<InstallTracker, InstallObserver>(this)) { 50effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_observer_->Add(InstallTrackerFactory::GetForProfile( 51effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch Profile::FromBrowserContext(browser_context))); 52effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 53effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 54effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI::~WebstoreAPI() {} 55effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 56effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// static 57effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochWebstoreAPI* WebstoreAPI::Get(content::BrowserContext* browser_context) { 58effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return BrowserContextKeyedAPIFactory<WebstoreAPI>::Get(browser_context); 59effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 60effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 61effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnInlineInstallStart(int routing_id, 62effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch IPC::Sender* ipc_sender, 63effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 64effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int listeners_mask) { 65effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (listeners_mask & api::webstore::INSTALL_STAGE_LISTENER) { 66effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_stage_listeners_.push_back( 67effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(routing_id, extension_id, ipc_sender)); 68effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 69effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 70effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (listeners_mask & api::webstore::DOWNLOAD_PROGRESS_LISTENER) { 71effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch download_progress_listeners_.push_back( 72effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfo(routing_id, extension_id, ipc_sender)); 73effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 74effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 75effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 76effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnInlineInstallFinished(int routing_id, 77effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id) { 78effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch RemoveListeners(routing_id, extension_id, &download_progress_listeners_); 79effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch RemoveListeners(routing_id, extension_id, &install_stage_listeners_); 80effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 81effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 82effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnBeginExtensionDownload(const std::string& extension_id) { 83effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch SendInstallMessageIfObserved(extension_id, 84effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::INSTALL_STAGE_DOWNLOADING); 85effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 86effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 87effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnDownloadProgress(const std::string& extension_id, 88effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch int percent_downloaded) { 89effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::const_iterator iter = 90effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch download_progress_listeners_.begin(); 91effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != download_progress_listeners_.end(); 92effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter) { 93effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id) { 94effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->ipc_sender->Send(new ExtensionMsg_InlineInstallDownloadProgress( 95effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->routing_id, percent_downloaded)); 96effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 97effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 98effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 99effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 100effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnBeginCrxInstall(const std::string& extension_id) { 101effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch SendInstallMessageIfObserved(extension_id, 102effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::INSTALL_STAGE_INSTALLING); 103effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 104effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 105effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::OnShutdown() { 106effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_observer_.reset(); 107effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 108effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 109effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::Shutdown() {} 110effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 111effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch// static 112effb81e5f8246d0db0270817048dc992db66e9fbBen MurdochBrowserContextKeyedAPIFactory<WebstoreAPI>* WebstoreAPI::GetFactoryInstance() { 113effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch return g_factory.Pointer(); 114effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 115effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 116effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::SendInstallMessageIfObserved( 117effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 118effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch api::webstore::InstallStage install_stage) { 119effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::const_iterator iter = 120effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch install_stage_listeners_.begin(); 121effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != install_stage_listeners_.end(); 122effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter) { 123effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id) { 124effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->ipc_sender->Send(new ExtensionMsg_InlineInstallStageChanged( 125effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter->routing_id, install_stage)); 126effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 127effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 128effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 129effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 130effb81e5f8246d0db0270817048dc992db66e9fbBen Murdochvoid WebstoreAPI::RemoveListeners(int routing_id, 131effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch const std::string& extension_id, 132effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ObservedInstallInfoList* listeners) { 133effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch for (ObservedInstallInfoList::iterator iter = listeners->begin(); 134effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter != listeners->end();) { 135effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch if (iter->extension_id == extension_id && iter->routing_id == routing_id) 136effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch iter = listeners->erase(iter); 137effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch else 138effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch ++iter; 139effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch } 140effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} 141effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch 142effb81e5f8246d0db0270817048dc992db66e9fbBen Murdoch} // namespace extensions 143