blob: 90b7196d7f389a8a67cc3e58433fcfae3fe6e722 [file] [log] [blame]
// 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 "jingle/notifier/listener/send_ping_task.h"
#include <string>
#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "jingle/notifier/listener/xml_element_util.h"
#include "talk/xmllite/qname.h"
#include "talk/xmllite/xmlelement.h"
#include "talk/xmpp/constants.h"
#include "talk/xmpp/jid.h"
#include "talk/xmpp/xmppclient.h"
namespace notifier {
SendPingTask::Delegate::~Delegate() {
}
SendPingTask::SendPingTask(buzz::XmppTaskParentInterface* parent,
Delegate* delegate)
: XmppTask(parent, buzz::XmppEngine::HL_SINGLE), delegate_(delegate) {
}
SendPingTask::~SendPingTask() {
}
int SendPingTask::ProcessStart() {
ping_task_id_ = task_id();
scoped_ptr<buzz::XmlElement> stanza(MakePingStanza(ping_task_id_));
DVLOG(1) << "Sending ping stanza " << XmlElementToString(*stanza);
if (SendStanza(stanza.get()) != buzz::XMPP_RETURN_OK) {
DLOG(WARNING) << "Could not send stanza " << XmlElementToString(*stanza);
return STATE_ERROR;
}
return STATE_RESPONSE;
}
int SendPingTask::ProcessResponse() {
const buzz::XmlElement* stanza = NextStanza();
if (stanza == NULL) {
return STATE_BLOCKED;
}
DVLOG(1) << "Received stanza " << XmlElementToString(*stanza);
std::string type = stanza->Attr(buzz::QN_TYPE);
if (type != buzz::STR_RESULT) {
DLOG(WARNING) << "No type=\"result\" attribute found in stanza "
<< XmlElementToString(*stanza);
return STATE_ERROR;
}
delegate_->OnPingResponseReceived();
return STATE_DONE;
}
bool SendPingTask::HandleStanza(const buzz::XmlElement* stanza) {
// MatchResponseIq() matches the given Jid with the "from" field of the given
// stanza, which in this case should be the empty string
// (signifying the server).
if (MatchResponseIq(stanza, buzz::Jid(buzz::STR_EMPTY), ping_task_id_)) {
QueueStanza(stanza);
return true;
}
return false;
}
buzz::XmlElement* SendPingTask::MakePingStanza(const std::string& task_id) {
buzz::XmlElement* stanza = MakeIq(buzz::STR_GET,
buzz::Jid(buzz::STR_EMPTY),
task_id);
stanza->AddElement(new buzz::XmlElement(buzz::QN_PING));
return stanza;
}
} // namespace notifier