// Copyright 2014 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/autofill/core/browser/logging/log_router.h"

#include <string>

#include "base/check.h"
#include "base/observer_list.h"
#include "base/strings/string_split.h"
#include "components/autofill/core/browser/logging/log_manager.h"
#include "components/autofill/core/browser/logging/log_receiver.h"
#include "components/autofill/core/common/logging/log_buffer.h"

namespace autofill {

LogRouter::LogRouter() = default;

LogRouter::~LogRouter() {
  receivers_.RemoveObserver(&text_log_receiver_);
}

// static
base::DictValue LogRouter::CreateEntryForText(const std::string& text) {
  LogBuffer buffer(LogBuffer::IsActive(true));
  buffer << Tag{"div"};
  for (const auto& line : base::SplitStringPiece(
           text, "\n", base::TRIM_WHITESPACE, base::SPLIT_WANT_NONEMPTY)) {
    buffer << line << Br{};
  }
  buffer << CTag{};
  return *buffer.RetrieveResult();
}

void LogRouter::LogToTerminal() {
  if (!receivers_.HasObserver(&text_log_receiver_)) {
    receivers_.AddObserver(&text_log_receiver_);
  }
}

bool LogRouter::HasReceivers() const {
  return !receivers_.empty();
}

void LogRouter::ProcessLog(const std::string& text) {
  ProcessLog(CreateEntryForText(text));
}

void LogRouter::ProcessLog(const base::DictValue& node) {
  // This may not be called when there are no receivers (i.e., the router is
  // inactive), because in that case the logs cannot be displayed.
  DCHECK(HasReceivers());
  for (LogReceiver& receiver : receivers_)
    receiver.LogEntry(node);
}

bool LogRouter::RegisterManager(RoutingLogManager* manager) {
  DCHECK(manager);
  managers_.AddObserver(manager);
  return HasReceivers();
}

void LogRouter::UnregisterManager(RoutingLogManager* manager) {
  DCHECK(managers_.HasObserver(manager));
  managers_.RemoveObserver(manager);
}

void LogRouter::RegisterReceiver(LogReceiver* receiver) {
  DCHECK(receiver);
  if (!HasReceivers()) {
    for (RoutingLogManager& manager : managers_)
      manager.OnLogRouterAvailabilityChanged(true);
  }
  receivers_.AddObserver(receiver);
}

void LogRouter::UnregisterReceiver(LogReceiver* receiver) {
  DCHECK(receivers_.HasObserver(receiver));
  receivers_.RemoveObserver(receiver);
  if (!HasReceivers()) {
    for (RoutingLogManager& manager : managers_)
      manager.OnLogRouterAvailabilityChanged(false);
  }
}

}  // namespace autofill