// Copyright 2016 The Fuchsia 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 "garnet/bin/netconnector/device_service_provider.h"

#include <memory>

#include "garnet/bin/netconnector/netconnector_impl.h"
#include "garnet/bin/netconnector/requestor_agent.h"
#include "garnet/lib/inet/socket_address.h"
#include "src/lib/fxl/logging.h"

namespace netconnector {

// static
std::unique_ptr<DeviceServiceProvider> DeviceServiceProvider::Create(
    const std::string& device_name, const inet::SocketAddress& address,
    fidl::InterfaceRequest<fuchsia::sys::ServiceProvider> request,
    NetConnectorImpl* owner) {
  return std::unique_ptr<DeviceServiceProvider>(new DeviceServiceProvider(
      device_name, address, std::move(request), owner));
}

DeviceServiceProvider::DeviceServiceProvider(
    const std::string& device_name, const inet::SocketAddress& address,
    fidl::InterfaceRequest<fuchsia::sys::ServiceProvider> request,
    NetConnectorImpl* owner)
    : device_name_(device_name),
      address_(address),
      binding_(this, std::move(request)),
      owner_(owner) {
  FXL_DCHECK(!device_name_.empty());
  FXL_DCHECK(address_.is_valid());
  FXL_DCHECK(binding_.is_bound());
  FXL_DCHECK(owner_ != nullptr);

  binding_.set_error_handler([this](zx_status_t status) {
    FXL_DCHECK(owner_ != nullptr);
    binding_.set_error_handler(nullptr);
    binding_.Unbind();
    owner_->ReleaseDeviceServiceProvider(this);
  });
}

DeviceServiceProvider::~DeviceServiceProvider() {}

void DeviceServiceProvider::ConnectToService(std::string service_name,
                                             zx::channel channel) {
  std::unique_ptr<RequestorAgent> requestor_agent = RequestorAgent::Create(
      address_, service_name, std::move(channel), owner_);

  if (!requestor_agent) {
    FXL_LOG(ERROR) << "Connection failed, device " << device_name_;
    return;
  }

  owner_->AddRequestorAgent(std::move(requestor_agent));
}

}  // namespace netconnector