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

#include "remoting/protocol/named_message_pipe_handler.h"

#include <utility>

#include "base/location.h"
#include "base/logging.h"
#include "base/threading/thread_task_runner_handle.h"
#include "remoting/base/compound_buffer.h"

namespace remoting {
namespace protocol {

NamedMessagePipeHandler::NamedMessagePipeHandler(
    const std::string& name,
    std::unique_ptr<MessagePipe> pipe)
    : name_(name),
      pipe_(std::move(pipe)) {
  DCHECK(pipe_);
  pipe_->Start(this);
}

NamedMessagePipeHandler::~NamedMessagePipeHandler() = default;

void NamedMessagePipeHandler::Close() {
  DCHECK(thread_checker_.CalledOnValidThread());
  if (connected()) {
    OnDisconnecting();
    is_connected_ = false;
  }
  delete this;
}

void NamedMessagePipeHandler::Send(const google::protobuf::MessageLite& message,
                                   const base::Closure& done) {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(connected());
  pipe_->Send(const_cast<google::protobuf::MessageLite*>(&message), done);
}

void NamedMessagePipeHandler::OnIncomingMessage(
    std::unique_ptr<CompoundBuffer> message) {}

void NamedMessagePipeHandler::OnConnected() {}

void NamedMessagePipeHandler::OnDisconnecting() {}

void NamedMessagePipeHandler::OnMessagePipeOpen() {
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(!is_connected_);
  is_connected_ = true;
  OnConnected();
}

void NamedMessagePipeHandler::OnMessageReceived(
    std::unique_ptr<CompoundBuffer> message) {
  DCHECK(thread_checker_.CalledOnValidThread());
  OnIncomingMessage(std::move(message));
}

void NamedMessagePipeHandler::OnMessagePipeClosed() {
  Close();
}

}  // namespace protocol
}  // namespace remoting