// Copyright (c) 2012 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/client/plugin/pepper_xmpp_proxy.h"

#include "base/bind.h"
#include "base/location.h"
#include "base/message_loop/message_loop_proxy.h"

namespace remoting {

PepperXmppProxy::PepperXmppProxy(
    const SendIqCallback& send_iq_callback,
    base::SingleThreadTaskRunner* plugin_task_runner,
    base::SingleThreadTaskRunner* callback_task_runner)
    : send_iq_callback_(send_iq_callback),
      plugin_task_runner_(plugin_task_runner),
      callback_task_runner_(callback_task_runner) {
  DCHECK(plugin_task_runner_->BelongsToCurrentThread());
}

PepperXmppProxy::~PepperXmppProxy() {
}

void PepperXmppProxy::AttachCallback(
    base::WeakPtr<ResponseCallback> callback) {
  DCHECK(callback_task_runner_->BelongsToCurrentThread());
  callback_ = callback;
}

void PepperXmppProxy::DetachCallback() {
  DCHECK(callback_task_runner_->BelongsToCurrentThread());
  callback_.reset();
}

void PepperXmppProxy::SendIq(const std::string& request_xml) {
  if (!plugin_task_runner_->BelongsToCurrentThread()) {
    plugin_task_runner_->PostTask(FROM_HERE, base::Bind(
        &PepperXmppProxy::SendIq, this, request_xml));
    return;
  }

  send_iq_callback_.Run(request_xml);
}

void PepperXmppProxy::OnIq(const std::string& response_xml) {
  if (!callback_task_runner_->BelongsToCurrentThread()) {
    callback_task_runner_->PostTask(
        FROM_HERE, base::Bind(&PepperXmppProxy::OnIq, this, response_xml));
    return;
  }

  if (callback_.get())
    callback_->OnIq(response_xml);
}

}  // namespace remoting