| 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/sync_internals_message_handler.h" | 5 #include "chrome/browser/ui/webui/sync_internals_message_handler.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/logging.h" | 9 #include "base/logging.h" |
| 10 #include "chrome/browser/profiles/profile.h" | 10 #include "chrome/browser/profiles/profile.h" |
| (...skipping 16 matching lines...) Expand all Loading... |
| 27 : weak_ptr_factory_(this) {} | 27 : weak_ptr_factory_(this) {} |
| 28 | 28 |
| 29 SyncInternalsMessageHandler::~SyncInternalsMessageHandler() { | 29 SyncInternalsMessageHandler::~SyncInternalsMessageHandler() { |
| 30 if (js_controller_) | 30 if (js_controller_) |
| 31 js_controller_->RemoveJsEventHandler(this); | 31 js_controller_->RemoveJsEventHandler(this); |
| 32 } | 32 } |
| 33 | 33 |
| 34 void SyncInternalsMessageHandler::RegisterMessages() { | 34 void SyncInternalsMessageHandler::RegisterMessages() { |
| 35 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); | 35 DCHECK(content::BrowserThread::CurrentlyOn(content::BrowserThread::UI)); |
| 36 | 36 |
| 37 // Init our link to the JsController. | 37 // Register for ProfileSyncService events. |
| 38 ProfileSyncService* service = GetProfileSyncService(); | 38 ProfileSyncService* service = GetProfileSyncService(); |
| 39 if (service) | 39 if (service) { |
| 40 service->AddObserver(this); |
| 40 js_controller_ = service->GetJsController(); | 41 js_controller_ = service->GetJsController(); |
| 41 if (js_controller_) | |
| 42 js_controller_->AddJsEventHandler(this); | 42 js_controller_->AddJsEventHandler(this); |
| 43 } |
| 43 | 44 |
| 44 web_ui()->RegisterMessageCallback( | 45 web_ui()->RegisterMessageCallback( |
| 45 "getAboutInfo", | 46 "requestUpdatedAboutInfo", |
| 46 base::Bind(&SyncInternalsMessageHandler::OnGetAboutInfo, | 47 base::Bind(&SyncInternalsMessageHandler::HandleRequestUpdatedAboutInfo, |
| 47 base::Unretained(this))); | 48 base::Unretained(this))); |
| 48 | 49 |
| 49 web_ui()->RegisterMessageCallback( | 50 web_ui()->RegisterMessageCallback( |
| 50 "getListOfTypes", | 51 "requestListOfTypes", |
| 51 base::Bind(&SyncInternalsMessageHandler::OnGetListOfTypes, | 52 base::Bind(&SyncInternalsMessageHandler::HandleRequestListOfTypes, |
| 52 base::Unretained(this))); | 53 base::Unretained(this))); |
| 53 | 54 |
| 54 RegisterJsControllerCallback("getNotificationState"); | 55 RegisterJsControllerCallback("getNotificationState"); |
| 55 RegisterJsControllerCallback("getNotificationInfo"); | 56 RegisterJsControllerCallback("getNotificationInfo"); |
| 56 RegisterJsControllerCallback("getAllNodes"); | 57 RegisterJsControllerCallback("getAllNodes"); |
| 57 RegisterJsControllerCallback("getClientServerTraffic"); | 58 RegisterJsControllerCallback("getClientServerTraffic"); |
| 58 } | 59 } |
| 59 | 60 |
| 60 void SyncInternalsMessageHandler::OnGetAboutInfo(const base::ListValue* args) { | 61 void SyncInternalsMessageHandler::HandleRequestUpdatedAboutInfo( |
| 61 // TODO(rlarocque): We should DCHECK(!args) here. See crbug.com/334431. | 62 const base::ListValue* args) { |
| 62 scoped_ptr<base::DictionaryValue> value = | 63 DCHECK(args->empty()); |
| 63 sync_ui_util::ConstructAboutInformation(GetProfileSyncService()); | 64 SendAboutInfo(); |
| 64 web_ui()->CallJavascriptFunction( | |
| 65 "chrome.sync.getAboutInfo.handleReply", | |
| 66 *value); | |
| 67 } | 65 } |
| 68 | 66 |
| 69 void SyncInternalsMessageHandler::OnGetListOfTypes( | 67 void SyncInternalsMessageHandler::HandleRequestListOfTypes( |
| 70 const base::ListValue* args) { | 68 const base::ListValue* args) { |
| 71 // TODO(rlarocque): We should DCHECK(!args) here. See crbug.com/334431. | 69 DCHECK(args->empty()); |
| 72 base::ListValue type_list; | 70 base::DictionaryValue event_details; |
| 71 scoped_ptr<base::ListValue> type_list(new base::ListValue()); |
| 73 ModelTypeSet protocol_types = syncer::ProtocolTypes(); | 72 ModelTypeSet protocol_types = syncer::ProtocolTypes(); |
| 74 for (ModelTypeSet::Iterator it = protocol_types.First(); | 73 for (ModelTypeSet::Iterator it = protocol_types.First(); |
| 75 it.Good(); it.Inc()) { | 74 it.Good(); it.Inc()) { |
| 76 type_list.Append(new base::StringValue(ModelTypeToString(it.Get()))); | 75 type_list->Append(new base::StringValue(ModelTypeToString(it.Get()))); |
| 77 } | 76 } |
| 77 event_details.Set("types", type_list.release()); |
| 78 web_ui()->CallJavascriptFunction( | 78 web_ui()->CallJavascriptFunction( |
| 79 "chrome.sync.getListOfTypes.handleReply", | 79 "chrome.sync.dispatchEvent", |
| 80 type_list); | 80 base::StringValue("onReceivedListOfTypes"), |
| 81 event_details); |
| 81 } | 82 } |
| 82 | 83 |
| 83 void SyncInternalsMessageHandler::HandleJsReply( | 84 void SyncInternalsMessageHandler::HandleJsReply( |
| 84 const std::string& name, const JsArgList& args) { | 85 const std::string& name, const JsArgList& args) { |
| 85 DVLOG(1) << "Handling reply for " << name << " message" | 86 DVLOG(1) << "Handling reply for " << name << " message" |
| 86 << " with args " << args.ToString(); | 87 << " with args " << args.ToString(); |
| 87 const std::string& reply_handler = "chrome.sync." + name + ".handleReply"; | 88 const std::string& reply_handler = "chrome.sync." + name + ".handleReply"; |
| 88 std::vector<const base::Value*> arg_list(args.Get().begin(), | 89 std::vector<const base::Value*> arg_list(args.Get().begin(), |
| 89 args.Get().end()); | 90 args.Get().end()); |
| 90 web_ui()->CallJavascriptFunction(reply_handler, arg_list); | 91 web_ui()->CallJavascriptFunction(reply_handler, arg_list); |
| 91 } | 92 } |
| 92 | 93 |
| 94 void SyncInternalsMessageHandler::OnStateChanged() { |
| 95 SendAboutInfo(); |
| 96 } |
| 97 |
| 93 void SyncInternalsMessageHandler::HandleJsEvent( | 98 void SyncInternalsMessageHandler::HandleJsEvent( |
| 94 const std::string& name, | 99 const std::string& name, |
| 95 const JsEventDetails& details) { | 100 const JsEventDetails& details) { |
| 96 DVLOG(1) << "Handling event: " << name | 101 DVLOG(1) << "Handling event: " << name |
| 97 << " with details " << details.ToString(); | 102 << " with details " << details.ToString(); |
| 98 web_ui()->CallJavascriptFunction("chrome.sync.dispatchEvent", | 103 web_ui()->CallJavascriptFunction("chrome.sync.dispatchEvent", |
| 99 base::StringValue(name), | 104 base::StringValue(name), |
| 100 details.Get()); | 105 details.Get()); |
| 101 } | 106 } |
| 102 | 107 |
| 103 void SyncInternalsMessageHandler::RegisterJsControllerCallback( | 108 void SyncInternalsMessageHandler::RegisterJsControllerCallback( |
| 104 const std::string& name) { | 109 const std::string& name) { |
| 105 web_ui()->RegisterMessageCallback( | 110 web_ui()->RegisterMessageCallback( |
| 106 name, | 111 name, |
| 107 base::Bind(&SyncInternalsMessageHandler::ForwardToJsController, | 112 base::Bind(&SyncInternalsMessageHandler::ForwardToJsController, |
| 108 base::Unretained(this), | 113 base::Unretained(this), |
| 109 name)); | 114 name)); |
| 110 } | 115 } |
| 111 | 116 |
| 117 void SyncInternalsMessageHandler::SendAboutInfo() { |
| 118 scoped_ptr<base::DictionaryValue> value = |
| 119 sync_ui_util::ConstructAboutInformation(GetProfileSyncService()); |
| 120 web_ui()->CallJavascriptFunction( |
| 121 "chrome.sync.dispatchEvent", |
| 122 base::StringValue("onAboutInfoUpdated"), |
| 123 *value); |
| 124 } |
| 125 |
| 112 void SyncInternalsMessageHandler::ForwardToJsController( | 126 void SyncInternalsMessageHandler::ForwardToJsController( |
| 113 const std::string& name, | 127 const std::string& name, |
| 114 const base::ListValue* args) { | 128 const base::ListValue* args) { |
| 115 if (js_controller_) { | 129 if (js_controller_) { |
| 116 scoped_ptr<base::ListValue> args_copy(args->DeepCopy()); | 130 scoped_ptr<base::ListValue> args_copy(args->DeepCopy()); |
| 117 JsArgList js_arg_list(args_copy.get()); | 131 JsArgList js_arg_list(args_copy.get()); |
| 118 js_controller_->ProcessJsMessage( | 132 js_controller_->ProcessJsMessage( |
| 119 name, js_arg_list, | 133 name, js_arg_list, |
| 120 MakeWeakHandle(weak_ptr_factory_.GetWeakPtr())); | 134 MakeWeakHandle(weak_ptr_factory_.GetWeakPtr())); |
| 121 } else { | 135 } else { |
| 122 DLOG(WARNING) << "No sync service; dropping message " << name; | 136 DLOG(WARNING) << "No sync service; dropping message " << name; |
| 123 } | 137 } |
| 124 } | 138 } |
| 125 | 139 |
| 126 // Gets the ProfileSyncService of the underlying original profile. | 140 // Gets the ProfileSyncService of the underlying original profile. |
| 127 // May return NULL (e.g., if sync is disabled on the command line). | 141 // May return NULL (e.g., if sync is disabled on the command line). |
| 128 ProfileSyncService* SyncInternalsMessageHandler::GetProfileSyncService() { | 142 ProfileSyncService* SyncInternalsMessageHandler::GetProfileSyncService() { |
| 129 Profile* profile = Profile::FromWebUI(web_ui()); | 143 Profile* profile = Profile::FromWebUI(web_ui()); |
| 130 ProfileSyncServiceFactory* factory = ProfileSyncServiceFactory::GetInstance(); | 144 ProfileSyncServiceFactory* factory = ProfileSyncServiceFactory::GetInstance(); |
| 131 return factory->GetForProfile(profile->GetOriginalProfile()); | 145 return factory->GetForProfile(profile->GetOriginalProfile()); |
| 132 } | 146 } |
| 133 | 147 |
| OLD | NEW |