Index: webrtc/libjingle/xmpp/presenceouttask.cc |
diff --git a/webrtc/libjingle/xmpp/presenceouttask.cc b/webrtc/libjingle/xmpp/presenceouttask.cc |
new file mode 100644 |
index 0000000000000000000000000000000000000000..5519a4fd4ab441f9dfc3b3901e353c3717ae82a0 |
--- /dev/null |
+++ b/webrtc/libjingle/xmpp/presenceouttask.cc |
@@ -0,0 +1,141 @@ |
+/* |
+ * Copyright 2004 The WebRTC Project Authors. All rights reserved. |
+ * |
+ * Use of this source code is governed by a BSD-style license |
+ * that can be found in the LICENSE file in the root of the source |
+ * tree. An additional intellectual property rights grant can be found |
+ * in the file PATENTS. All contributing project authors may |
+ * be found in the AUTHORS file in the root of the source tree. |
+ */ |
+ |
+#include <time.h> |
+#include <sstream> |
+#include "webrtc/libjingle/xmpp/constants.h" |
+#include "webrtc/libjingle/xmpp/presenceouttask.h" |
+#include "webrtc/libjingle/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; |
+} |
+ |
+ |
+} |