OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 #ifndef SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ | 5 #ifndef COMPONENTS_SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ |
6 #define SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ | 6 #define COMPONENTS_SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ |
7 | 7 |
8 #include <stdint.h> | 8 #include <stdint.h> |
9 | 9 |
10 #include <map> | 10 #include <map> |
11 #include <memory> | 11 #include <memory> |
12 #include <string> | 12 #include <string> |
13 #include <vector> | 13 #include <vector> |
14 | 14 |
15 #include "base/callback.h" | 15 #include "base/callback.h" |
16 #include "base/observer_list.h" | 16 #include "base/observer_list.h" |
17 #include "base/threading/thread_checker.h" | 17 #include "base/threading/thread_checker.h" |
18 #include "base/values.h" | 18 #include "base/values.h" |
19 #include "sync/internal_api/public/base/model_type.h" | 19 #include "components/sync/base/model_type.h" |
20 #include "sync/protocol/sync.pb.h" | 20 #include "components/sync/protocol/sync.pb.h" |
21 #include "sync/test/fake_server/fake_server_entity.h" | 21 #include "components/sync/test/fake_server/fake_server_entity.h" |
22 | 22 |
23 namespace fake_server { | 23 namespace fake_server { |
24 | 24 |
25 // A fake version of the Sync server used for testing. This class is not thread | 25 // A fake version of the Sync server used for testing. This class is not thread |
26 // safe. | 26 // safe. |
27 class FakeServer { | 27 class FakeServer { |
28 public: | 28 public: |
29 class Observer { | 29 class Observer { |
30 public: | 30 public: |
31 virtual ~Observer() {} | 31 virtual ~Observer() {} |
32 | 32 |
33 // Called after FakeServer has processed a successful commit. The types | 33 // Called after FakeServer has processed a successful commit. The types |
34 // updated as part of the commit are passed in |committed_model_types|. | 34 // updated as part of the commit are passed in |committed_model_types|. |
35 virtual void OnCommit( | 35 virtual void OnCommit(const std::string& committer_id, |
36 const std::string& committer_id, | 36 syncer::ModelTypeSet committed_model_types) = 0; |
37 syncer::ModelTypeSet committed_model_types) = 0; | |
38 }; | 37 }; |
39 | 38 |
40 FakeServer(); | 39 FakeServer(); |
41 virtual ~FakeServer(); | 40 virtual ~FakeServer(); |
42 | 41 |
43 // Handles a /command POST (with the given |request|) to the server. Three | 42 // Handles a /command POST (with the given |request|) to the server. Three |
44 // output arguments, |error_code|, |response_code|, and |response|, are used | 43 // output arguments, |error_code|, |response_code|, and |response|, are used |
45 // to pass data back to the caller. The command has failed if the value | 44 // to pass data back to the caller. The command has failed if the value |
46 // pointed to by |error_code| is nonzero. |completion_closure| will be called | 45 // pointed to by |error_code| is nonzero. |completion_closure| will be called |
47 // immediately before return. | 46 // immediately before return. |
(...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
106 // Force the server to return |error_type| in the error_code field of | 105 // Force the server to return |error_type| in the error_code field of |
107 // ClientToServerResponse on all subsequent sync requests. This method should | 106 // ClientToServerResponse on all subsequent sync requests. This method should |
108 // not be called if TriggerActionableError has previously been called. Returns | 107 // not be called if TriggerActionableError has previously been called. Returns |
109 // true if error triggering was successfully configured. | 108 // true if error triggering was successfully configured. |
110 bool TriggerError(const sync_pb::SyncEnums::ErrorType& error_type); | 109 bool TriggerError(const sync_pb::SyncEnums::ErrorType& error_type); |
111 | 110 |
112 // Force the server to return the given data as part of the error field of | 111 // Force the server to return the given data as part of the error field of |
113 // ClientToServerResponse on all subsequent sync requests. This method should | 112 // ClientToServerResponse on all subsequent sync requests. This method should |
114 // not be called if TriggerError has previously been called. Returns true if | 113 // not be called if TriggerError has previously been called. Returns true if |
115 // error triggering was successfully configured. | 114 // error triggering was successfully configured. |
116 bool TriggerActionableError( | 115 bool TriggerActionableError(const sync_pb::SyncEnums::ErrorType& error_type, |
117 const sync_pb::SyncEnums::ErrorType& error_type, | 116 const std::string& description, |
118 const std::string& description, | 117 const std::string& url, |
119 const std::string& url, | 118 const sync_pb::SyncEnums::Action& action); |
120 const sync_pb::SyncEnums::Action& action); | |
121 | 119 |
122 // Instructs the server to send triggered errors on every other request | 120 // Instructs the server to send triggered errors on every other request |
123 // (starting with the first one after this call). This feature can be used to | 121 // (starting with the first one after this call). This feature can be used to |
124 // test the resiliency of the client when communicating with a problematic | 122 // test the resiliency of the client when communicating with a problematic |
125 // server or flaky network connection. This method should only be called | 123 // server or flaky network connection. This method should only be called |
126 // after a call to TriggerError or TriggerActionableError. Returns true if | 124 // after a call to TriggerError or TriggerActionableError. Returns true if |
127 // triggered error alternating was successful. | 125 // triggered error alternating was successful. |
128 bool EnableAlternatingTriggeredErrors(); | 126 bool EnableAlternatingTriggeredErrors(); |
129 | 127 |
130 // Adds |observer| to FakeServer's observer list. This should be called | 128 // Adds |observer| to FakeServer's observer list. This should be called |
(...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
260 // Used to verify that FakeServer is only used from one thread. | 258 // Used to verify that FakeServer is only used from one thread. |
261 base::ThreadChecker thread_checker_; | 259 base::ThreadChecker thread_checker_; |
262 | 260 |
263 // Creates WeakPtr versions of the current FakeServer. This must be the last | 261 // Creates WeakPtr versions of the current FakeServer. This must be the last |
264 // data member! | 262 // data member! |
265 base::WeakPtrFactory<FakeServer> weak_ptr_factory_; | 263 base::WeakPtrFactory<FakeServer> weak_ptr_factory_; |
266 }; | 264 }; |
267 | 265 |
268 } // namespace fake_server | 266 } // namespace fake_server |
269 | 267 |
270 #endif // SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ | 268 #endif // COMPONENTS_SYNC_TEST_FAKE_SERVER_FAKE_SERVER_H_ |
OLD | NEW |