OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 "chrome/browser/sync/engine/clear_data_command.h" | 5 #include "chrome/browser/sync/engine/clear_data_command.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "chrome/browser/sync/engine/syncer.h" | 9 #include "chrome/browser/sync/engine/syncer.h" |
10 #include "chrome/browser/sync/engine/syncer_proto_util.h" | 10 #include "chrome/browser/sync/engine/syncer_proto_util.h" |
11 #include "chrome/browser/sync/engine/syncproto.h" | 11 #include "chrome/browser/sync/engine/syncproto.h" |
12 #include "chrome/browser/sync/sessions/sync_session.h" | 12 #include "chrome/browser/sync/sessions/sync_session.h" |
13 #include "chrome/browser/sync/syncable/directory_manager.h" | 13 #include "chrome/browser/sync/syncable/directory_manager.h" |
14 | 14 |
15 using syncable::ScopedDirLookup; | 15 using syncable::ScopedDirLookup; |
16 | 16 |
17 namespace browser_sync { | 17 namespace browser_sync { |
18 | 18 |
19 using sessions::StatusController; | 19 using sessions::StatusController; |
20 using sessions::SyncSession; | 20 using sessions::SyncSession; |
21 using std::string; | 21 using std::string; |
22 using syncable::FIRST_REAL_MODEL_TYPE; | 22 using syncable::FIRST_REAL_MODEL_TYPE; |
23 using syncable::MODEL_TYPE_COUNT; | 23 using syncable::MODEL_TYPE_COUNT; |
24 | 24 |
25 | 25 |
26 ClearDataCommand::ClearDataCommand() {} | 26 ClearDataCommand::ClearDataCommand() {} |
27 ClearDataCommand::~ClearDataCommand() {} | 27 ClearDataCommand::~ClearDataCommand() {} |
28 | 28 |
29 void ClearDataCommand::ExecuteImpl(SyncSession* session) { | 29 SyncerError ClearDataCommand::ExecuteImpl(SyncSession* session) { |
30 ClientToServerMessage client_to_server_message; | 30 ClientToServerMessage client_to_server_message; |
31 ClientToServerResponse client_to_server_response; | 31 ClientToServerResponse client_to_server_response; |
32 | 32 |
33 client_to_server_message.set_share(session->context()->account_name()); | 33 client_to_server_message.set_share(session->context()->account_name()); |
34 client_to_server_message.set_message_contents( | 34 client_to_server_message.set_message_contents( |
35 ClientToServerMessage::CLEAR_DATA); | 35 ClientToServerMessage::CLEAR_DATA); |
36 | 36 |
37 client_to_server_message.mutable_clear_user_data(); | 37 client_to_server_message.mutable_clear_user_data(); |
38 | 38 |
39 ScopedDirLookup dir(session->context()->directory_manager(), | 39 ScopedDirLookup dir(session->context()->directory_manager(), |
40 session->context()->account_name()); | 40 session->context()->account_name()); |
41 if (!dir.good()) { | 41 if (!dir.good()) { |
42 LOG(ERROR) << "Scoped dir lookup failed!"; | 42 LOG(ERROR) << "Scoped dir lookup failed!"; |
43 return; | 43 return DIRECTORY_LOOKUP_FAILED; |
44 } | 44 } |
45 | 45 |
46 SyncerProtoUtil::AddRequestBirthday(dir, &client_to_server_message); | 46 SyncerProtoUtil::AddRequestBirthday(dir, &client_to_server_message); |
47 | 47 |
48 DVLOG(1) << "Clearing server data"; | 48 DVLOG(1) << "Clearing server data"; |
49 | 49 |
50 bool ok = SyncerProtoUtil::PostClientToServerMessage( | 50 SyncerError result = SyncerProtoUtil::PostClientToServerMessage( |
51 client_to_server_message, | 51 client_to_server_message, |
52 &client_to_server_response, | 52 &client_to_server_response, |
53 session); | 53 session); |
54 | 54 |
55 DVLOG(1) << SyncerProtoUtil::ClientToServerResponseDebugString( | 55 DVLOG(1) << SyncerProtoUtil::ClientToServerResponseDebugString( |
56 client_to_server_response); | 56 client_to_server_response); |
57 | 57 |
| 58 // FIXME(rlarocque): This code is wrong. The response error codes it checks |
| 59 // have been obsoleted. The only reason it hasn't caused problems is that it |
| 60 // is unreachable. We should do something to clean up this mess. |
| 61 // |
58 // Clear pending indicates that the server has received our clear message | 62 // Clear pending indicates that the server has received our clear message |
59 if (!ok || !client_to_server_response.has_error_code() || | 63 if (result != NO_ERROR || !client_to_server_response.has_error_code() || |
60 client_to_server_response.error_code() != | 64 client_to_server_response.error_code() != |
61 sync_pb::ClientToServerResponse::SUCCESS) { | 65 sync_pb::ClientToServerResponse::SUCCESS) { |
62 // On failure, subsequent requests to the server will cause it to attempt | 66 // On failure, subsequent requests to the server will cause it to attempt |
63 // to resume the clear. The client will handle disabling of sync in | 67 // to resume the clear. The client will handle disabling of sync in |
64 // response to a store birthday error from the server. | 68 // response to a store birthday error from the server. |
65 SyncEngineEvent event(SyncEngineEvent::CLEAR_SERVER_DATA_FAILED); | 69 SyncEngineEvent event(SyncEngineEvent::CLEAR_SERVER_DATA_FAILED); |
66 session->context()->NotifyListeners(event); | 70 session->context()->NotifyListeners(event); |
67 | 71 |
68 LOG(ERROR) << "Error posting ClearData."; | 72 LOG(ERROR) << "Error posting ClearData."; |
69 | 73 |
70 return; | 74 return result; |
71 } | 75 } |
72 | 76 |
73 SyncEngineEvent event(SyncEngineEvent::CLEAR_SERVER_DATA_SUCCEEDED); | 77 SyncEngineEvent event(SyncEngineEvent::CLEAR_SERVER_DATA_SUCCEEDED); |
74 session->context()->NotifyListeners(event); | 78 session->context()->NotifyListeners(event); |
75 | 79 |
76 session->delegate()->OnShouldStopSyncingPermanently(); | 80 session->delegate()->OnShouldStopSyncingPermanently(); |
77 | 81 |
78 DVLOG(1) << "ClearData succeeded."; | 82 DVLOG(1) << "ClearData succeeded."; |
| 83 return NO_ERROR; |
79 } | 84 } |
80 | 85 |
81 } // namespace browser_sync | 86 } // namespace browser_sync |
82 | 87 |
OLD | NEW |