Index: third_party/libjingle_xmpp/xmpp/presenceouttask.cc |
diff --git a/third_party/libjingle_xmpp/xmpp/presenceouttask.cc b/third_party/libjingle_xmpp/xmpp/presenceouttask.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..59b1325fc4ead06081fbd6bdea6411a661adf3cc |
--- /dev/null |
+++ b/third_party/libjingle_xmpp/xmpp/presenceouttask.cc |
@@ -0,0 +1,135 @@ |
+// Copyright 2004 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 <time.h> |
+#include <sstream> |
+#include "third_party/libjingle_xmpp/xmpp/constants.h" |
+#include "third_party/libjingle_xmpp/xmpp/presenceouttask.h" |
+#include "third_party/libjingle_xmpp/xmpp/xmppclient.h" |
+#include "webrtc/base/arraysize.h" |
+#include "webrtc/base/stringencode.h" |
+ |
+namespace buzz { |
+ |
+XmppReturnStatus |
+PresenceOutTask::Send(const PresenceStatus & s) { |
+ if (GetState() != STATE_INIT && GetState() != STATE_START) |
+ return XMPP_RETURN_BADSTATE; |
+ |
+ XmlElement * presence = TranslateStatus(s); |
+ QueueStanza(presence); |
+ delete presence; |
+ return XMPP_RETURN_OK; |
+} |
+ |
+XmppReturnStatus |
+PresenceOutTask::SendDirected(const Jid & j, const PresenceStatus & s) { |
+ if (GetState() != STATE_INIT && GetState() != STATE_START) |
+ return XMPP_RETURN_BADSTATE; |
+ |
+ XmlElement * presence = TranslateStatus(s); |
+ presence->AddAttr(QN_TO, j.Str()); |
+ QueueStanza(presence); |
+ delete presence; |
+ return XMPP_RETURN_OK; |
+} |
+ |
+XmppReturnStatus PresenceOutTask::SendProbe(const Jid & jid) { |
+ if (GetState() != STATE_INIT && GetState() != STATE_START) |
+ return XMPP_RETURN_BADSTATE; |
+ |
+ XmlElement * presence = new XmlElement(QN_PRESENCE); |
+ presence->AddAttr(QN_TO, jid.Str()); |
+ presence->AddAttr(QN_TYPE, "probe"); |
+ |
+ QueueStanza(presence); |
+ delete presence; |
+ return XMPP_RETURN_OK; |
+} |
+ |
+int |
+PresenceOutTask::ProcessStart() { |
+ const XmlElement * stanza = NextStanza(); |
+ if (stanza == NULL) |
+ return STATE_BLOCKED; |
+ |
+ if (SendStanza(stanza) != XMPP_RETURN_OK) |
+ return STATE_ERROR; |
+ |
+ return STATE_START; |
+} |
+ |
+XmlElement * |
+PresenceOutTask::TranslateStatus(const PresenceStatus & s) { |
+ XmlElement * result = new XmlElement(QN_PRESENCE); |
+ if (!s.available()) { |
+ result->AddAttr(QN_TYPE, STR_UNAVAILABLE); |
+ } |
+ else { |
+ if (s.show() != PresenceStatus::SHOW_ONLINE && |
+ s.show() != PresenceStatus::SHOW_OFFLINE) { |
+ result->AddElement(new XmlElement(QN_SHOW)); |
+ switch (s.show()) { |
+ default: |
+ result->AddText(STR_SHOW_AWAY, 1); |
+ break; |
+ case PresenceStatus::SHOW_XA: |
+ result->AddText(STR_SHOW_XA, 1); |
+ break; |
+ case PresenceStatus::SHOW_DND: |
+ result->AddText(STR_SHOW_DND, 1); |
+ break; |
+ case PresenceStatus::SHOW_CHAT: |
+ result->AddText(STR_SHOW_CHAT, 1); |
+ break; |
+ } |
+ } |
+ |
+ result->AddElement(new XmlElement(QN_STATUS)); |
+ result->AddText(s.status(), 1); |
+ |
+ if (!s.nick().empty()) { |
+ result->AddElement(new XmlElement(QN_NICKNAME)); |
+ result->AddText(s.nick(), 1); |
+ } |
+ |
+ std::string pri; |
+ rtc::ToString(s.priority(), &pri); |
+ |
+ result->AddElement(new XmlElement(QN_PRIORITY)); |
+ result->AddText(pri, 1); |
+ |
+ if (s.know_capabilities()) { |
+ result->AddElement(new XmlElement(QN_CAPS_C, true)); |
+ result->AddAttr(QN_NODE, s.caps_node(), 1); |
+ result->AddAttr(QN_VER, s.version(), 1); |
+ |
+ std::string caps; |
+ caps.append(s.voice_capability() ? "voice-v1" : ""); |
+ caps.append(s.pmuc_capability() ? " pmuc-v1" : ""); |
+ caps.append(s.video_capability() ? " video-v1" : ""); |
+ caps.append(s.camera_capability() ? " camera-v1" : ""); |
+ |
+ result->AddAttr(QN_EXT, caps, 1); |
+ } |
+ |
+ // Put the delay mark on the presence according to JEP-0091 |
+ { |
+ result->AddElement(new XmlElement(kQnDelayX, true)); |
+ |
+ // This here is why we *love* the C runtime |
+ time_t current_time_seconds; |
+ time(¤t_time_seconds); |
+ struct tm* current_time = gmtime(¤t_time_seconds); |
+ char output[256]; |
+ strftime(output, arraysize(output), "%Y%m%dT%H:%M:%S", current_time); |
+ result->AddAttr(kQnStamp, output, 1); |
+ } |
+ } |
+ |
+ return result; |
+} |
+ |
+ |
+} |