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 |