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 #include "chrome/browser/ui/webui/invalidations_message_handler.h" | 5 #include "chrome/browser/ui/webui/invalidations_message_handler.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "chrome/browser/invalidation/invalidation_logger.h" | 8 #include "chrome/browser/invalidation/invalidation_logger.h" |
9 #include "chrome/browser/invalidation/invalidation_service.h" | 9 #include "chrome/browser/invalidation/invalidation_service.h" |
10 #include "chrome/browser/invalidation/invalidation_service_factory.h" | 10 #include "chrome/browser/invalidation/invalidation_service_factory.h" |
11 #include "chrome/browser/profiles/profile.h" | 11 #include "chrome/browser/profiles/profile.h" |
12 #include "content/public/browser/web_ui.h" | 12 #include "content/public/browser/web_ui.h" |
| 13 #include "sync/notifier/invalidation_handler.h" |
13 | 14 |
14 namespace invalidation { | 15 namespace invalidation { |
15 class InvalidationLogger; | 16 class InvalidationLogger; |
16 } // namespace invalidation | 17 } // namespace invalidation |
17 | 18 |
18 namespace syncer { | 19 namespace syncer { |
19 class ObjectIdInvalidationMap; | 20 class ObjectIdInvalidationMap; |
20 } // namespace syncer | 21 } // namespace syncer |
21 | 22 |
22 InvalidationsMessageHandler::InvalidationsMessageHandler() | 23 InvalidationsMessageHandler::InvalidationsMessageHandler() |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
61 const base::DictionaryValue& newRegistrationState) {} | 62 const base::DictionaryValue& newRegistrationState) {} |
62 | 63 |
63 void InvalidationsMessageHandler::OnStateChange( | 64 void InvalidationsMessageHandler::OnStateChange( |
64 const syncer::InvalidatorState& newState) { | 65 const syncer::InvalidatorState& newState) { |
65 std::string state(syncer::InvalidatorStateToString(newState)); | 66 std::string state(syncer::InvalidatorStateToString(newState)); |
66 web_ui()->CallJavascriptFunction("chrome.invalidations.updateState", | 67 web_ui()->CallJavascriptFunction("chrome.invalidations.updateState", |
67 base::StringValue(state)); | 68 base::StringValue(state)); |
68 } | 69 } |
69 | 70 |
70 void InvalidationsMessageHandler::OnUpdateIds( | 71 void InvalidationsMessageHandler::OnUpdateIds( |
71 const base::DictionaryValue& newIds) {} | 72 std::string handlerName, |
72 | 73 const syncer::ObjectIdSet& idsSet) { |
| 74 scoped_ptr<base::ListValue> listOfObjects = ObjectIdSetToList(idsSet); |
| 75 web_ui()->CallJavascriptFunction("chrome.invalidations.updateIds", |
| 76 base::StringValue(handlerName), |
| 77 *listOfObjects); |
| 78 } |
73 void InvalidationsMessageHandler::OnDebugMessage( | 79 void InvalidationsMessageHandler::OnDebugMessage( |
74 const base::DictionaryValue& details) {} | 80 const base::DictionaryValue& details) {} |
75 | 81 |
76 void InvalidationsMessageHandler::OnInvalidation( | 82 void InvalidationsMessageHandler::OnInvalidation( |
77 const syncer::ObjectIdInvalidationMap& newInvalidations) { | 83 const syncer::ObjectIdInvalidationMap& newInvalidations) { |
78 scoped_ptr<base::ListValue> invalidationsList = newInvalidations.ToValue(); | 84 scoped_ptr<base::ListValue> invalidationsList = newInvalidations.ToValue(); |
79 web_ui()->CallJavascriptFunction("chrome.invalidations.logInvalidations", | 85 web_ui()->CallJavascriptFunction("chrome.invalidations.logInvalidations", |
80 *invalidationsList); | 86 *invalidationsList); |
81 } | 87 } |
| 88 |
| 89 scoped_ptr<base::ListValue> InvalidationsMessageHandler::ObjectIdSetToList( |
| 90 const syncer::ObjectIdSet& idsSet) { |
| 91 scoped_ptr<base::ListValue> list(new base::ListValue()); |
| 92 |
| 93 for (syncer::ObjectIdSet::iterator it = idsSet.begin(); it != idsSet.end(); |
| 94 ++it) { |
| 95 scoped_ptr<base::DictionaryValue> dic(new base::DictionaryValue); |
| 96 dic->SetString("name", it->name()); |
| 97 dic->SetInteger("source", it->source()); |
| 98 list->Append(dic.release()); |
| 99 } |
| 100 return list.Pass(); |
| 101 } |
OLD | NEW |