content/browser/direct_sockets/direct_udp_socket_impl.h

// Copyright 2021 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.

#ifndef CONTENT_BROWSER_DIRECT_SOCKETS_DIRECT_UDP_SOCKET_IMPL_H_
#define CONTENT_BROWSER_DIRECT_SOCKETS_DIRECT_UDP_SOCKET_IMPL_H_

#include "content/common/content_export.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/remote.h"
#include "net/base/ip_endpoint.h"
#include "services/network/public/mojom/network_context.mojom.h"
#include "services/network/public/mojom/udp_socket.mojom.h"
#include "third_party/blink/public/mojom/direct_sockets/direct_sockets.mojom.h"

namespace content {

// Forwards requests from the Renderer to the connected UDPSocket.
// We do not expose the UDPSocket directly to the Renderer, as that
// would allow a compromised Renderer to contact other end points.
class CONTENT_EXPORT DirectUDPSocketImpl
    : public blink::mojom::DirectUDPSocket {
 public:
  typedef network::mojom::UDPSocket::ConnectCallback ConnectCallback;

  DirectUDPSocketImpl(
      network::mojom::NetworkContext* network_context,
      mojo::PendingRemote<network::mojom::UDPSocketListener> listener);
  ~DirectUDPSocketImpl() override;

  // Connect should be called once, immediately after construction.
  void Connect(const net::IPEndPoint& remote_addr,
               network::mojom::UDPSocketOptionsPtr options,
               ConnectCallback callback);

  // blink::mojom::DirectUDPSocket:
  void ReceiveMore(uint32_t num_additional_datagrams) override;
  void Send(base::span<const uint8_t> data, SendCallback callback) override;
  void Close() override;

 private:
  void OnDisconnect();

  mojo::Remote<network::mojom::UDPSocket> remote_;
};

}  // namespace content

#endif  // CONTENT_BROWSER_DIRECT_SOCKETS_DIRECT_UDP_SOCKET_IMPL_H_