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" |
11 #include "base/time/time.h" | 11 #include "base/time/time.h" |
12 #include "base/timer/mock_timer.h" | 12 #include "base/timer/mock_timer.h" |
13 #include "base/values.h" | 13 #include "base/values.h" |
| 14 #include "net/base/test_completion_callback.h" |
14 #include "net/reporting/reporting_cache.h" | 15 #include "net/reporting/reporting_cache.h" |
15 #include "net/reporting/reporting_client.h" | 16 #include "net/reporting/reporting_client.h" |
16 #include "net/reporting/reporting_policy.h" | 17 #include "net/reporting/reporting_policy.h" |
17 #include "net/reporting/reporting_report.h" | 18 #include "net/reporting/reporting_report.h" |
18 #include "net/reporting/reporting_test_util.h" | 19 #include "net/reporting/reporting_test_util.h" |
19 #include "testing/gtest/include/gtest/gtest.h" | 20 #include "testing/gtest/include/gtest/gtest.h" |
20 | 21 |
21 namespace net { | 22 namespace net { |
22 namespace { | 23 namespace { |
23 | 24 |
(...skipping 19 matching lines...) Expand all Loading... |
43 | 44 |
44 base::DictionaryValue body; | 45 base::DictionaryValue body; |
45 body.SetString("key", "value"); | 46 body.SetString("key", "value"); |
46 | 47 |
47 cache()->AddReport(kUrl_, kGroup_, kType_, body.CreateDeepCopy(), | 48 cache()->AddReport(kUrl_, kGroup_, kType_, body.CreateDeepCopy(), |
48 tick_clock()->NowTicks(), kAttempts); | 49 tick_clock()->NowTicks(), kAttempts); |
49 cache()->SetClient(kOrigin_, kEndpoint_, ReportingClient::Subdomains::EXCLUDE, | 50 cache()->SetClient(kOrigin_, kEndpoint_, ReportingClient::Subdomains::EXCLUDE, |
50 kGroup_, | 51 kGroup_, |
51 tick_clock()->NowTicks() + base::TimeDelta::FromDays(1)); | 52 tick_clock()->NowTicks() + base::TimeDelta::FromDays(1)); |
52 | 53 |
53 // TODO: Actually trigger persistence, once it's possible. | 54 // TODO: Actually save data, once it's possible. |
54 | 55 |
55 SimulateRestart(/* delta= */ base::TimeDelta::FromHours(1), | 56 SimulateRestart(/* delta= */ base::TimeDelta::FromHours(1), |
56 /* delta_ticks= */ base::TimeDelta::FromHours(-3)); | 57 /* delta_ticks= */ base::TimeDelta::FromHours(-3)); |
57 | 58 |
| 59 // TODO: Actually load data, once it's possible. |
| 60 |
58 std::vector<const ReportingReport*> reports; | 61 std::vector<const ReportingReport*> reports; |
59 cache()->GetReports(&reports); | 62 cache()->GetReports(&reports); |
60 ASSERT_EQ(1u, reports.size()); | 63 ASSERT_EQ(1u, reports.size()); |
61 EXPECT_EQ(kUrl_, reports[0]->url); | 64 EXPECT_EQ(kUrl_, reports[0]->url); |
62 EXPECT_EQ(kGroup_, reports[0]->group); | 65 EXPECT_EQ(kGroup_, reports[0]->group); |
63 EXPECT_EQ(kType_, reports[0]->type); | 66 EXPECT_EQ(kType_, reports[0]->type); |
64 EXPECT_TRUE(base::Value::Equals(&body, reports[0]->body.get())); | 67 EXPECT_TRUE(base::Value::Equals(&body, reports[0]->body.get())); |
65 EXPECT_EQ(tick_clock()->NowTicks() - base::TimeDelta::FromHours(1), | 68 EXPECT_EQ(tick_clock()->NowTicks() - base::TimeDelta::FromHours(1), |
66 reports[0]->queued); | 69 reports[0]->queued); |
67 EXPECT_EQ(kAttempts, reports[0]->attempts); | 70 EXPECT_EQ(kAttempts, reports[0]->attempts); |
68 | 71 |
69 const ReportingClient* client = | 72 const ReportingClient* client = |
70 FindClientInCache(cache(), kOrigin_, kEndpoint_); | 73 FindClientInCache(cache(), kOrigin_, kEndpoint_); |
71 ASSERT_TRUE(client); | 74 ASSERT_TRUE(client); |
72 EXPECT_EQ(ReportingClient::Subdomains::EXCLUDE, client->subdomains); | 75 EXPECT_EQ(ReportingClient::Subdomains::EXCLUDE, client->subdomains); |
73 EXPECT_EQ(kGroup_, client->group); | 76 EXPECT_EQ(kGroup_, client->group); |
74 EXPECT_EQ(tick_clock()->NowTicks() + base::TimeDelta::FromDays(1) - | 77 EXPECT_EQ(tick_clock()->NowTicks() + base::TimeDelta::FromDays(1) - |
75 base::TimeDelta::FromHours(1), | 78 base::TimeDelta::FromHours(1), |
76 client->expires); | 79 client->expires); |
77 } | 80 } |
78 | 81 |
| 82 // TODO(juliatuttle): Test asynchronous behavior. |
| 83 |
79 } // namespace | 84 } // namespace |
80 } // namespace net | 85 } // namespace net |
OLD | NEW |