components/metrics/structured/delegating_events_processor.cc

// Copyright 2022 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "components/metrics/structured/delegating_events_processor.h"
#include "third_party/metrics_proto/chrome_user_metrics_extension.pb.h"

namespace metrics::structured {

DelegatingEventsProcessor::DelegatingEventsProcessor() = default;
DelegatingEventsProcessor::~DelegatingEventsProcessor() = default;

// Each individual events_processor could be checked, but this will need to be
// checked during OnEventsRecord().
bool DelegatingEventsProcessor::ShouldProcessOnEventRecord(const Event& event) {
  return true;
}

void DelegatingEventsProcessor::OnEventsRecord(Event* event) {
  DCHECK(event);

  for (auto& events_processor : events_processors_) {
    if (events_processor->ShouldProcessOnEventRecord(*event)) {
      // Note that every |events_processor| is operating on the same |event|.
      // Race conditions should be mangaged by the client.
      events_processor->OnEventsRecord(event);
    }
  }
}

void DelegatingEventsProcessor::OnEventRecorded(StructuredEventProto* event) {
  DCHECK(event);

  for (auto& events_processor : events_processors_) {
    // Note that every |events_processor| is operating on the same |event|.
    // Race conditions should be mangaged by the client.
    events_processor->OnEventRecorded(event);
  }
}

void DelegatingEventsProcessor::AddEventsProcessor(
    std::unique_ptr<EventsProcessorInterface> events_processor) {
  DCHECK(events_processor);

  events_processors_.push_back(std::move(events_processor));
}

void DelegatingEventsProcessor::OnProvideIndependentMetrics(
    ChromeUserMetricsExtension* uma_proto) {
  for (auto& events_processor : events_processors_) {
    events_processor->OnProvideIndependentMetrics(uma_proto);
  }
}

}  // namespace metrics::structured