// Copyright 2025 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "net/base/reconnect_notifier.h"

#include <utility>

#include "base/functional/bind.h"

namespace net {

ConnectionChangeNotifier::Observer::Observer() = default;
ConnectionChangeNotifier::Observer::~Observer() {
  if (notifier_) {
    notifier_->RemoveObserver(this);
  }
}

void ConnectionChangeNotifier::Observer::OnAttach(
    base::WeakPtr<ConnectionChangeNotifier> notifier) {
  CHECK(!notifier_);
  notifier_ = notifier;
}

base::WeakPtr<ConnectionChangeNotifier::Observer>
ConnectionChangeNotifier::Observer::GetWeakPtr() {
  return weak_factory_.GetWeakPtr();
}

ConnectionChangeNotifier::EstablishedConnectionInfo::
    EstablishedConnectionInfo() = default;
ConnectionChangeNotifier::EstablishedConnectionInfo::
    ~EstablishedConnectionInfo() = default;
ConnectionChangeNotifier::EstablishedConnectionInfo::EstablishedConnectionInfo(
    const EstablishedConnectionInfo& other) = default;
ConnectionChangeNotifier::EstablishedConnectionInfo&
ConnectionChangeNotifier::EstablishedConnectionInfo::operator=(
    const EstablishedConnectionInfo& other) = default;

void ConnectionChangeNotifier::OnConnectionEstablished(
    const EstablishedConnectionInfo& info) {
  observer_list_.Notify(
      &ConnectionChangeNotifier::Observer::OnConnectionEstablished, info);
}

void ConnectionChangeNotifier::OnSessionClosed(
    bool was_ever_used_to_create_streams) {
  observer_list_.Notify(&ConnectionChangeNotifier::Observer::OnSessionClosed,
                        was_ever_used_to_create_streams);
}

void ConnectionChangeNotifier::OnConnectionFailed() {
  observer_list_.Notify(
      &ConnectionChangeNotifier::Observer::OnConnectionFailed);
}

void ConnectionChangeNotifier::OnNetworkEvent(NetworkChangeEvent event) {
  observer_list_.Notify(&ConnectionChangeNotifier::Observer::OnNetworkEvent,
                        event);
}

void ConnectionChangeNotifier::AddObserver(
    ConnectionChangeNotifier::Observer* observer) {
  CHECK(observer);
  // If the observer is already in the observer list, then we should not add it
  // again. This might happen when racing the Http2 and Http3 creation (in
  // HttpStreamFactoryJob), and both connections were successfully established.
  // TODO(crbug.com/453308537): Update to prioritize the Http3 connection's
  // observer if it is already in the observer list.
  if (observer->IsInObserverList()) {
    return;
  }
  observer_list_.AddObserver(observer);

  // Set the WeakPtr of `this` so that the observer can remove itself when
  // it is being destructed.
  observer->OnAttach(weak_factory_.GetWeakPtr());
}

void ConnectionChangeNotifier::RemoveObserver(const Observer* observer) {
  CHECK(observer);
  observer_list_.RemoveObserver(observer);
}

ConnectionChangeNotifier::ConnectionChangeNotifier() = default;
ConnectionChangeNotifier::~ConnectionChangeNotifier() = default;

ConnectionManagementConfig::ConnectionManagementConfig() = default;
ConnectionManagementConfig::~ConnectionManagementConfig() = default;

ConnectionManagementConfig::ConnectionManagementConfig(
    const ConnectionManagementConfig& other) = default;

ConnectionManagementConfig::ConnectionManagementConfig(
    ConnectionManagementConfig&& other) = default;
}  // namespace net