Refactor UpgradeDetector.

- Move peroidically timer based detection code into UpgradeDetectorImpl
  for use on non-ChromeOS platform;
- Implement ChromeOS upgrade detection via UpdateLibrary observer and
  apply a slightly different advisory timing for showing the badges
  (show green arrow immediately on upgrade detected, then 2, 4, 7 days
  for yellow, red and orange color);

BUG=chromium-os:16146
TEST=Verify fix for chromium-os:16146.

Review URL: http://codereview.chromium.org/7046096

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@88800 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 3 insertions, 256 deletions

diff --git a/chrome/browser/upgrade_detector.cc b/chrome/browser/upgrade_detector.cc
index a0d8f0c..e0fb2d5 100644
--- a/chrome/browser/upgrade_detector.cc
+++ b/chrome/browser/upgrade_detector.cc
@@ -4,158 +4,11 @@
 
 #include "chrome/browser/upgrade_detector.h"
 
-#include <string>
-
-#include "base/command_line.h"
-#include "base/memory/scoped_ptr.h"
-#include "base/memory/singleton.h"
-#include "base/string_number_conversions.h"
-#include "base/string_util.h"
-#include "base/task.h"
-#include "base/time.h"
-#include "base/utf_string_conversions.h"
-#include "chrome/browser/platform_util.h"
 #include "chrome/browser/prefs/pref_service.h"
-#include "chrome/common/chrome_switches.h"
-#include "chrome/common/chrome_version_info.h"
 #include "chrome/common/pref_names.h"
-#include "chrome/installer/util/browser_distribution.h"
-#include "content/browser/browser_thread.h"
 #include "content/common/notification_service.h"
 #include "content/common/notification_type.h"
 #include "grit/theme_resources.h"
-#include "ui/base/resource/resource_bundle.h"
-
-#if defined(OS_WIN)
-#include "chrome/installer/util/install_util.h"
-#elif defined(OS_MACOSX)
-#include "chrome/browser/cocoa/keystone_glue.h"
-#elif defined(OS_POSIX)
-#include "base/process_util.h"
-#include "base/version.h"
-#endif
-
-#if defined(OS_CHROMEOS)
-#include "chrome/browser/chromeos/cros/cros_library.h"
-#include "chrome/browser/chromeos/cros/update_library.h"
-#endif
-
-namespace {
-
-// How long (in milliseconds) to wait (each cycle) before checking whether
-// Chrome's been upgraded behind our back.
-const int kCheckForUpgradeMs = 2 * 60 * 60 * 1000;  // 2 hours.
-
-// How long to wait (each cycle) before checking which severity level we should
-// be at. Once we reach the highest severity, the timer will stop.
-const int kNotifyCycleTimeMs = 20 * 60 * 1000;  // 20 minutes.
-
-// Same as kNotifyCycleTimeMs but only used during testing.
-const int kNotifyCycleTimeForTestingMs = 500;  // Half a second.
-
-std::string CmdLineInterval() {
-  const CommandLine& cmd_line = *CommandLine::ForCurrentProcess();
-  return cmd_line.GetSwitchValueASCII(switches::kCheckForUpdateIntervalSec);
-}
-
-// How often to check for an upgrade.
-int GetCheckForUpgradeEveryMs() {
-  // Check for a value passed via the command line.
-  int interval_ms;
-  std::string interval = CmdLineInterval();
-  if (!interval.empty() && base::StringToInt(interval, &interval_ms))
-    return interval_ms * 1000;  // Command line value is in seconds.
-
-  return kCheckForUpgradeMs;
-}
-
-// This task checks the currently running version of Chrome against the
-// installed version. If the installed version is newer, it runs the passed
-// callback task. Otherwise it just deletes the task.
-class DetectUpgradeTask : public Task {
- public:
-  explicit DetectUpgradeTask(Task* upgrade_detected_task,
-                             bool* is_unstable_channel)
-      : upgrade_detected_task_(upgrade_detected_task),
-        is_unstable_channel_(is_unstable_channel) {
-  }
-
-  virtual ~DetectUpgradeTask() {
-    if (upgrade_detected_task_) {
-      // This has to get deleted on the same thread it was created.
-      BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-                              new DeleteTask<Task>(upgrade_detected_task_));
-    }
-  }
-
-  virtual void Run() {
-    DCHECK(BrowserThread::CurrentlyOn(BrowserThread::FILE));
-
-    scoped_ptr<Version> installed_version;
-
-#if defined(OS_WIN)
-    // Get the version of the currently *installed* instance of Chrome,
-    // which might be newer than the *running* instance if we have been
-    // upgraded in the background.
-    // TODO(tommi): Check if using the default distribution is always the right
-    // thing to do.
-    BrowserDistribution* dist = BrowserDistribution::GetDistribution();
-    installed_version.reset(InstallUtil::GetChromeVersion(dist, false));
-    if (!installed_version.get()) {
-      // User level Chrome is not installed, check system level.
-      installed_version.reset(InstallUtil::GetChromeVersion(dist, true));
-    }
-#elif defined(OS_MACOSX)
-    installed_version.reset(
-        Version::GetVersionFromString(UTF16ToASCII(
-            keystone_glue::CurrentlyInstalledVersion())));
-#elif defined(OS_POSIX)
-    // POSIX but not Mac OS X: Linux, etc.
-    CommandLine command_line(*CommandLine::ForCurrentProcess());
-    command_line.AppendSwitch(switches::kProductVersion);
-    std::string reply;
-    if (!base::GetAppOutput(command_line, &reply)) {
-      DLOG(ERROR) << "Failed to get current file version";
-      return;
-    }
-
-    installed_version.reset(Version::GetVersionFromString(reply));
-#endif
-
-    platform_util::Channel channel = platform_util::GetChannel();
-    *is_unstable_channel_ = channel == platform_util::CHANNEL_DEV ||
-                            channel == platform_util::CHANNEL_CANARY;
-
-    // Get the version of the currently *running* instance of Chrome.
-    chrome::VersionInfo version_info;
-    if (!version_info.is_valid()) {
-      NOTREACHED() << "Failed to get current file version";
-      return;
-    }
-    scoped_ptr<Version> running_version(
-        Version::GetVersionFromString(version_info.Version()));
-    if (running_version.get() == NULL) {
-      NOTREACHED() << "Failed to parse version info";
-      return;
-    }
-
-    // |installed_version| may be NULL when the user downgrades on Linux (by
-    // switching from dev to beta channel, for example). The user needs a
-    // restart in this case as well. See http://crbug.com/46547
-    if (!installed_version.get() ||
-        (installed_version->CompareTo(*running_version) > 0)) {
-      BrowserThread::PostTask(BrowserThread::UI, FROM_HERE,
-                              upgrade_detected_task_);
-      upgrade_detected_task_ = NULL;
-    }
-  }
-
- private:
-  Task* upgrade_detected_task_;
-  bool* is_unstable_channel_;
-};
-
-}  // namespace
 
 // static
 void UpgradeDetector::RegisterPrefs(PrefService* prefs) {
@@ -179,129 +32,23 @@ int UpgradeDetector::GetIconResourceID(UpgradeNotificationIconType type) {
 }
 
 UpgradeDetector::UpgradeDetector()
-    : ALLOW_THIS_IN_INITIALIZER_LIST(method_factory_(this)),
-      is_unstable_channel_(false),
-      upgrade_notification_stage_(UPGRADE_ANNOYANCE_NONE),
+    : upgrade_notification_stage_(UPGRADE_ANNOYANCE_NONE),
       notify_upgrade_(false) {
-  CommandLine command_line(*CommandLine::ForCurrentProcess());
-  if (command_line.HasSwitch(switches::kDisableBackgroundNetworking))
-    return;
-  // Windows: only enable upgrade notifications for official builds.
-  // Mac: only enable them if the updater (Keystone) is present.
-  // Linux (and other POSIX): always enable regardless of branding.
-#if (defined(OS_WIN) && defined(GOOGLE_CHROME_BUILD)) || defined(OS_POSIX)
-#if defined(OS_MACOSX)
-  if (keystone_glue::KeystoneEnabled())
-#endif
-  {
-    detect_upgrade_timer_.Start(
-        base::TimeDelta::FromMilliseconds(GetCheckForUpgradeEveryMs()),
-        this, &UpgradeDetector::CheckForUpgrade);
-  }
-#endif
 }
 
 UpgradeDetector::~UpgradeDetector() {
 }
 
-// static
-UpgradeDetector* UpgradeDetector::GetInstance() {
-  return Singleton<UpgradeDetector>::get();
-}
-
-void UpgradeDetector::CheckForUpgrade() {
-#if defined(OS_CHROMEOS)
-  // For ChromeOS, check update library status to detect upgrade.
-  if (chromeos::CrosLibrary::Get()->GetUpdateLibrary()->status().status ==
-      chromeos::UPDATE_STATUS_UPDATED_NEED_REBOOT) {
-    UpgradeDetected();
-  }
-#else
-  method_factory_.RevokeAll();
-  Task* callback_task =
-      method_factory_.NewRunnableMethod(&UpgradeDetector::UpgradeDetected);
-  // We use FILE as the thread to run the upgrade detection code on all
-  // platforms. For Linux, this is because we don't want to block the UI thread
-  // while launching a background process and reading its output; on the Mac and
-  // on Windows checking for an upgrade requires reading a file.
-  BrowserThread::PostTask(BrowserThread::FILE, FROM_HERE,
-                          new DetectUpgradeTask(callback_task,
-                                                &is_unstable_channel_));
-#endif
-}
-
-void UpgradeDetector::UpgradeDetected() {
-  DCHECK(BrowserThread::CurrentlyOn(BrowserThread::UI));
-
-  // Stop the recurring timer (that is checking for changes).
-  detect_upgrade_timer_.Stop();
-
+void UpgradeDetector::NotifyUpgradeDetected() {
   upgrade_detected_time_ = base::Time::Now();
 
   NotificationService::current()->Notify(
       NotificationType::UPGRADE_DETECTED,
       Source<UpgradeDetector>(this),
       NotificationService::NoDetails());
-
-  // Start the repeating timer for notifying the user after a certain period.
-  // The called function will eventually figure out that enough time has passed
-  // and stop the timer.
-  int cycle_time = CmdLineInterval().empty() ? kNotifyCycleTimeMs :
-                                               kNotifyCycleTimeForTestingMs;
-  upgrade_notification_timer_.Start(
-      base::TimeDelta::FromMilliseconds(cycle_time),
-      this, &UpgradeDetector::NotifyOnUpgrade);
 }
 
-void UpgradeDetector::NotifyOnUpgrade() {
-  base::TimeDelta delta = base::Time::Now() - upgrade_detected_time_;
-  std::string interval = CmdLineInterval();
-
-  // A command line interval implies testing, which we'll make more convenient
-  // by switching to seconds of waiting instead of days between flipping
-  // severity. This works in conjunction with the similar interval.empty()
-  // check below.
-  int64 time_passed = interval.empty() ? delta.InHours() : delta.InSeconds();
-
-  if (is_unstable_channel_) {
-    // There's only one threat level for unstable channels like dev and
-    // canary, and it hits after one hour. During testing, it hits after one
-    // minute.
-    const int kUnstableThreshold = 1;
-
-    if (time_passed >= kUnstableThreshold) {
-      upgrade_notification_stage_ = UPGRADE_ANNOYANCE_LOW;
-
-      // That's as high as it goes.
-      upgrade_notification_timer_.Stop();
-    } else {
-      return;  // Not ready to recommend upgrade.
-    }
-  } else {
-    const int kMultiplier = interval.empty() ? 24 : 1;
-    // 14 days when not testing, otherwise 14 seconds.
-    const int kSevereThreshold = 14 * kMultiplier;
-    const int kHighThreshold = 7 * kMultiplier;
-    const int kElevatedThreshold = 4 * kMultiplier;
-    const int kLowThreshold = 2 * kMultiplier;
-
-    // These if statements must be sorted (highest interval first).
-    if (time_passed >= kSevereThreshold) {
-      upgrade_notification_stage_ = UPGRADE_ANNOYANCE_SEVERE;
-
-      // We can't get any higher, baby.
-      upgrade_notification_timer_.Stop();
-    } else if (time_passed >= kHighThreshold) {
-      upgrade_notification_stage_ = UPGRADE_ANNOYANCE_HIGH;
-    } else if (time_passed >= kElevatedThreshold) {
-      upgrade_notification_stage_ = UPGRADE_ANNOYANCE_ELEVATED;
-    } else if (time_passed >= kLowThreshold) {
-      upgrade_notification_stage_ = UPGRADE_ANNOYANCE_LOW;
-    } else {
-      return;  // Not ready to recommend upgrade.
-    }
-  }
-
+void UpgradeDetector::NotifyUpgradeRecommended() {
   notify_upgrade_ = true;
 
   NotificationService::current()->Notify(