Index: webrtc/libjingle/xmpp/chatroommoduleimpl.cc |
diff --git a/webrtc/libjingle/xmpp/chatroommoduleimpl.cc b/webrtc/libjingle/xmpp/chatroommoduleimpl.cc |
deleted file mode 100644 |
index 4feb5bc9b8c9141822e62a0beba64c121cd1725d..0000000000000000000000000000000000000000 |
--- a/webrtc/libjingle/xmpp/chatroommoduleimpl.cc |
+++ /dev/null |
@@ -1,737 +0,0 @@ |
-/* |
- * 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 <algorithm> |
-#include <iostream> |
-#include <map> |
-#include <memory> |
-#include <sstream> |
-#include <string> |
-#include <vector> |
-#include "webrtc/libjingle/xmpp/chatroommodule.h" |
-#include "webrtc/libjingle/xmpp/constants.h" |
-#include "webrtc/libjingle/xmpp/moduleimpl.h" |
-#include "webrtc/base/arraysize.h" |
-#include "webrtc/base/common.h" |
- |
-namespace buzz { |
- |
-// forward declarations |
-class XmppChatroomImpl; |
-class XmppChatroomMemberImpl; |
- |
-//! Module that encapsulates multiple chatrooms. |
-//! Each chatroom is represented by an XmppChatroomImpl instance |
-class XmppChatroomModuleImpl : public XmppChatroomModule, |
- public XmppModuleImpl, public XmppIqHandler { |
-public: |
- IMPLEMENT_XMPPMODULE |
- |
- // Creates a chatroom with specified Jid |
- XmppChatroomModuleImpl(); |
- ~XmppChatroomModuleImpl(); |
- |
- // XmppChatroomModule |
- virtual XmppReturnStatus set_chatroom_handler(XmppChatroomHandler* handler); |
- virtual XmppChatroomHandler* chatroom_handler(); |
- virtual XmppReturnStatus set_chatroom_jid(const Jid& chatroom_jid); |
- virtual const Jid& chatroom_jid() const; |
- virtual XmppReturnStatus set_nickname(const std::string& nickname); |
- virtual const std::string& nickname() const; |
- virtual const Jid member_jid() const; |
- virtual XmppReturnStatus RequestEnterChatroom(const std::string& password, |
- const std::string& client_version, |
- const std::string& locale); |
- virtual XmppReturnStatus RequestExitChatroom(); |
- virtual XmppReturnStatus RequestConnectionStatusChange( |
- XmppPresenceConnectionStatus connection_status); |
- virtual size_t GetChatroomMemberCount(); |
- virtual XmppReturnStatus CreateMemberEnumerator(XmppChatroomMemberEnumerator** enumerator); |
- virtual const std::string subject(); |
- virtual XmppChatroomState state() { return chatroom_state_; } |
- virtual XmppReturnStatus SendMessage(const XmlElement& message); |
- |
- // XmppModule |
- virtual void IqResponse(XmppIqCookie cookie, const XmlElement * pelStanza) {RTC_UNUSED2(cookie, pelStanza);} |
- virtual bool HandleStanza(const XmlElement *); |
- |
-private: |
- friend class XmppChatroomMemberEnumeratorImpl; |
- |
- XmppReturnStatus ServerChangeMyPresence(const XmlElement& presence); |
- XmppReturnStatus ClientChangeMyPresence(XmppChatroomState new_state); |
- XmppReturnStatus ChangePresence(XmppChatroomState new_state, const XmlElement* presence, bool isServer); |
- XmppReturnStatus ServerChangedOtherPresence(const XmlElement& presence_element); |
- XmppChatroomEnteredStatus GetEnterFailureFromXml(const XmlElement* presence); |
- XmppChatroomExitedStatus GetExitFailureFromXml(const XmlElement* presence); |
- |
- bool CheckEnterChatroomStateOk(); |
- |
- void FireEnteredStatus(const XmlElement* presence, |
- XmppChatroomEnteredStatus status); |
- void FireExitStatus(XmppChatroomExitedStatus status); |
- void FireMessageReceived(const XmlElement& message); |
- void FireMemberEntered(const XmppChatroomMember* entered_member); |
- void FireMemberChanged(const XmppChatroomMember* changed_member); |
- void FireMemberExited(const XmppChatroomMember* exited_member); |
- |
- |
- typedef std::map<Jid, XmppChatroomMemberImpl*> JidMemberMap; |
- |
- XmppChatroomHandler* chatroom_handler_; |
- Jid chatroom_jid_; |
- std::string nickname_; |
- XmppChatroomState chatroom_state_; |
- JidMemberMap chatroom_jid_members_; |
- int chatroom_jid_members_version_; |
-}; |
- |
- |
-class XmppChatroomMemberImpl : public XmppChatroomMember { |
-public: |
- ~XmppChatroomMemberImpl() {} |
- XmppReturnStatus SetPresence(const XmppPresence* presence); |
- |
- // XmppChatroomMember |
- const Jid member_jid() const; |
- const Jid full_jid() const; |
- const std::string name() const; |
- const XmppPresence* presence() const; |
- |
-private: |
- std::unique_ptr<XmppPresence> presence_; |
-}; |
- |
-class XmppChatroomMemberEnumeratorImpl : |
- public XmppChatroomMemberEnumerator { |
-public: |
- XmppChatroomMemberEnumeratorImpl(XmppChatroomModuleImpl::JidMemberMap* chatroom_jid_members, |
- int* map_version); |
- |
- // XmppChatroomMemberEnumerator |
- virtual XmppChatroomMember* current(); |
- virtual bool Next(); |
- virtual bool Prev(); |
- virtual bool IsValid(); |
- virtual bool IsBeforeBeginning(); |
- virtual bool IsAfterEnd(); |
- |
-private: |
- XmppChatroomModuleImpl::JidMemberMap* map_; |
- int map_version_created_; |
- int* map_version_; |
- XmppChatroomModuleImpl::JidMemberMap::iterator iterator_; |
- bool before_beginning_; |
-}; |
- |
- |
-// XmppChatroomModuleImpl ------------------------------------------------ |
-XmppChatroomModule * |
-XmppChatroomModule::Create() { |
- return new XmppChatroomModuleImpl(); |
-} |
- |
-XmppChatroomModuleImpl::XmppChatroomModuleImpl() : |
- chatroom_handler_(NULL), |
- chatroom_jid_(STR_EMPTY), |
- chatroom_state_(XMPP_CHATROOM_STATE_NOT_IN_ROOM), |
- chatroom_jid_members_version_(0) { |
-} |
- |
-XmppChatroomModuleImpl::~XmppChatroomModuleImpl() { |
- JidMemberMap::iterator iterator = chatroom_jid_members_.begin(); |
- while (iterator != chatroom_jid_members_.end()) { |
- delete iterator->second; |
- iterator++; |
- } |
-} |
- |
- |
-bool |
-XmppChatroomModuleImpl::HandleStanza(const XmlElement* stanza) { |
- ASSERT(engine() != NULL); |
- |
- // we handle stanzas that are for one of our chatrooms |
- Jid from_jid = Jid(stanza->Attr(QN_FROM)); |
- // see if it's one of our chatrooms |
- if (chatroom_jid_ != from_jid.BareJid()) { |
- return false; // not one of our chatrooms |
- } else { |
- // handle presence stanza |
- if (stanza->Name() == QN_PRESENCE) { |
- if (from_jid == member_jid()) { |
- ServerChangeMyPresence(*stanza); |
- } else { |
- ServerChangedOtherPresence(*stanza); |
- } |
- } else if (stanza->Name() == QN_MESSAGE) { |
- FireMessageReceived(*stanza); |
- } |
- return true; |
- } |
-} |
- |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::set_chatroom_handler(XmppChatroomHandler* handler) { |
- // Calling with NULL removes the handler. |
- chatroom_handler_ = handler; |
- return XMPP_RETURN_OK; |
-} |
- |
- |
-XmppChatroomHandler* |
-XmppChatroomModuleImpl::chatroom_handler() { |
- return chatroom_handler_; |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::set_chatroom_jid(const Jid& chatroom_jid) { |
- if (chatroom_state_ != XMPP_CHATROOM_STATE_NOT_IN_ROOM) { |
- return XMPP_RETURN_BADSTATE; // $TODO - this isn't a bad state, it's a bad call, diff error code? |
- } |
- if (chatroom_jid != chatroom_jid.BareJid()) { |
- // chatroom_jid must be a bare jid |
- return XMPP_RETURN_BADARGUMENT; |
- } |
- |
- chatroom_jid_ = chatroom_jid; |
- return XMPP_RETURN_OK; |
-} |
- |
-const Jid& |
-XmppChatroomModuleImpl::chatroom_jid() const { |
- return chatroom_jid_; |
-} |
- |
- XmppReturnStatus |
- XmppChatroomModuleImpl::set_nickname(const std::string& nickname) { |
- if (chatroom_state_ != XMPP_CHATROOM_STATE_NOT_IN_ROOM) { |
- return XMPP_RETURN_BADSTATE; // $TODO - this isn't a bad state, it's a bad call, diff error code? |
- } |
- nickname_ = nickname; |
- return XMPP_RETURN_OK; |
- } |
- |
- const std::string& |
- XmppChatroomModuleImpl::nickname() const { |
- return nickname_; |
- } |
- |
-const Jid |
-XmppChatroomModuleImpl::member_jid() const { |
- return Jid(chatroom_jid_.node(), chatroom_jid_.domain(), nickname_); |
-} |
- |
- |
-bool |
-XmppChatroomModuleImpl::CheckEnterChatroomStateOk() { |
- if (chatroom_jid_.IsValid() == false) { |
- ASSERT(0); |
- return false; |
- } |
- if (nickname_ == STR_EMPTY) { |
- ASSERT(0); |
- return false; |
- } |
- return true; |
-} |
- |
-std::string GetAttrValueFor(XmppPresenceConnectionStatus connection_status) { |
- switch (connection_status) { |
- default: |
- case XMPP_CONNECTION_STATUS_UNKNOWN: |
- return ""; |
- case XMPP_CONNECTION_STATUS_CONNECTING: |
- return STR_PSTN_CONFERENCE_STATUS_CONNECTING; |
- case XMPP_CONNECTION_STATUS_CONNECTED: |
- return STR_PSTN_CONFERENCE_STATUS_CONNECTED; |
- } |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::RequestEnterChatroom( |
- const std::string& password, |
- const std::string& client_version, |
- const std::string& locale) { |
- RTC_UNUSED(password); |
- if (!engine()) |
- return XMPP_RETURN_BADSTATE; |
- |
- if (chatroom_state_ != XMPP_CHATROOM_STATE_NOT_IN_ROOM) |
- return XMPP_RETURN_BADSTATE; // $TODO - this isn't a bad state, it's a bad call, diff error code? |
- |
- if (CheckEnterChatroomStateOk() == false) { |
- return XMPP_RETURN_BADSTATE; |
- } |
- |
- // entering a chatroom is a presence request to the server |
- XmlElement element(QN_PRESENCE); |
- element.AddAttr(QN_TO, member_jid().Str()); |
- |
- XmlElement* muc_x = new XmlElement(QN_MUC_X); |
- element.AddElement(muc_x); |
- |
- if (!client_version.empty()) { |
- XmlElement* client_version_element = new XmlElement(QN_CLIENT_VERSION, |
- false); |
- client_version_element->SetBodyText(client_version); |
- muc_x->AddElement(client_version_element); |
- } |
- |
- if (!locale.empty()) { |
- XmlElement* locale_element = new XmlElement(QN_LOCALE, false); |
- |
- locale_element->SetBodyText(locale); |
- muc_x->AddElement(locale_element); |
- } |
- |
- XmppReturnStatus status = engine()->SendStanza(&element); |
- if (status == XMPP_RETURN_OK) { |
- return ClientChangeMyPresence(XMPP_CHATROOM_STATE_REQUESTED_ENTER); |
- } |
- return status; |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::RequestExitChatroom() { |
- if (!engine()) |
- return XMPP_RETURN_BADSTATE; |
- |
- // exiting a chatroom is a presence request to the server |
- XmlElement element(QN_PRESENCE); |
- element.AddAttr(QN_TO, member_jid().Str()); |
- element.AddAttr(QN_TYPE, "unavailable"); |
- XmppReturnStatus status = engine()->SendStanza(&element); |
- if (status == XMPP_RETURN_OK && |
- chatroom_state_ == XMPP_CHATROOM_STATE_IN_ROOM) { |
- return ClientChangeMyPresence(XMPP_CHATROOM_STATE_REQUESTED_EXIT); |
- } |
- return status; |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::RequestConnectionStatusChange( |
- XmppPresenceConnectionStatus connection_status) { |
- if (!engine()) |
- return XMPP_RETURN_BADSTATE; |
- |
- if (chatroom_state_ != XMPP_CHATROOM_STATE_IN_ROOM) { |
- // $TODO - this isn't a bad state, it's a bad call, diff error code? |
- return XMPP_RETURN_BADSTATE; |
- } |
- |
- if (CheckEnterChatroomStateOk() == false) { |
- return XMPP_RETURN_BADSTATE; |
- } |
- |
- // entering a chatroom is a presence request to the server |
- XmlElement element(QN_PRESENCE); |
- element.AddAttr(QN_TO, member_jid().Str()); |
- element.AddElement(new XmlElement(QN_MUC_X)); |
- if (connection_status != XMPP_CONNECTION_STATUS_UNKNOWN) { |
- XmlElement* con_status_element = |
- new XmlElement(QN_GOOGLE_PSTN_CONFERENCE_STATUS); |
- con_status_element->AddAttr(QN_STATUS, GetAttrValueFor(connection_status)); |
- element.AddElement(con_status_element); |
- } |
- XmppReturnStatus status = engine()->SendStanza(&element); |
- |
- return status; |
-} |
- |
-size_t |
-XmppChatroomModuleImpl::GetChatroomMemberCount() { |
- return chatroom_jid_members_.size(); |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::CreateMemberEnumerator(XmppChatroomMemberEnumerator** enumerator) { |
- *enumerator = new XmppChatroomMemberEnumeratorImpl(&chatroom_jid_members_, &chatroom_jid_members_version_); |
- return XMPP_RETURN_OK; |
-} |
- |
-const std::string |
-XmppChatroomModuleImpl::subject() { |
- return ""; //NYI |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::SendMessage(const XmlElement& message) { |
- XmppReturnStatus xmpp_status = XMPP_RETURN_OK; |
- |
- // can only send a message if we're in the room |
- if (chatroom_state_ != XMPP_CHATROOM_STATE_IN_ROOM) { |
- return XMPP_RETURN_BADSTATE; // $TODO - this isn't a bad state, it's a bad call, diff error code? |
- } |
- |
- if (message.Name() != QN_MESSAGE) { |
- IFR(XMPP_RETURN_BADARGUMENT); |
- } |
- |
- const std::string& type = message.Attr(QN_TYPE); |
- if (type != "groupchat") { |
- IFR(XMPP_RETURN_BADARGUMENT); |
- } |
- |
- if (message.HasAttr(QN_FROM)) { |
- IFR(XMPP_RETURN_BADARGUMENT); |
- } |
- |
- if (message.Attr(QN_TO) != chatroom_jid_.Str()) { |
- IFR(XMPP_RETURN_BADARGUMENT); |
- } |
- |
- IFR(engine()->SendStanza(&message)); |
- |
- return xmpp_status; |
-} |
- |
-enum TransitionType { |
- TRANSITION_TYPE_NONE = 0, |
- TRANSITION_TYPE_ENTER_SUCCESS = 1, |
- TRANSITION_TYPE_ENTER_FAILURE = 2, |
- TRANSITION_TYPE_EXIT_VOLUNTARILY = 3, |
- TRANSITION_TYPE_EXIT_INVOLUNTARILY = 4, |
-}; |
- |
-struct StateTransitionDescription { |
- XmppChatroomState old_state; |
- XmppChatroomState new_state; |
- bool is_valid_server_transition; |
- bool is_valid_client_transition; |
- TransitionType transition_type; |
-}; |
- |
-StateTransitionDescription Transitions[] = { |
- { XMPP_CHATROOM_STATE_NOT_IN_ROOM, XMPP_CHATROOM_STATE_REQUESTED_ENTER, false, true, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_NOT_IN_ROOM, XMPP_CHATROOM_STATE_IN_ROOM, false, false, TRANSITION_TYPE_ENTER_SUCCESS, }, |
- { XMPP_CHATROOM_STATE_NOT_IN_ROOM, XMPP_CHATROOM_STATE_REQUESTED_EXIT, false, false, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_ENTER, XMPP_CHATROOM_STATE_NOT_IN_ROOM, true, false, TRANSITION_TYPE_ENTER_FAILURE, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_ENTER, XMPP_CHATROOM_STATE_IN_ROOM, true, false, TRANSITION_TYPE_ENTER_SUCCESS, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_ENTER, XMPP_CHATROOM_STATE_REQUESTED_EXIT, false, false, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_IN_ROOM, XMPP_CHATROOM_STATE_NOT_IN_ROOM, true, false, TRANSITION_TYPE_EXIT_INVOLUNTARILY, }, |
- { XMPP_CHATROOM_STATE_IN_ROOM, XMPP_CHATROOM_STATE_REQUESTED_ENTER, false, false, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_IN_ROOM, XMPP_CHATROOM_STATE_REQUESTED_EXIT, false, true, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_EXIT, XMPP_CHATROOM_STATE_NOT_IN_ROOM, true, false, TRANSITION_TYPE_EXIT_VOLUNTARILY, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_EXIT, XMPP_CHATROOM_STATE_REQUESTED_ENTER, false, false, TRANSITION_TYPE_NONE, }, |
- { XMPP_CHATROOM_STATE_REQUESTED_EXIT, XMPP_CHATROOM_STATE_IN_ROOM, false, false, TRANSITION_TYPE_NONE, }, |
-}; |
- |
- |
- |
-void |
-XmppChatroomModuleImpl::FireEnteredStatus(const XmlElement* presence, |
- XmppChatroomEnteredStatus status) { |
- if (chatroom_handler_) { |
- std::unique_ptr<XmppPresence> xmpp_presence(XmppPresence::Create()); |
- xmpp_presence->set_raw_xml(presence); |
- chatroom_handler_->ChatroomEnteredStatus(this, xmpp_presence.get(), status); |
- } |
-} |
- |
-void |
-XmppChatroomModuleImpl::FireExitStatus(XmppChatroomExitedStatus status) { |
- if (chatroom_handler_) |
- chatroom_handler_->ChatroomExitedStatus(this, status); |
-} |
- |
-void |
-XmppChatroomModuleImpl::FireMessageReceived(const XmlElement& message) { |
- if (chatroom_handler_) |
- chatroom_handler_->MessageReceived(this, message); |
-} |
- |
-void |
-XmppChatroomModuleImpl::FireMemberEntered(const XmppChatroomMember* entered_member) { |
- if (chatroom_handler_) |
- chatroom_handler_->MemberEntered(this, entered_member); |
-} |
- |
-void |
-XmppChatroomModuleImpl::FireMemberChanged( |
- const XmppChatroomMember* changed_member) { |
- if (chatroom_handler_) |
- chatroom_handler_->MemberChanged(this, changed_member); |
-} |
- |
-void |
-XmppChatroomModuleImpl::FireMemberExited(const XmppChatroomMember* exited_member) { |
- if (chatroom_handler_) |
- chatroom_handler_->MemberExited(this, exited_member); |
-} |
- |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::ServerChangedOtherPresence(const XmlElement& |
- presence_element) { |
- XmppReturnStatus xmpp_status = XMPP_RETURN_OK; |
- std::unique_ptr<XmppPresence> presence(XmppPresence::Create()); |
- IFR(presence->set_raw_xml(&presence_element)); |
- |
- JidMemberMap::iterator pos = chatroom_jid_members_.find(presence->jid()); |
- |
- if (pos == chatroom_jid_members_.end()) { |
- if (presence->available() == XMPP_PRESENCE_AVAILABLE) { |
- XmppChatroomMemberImpl* member = new XmppChatroomMemberImpl(); |
- member->SetPresence(presence.get()); |
- chatroom_jid_members_.insert(std::make_pair(member->member_jid(), member)); |
- chatroom_jid_members_version_++; |
- FireMemberEntered(member); |
- } |
- } else { |
- XmppChatroomMemberImpl* member = pos->second; |
- if (presence->available() == XMPP_PRESENCE_AVAILABLE) { |
- member->SetPresence(presence.get()); |
- chatroom_jid_members_version_++; |
- FireMemberChanged(member); |
- } |
- else if (presence->available() == XMPP_PRESENCE_UNAVAILABLE) { |
- member->SetPresence(presence.get()); |
- chatroom_jid_members_.erase(pos); |
- chatroom_jid_members_version_++; |
- FireMemberExited(member); |
- delete member; |
- } |
- } |
- |
- return xmpp_status; |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::ClientChangeMyPresence(XmppChatroomState new_state) { |
- return ChangePresence(new_state, NULL, false); |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::ServerChangeMyPresence(const XmlElement& presence) { |
- XmppChatroomState new_state; |
- |
- if (presence.HasAttr(QN_TYPE) == false) { |
- new_state = XMPP_CHATROOM_STATE_IN_ROOM; |
- } else { |
- new_state = XMPP_CHATROOM_STATE_NOT_IN_ROOM; |
- } |
- return ChangePresence(new_state, &presence, true); |
- |
-} |
- |
-XmppReturnStatus |
-XmppChatroomModuleImpl::ChangePresence(XmppChatroomState new_state, |
- const XmlElement* presence, |
- bool isServer) { |
- RTC_UNUSED(presence); |
- |
- XmppChatroomState old_state = chatroom_state_; |
- |
- // do nothing if state hasn't changed |
- if (old_state == new_state) |
- return XMPP_RETURN_OK; |
- |
- // find the right transition description |
- StateTransitionDescription* transition_desc = NULL; |
- for (size_t i = 0; i < arraysize(Transitions); i++) { |
- if (Transitions[i].old_state == old_state && |
- Transitions[i].new_state == new_state) { |
- transition_desc = &Transitions[i]; |
- break; |
- } |
- } |
- |
- if (transition_desc == NULL) { |
- ASSERT(0); |
- return XMPP_RETURN_BADSTATE; |
- } |
- |
- // we assert for any invalid transition states, and we'll |
- if (isServer) { |
- // $TODO send original stanza back to server and log an error? |
- // Disable the assert because of b/6133072 |
- // ASSERT(transition_desc->is_valid_server_transition); |
- if (!transition_desc->is_valid_server_transition) { |
- return XMPP_RETURN_BADSTATE; |
- } |
- } else { |
- if (transition_desc->is_valid_client_transition == false) { |
- ASSERT(0); |
- return XMPP_RETURN_BADARGUMENT; |
- } |
- } |
- |
- // set the new state and then fire any notifications to the handler |
- chatroom_state_ = new_state; |
- |
- switch (transition_desc->transition_type) { |
- case TRANSITION_TYPE_ENTER_SUCCESS: |
- FireEnteredStatus(presence, XMPP_CHATROOM_ENTERED_SUCCESS); |
- break; |
- case TRANSITION_TYPE_ENTER_FAILURE: |
- FireEnteredStatus(presence, GetEnterFailureFromXml(presence)); |
- break; |
- case TRANSITION_TYPE_EXIT_INVOLUNTARILY: |
- FireExitStatus(GetExitFailureFromXml(presence)); |
- break; |
- case TRANSITION_TYPE_EXIT_VOLUNTARILY: |
- FireExitStatus(XMPP_CHATROOM_EXITED_REQUESTED); |
- break; |
- case TRANSITION_TYPE_NONE: |
- break; |
- } |
- |
- return XMPP_RETURN_OK; |
-} |
- |
-XmppChatroomEnteredStatus |
-XmppChatroomModuleImpl::GetEnterFailureFromXml(const XmlElement* presence) { |
- XmppChatroomEnteredStatus status = XMPP_CHATROOM_ENTERED_FAILURE_UNSPECIFIED; |
- const XmlElement* error = presence->FirstNamed(QN_ERROR); |
- if (error != NULL && error->HasAttr(QN_CODE)) { |
- int code = atoi(error->Attr(QN_CODE).c_str()); |
- switch (code) { |
- case 401: status = XMPP_CHATROOM_ENTERED_FAILURE_PASSWORD_REQUIRED; break; |
- case 403: { |
- status = XMPP_CHATROOM_ENTERED_FAILURE_MEMBER_BANNED; |
- if (error->FirstNamed(QN_GOOGLE_SESSION_BLOCKED)) { |
- status = XMPP_CHATROOM_ENTERED_FAILURE_MEMBER_BLOCKED; |
- } else if (error->FirstNamed(QN_GOOGLE_SESSION_BLOCKING)) { |
- status = XMPP_CHATROOM_ENTERED_FAILURE_MEMBER_BLOCKING; |
- } |
- break; |
- } |
- case 405: status = XMPP_CHATROOM_ENTERED_FAILURE_ROOM_LOCKED; break; |
- case 406: status = XMPP_CHATROOM_ENTERED_FAILURE_OUTDATED_CLIENT; break; |
- case 407: status = XMPP_CHATROOM_ENTERED_FAILURE_NOT_A_MEMBER; break; |
- case 409: status = XMPP_CHATROOM_ENTERED_FAILURE_NICKNAME_CONFLICT; break; |
- // http://xmpp.org/extensions/xep-0045.html#enter-maxusers |
- case 503: status = XMPP_CHATROOM_ENTERED_FAILURE_MAX_USERS; break; |
- } |
- } |
- return status; |
-} |
- |
-XmppChatroomExitedStatus |
-XmppChatroomModuleImpl::GetExitFailureFromXml(const XmlElement* presence) { |
- XmppChatroomExitedStatus status = XMPP_CHATROOM_EXITED_UNSPECIFIED; |
- const XmlElement* muc_user = presence->FirstNamed(QN_MUC_USER_X); |
- if (muc_user != NULL) { |
- const XmlElement* user_status = muc_user->FirstNamed(QN_MUC_USER_STATUS); |
- if (user_status != NULL && user_status->HasAttr(QN_CODE)) { |
- int code = atoi(user_status->Attr(QN_CODE).c_str()); |
- switch (code) { |
- case 307: status = XMPP_CHATROOM_EXITED_KICKED; break; |
- case 322: status = XMPP_CHATROOM_EXITED_NOT_A_MEMBER; break; |
- case 332: status = XMPP_CHATROOM_EXITED_SYSTEM_SHUTDOWN; break; |
- } |
- } |
- } |
- return status; |
-} |
- |
-XmppReturnStatus |
-XmppChatroomMemberImpl::SetPresence(const XmppPresence* presence) { |
- ASSERT(presence != NULL); |
- |
- // copy presence |
- presence_.reset(XmppPresence::Create()); |
- presence_->set_raw_xml(presence->raw_xml()); |
- return XMPP_RETURN_OK; |
-} |
- |
-const Jid |
-XmppChatroomMemberImpl::member_jid() const { |
- return presence_->jid(); |
-} |
- |
-const Jid |
-XmppChatroomMemberImpl::full_jid() const { |
- return Jid(""); |
-} |
- |
-const std::string |
-XmppChatroomMemberImpl::name() const { |
- return member_jid().resource(); |
-} |
- |
-const XmppPresence* |
-XmppChatroomMemberImpl::presence() const { |
- return presence_.get(); |
-} |
- |
- |
-// XmppChatroomMemberEnumeratorImpl -------------------------------------- |
-XmppChatroomMemberEnumeratorImpl::XmppChatroomMemberEnumeratorImpl( |
- XmppChatroomModuleImpl::JidMemberMap* map, int* map_version) { |
- map_ = map; |
- map_version_ = map_version; |
- map_version_created_ = *map_version_; |
- iterator_ = map->begin(); |
- before_beginning_ = true; |
-} |
- |
-XmppChatroomMember* |
-XmppChatroomMemberEnumeratorImpl::current() { |
- if (IsValid() == false) { |
- return NULL; |
- } else if (IsBeforeBeginning() || IsAfterEnd()) { |
- return NULL; |
- } else { |
- return iterator_->second; |
- } |
-} |
- |
-bool |
-XmppChatroomMemberEnumeratorImpl::Prev() { |
- if (IsValid() == false) { |
- return false; |
- } else if (IsBeforeBeginning()) { |
- return false; |
- } else if (iterator_ == map_->begin()) { |
- before_beginning_ = true; |
- return false; |
- } else { |
- iterator_--; |
- return current() != NULL; |
- } |
-} |
- |
-bool |
-XmppChatroomMemberEnumeratorImpl::Next() { |
- if (IsValid() == false) { |
- return false; |
- } else if (IsBeforeBeginning()) { |
- before_beginning_ = false; |
- iterator_ = map_->begin(); |
- return current() != NULL; |
- } else if (IsAfterEnd()) { |
- return false; |
- } else { |
- iterator_++; |
- return current() != NULL; |
- } |
-} |
- |
-bool |
-XmppChatroomMemberEnumeratorImpl::IsValid() { |
- return map_version_created_ == *map_version_; |
-} |
- |
-bool |
-XmppChatroomMemberEnumeratorImpl::IsBeforeBeginning() { |
- return before_beginning_; |
-} |
- |
-bool |
-XmppChatroomMemberEnumeratorImpl::IsAfterEnd() { |
- return (iterator_ == map_->end()); |
-} |
- |
- |
- |
-} // namespace buzz |