sync: migrate invalidation state from syncable::Directory to InvalidationStorage

sync/notifier/invalidation_notifier_unittest.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "sync/notifier/invalidation_notifier.h"
 
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "jingle/notifier/base/fake_base_task.h"
 #include "jingle/notifier/base/notifier_options.h"
 #include "jingle/notifier/listener/fake_push_client.h"
 #include "net/url_request/url_request_test_util.h"
 #include "sync/notifier/invalidation_state_tracker.h"
+#include "sync/notifier/mock_invalidation_state_tracker.h"
 #include "sync/notifier/mock_sync_notifier_observer.h"
 #include "sync/syncable/model_type.h"
 #include "sync/syncable/model_type_payload_map.h"
 #include "sync/util/weak_handle.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace sync_notifier {
 
 namespace {
 
 using ::testing::InSequence;
 using ::testing::StrictMock;
 
 class InvalidationNotifierTest : public testing::Test {
  protected:
-  virtual void SetUp() {
+  virtual void TearDown() {
+    if (invalidation_notifier_.get())
+      ResetNotifier();
+  }
+
+  // Constructs an InvalidationNotifier, places it in
+  // |invalidation_notifier_|, and adds |mock_observer_| as an observer. This
+  // remains in place until either TearDown (automatic) or ResetNotifier
+  // (manual) is called.
+  void CreateAndObserveNotifier(
+      const std::string& initial_invalidation_state) {
     notifier::NotifierOptions notifier_options;
     // Note: URLRequestContextGetters are ref-counted.
     notifier_options.request_context_getter =
         new TestURLRequestContextGetter(message_loop_.message_loop_proxy());
     invalidation_notifier_.reset(
         new InvalidationNotifier(
             scoped_ptr<notifier::PushClient>(new notifier::FakePushClient()),
             InvalidationVersionMap(),
-            browser_sync::MakeWeakHandle(
-                base::WeakPtr<InvalidationStateTracker>()),
+            initial_invalidation_state,
+            browser_sync::MakeWeakHandle(mock_tracker_.AsWeakPtr()),
             "fake_client_info"));
     invalidation_notifier_->AddObserver(&mock_observer_);
   }
 
-  virtual void TearDown() {
+  void ResetNotifier() {
     invalidation_notifier_->RemoveObserver(&mock_observer_);
     // Stopping the invalidation notifier stops its scheduler, which deletes any
     // pending tasks without running them.  Some tasks "run and delete" another
     // task, so they must be run in order to avoid leaking the inner task.
     // Stopping does not schedule any tasks, so it's both necessary and
     // sufficient to drain the task queue before stopping the notifier.
     message_loop_.RunAllPending();
     invalidation_notifier_.reset();
   }
 
   MessageLoopForIO message_loop_;
   scoped_ptr<InvalidationNotifier> invalidation_notifier_;
+  StrictMock<MockInvalidationStateTracker> mock_tracker_;
   StrictMock<MockSyncNotifierObserver> mock_observer_;
   notifier::FakeBaseTask fake_base_task_;
 };
 
 TEST_F(InvalidationNotifierTest, Basic) {
+  CreateAndObserveNotifier("fake_state");
   InSequence dummy;
 
   syncable::ModelTypePayloadMap type_payloads;
   type_payloads[syncable::PREFERENCES] = "payload";
   type_payloads[syncable::BOOKMARKS] = "";
   type_payloads[syncable::AUTOFILL] = "";
 
   EXPECT_CALL(mock_observer_, OnNotificationStateChange(true));
-  EXPECT_CALL(mock_observer_, StoreState("new_fake_state"));
   EXPECT_CALL(mock_observer_,
               OnIncomingNotification(type_payloads,
                                      REMOTE_NOTIFICATION));
   EXPECT_CALL(mock_observer_, OnNotificationStateChange(false));
+  // Note no expectation on mock_tracker_, as we initialized with
+  // non-empty initial_invalidation_state above.
 
-  invalidation_notifier_->SetState("fake_state");
+  // TODO(tim): This call should be a no-op, Remove once bug 124140 and
+  // associated issues are fixed.
+  invalidation_notifier_->SetStateDeprecated("fake_state");
   invalidation_notifier_->SetUniqueId("fake_id");
   invalidation_notifier_->UpdateCredentials("foo@bar.com", "fake_token");
 
   invalidation_notifier_->OnSessionStatusChanged(true);
 
-  invalidation_notifier_->WriteState("new_fake_state");
-
   invalidation_notifier_->OnInvalidate(type_payloads);
 
   invalidation_notifier_->OnSessionStatusChanged(false);
 }
 
+TEST_F(InvalidationNotifierTest, MigrateState) {
+  CreateAndObserveNotifier(std::string());
+  InSequence dummy;
+
+  EXPECT_CALL(mock_tracker_, SetInvalidationState("fake_state"));
+  invalidation_notifier_->SetStateDeprecated("fake_state");
+
+  // Should do nothing.
+  invalidation_notifier_->SetStateDeprecated("spurious_fake_state");
+
+  // Pretend Chrome shut down.
+  ResetNotifier();
+
+  CreateAndObserveNotifier("fake_state");
+  // Should do nothing.
+  invalidation_notifier_->SetStateDeprecated("more_spurious_fake_state");
+}
+
 }  // namespace
 
 }  // namespace sync_notifier