Add an IPC method for Blink to call RapporService::RecordSample()

components/rappor/rappor_service.cc

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "components/rappor/rappor_service.h"
 
 #include "base/metrics/field_trial.h"
+#include "base/metrics/user_metrics.h"
 #include "base/stl_util.h"
 #include "base/time/time.h"
 #include "components/metrics/metrics_hashes.h"
 #include "components/rappor/log_uploader.h"
 #include "components/rappor/proto/rappor_metric.pb.h"
 #include "components/rappor/rappor_metric.h"
 #include "components/rappor/rappor_pref_names.h"
 #include "components/rappor/rappor_prefs.h"
 #include "components/variations/variations_associated_data.h"
 
@@ skipping 80 matching lines @@
     DVLOG(1) << server_url.spec() << " is invalid. "
              << "RapporService not started.";
     return;
   }
   DVLOG(1) << "RapporService reporting to " << server_url.spec();
   InitializeInternal(make_scoped_ptr(new LogUploader(server_url,
                                                      kMimeType,
                                                      request_context)),
                      internal::LoadCohort(pref_service_),
                      internal::LoadSecret(pref_service_));
+
+  EnableRecordFromUserMetrics();
 }
 
 void RapporService::Update(RecordingLevel recording_level, bool may_upload) {
   DCHECK(IsInitialized());
   if (recording_level_ != recording_level) {
     if (recording_level == RECORDING_DISABLED) {
       DVLOG(1) << "Rappor service stopped due to RECORDING_DISABLED.";
       recording_level_ = RECORDING_DISABLED;
       CancelNextLogRotation();
     } else if (recording_level_ == RECORDING_DISABLED) {
@@ skipping 58 matching lines @@
     std::string log_text;
     bool success = reports.SerializeToString(&log_text);
     DCHECK(success);
     DVLOG(1) << "RapporService sending a report of "
              << reports.report_size() << " value(s).";
     uploader_->QueueLog(log_text);
   }
   ScheduleNextLogRotation(base::TimeDelta::FromSeconds(kLogIntervalSeconds));
 }
 
+void RapporService::EnableRecordFromUserMetrics() {
+  user_metrics_callback_ = base::Bind(&RapporService::OnUserMetricsCallback,
+                                      base::Unretained(this));
+  base::AddRapporCallback(user_metrics_callback_);
+}
+
+void RapporService::OnUserMetricsCallback(
+    const std::string& metric,
+    const std::string& sample) {
+  RecordSample(metric, COARSE_RAPPOR_TYPE, sample);

[Steven Holte, 2015/03/23 20:34:06]

This should probably be ETLD_PLUS_ONE type or just passed as a parameter. 
COARSE_RAPPOR_TYPE is just for SafeBrowsing metrics now.

+}
+
 bool RapporService::ExportMetrics(RapporReports* reports) {
   if (metrics_map_.empty()) {
     DVLOG(2) << "metrics_map_ is empty.";
     return false;
   }
 
   DCHECK_GE(cohort_, 0);
   reports->set_cohort(cohort_);
 
   for (std::map<std::string, RapporMetric*>::const_iterator it =
@@ skipping 57 matching lines @@
     DCHECK_EQ(parameters.ToString(), metric->parameters().ToString());
     return metric;
   }
 
   RapporMetric* new_metric = new RapporMetric(metric_name, parameters, cohort_);
   metrics_map_[metric_name] = new_metric;
   return new_metric;
 }
 
 }  // namespace rappor