Index: chrome/browser/ui/webui/sync_internals_message_handler.cc |
diff --git a/chrome/browser/ui/webui/sync_internals_message_handler.cc b/chrome/browser/ui/webui/sync_internals_message_handler.cc |
index 3a68db41789f4ca9e129e3fed8c5468fd2d34065..5979034d19cda2d3c647cf2f241f45841a2e9a7b 100644 |
--- a/chrome/browser/ui/webui/sync_internals_message_handler.cc |
+++ b/chrome/browser/ui/webui/sync_internals_message_handler.cc |
@@ -9,20 +9,26 @@ |
#include <utility> |
#include <vector> |
+#include "base/feature_list.h" |
#include "base/logging.h" |
#include "base/memory/ptr_util.h" |
+#include "base/strings/string_number_conversions.h" |
#include "chrome/browser/profiles/profile.h" |
#include "chrome/browser/sync/profile_sync_service_factory.h" |
+#include "chrome/browser/sync/user_event_service_factory.h" |
#include "chrome/common/channel_info.h" |
#include "components/browser_sync/profile_sync_service.h" |
#include "components/sync/base/weak_handle.h" |
#include "components/sync/driver/about_sync_util.h" |
+#include "components/sync/driver/sync_driver_switches.h" |
#include "components/sync/driver/sync_service.h" |
#include "components/sync/engine/cycle/commit_counters.h" |
#include "components/sync/engine/cycle/status_counters.h" |
#include "components/sync/engine/cycle/update_counters.h" |
#include "components/sync/engine/events/protocol_event.h" |
#include "components/sync/js/js_event_details.h" |
+#include "components/sync/protocol/sync.pb.h" |
+#include "components/sync/user_events/user_event_service.h" |
#include "content/public/browser/browser_thread.h" |
#include "content/public/browser/web_ui.h" |
@@ -35,6 +41,21 @@ using syncer::ModelTypeSet; |
using syncer::SyncService; |
using syncer::WeakHandle; |
+namespace { |
+ |
+// Converts the string at |index| in |list| to an int, defaulting to 0 on error. |
+int64_t StringAtIndexToInt64(const base::ListValue* list, int index) { |
+ std::string str; |
+ if (list->GetString(index, &str)) { |
+ int64_t integer = 0; |
+ if (base::StringToInt64(str, &integer)) |
+ return integer; |
+ } |
+ return 0; |
+} |
+ |
+} // namespace |
+ |
SyncInternalsMessageHandler::SyncInternalsMessageHandler() |
: SyncInternalsMessageHandler( |
base::BindRepeating( |
@@ -87,6 +108,17 @@ void SyncInternalsMessageHandler::RegisterMessages() { |
base::Unretained(this))); |
web_ui()->RegisterMessageCallback( |
+ syncer::sync_ui_util::kRequestUserEventsVisibility, |
+ base::Bind( |
+ &SyncInternalsMessageHandler::HandleRequestUserEventsVisibility, |
+ base::Unretained(this))); |
+ |
+ web_ui()->RegisterMessageCallback( |
+ syncer::sync_ui_util::kWriteUserEvent, |
+ base::Bind(&SyncInternalsMessageHandler::HandleWriteUserEvent, |
+ base::Unretained(this))); |
+ |
+ web_ui()->RegisterMessageCallback( |
syncer::sync_ui_util::kGetAllNodes, |
base::Bind(&SyncInternalsMessageHandler::HandleGetAllNodes, |
base::Unretained(this))); |
@@ -172,6 +204,31 @@ void SyncInternalsMessageHandler::HandleGetAllNodes(const ListValue* args) { |
} |
} |
+void SyncInternalsMessageHandler::HandleRequestUserEventsVisibility( |
+ const base::ListValue* args) { |
+ DCHECK(args->empty()); |
+ AllowJavascript(); |
+ CallJavascriptFunction( |
+ syncer::sync_ui_util::kUserEventsVisibilityCallback, |
+ Value(base::FeatureList::IsEnabled(switches::kSyncUserEvents))); |
+} |
+ |
+void SyncInternalsMessageHandler::HandleWriteUserEvent( |
+ const base::ListValue* args) { |
+ DCHECK_EQ(2U, args->GetSize()); |
+ AllowJavascript(); |
+ |
+ Profile* profile = Profile::FromWebUI(web_ui()); |
+ syncer::UserEventService* user_event_service = |
+ browser_sync::UserEventServiceFactory::GetForProfile( |
+ profile->GetOriginalProfile()); |
+ |
+ sync_pb::UserEventSpecifics event_specifics; |
+ event_specifics.set_event_time_usec(StringAtIndexToInt64(args, 0)); |
+ event_specifics.set_navigation_id(StringAtIndexToInt64(args, 1)); |
+ user_event_service->RecordUserEvent(event_specifics); |
+} |
+ |
void SyncInternalsMessageHandler::OnReceivedAllNodes( |
int request_id, |
std::unique_ptr<ListValue> nodes) { |