| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "net/reporting/reporting_persister.h" | 5 #include "net/reporting/reporting_persister.h" |
| 6 | 6 |
| 7 #include "base/json/json_writer.h" | 7 #include "base/json/json_writer.h" |
| 8 #include "base/memory/ptr_util.h" | 8 #include "base/memory/ptr_util.h" |
| 9 #include "base/test/simple_test_clock.h" | 9 #include "base/test/simple_test_clock.h" |
| 10 #include "base/test/simple_test_tick_clock.h" | 10 #include "base/test/simple_test_tick_clock.h" |
| (...skipping 12 matching lines...) Expand all Loading... |
| 23 | 23 |
| 24 class ReportingPersisterTest : public ReportingTestBase { | 24 class ReportingPersisterTest : public ReportingTestBase { |
| 25 protected: | 25 protected: |
| 26 const GURL kUrl_ = GURL("https://origin/path"); | 26 const GURL kUrl_ = GURL("https://origin/path"); |
| 27 const url::Origin kOrigin_ = url::Origin(kUrl_); | 27 const url::Origin kOrigin_ = url::Origin(kUrl_); |
| 28 const GURL kEndpoint_ = GURL("https://endpoint/"); | 28 const GURL kEndpoint_ = GURL("https://endpoint/"); |
| 29 const std::string kGroup_ = "group"; | 29 const std::string kGroup_ = "group"; |
| 30 const std::string kType_ = "default"; | 30 const std::string kType_ = "default"; |
| 31 }; | 31 }; |
| 32 | 32 |
| 33 TEST_F(ReportingPersisterTest, Test) { | 33 // Disabled because the Persister has no persistence layer to use yet. |
| 34 TEST_F(ReportingPersisterTest, DISABLED_Test) { |
| 34 ReportingPolicy policy; | 35 ReportingPolicy policy; |
| 35 policy.persist_reports_across_restarts = true; | 36 policy.persist_reports_across_restarts = true; |
| 36 policy.persist_clients_across_restarts = true; | 37 policy.persist_clients_across_restarts = true; |
| 37 // Make sure reports don't expire on our simulated restart. | 38 // Make sure reports don't expire on our simulated restart. |
| 38 policy.max_report_age = base::TimeDelta::FromDays(30); | 39 policy.max_report_age = base::TimeDelta::FromDays(30); |
| 39 UsePolicy(policy); | 40 UsePolicy(policy); |
| 40 | 41 |
| 41 static const int kAttempts = 3; | 42 static const int kAttempts = 3; |
| 42 | 43 |
| 43 base::DictionaryValue body; | 44 base::DictionaryValue body; |
| 44 body.SetString("key", "value"); | 45 body.SetString("key", "value"); |
| 45 | 46 |
| 46 cache()->AddReport(kUrl_, kGroup_, kType_, body.CreateDeepCopy(), | 47 cache()->AddReport(kUrl_, kGroup_, kType_, body.CreateDeepCopy(), |
| 47 tick_clock()->NowTicks(), kAttempts); | 48 tick_clock()->NowTicks(), kAttempts); |
| 48 cache()->SetClient(kOrigin_, kEndpoint_, ReportingClient::Subdomains::EXCLUDE, | 49 cache()->SetClient(kOrigin_, kEndpoint_, ReportingClient::Subdomains::EXCLUDE, |
| 49 kGroup_, | 50 kGroup_, |
| 50 tick_clock()->NowTicks() + base::TimeDelta::FromDays(1)); | 51 tick_clock()->NowTicks() + base::TimeDelta::FromDays(1)); |
| 51 | 52 |
| 52 EXPECT_TRUE(persistence_timer()->IsRunning()); | 53 // TODO: Actually trigger persistence, once it's possible. |
| 53 persistence_timer()->Fire(); | |
| 54 | 54 |
| 55 SimulateRestart(/* delta= */ base::TimeDelta::FromHours(1), | 55 SimulateRestart(/* delta= */ base::TimeDelta::FromHours(1), |
| 56 /* delta_ticks= */ base::TimeDelta::FromHours(-3)); | 56 /* delta_ticks= */ base::TimeDelta::FromHours(-3)); |
| 57 | 57 |
| 58 std::vector<const ReportingReport*> reports; | 58 std::vector<const ReportingReport*> reports; |
| 59 cache()->GetReports(&reports); | 59 cache()->GetReports(&reports); |
| 60 ASSERT_EQ(1u, reports.size()); | 60 ASSERT_EQ(1u, reports.size()); |
| 61 EXPECT_EQ(kUrl_, reports[0]->url); | 61 EXPECT_EQ(kUrl_, reports[0]->url); |
| 62 EXPECT_EQ(kGroup_, reports[0]->group); | 62 EXPECT_EQ(kGroup_, reports[0]->group); |
| 63 EXPECT_EQ(kType_, reports[0]->type); | 63 EXPECT_EQ(kType_, reports[0]->type); |
| 64 EXPECT_TRUE(base::Value::Equals(&body, reports[0]->body.get())); | 64 EXPECT_TRUE(base::Value::Equals(&body, reports[0]->body.get())); |
| 65 EXPECT_EQ(tick_clock()->NowTicks() - base::TimeDelta::FromHours(1), | 65 EXPECT_EQ(tick_clock()->NowTicks() - base::TimeDelta::FromHours(1), |
| 66 reports[0]->queued); | 66 reports[0]->queued); |
| 67 EXPECT_EQ(kAttempts, reports[0]->attempts); | 67 EXPECT_EQ(kAttempts, reports[0]->attempts); |
| 68 | 68 |
| 69 const ReportingClient* client = | 69 const ReportingClient* client = |
| 70 FindClientInCache(cache(), kOrigin_, kEndpoint_); | 70 FindClientInCache(cache(), kOrigin_, kEndpoint_); |
| 71 ASSERT_TRUE(client); | 71 ASSERT_TRUE(client); |
| 72 EXPECT_EQ(ReportingClient::Subdomains::EXCLUDE, client->subdomains); | 72 EXPECT_EQ(ReportingClient::Subdomains::EXCLUDE, client->subdomains); |
| 73 EXPECT_EQ(kGroup_, client->group); | 73 EXPECT_EQ(kGroup_, client->group); |
| 74 EXPECT_EQ(tick_clock()->NowTicks() + base::TimeDelta::FromDays(1) - | 74 EXPECT_EQ(tick_clock()->NowTicks() + base::TimeDelta::FromDays(1) - |
| 75 base::TimeDelta::FromHours(1), | 75 base::TimeDelta::FromHours(1), |
| 76 client->expires); | 76 client->expires); |
| 77 } | 77 } |
| 78 | 78 |
| 79 } // namespace | 79 } // namespace |
| 80 } // namespace net | 80 } // namespace net |
| OLD | NEW |