| // Copyright 2014 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 "components/sync_driver/device_info_sync_service.h" |
| |
| #include <stddef.h> |
| #include <stdint.h> |
| |
| #include <string> |
| |
| #include "base/message_loop/message_loop.h" |
| #include "components/sync_driver/device_info_util.h" |
| #include "components/sync_driver/local_device_info_provider_mock.h" |
| #include "sync/api/sync_change.h" |
| #include "sync/api/sync_change_processor.h" |
| #include "sync/api/sync_change_processor_wrapper_for_test.h" |
| #include "sync/api/sync_error_factory_mock.h" |
| #include "sync/internal_api/public/attachments/attachment_service_proxy_for_test.h" |
| #include "sync/util/time.h" |
| #include "testing/gtest/include/gtest/gtest.h" |
| |
| using base::Time; |
| using base::TimeDelta; |
| using syncer::AttachmentIdList; |
| using syncer::AttachmentServiceProxyForTest; |
| using syncer::ModelType; |
| using syncer::SyncChange; |
| using syncer::SyncChangeList; |
| using syncer::SyncChangeProcessor; |
| using syncer::SyncChangeProcessorWrapperForTest; |
| using syncer::SyncData; |
| using syncer::SyncDataList; |
| using syncer::SyncError; |
| using syncer::SyncErrorFactory; |
| using syncer::SyncErrorFactoryMock; |
| using syncer::SyncMergeResult; |
| using sync_pb::EntitySpecifics; |
| |
| namespace sync_driver { |
| |
| namespace { |
| |
| class TestChangeProcessor : public SyncChangeProcessor { |
| public: |
| TestChangeProcessor() {} |
| ~TestChangeProcessor() override {} |
| |
| // SyncChangeProcessor implementation. |
| // Store a copy of all the changes passed in so we can examine them later. |
| SyncError ProcessSyncChanges(const tracked_objects::Location& from_here, |
| const SyncChangeList& change_list) override { |
| change_list_ = change_list; |
| return SyncError(); |
| } |
| |
| // This method isn't used in these tests. |
| SyncDataList GetAllSyncData(ModelType type) const override { |
| return SyncDataList(); |
| } |
| |
| size_t change_list_size() const { return change_list_.size(); } |
| |
| SyncChange::SyncChangeType change_type_at(size_t index) const { |
| CHECK_LT(index, change_list_size()); |
| return change_list_[index].change_type(); |
| } |
| |
| const sync_pb::DeviceInfoSpecifics& device_info_at(size_t index) const { |
| CHECK_LT(index, change_list_size()); |
| return change_list_[index].sync_data().GetSpecifics().device_info(); |
| } |
| |
| const std::string& cache_guid_at(size_t index) const { |
| return device_info_at(index).cache_guid(); |
| } |
| |
| const std::string& client_name_at(size_t index) const { |
| return device_info_at(index).client_name(); |
| } |
| |
| private: |
| SyncChangeList change_list_; |
| }; |
| |
| } // namespace |
| |
| class DeviceInfoSyncServiceTest : public testing::Test, |
| public DeviceInfoTracker::Observer { |
| public: |
| DeviceInfoSyncServiceTest() : num_device_info_changed_callbacks_(0) {} |
| ~DeviceInfoSyncServiceTest() override {} |
| |
| void SetUp() override { |
| local_device_.reset(new LocalDeviceInfoProviderMock( |
| "guid_1", |
| "client_1", |
| "Chromium 10k", |
| "Chrome 10k", |
| sync_pb::SyncEnums_DeviceType_TYPE_LINUX, |
| "device_id")); |
| sync_service_.reset(new DeviceInfoSyncService(local_device_.get())); |
| sync_processor_.reset(new TestChangeProcessor()); |
| // Register observer |
| sync_service_->AddObserver(this); |
| } |
| |
| void TearDown() override { sync_service_->RemoveObserver(this); } |
| |
| void OnDeviceInfoChange() override { num_device_info_changed_callbacks_++; } |
| |
| std::unique_ptr<SyncChangeProcessor> PassProcessor() { |
| return std::unique_ptr<SyncChangeProcessor>( |
| new SyncChangeProcessorWrapperForTest(sync_processor_.get())); |
| } |
| |
| std::unique_ptr<SyncErrorFactory> CreateAndPassSyncErrorFactory() { |
| return std::unique_ptr<SyncErrorFactory>(new SyncErrorFactoryMock()); |
| } |
| |
| sync_pb::EntitySpecifics CreateEntitySpecifics( |
| const std::string& client_id, |
| const std::string& client_name) { |
| sync_pb::EntitySpecifics entity; |
| sync_pb::DeviceInfoSpecifics& specifics = *entity.mutable_device_info(); |
| |
| specifics.set_cache_guid(client_id); |
| specifics.set_client_name(client_name); |
| specifics.set_chrome_version("Chromium 10k"); |
| specifics.set_sync_user_agent("Chrome 10k"); |
| specifics.set_device_type(sync_pb::SyncEnums_DeviceType_TYPE_LINUX); |
| specifics.set_signin_scoped_device_id("device_id"); |
| return entity; |
| } |
| |
| // Default |last_updated_timestamp| to now to avoid pulse update on merge. |
| SyncData CreateRemoteData(const std::string& client_id, |
| const std::string& client_name, |
| Time last_updated_timestamp = Time::Now()) { |
| sync_pb::EntitySpecifics entity( |
| CreateEntitySpecifics(client_id, client_name)); |
| entity.mutable_device_info()->set_last_updated_timestamp( |
| syncer::TimeToProtoTime(last_updated_timestamp)); |
| return SyncData::CreateRemoteData(1, entity, Time(), AttachmentIdList(), |
| AttachmentServiceProxyForTest::Create()); |
| } |
| |
| void AddInitialData(SyncDataList* sync_data_list, |
| const std::string& client_id, |
| const std::string& client_name) { |
| SyncData sync_data = CreateRemoteData(client_id, client_name); |
| sync_data_list->push_back(sync_data); |
| } |
| |
| void AddChange(SyncChangeList* change_list, |
| SyncChange::SyncChangeType change_type, |
| const std::string& client_id, |
| const std::string& client_name) { |
| SyncData sync_data = CreateRemoteData(client_id, client_name); |
| SyncChange sync_change(FROM_HERE, change_type, sync_data); |
| change_list->push_back(sync_change); |
| } |
| |
| protected: |
| // Private method wrappers through friend class. |
| Time GetLastUpdateTime(const syncer::SyncData& data) { |
| return sync_service_->GetLastUpdateTime(data); |
| } |
| int CountActiveDevices(const Time now) { |
| return sync_service_->CountActiveDevices(now); |
| } |
| void StoreSyncData(const std::string& client_id, |
| const syncer::SyncData& sync_data) { |
| sync_service_->StoreSyncData(client_id, sync_data); |
| } |
| bool IsPulseTimerRunning() { return sync_service_->pulse_timer_.IsRunning(); } |
| |
| // Needs to be created for OneShotTimer to grab the current task runner. |
| base::MessageLoop message_loop_; |
| |
| int num_device_info_changed_callbacks_; |
| std::unique_ptr<LocalDeviceInfoProviderMock> local_device_; |
| std::unique_ptr<DeviceInfoSyncService> sync_service_; |
| std::unique_ptr<TestChangeProcessor> sync_processor_; |
| }; |
| |
| namespace { |
| |
| // Sync with empty initial data. |
| TEST_F(DeviceInfoSyncServiceTest, StartSyncEmptyInitialData) { |
| EXPECT_FALSE(sync_service_->IsSyncing()); |
| |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| SyncDataList(), |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| |
| EXPECT_TRUE(sync_service_->IsSyncing()); |
| EXPECT_EQ(0, merge_result.num_items_added()); |
| EXPECT_EQ(0, merge_result.num_items_modified()); |
| EXPECT_EQ(0, merge_result.num_items_deleted()); |
| EXPECT_EQ(1, merge_result.num_items_before_association()); |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| EXPECT_EQ(SyncChange::ACTION_ADD, sync_processor_->change_type_at(0)); |
| |
| EXPECT_EQ(1U, sync_processor_->change_list_size()); |
| EXPECT_EQ("guid_1", sync_processor_->cache_guid_at(0)); |
| |
| // Should have one device info corresponding to local device info. |
| EXPECT_EQ(1U, sync_service_->GetAllSyncData(syncer::DEVICE_INFO).size()); |
| EXPECT_EQ(1U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_1")); |
| EXPECT_FALSE(sync_service_->GetDeviceInfo("guid_0")); |
| } |
| |
| TEST_F(DeviceInfoSyncServiceTest, StopSyncing) { |
| SyncMergeResult merge_result = sync_service_->MergeDataAndStartSyncing( |
| syncer::DEVICE_INFO, SyncDataList(), PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_TRUE(sync_service_->IsSyncing()); |
| EXPECT_EQ(1, num_device_info_changed_callbacks_); |
| EXPECT_TRUE(IsPulseTimerRunning()); |
| sync_service_->StopSyncing(syncer::DEVICE_INFO); |
| EXPECT_FALSE(sync_service_->IsSyncing()); |
| EXPECT_EQ(2, num_device_info_changed_callbacks_); |
| EXPECT_FALSE(IsPulseTimerRunning()); |
| } |
| |
| // Sync with initial data matching the local device data. |
| TEST_F(DeviceInfoSyncServiceTest, StartSyncMatchingInitialData) { |
| SyncDataList sync_data; |
| AddInitialData(&sync_data, "guid_1", "client_1"); |
| |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| sync_data, |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(0, merge_result.num_items_added()); |
| EXPECT_EQ(0, merge_result.num_items_modified()); |
| EXPECT_EQ(0, merge_result.num_items_deleted()); |
| EXPECT_EQ(1, merge_result.num_items_before_association()); |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| |
| // No changes expected because the device info matches. |
| EXPECT_EQ(0U, sync_processor_->change_list_size()); |
| |
| EXPECT_EQ(1U, sync_service_->GetAllSyncData(syncer::DEVICE_INFO).size()); |
| EXPECT_EQ(1U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_1")); |
| EXPECT_FALSE(sync_service_->GetDeviceInfo("guid_0")); |
| } |
| |
| // Sync with misc initial data. |
| TEST_F(DeviceInfoSyncServiceTest, StartSync) { |
| SyncDataList sync_data; |
| AddInitialData(&sync_data, "guid_2", "foo"); |
| AddInitialData(&sync_data, "guid_3", "bar"); |
| // This guid matches the local device but the client name is different. |
| AddInitialData(&sync_data, "guid_1", "baz"); |
| |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| sync_data, |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| |
| EXPECT_EQ(2, merge_result.num_items_added()); |
| EXPECT_EQ(1, merge_result.num_items_modified()); |
| EXPECT_EQ(0, merge_result.num_items_deleted()); |
| EXPECT_EQ(1, merge_result.num_items_before_association()); |
| EXPECT_EQ(3, merge_result.num_items_after_association()); |
| |
| EXPECT_EQ(1U, sync_processor_->change_list_size()); |
| EXPECT_EQ(SyncChange::ACTION_UPDATE, sync_processor_->change_type_at(0)); |
| EXPECT_EQ("client_1", sync_processor_->client_name_at(0)); |
| |
| EXPECT_EQ(3U, sync_service_->GetAllSyncData(syncer::DEVICE_INFO).size()); |
| EXPECT_EQ(3U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_1")); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_2")); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_3")); |
| EXPECT_FALSE(sync_service_->GetDeviceInfo("guid_0")); |
| } |
| |
| // Process sync change with ACTION_ADD. |
| // Verify callback. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessAddChange) { |
| EXPECT_EQ(0, num_device_info_changed_callbacks_); |
| |
| // Start with an empty initial data. |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| SyncDataList(), |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| // There should be only one item corresponding to the local device |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| EXPECT_EQ(1, num_device_info_changed_callbacks_); |
| |
| // Add a new device info with a non-matching guid. |
| SyncChangeList change_list; |
| AddChange(&change_list, SyncChange::ACTION_ADD, "guid_2", "foo"); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| EXPECT_EQ(2, num_device_info_changed_callbacks_); |
| |
| EXPECT_EQ(2U, sync_service_->GetAllDeviceInfo().size()); |
| |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_1")); |
| EXPECT_TRUE(sync_service_->GetDeviceInfo("guid_2")); |
| EXPECT_FALSE(sync_service_->GetDeviceInfo("guid_0")); |
| } |
| |
| // Process multiple sync change with ACTION_UPDATE and ACTION_ADD. |
| // Verify that callback is called multiple times. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessMultipleChanges) { |
| SyncDataList sync_data; |
| AddInitialData(&sync_data, "guid_2", "foo"); |
| AddInitialData(&sync_data, "guid_3", "bar"); |
| |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| sync_data, |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(3, merge_result.num_items_after_association()); |
| // reset callbacks counter |
| num_device_info_changed_callbacks_ = 0; |
| |
| SyncChangeList change_list; |
| AddChange(&change_list, SyncChange::ACTION_UPDATE, "guid_2", "foo_2"); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| |
| EXPECT_EQ(1, num_device_info_changed_callbacks_); |
| EXPECT_EQ(3U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_EQ("foo_2", sync_service_->GetDeviceInfo("guid_2")->client_name()); |
| |
| change_list.clear(); |
| AddChange(&change_list, SyncChange::ACTION_UPDATE, "guid_3", "bar_3"); |
| AddChange(&change_list, SyncChange::ACTION_ADD, "guid_4", "baz_4"); |
| |
| error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| |
| EXPECT_EQ(2, num_device_info_changed_callbacks_); |
| EXPECT_EQ(4U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_EQ("bar_3", sync_service_->GetDeviceInfo("guid_3")->client_name()); |
| EXPECT_EQ("baz_4", sync_service_->GetDeviceInfo("guid_4")->client_name()); |
| } |
| |
| // Process update to the local device info and verify that it is ignored. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessUpdateChangeMatchingLocalDevice) { |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| SyncDataList(), |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| // reset callbacks counter |
| num_device_info_changed_callbacks_ = 0; |
| |
| SyncChangeList change_list; |
| AddChange(&change_list, SyncChange::ACTION_UPDATE, "guid_1", "foo_1"); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| // Callback shouldn't be sent in this case. |
| EXPECT_EQ(0, num_device_info_changed_callbacks_); |
| // Should still have the old local device Info. |
| EXPECT_EQ(1U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_EQ("client_1", sync_service_->GetDeviceInfo("guid_1")->client_name()); |
| } |
| |
| // Process sync change with ACTION_DELETE. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessDeleteChange) { |
| SyncDataList sync_data; |
| AddInitialData(&sync_data, "guid_2", "foo"); |
| AddInitialData(&sync_data, "guid_3", "bar"); |
| |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| sync_data, |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(3, merge_result.num_items_after_association()); |
| // reset callbacks counter |
| num_device_info_changed_callbacks_ = 0; |
| |
| SyncChangeList change_list; |
| AddChange(&change_list, SyncChange::ACTION_DELETE, "guid_2", "foo_2"); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| |
| EXPECT_EQ(1, num_device_info_changed_callbacks_); |
| EXPECT_EQ(2U, sync_service_->GetAllDeviceInfo().size()); |
| EXPECT_FALSE(sync_service_->GetDeviceInfo("guid_2")); |
| } |
| |
| // Process sync change with unexpected action. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessInvalidChange) { |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| SyncDataList(), |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| // reset callbacks counter |
| num_device_info_changed_callbacks_ = 0; |
| |
| SyncChangeList change_list; |
| AddChange(&change_list, (SyncChange::SyncChangeType)100, "guid_2", "foo_2"); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_TRUE(error.IsSet()); |
| |
| // The number of callback should still be zero. |
| EXPECT_EQ(0, num_device_info_changed_callbacks_); |
| EXPECT_EQ(1U, sync_service_->GetAllDeviceInfo().size()); |
| } |
| |
| // Process sync change after unsubscribing from notifications. |
| TEST_F(DeviceInfoSyncServiceTest, ProcessChangesAfterUnsubscribing) { |
| SyncMergeResult merge_result = |
| sync_service_->MergeDataAndStartSyncing(syncer::DEVICE_INFO, |
| SyncDataList(), |
| PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| EXPECT_EQ(1, merge_result.num_items_after_association()); |
| // reset callbacks counter |
| num_device_info_changed_callbacks_ = 0; |
| |
| SyncChangeList change_list; |
| AddChange(&change_list, SyncChange::ACTION_ADD, "guid_2", "foo_2"); |
| |
| // Unsubscribe observer before processing changes. |
| sync_service_->RemoveObserver(this); |
| |
| SyncError error = sync_service_->ProcessSyncChanges(FROM_HERE, change_list); |
| EXPECT_FALSE(error.IsSet()); |
| |
| // The number of callback should still be zero. |
| EXPECT_EQ(0, num_device_info_changed_callbacks_); |
| } |
| |
| // While the initial data will match the current device, the last modified time |
| // should be greater than the threshold and cause an update anyways. |
| TEST_F(DeviceInfoSyncServiceTest, StartSyncMatchingButStale) { |
| SyncDataList sync_data; |
| sync_data.push_back(CreateRemoteData("guid_1", "foo_1", Time())); |
| SyncMergeResult merge_result = sync_service_->MergeDataAndStartSyncing( |
| syncer::DEVICE_INFO, sync_data, PassProcessor(), |
| CreateAndPassSyncErrorFactory()); |
| |
| EXPECT_EQ(1U, sync_processor_->change_list_size()); |
| EXPECT_EQ(SyncChange::ACTION_UPDATE, sync_processor_->change_type_at(0)); |
| EXPECT_EQ("guid_1", sync_processor_->cache_guid_at(0)); |
| EXPECT_EQ("client_1", sync_processor_->client_name_at(0)); |
| } |
| |
| TEST_F(DeviceInfoSyncServiceTest, GetLastUpdateTime) { |
| Time time1(Time() + TimeDelta::FromDays(1)); |
| Time time2(Time() + TimeDelta::FromDays(2)); |
| |
| SyncData localA( |
| SyncData::CreateLocalData("a", "a", CreateEntitySpecifics("a", "a"))); |
| |
| EntitySpecifics entityB(CreateEntitySpecifics("b", "b")); |
| entityB.mutable_device_info()->set_last_updated_timestamp( |
| syncer::TimeToProtoTime(time1)); |
| SyncData localB(SyncData::CreateLocalData("b", "b", entityB)); |
| |
| SyncData remoteC(SyncData::CreateRemoteData( |
| 1, CreateEntitySpecifics("c", "c"), time2, AttachmentIdList(), |
| AttachmentServiceProxyForTest::Create())); |
| |
| EntitySpecifics entityD(CreateEntitySpecifics("d", "d")); |
| entityD.mutable_device_info()->set_last_updated_timestamp( |
| syncer::TimeToProtoTime(time1)); |
| SyncData remoteD( |
| SyncData::CreateRemoteData(1, entityD, time2, AttachmentIdList(), |
| AttachmentServiceProxyForTest::Create())); |
| |
| EXPECT_EQ(Time(), GetLastUpdateTime(localA)); |
| EXPECT_EQ(time1, GetLastUpdateTime(localB)); |
| EXPECT_EQ(time2, GetLastUpdateTime(remoteC)); |
| EXPECT_EQ(time1, GetLastUpdateTime(remoteD)); |
| } |
| |
| // Verifies the number of active devices is 0 when there is no data. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesNone) { |
| EXPECT_EQ(0, CountActiveDevices(Time())); |
| } |
| |
| // Verifies the number of active devices when we have one active device info. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesOneActive) { |
| StoreSyncData("active", CreateRemoteData("active", "active", Time())); |
| EXPECT_EQ( |
| 1, CountActiveDevices(Time() + (DeviceInfoUtil::kActiveThreshold / 2))); |
| } |
| |
| // Verifies the number of active devices when we have one stale that hasn't been |
| // updated for exactly the threshold is considered stale. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesExactlyStale) { |
| StoreSyncData("stale", CreateRemoteData("stale", "stale", Time())); |
| EXPECT_EQ(0, CountActiveDevices(Time() + DeviceInfoUtil::kActiveThreshold)); |
| } |
| |
| // Verifies the number of active devices when we have a mix of active and stale |
| // device infos. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesManyMix) { |
| StoreSyncData("stale", CreateRemoteData("stale", "stale", Time())); |
| StoreSyncData("active1", CreateRemoteData( |
| "active1", "active1", |
| Time() + DeviceInfoUtil::kActiveThreshold / 2)); |
| StoreSyncData("active2", |
| CreateRemoteData("active2", "active2", |
| Time() + DeviceInfoUtil::kActiveThreshold)); |
| EXPECT_EQ(2, CountActiveDevices(Time() + DeviceInfoUtil::kActiveThreshold)); |
| } |
| |
| // Verifies the number of active devices when we have many that are stale. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesManyStale) { |
| StoreSyncData("stale1", CreateRemoteData("stale1", "stale1", Time())); |
| StoreSyncData("stale2", |
| CreateRemoteData("stale2", "stale2", |
| Time() + DeviceInfoUtil::kActiveThreshold)); |
| StoreSyncData("stale3", CreateRemoteData( |
| "stale3", "stale3", |
| Time() + (DeviceInfoUtil::kActiveThreshold * 2))); |
| EXPECT_EQ( |
| 0, CountActiveDevices(Time() + (DeviceInfoUtil::kActiveThreshold * 3))); |
| } |
| |
| // Verifies the number of active devices when we have devices that claim to have |
| // been updated in the future. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesFuture) { |
| StoreSyncData("now", |
| CreateRemoteData("now", "now", |
| Time() + DeviceInfoUtil::kActiveThreshold)); |
| StoreSyncData( |
| "future", |
| CreateRemoteData("future", "future", |
| Time() + (DeviceInfoUtil::kActiveThreshold * 10))); |
| EXPECT_EQ(2, CountActiveDevices(Time() + DeviceInfoUtil::kActiveThreshold)); |
| } |
| |
| // Verifies the number of active devices when they don't have an updated time |
| // set, and fallback to checking the SyncData's last modified time. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesModifiedTime) { |
| sync_pb::EntitySpecifics stale_entity; |
| sync_pb::DeviceInfoSpecifics& stale_specifics = |
| *stale_entity.mutable_device_info(); |
| stale_specifics.set_cache_guid("stale"); |
| StoreSyncData("stale", SyncData::CreateRemoteData( |
| 1, stale_entity, Time(), AttachmentIdList(), |
| AttachmentServiceProxyForTest::Create())); |
| |
| sync_pb::EntitySpecifics active_entity; |
| sync_pb::DeviceInfoSpecifics& active_specifics = |
| *active_entity.mutable_device_info(); |
| active_specifics.set_cache_guid("active"); |
| StoreSyncData( |
| "active", |
| SyncData::CreateRemoteData( |
| 1, active_entity, Time() + (DeviceInfoUtil::kActiveThreshold / 2), |
| AttachmentIdList(), AttachmentServiceProxyForTest::Create())); |
| |
| EXPECT_EQ(1, CountActiveDevices(Time() + DeviceInfoUtil::kActiveThreshold)); |
| } |
| |
| // Verifies the number of active devices when they don't have an updated time |
| // and they're not remote, which means we cannot use SyncData's last modified |
| // time. If now is close to uninitialized time, should still be active. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesLocalActive) { |
| sync_pb::EntitySpecifics entity; |
| sync_pb::DeviceInfoSpecifics& specifics = *entity.mutable_device_info(); |
| specifics.set_cache_guid("active"); |
| StoreSyncData("active", |
| SyncData::CreateLocalData("active", "active", entity)); |
| EXPECT_EQ( |
| 1, CountActiveDevices(Time() + (DeviceInfoUtil::kActiveThreshold / 2))); |
| } |
| |
| // Verifies the number of active devices when they don't have an updated time |
| // and they're not remote, which means we cannot use SyncData's last modified |
| // time. If now is far from uninitialized time, should be stale. |
| TEST_F(DeviceInfoSyncServiceTest, CountActiveDevicesLocalStale) { |
| sync_pb::EntitySpecifics entity; |
| sync_pb::DeviceInfoSpecifics& specifics = *entity.mutable_device_info(); |
| specifics.set_cache_guid("stale"); |
| StoreSyncData("stale", SyncData::CreateLocalData("stale", "stale", entity)); |
| EXPECT_EQ(0, CountActiveDevices(Time() + DeviceInfoUtil::kActiveThreshold)); |
| } |
| |
| } // namespace |
| |
| } // namespace sync_driver |
