summaryrefslogtreecommitdiff
path: root/indra/newview/llgroupmgr.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'indra/newview/llgroupmgr.cpp')
-rw-r--r--indra/newview/llgroupmgr.cpp5014
1 files changed, 2507 insertions, 2507 deletions
diff --git a/indra/newview/llgroupmgr.cpp b/indra/newview/llgroupmgr.cpp
index e0366f20c1..32943a9bb7 100644
--- a/indra/newview/llgroupmgr.cpp
+++ b/indra/newview/llgroupmgr.cpp
@@ -1,2507 +1,2507 @@
-/**
- * @file llgroupmgr.cpp
- * @brief LLGroupMgr class implementation
- *
- * $LicenseInfo:firstyear=2004&license=viewerlgpl$
- * Second Life Viewer Source Code
- * Copyright (C) 2010, Linden Research, Inc.
- *
- * This library is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License as published by the Free Software Foundation;
- * version 2.1 of the License only.
- *
- * This library is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- * Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public
- * License along with this library; if not, write to the Free Software
- * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
- *
- * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA
- * $/LicenseInfo$
- */
-
-/**
- * Manager for aggregating all client knowledge for specific groups
- * Keeps a cache of group information.
- */
-
-#include "llviewerprecompiledheaders.h"
-
-#include "llgroupmgr.h"
-
-#include <vector>
-#include <algorithm>
-
-#include "llappviewer.h"
-#include "llagent.h"
-#include "llavatarnamecache.h"
-#include "llui.h"
-#include "message.h"
-#include "roles_constants.h"
-#include "lltransactiontypes.h"
-#include "llstatusbar.h"
-#include "llviewerwindow.h"
-#include "llpanelgroupcreate.h"
-#include "llgroupactions.h"
-#include "llnotificationsutil.h"
-#include "lluictrlfactory.h"
-#include "lltrans.h"
-#include "llviewerregion.h"
-#include <boost/regex.hpp>
-#include "llcorehttputil.h"
-#include "lluiusage.h"
-
-
-#if LL_MSVC
-#pragma warning(push)
-// disable boost::lexical_cast warning
-#pragma warning (disable:4702)
-#endif
-
-#include <boost/lexical_cast.hpp>
-
-#if LL_MSVC
-#pragma warning(pop) // Restore all warnings to the previous state
-#endif
-
-const U32 MAX_CACHED_GROUPS = 20;
-
-//
-// LLRoleActionSet
-//
-LLRoleActionSet::LLRoleActionSet()
-: mActionSetData(NULL)
-{ }
-
-LLRoleActionSet::~LLRoleActionSet()
-{
- delete mActionSetData;
- std::for_each(mActions.begin(), mActions.end(), DeletePointer());
- mActions.clear();
-}
-
-//
-// LLGroupMemberData
-//
-
-LLGroupMemberData::LLGroupMemberData(const LLUUID& id,
- S32 contribution,
- U64 agent_powers,
- const std::string& title,
- const std::string& online_status,
- bool is_owner) :
- mID(id),
- mContribution(contribution),
- mAgentPowers(agent_powers),
- mTitle(title),
- mOnlineStatus(online_status),
- mIsOwner(is_owner)
-{
-}
-
-LLGroupMemberData::~LLGroupMemberData()
-{
-}
-
-void LLGroupMemberData::addRole(const LLUUID& role, LLGroupRoleData* rd)
-{
- mRolesList[role] = rd;
-}
-
-bool LLGroupMemberData::removeRole(const LLUUID& role)
-{
- role_list_t::iterator it = mRolesList.find(role);
-
- if (it != mRolesList.end())
- {
- mRolesList.erase(it);
- return true;
- }
-
- return false;
-}
-
-//
-// LLGroupRoleData
-//
-
-LLGroupRoleData::LLGroupRoleData(const LLUUID& role_id,
- const std::string& role_name,
- const std::string& role_title,
- const std::string& role_desc,
- const U64 role_powers,
- const S32 member_count) :
- mRoleID(role_id),
- mMemberCount(member_count),
- mMembersNeedsSort(false)
-{
- mRoleData.mRoleName = role_name;
- mRoleData.mRoleTitle = role_title;
- mRoleData.mRoleDescription = role_desc;
- mRoleData.mRolePowers = role_powers;
- mRoleData.mChangeType = RC_UPDATE_NONE;
-}
-
-LLGroupRoleData::LLGroupRoleData(const LLUUID& role_id,
- LLRoleData role_data,
- const S32 member_count) :
- mRoleID(role_id),
- mRoleData(role_data),
- mMemberCount(member_count),
- mMembersNeedsSort(false)
-{
-
-}
-
-LLGroupRoleData::~LLGroupRoleData()
-{
-}
-
-S32 LLGroupRoleData::getMembersInRole(uuid_vec_t members,
- bool needs_sort)
-{
- if (mRoleID.isNull())
- {
- // This is the everyone role, just return the size of members,
- // because everyone is in the everyone role.
- return members.size();
- }
-
- // Sort the members list, if needed.
- if (mMembersNeedsSort)
- {
- std::sort(mMemberIDs.begin(), mMemberIDs.end());
- mMembersNeedsSort = false;
- }
- if (needs_sort)
- {
- // Sort the members parameter.
- std::sort(members.begin(), members.end());
- }
-
- // Return the number of members in the intersection.
- S32 max_size = llmin( members.size(), mMemberIDs.size() );
- uuid_vec_t in_role( max_size );
- uuid_vec_t::iterator in_role_end;
- in_role_end = std::set_intersection(mMemberIDs.begin(), mMemberIDs.end(),
- members.begin(), members.end(),
- in_role.begin());
- return in_role_end - in_role.begin();
-}
-
-void LLGroupRoleData::addMember(const LLUUID& member)
-{
- mMembersNeedsSort = true;
- mMemberIDs.push_back(member);
-}
-
-bool LLGroupRoleData::removeMember(const LLUUID& member)
-{
- uuid_vec_t::iterator it = std::find(mMemberIDs.begin(),mMemberIDs.end(),member);
-
- if (it != mMemberIDs.end())
- {
- mMembersNeedsSort = true;
- mMemberIDs.erase(it);
- return true;
- }
-
- return false;
-}
-
-void LLGroupRoleData::clearMembers()
-{
- mMembersNeedsSort = false;
- mMemberIDs.clear();
-}
-
-
-//
-// LLGroupMgrGroupData
-//
-
-LLGroupMgrGroupData::LLGroupMgrGroupData(const LLUUID& id) :
- mID(id),
- mShowInList(true),
- mOpenEnrollment(false),
- mMembershipFee(0),
- mAllowPublish(false),
- mListInProfile(false),
- mMaturePublish(false),
- mChanged(false),
- mMemberCount(0),
- mRoleCount(0),
- mReceivedRoleMemberPairs(0),
- mMemberDataComplete(false),
- mRoleDataComplete(false),
- mRoleMemberDataComplete(false),
- mGroupPropertiesDataComplete(false),
- mPendingRoleMemberRequest(false),
- mAccessTime(0.0f),
- mPendingBanRequest(false)
-{
- mMemberVersion.generate();
-}
-
-void LLGroupMgrGroupData::setAccessed()
-{
- mAccessTime = (F32)LLFrameTimer::getTotalSeconds();
-}
-
-bool LLGroupMgrGroupData::getRoleData(const LLUUID& role_id, LLRoleData& role_data)
-{
- role_data_map_t::const_iterator it;
-
- // Do we have changes for it?
- it = mRoleChanges.find(role_id);
- if (it != mRoleChanges.end())
- {
- if ((*it).second.mChangeType == RC_DELETE) return false;
-
- role_data = (*it).second;
- return true;
- }
-
- // Ok, no changes, hasn't been deleted, isn't a new role, just find the role.
- role_list_t::const_iterator rit = mRoles.find(role_id);
- if (rit != mRoles.end())
- {
- role_data = (*rit).second->getRoleData();
- return true;
- }
-
- // This role must not exist.
- return false;
-}
-
-
-void LLGroupMgrGroupData::setRoleData(const LLUUID& role_id, LLRoleData role_data)
-{
- // If this is a newly created group, we need to change the data in the created list.
- role_data_map_t::iterator it;
- it = mRoleChanges.find(role_id);
- if (it != mRoleChanges.end())
- {
- if ((*it).second.mChangeType == RC_CREATE)
- {
- role_data.mChangeType = RC_CREATE;
- mRoleChanges[role_id] = role_data;
- return;
- }
- else if ((*it).second.mChangeType == RC_DELETE)
- {
- // Don't do anything for a role being deleted.
- return;
- }
- }
-
- // Not a new role, so put it in the changes list.
- LLRoleData old_role_data;
- role_list_t::iterator rit = mRoles.find(role_id);
- if (rit != mRoles.end())
- {
- bool data_change = ( ((*rit).second->mRoleData.mRoleDescription != role_data.mRoleDescription)
- || ((*rit).second->mRoleData.mRoleName != role_data.mRoleName)
- || ((*rit).second->mRoleData.mRoleTitle != role_data.mRoleTitle) );
- bool powers_change = ((*rit).second->mRoleData.mRolePowers != role_data.mRolePowers);
-
- if (!data_change && !powers_change)
- {
- // We are back to the original state, the changes have been 'undone' so take out the change.
- mRoleChanges.erase(role_id);
- return;
- }
-
- if (data_change && powers_change)
- {
- role_data.mChangeType = RC_UPDATE_ALL;
- }
- else if (data_change)
- {
- role_data.mChangeType = RC_UPDATE_DATA;
- }
- else
- {
- role_data.mChangeType = RC_UPDATE_POWERS;
- }
-
- mRoleChanges[role_id] = role_data;
- }
- else
- {
- LL_WARNS() << "Change being made to non-existant role " << role_id << LL_ENDL;
- }
-}
-
-bool LLGroupMgrGroupData::pendingRoleChanges()
-{
- return (!mRoleChanges.empty());
-}
-
-// This is a no-op if the role has already been created.
-void LLGroupMgrGroupData::createRole(const LLUUID& role_id, LLRoleData role_data)
-{
- if (mRoleChanges.find(role_id) != mRoleChanges.end())
- {
- LL_WARNS() << "create role for existing role! " << role_id << LL_ENDL;
- }
- else
- {
- role_data.mChangeType = RC_CREATE;
- mRoleChanges[role_id] = role_data;
- }
-}
-
-void LLGroupMgrGroupData::deleteRole(const LLUUID& role_id)
-{
- role_data_map_t::iterator it;
-
- // If this was a new role, just discard it.
- it = mRoleChanges.find(role_id);
- if (it != mRoleChanges.end()
- && (*it).second.mChangeType == RC_CREATE)
- {
- mRoleChanges.erase(it);
- return;
- }
-
- LLRoleData rd;
- rd.mChangeType = RC_DELETE;
- mRoleChanges[role_id] = rd;
-}
-
-void LLGroupMgrGroupData::addRolePower(const LLUUID &role_id, U64 power)
-{
- LLRoleData rd;
- if (getRoleData(role_id,rd))
- {
- rd.mRolePowers |= power;
- setRoleData(role_id,rd);
- }
- else
- {
- LL_WARNS() << "addRolePower: no role data found for " << role_id << LL_ENDL;
- }
-}
-
-void LLGroupMgrGroupData::removeRolePower(const LLUUID &role_id, U64 power)
-{
- LLRoleData rd;
- if (getRoleData(role_id,rd))
- {
- rd.mRolePowers &= ~power;
- setRoleData(role_id,rd);
- }
- else
- {
- LL_WARNS() << "removeRolePower: no role data found for " << role_id << LL_ENDL;
- }
-}
-
-U64 LLGroupMgrGroupData::getRolePowers(const LLUUID& role_id)
-{
- LLRoleData rd;
- if (getRoleData(role_id,rd))
- {
- return rd.mRolePowers;
- }
- else
- {
- LL_WARNS() << "getRolePowers: no role data found for " << role_id << LL_ENDL;
- return GP_NO_POWERS;
- }
-}
-
-void LLGroupMgrGroupData::removeData()
-{
- // Remove member data first, because removeRoleData will walk the member list
- removeMemberData();
- removeRoleData();
-}
-
-void LLGroupMgrGroupData::removeMemberData()
-{
- for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
- {
- delete mi->second;
- }
- mMembers.clear();
- mMemberDataComplete = false;
- mMemberVersion.generate();
-}
-
-void LLGroupMgrGroupData::removeRoleData()
-{
- for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
- {
- LLGroupMemberData* data = mi->second;
- if (data)
- {
- data->clearRoles();
- }
- }
-
- for (role_list_t::iterator ri = mRoles.begin(); ri != mRoles.end(); ++ri)
- {
- LLGroupRoleData* data = ri->second;
- delete data;
- }
- mRoles.clear();
- mReceivedRoleMemberPairs = 0;
- mRoleDataComplete = false;
- mRoleMemberDataComplete= false;
-}
-
-void LLGroupMgrGroupData::removeRoleMemberData()
-{
- for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
- {
- LLGroupMemberData* data = mi->second;
- if (data)
- {
- data->clearRoles();
- }
- }
-
- for (role_list_t::iterator ri = mRoles.begin(); ri != mRoles.end(); ++ri)
- {
- LLGroupRoleData* data = ri->second;
- if (data)
- {
- data->clearMembers();
- }
- }
-
- mReceivedRoleMemberPairs = 0;
- mRoleMemberDataComplete= false;
-}
-
-LLGroupMgrGroupData::~LLGroupMgrGroupData()
-{
- removeData();
-}
-
-bool LLGroupMgrGroupData::changeRoleMember(const LLUUID& role_id,
- const LLUUID& member_id,
- LLRoleMemberChangeType rmc)
-{
- role_list_t::iterator ri = mRoles.find(role_id);
- member_list_t::iterator mi = mMembers.find(member_id);
-
- if (ri == mRoles.end()
- || mi == mMembers.end() )
- {
- if (ri == mRoles.end()) LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't find role " << role_id << LL_ENDL;
- if (mi == mMembers.end()) LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't find member " << member_id << LL_ENDL;
- return false;
- }
-
- LLGroupRoleData* grd = ri->second;
- LLGroupMemberData* gmd = mi->second;
-
- if (!grd || !gmd)
- {
- LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't get member or role data." << LL_ENDL;
- return false;
- }
-
- if (RMC_ADD == rmc)
- {
- LL_INFOS() << " adding member to role." << LL_ENDL;
- grd->addMember(member_id);
- gmd->addRole(role_id,grd);
-
- //TODO move this into addrole function
- //see if they added someone to the owner role and update isOwner
- gmd->mIsOwner = (role_id == mOwnerRole) ? true : gmd->mIsOwner;
- }
- else if (RMC_REMOVE == rmc)
- {
- LL_INFOS() << " removing member from role." << LL_ENDL;
- grd->removeMember(member_id);
- gmd->removeRole(role_id);
-
- //see if they removed someone from the owner role and update isOwner
- gmd->mIsOwner = (role_id == mOwnerRole) ? false : gmd->mIsOwner;
- }
-
- lluuid_pair role_member;
- role_member.first = role_id;
- role_member.second = member_id;
-
- change_map_t::iterator it = mRoleMemberChanges.find(role_member);
- if (it != mRoleMemberChanges.end())
- {
- // There was already a role change for this role_member
- if (it->second.mChange == rmc)
- {
- // Already recorded this change? Weird.
- LL_INFOS() << "Received duplicate change for "
- << " role: " << role_id << " member " << member_id
- << " change " << (rmc == RMC_ADD ? "ADD" : "REMOVE") << LL_ENDL;
- }
- else
- {
- // The only two operations (add and remove) currently cancel each other out
- // If that changes this will need more logic
- if (rmc == RMC_NONE)
- {
- LL_WARNS() << "changeRoleMember: existing entry with 'RMC_NONE' change! This shouldn't happen." << LL_ENDL;
- LLRoleMemberChange rc(role_id,member_id,rmc);
- mRoleMemberChanges[role_member] = rc;
- }
- else
- {
- mRoleMemberChanges.erase(it);
- }
- }
- }
- else
- {
- LLRoleMemberChange rc(role_id,member_id,rmc);
- mRoleMemberChanges[role_member] = rc;
- }
-
- recalcAgentPowers(member_id);
-
- mChanged = true;
- return true;
-}
-
-void LLGroupMgrGroupData::recalcAllAgentPowers()
-{
- LLGroupMemberData* gmd;
-
- for (member_list_t::iterator mit = mMembers.begin();
- mit != mMembers.end(); ++mit)
- {
- gmd = mit->second;
- if (!gmd) continue;
-
- gmd->mAgentPowers = 0;
- for (LLGroupMemberData::role_list_t::iterator it = gmd->mRolesList.begin();
- it != gmd->mRolesList.end(); ++it)
- {
- LLGroupRoleData* grd = (*it).second;
- if (!grd) continue;
-
- gmd->mAgentPowers |= grd->mRoleData.mRolePowers;
- }
- }
-}
-
-void LLGroupMgrGroupData::recalcAgentPowers(const LLUUID& agent_id)
-{
- member_list_t::iterator mi = mMembers.find(agent_id);
- if (mi == mMembers.end()) return;
-
- LLGroupMemberData* gmd = mi->second;
-
- if (!gmd) return;
-
- gmd->mAgentPowers = 0;
- for (LLGroupMemberData::role_list_t::iterator it = gmd->mRolesList.begin();
- it != gmd->mRolesList.end(); ++it)
- {
- LLGroupRoleData* grd = (*it).second;
- if (!grd) continue;
-
- gmd->mAgentPowers |= grd->mRoleData.mRolePowers;
- }
-}
-
-bool LLGroupMgrGroupData::isSingleMemberNotOwner()
-{
- return mMembers.size() == 1 && !mMembers.begin()->second->isOwner();
-}
-
-bool packRoleUpdateMessageBlock(LLMessageSystem* msg,
- const LLUUID& group_id,
- const LLUUID& role_id,
- const LLRoleData& role_data,
- bool start_message)
-{
- if (start_message)
- {
- msg->newMessage("GroupRoleUpdate");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->addUUID("GroupID",group_id);
- start_message = false;
- }
-
- msg->nextBlock("RoleData");
- msg->addUUID("RoleID",role_id);
- msg->addString("Name", role_data.mRoleName);
- msg->addString("Description", role_data.mRoleDescription);
- msg->addString("Title", role_data.mRoleTitle);
- msg->addU64("Powers", role_data.mRolePowers);
- msg->addU8("UpdateType", (U8)role_data.mChangeType);
-
- if (msg->isSendFullFast())
- {
- gAgent.sendReliableMessage();
- start_message = true;
- }
-
- return start_message;
-}
-
-void LLGroupMgrGroupData::sendRoleChanges()
-{
- // Commit changes locally
- LLGroupRoleData* grd;
- role_list_t::iterator role_it;
- LLMessageSystem* msg = gMessageSystem;
- bool start_message = true;
-
- bool need_role_cleanup = false;
- bool need_role_data = false;
- bool need_power_recalc = false;
-
- // Apply all changes
- for (role_data_map_t::iterator iter = mRoleChanges.begin();
- iter != mRoleChanges.end(); )
- {
- role_data_map_t::iterator it = iter++; // safely incrament iter
- const LLUUID& role_id = (*it).first;
- const LLRoleData& role_data = (*it).second;
-
- // Commit to local data set
- role_it = mRoles.find((*it).first);
- if ( (mRoles.end() == role_it
- && RC_CREATE != role_data.mChangeType)
- || (mRoles.end() != role_it
- && RC_CREATE == role_data.mChangeType))
- {
- continue;
- }
-
- // NOTE: role_it is valid EXCEPT for the RC_CREATE case
- switch (role_data.mChangeType)
- {
- case RC_CREATE:
- {
- // NOTE: role_it is NOT valid in this case
- grd = new LLGroupRoleData(role_id, role_data, 0);
- mRoles[role_id] = grd;
- need_role_data = true;
- break;
- }
- case RC_DELETE:
- {
- LLGroupRoleData* group_role_data = (*role_it).second;
- delete group_role_data;
- mRoles.erase(role_it);
- need_role_cleanup = true;
- need_power_recalc = true;
- break;
- }
- case RC_UPDATE_ALL:
- // fall through
- case RC_UPDATE_POWERS:
- need_power_recalc = true;
- // fall through
- case RC_UPDATE_DATA:
- // fall through
- default:
- {
- LLGroupRoleData* group_role_data = (*role_it).second;
- group_role_data->setRoleData(role_data); // NOTE! might modify mRoleChanges!
- break;
- }
- }
-
- // Update dataserver
- start_message = packRoleUpdateMessageBlock(msg,getID(),role_id,role_data,start_message);
- }
-
- if (!start_message)
- {
- gAgent.sendReliableMessage();
- }
-
- // If we delete a role then all the role-member pairs are invalid!
- if (need_role_cleanup)
- {
- removeRoleMemberData();
- }
-
- // If we create a new role, then we need to re-fetch all the role data.
- if (need_role_data)
- {
- LLGroupMgr::getInstance()->sendGroupRoleDataRequest(getID());
- }
-
- // Clean up change lists
- mRoleChanges.clear();
-
- // Recalculate all the agent powers because role powers have now changed.
- if (need_power_recalc)
- {
- recalcAllAgentPowers();
- }
-}
-
-void LLGroupMgrGroupData::cancelRoleChanges()
-{
- // Clear out all changes!
- mRoleChanges.clear();
-}
-
-void LLGroupMgrGroupData::createBanEntry(const LLUUID& ban_id, const LLGroupBanData& ban_data)
-{
- mBanList[ban_id] = ban_data;
-}
-
-void LLGroupMgrGroupData::removeBanEntry(const LLUUID& ban_id)
-{
- mBanList.erase(ban_id);
-}
-
-void LLGroupMgrGroupData::banMemberById(const LLUUID& participant_uuid)
-{
- if (!mMemberDataComplete ||
- !mRoleDataComplete ||
- !(mRoleMemberDataComplete && mMembers.size()))
- {
- LL_WARNS() << "No Role-Member data yet, setting ban request to pending." << LL_ENDL;
- mPendingBanRequest = true;
- mPendingBanMemberID = participant_uuid;
-
- if (!mMemberDataComplete || !mMembers.size())
- {
- LLGroupMgr::getInstance()->sendCapGroupMembersRequest(mID);
- }
-
- if (!mRoleDataComplete)
- {
- LLGroupMgr::getInstance()->sendGroupRoleDataRequest(mID);
- }
-
- return;
- }
-
- LLGroupMgrGroupData::member_list_t::iterator mi = mMembers.find((participant_uuid));
- if (mi == mMembers.end())
- {
- if (!mPendingBanRequest)
- {
- mPendingBanRequest = true;
- mPendingBanMemberID = participant_uuid;
- LLGroupMgr::getInstance()->sendCapGroupMembersRequest(mID); // member isn't in members list, request reloading
- }
- else
- {
- mPendingBanRequest = false;
- }
-
- return;
- }
-
- mPendingBanRequest = false;
-
- LLGroupMemberData* member_data = (*mi).second;
- if (member_data && member_data->isInRole(mOwnerRole))
- {
- return; // can't ban group owner
- }
-
- std::vector<LLUUID> ids;
- ids.push_back(participant_uuid);
-
- LLGroupBanData ban_data;
- createBanEntry(participant_uuid, ban_data);
- LLGroupMgr::getInstance()->sendGroupBanRequest(LLGroupMgr::REQUEST_POST, mID, LLGroupMgr::BAN_CREATE, ids);
- LLGroupMgr::getInstance()->sendGroupMemberEjects(mID, ids);
- LLGroupMgr::getInstance()->sendGroupMembersRequest(mID);
- LLSD args;
- LLAvatarName av_name;
- LLAvatarNameCache::get(participant_uuid, &av_name);
- args["AVATAR_NAME"] = av_name.getUserName();
- args["GROUP_NAME"] = mName;
- LLNotifications::instance().add(LLNotification::Params("EjectAvatarFromGroup").substitutions(args));
-}
-
-//
-// LLGroupMgr
-//
-
-LLGroupMgr::LLGroupMgr():
- mMemberRequestInFlight(false)
-{
-}
-
-LLGroupMgr::~LLGroupMgr()
-{
- clearGroups();
-}
-
-void LLGroupMgr::clearGroups()
-{
- std::for_each(mRoleActionSets.begin(), mRoleActionSets.end(), DeletePointer());
- mRoleActionSets.clear();
- std::for_each(mGroups.begin(), mGroups.end(), DeletePairedPointer());
- mGroups.clear();
- mObservers.clear();
-}
-
-void LLGroupMgr::clearGroupData(const LLUUID& group_id)
-{
- group_map_t::iterator iter = mGroups.find(group_id);
- if (iter != mGroups.end())
- {
- delete (*iter).second;
- mGroups.erase(iter);
- }
-}
-
-void LLGroupMgr::addObserver(LLGroupMgrObserver* observer)
-{
- if( observer->getID() != LLUUID::null )
- mObservers.insert(std::pair<LLUUID, LLGroupMgrObserver*>(observer->getID(), observer));
-}
-
-void LLGroupMgr::addObserver(const LLUUID& group_id, LLParticularGroupObserver* observer)
-{
- if(group_id.notNull() && observer)
- {
- mParticularObservers[group_id].insert(observer);
- }
-}
-
-void LLGroupMgr::removeObserver(LLGroupMgrObserver* observer)
-{
- if (!observer)
- {
- return;
- }
- observer_multimap_t::iterator it;
- it = mObservers.find(observer->getID());
- while (it != mObservers.end())
- {
- if (it->second == observer)
- {
- mObservers.erase(it);
- break;
- }
- else
- {
- ++it;
- }
- }
-}
-
-void LLGroupMgr::removeObserver(const LLUUID& group_id, LLParticularGroupObserver* observer)
-{
- if(group_id.isNull() || !observer)
- {
- return;
- }
-
- observer_map_t::iterator obs_it = mParticularObservers.find(group_id);
- if(obs_it == mParticularObservers.end())
- return;
-
- obs_it->second.erase(observer);
-
- if (obs_it->second.size() == 0)
- mParticularObservers.erase(obs_it);
-}
-
-LLGroupMgrGroupData* LLGroupMgr::getGroupData(const LLUUID& id)
-{
- group_map_t::iterator gi = mGroups.find(id);
-
- if (gi != mGroups.end())
- {
- return gi->second;
- }
- return NULL;
-}
-
-// Helper function for LLGroupMgr::processGroupMembersReply
-// This reformats date strings from MM/DD/YYYY to YYYY/MM/DD ( e.g. 1/27/2008 -> 2008/1/27 )
-// so that the sorter can sort by year before month before day.
-static void formatDateString(std::string &date_string)
-{
- using namespace boost;
- cmatch result;
- const regex expression("([0-9]{1,2})/([0-9]{1,2})/([0-9]{4})");
- if (regex_match(date_string.c_str(), result, expression))
- {
- // convert matches to integers so that we can pad them with zeroes on Linux
- S32 year = boost::lexical_cast<S32>(result[3]);
- S32 month = boost::lexical_cast<S32>(result[1]);
- S32 day = boost::lexical_cast<S32>(result[2]);
-
- // ISO 8601 date format
- date_string = llformat("%04d/%02d/%02d", year, month, day);
- }
-}
-
-// static
-void LLGroupMgr::processGroupMembersReply(LLMessageSystem* msg, void** data)
-{
- LL_PROFILE_ZONE_SCOPED;
-
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupMembersReply" << LL_ENDL;
- LLUUID agent_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
- if (gAgent.getID() != agent_id)
- {
- LL_WARNS() << "Got group members reply for another agent!" << LL_ENDL;
- return;
- }
-
- LLUUID group_id;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
-
- LLUUID request_id;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_RequestID, request_id);
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!group_datap || (group_datap->mMemberRequestID != request_id))
- {
- LL_WARNS() << "processGroupMembersReply: Received incorrect (stale?) group or request id" << LL_ENDL;
- return;
- }
-
- msg->getS32(_PREHASH_GroupData, "MemberCount", group_datap->mMemberCount );
-
- if (group_datap->mMemberCount > 0)
- {
- S32 contribution = 0;
- std::string online_status;
- std::string title;
- U64 agent_powers = 0;
- bool is_owner = false;
-
- S32 num_members = msg->getNumberOfBlocksFast(_PREHASH_MemberData);
- for (S32 i = 0; i < num_members; i++)
- {
- LLUUID member_id;
-
- msg->getUUIDFast(_PREHASH_MemberData, _PREHASH_AgentID, member_id, i );
- msg->getS32(_PREHASH_MemberData, _PREHASH_Contribution, contribution, i);
- msg->getU64(_PREHASH_MemberData, "AgentPowers", agent_powers, i);
- msg->getStringFast(_PREHASH_MemberData, _PREHASH_OnlineStatus, online_status, i);
- msg->getString(_PREHASH_MemberData, "Title", title, i);
- msg->getBOOL(_PREHASH_MemberData,"IsOwner",is_owner,i);
-
- if (member_id.notNull())
- {
- if (online_status == "Online")
- {
- static std::string localized_online(LLTrans::getString("group_member_status_online"));
- online_status = localized_online;
- }
- else
- {
- formatDateString(online_status); // reformat for sorting, e.g. 12/25/2008 -> 2008/12/25
- }
-
- //LL_INFOS() << "Member " << member_id << " has powers " << std::hex << agent_powers << std::dec << LL_ENDL;
- LLGroupMemberData* newdata = new LLGroupMemberData(member_id,
- contribution,
- agent_powers,
- title,
- online_status,
- is_owner);
-#if LL_DEBUG
- LLGroupMgrGroupData::member_list_t::iterator mit = group_datap->mMembers.find(member_id);
- if (mit != group_datap->mMembers.end())
- {
- LL_INFOS() << " *** Received duplicate member data for agent " << member_id << LL_ENDL;
- }
-#endif
- group_datap->mMembers[member_id] = newdata;
- }
- else
- {
- LL_INFOS() << "Received null group member data." << LL_ENDL;
- }
- }
-
- //if group members are loaded while titles are missing, load the titles.
- if(group_datap->mTitles.size() < 1)
- {
- LLGroupMgr::getInstance()->sendGroupTitlesRequest(group_id);
- }
- }
-
- group_datap->mMemberVersion.generate();
-
- if (group_datap->mMembers.size() == (U32)group_datap->mMemberCount)
- {
- group_datap->mMemberDataComplete = true;
- group_datap->mMemberRequestID.setNull();
- // We don't want to make role-member data requests until we have all the members
- if (group_datap->mPendingRoleMemberRequest)
- {
- group_datap->mPendingRoleMemberRequest = false;
- LLGroupMgr::getInstance()->sendGroupRoleMembersRequest(group_datap->mID);
- }
- }
-
- group_datap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_MEMBER_DATA);
-}
-
-//static
-void LLGroupMgr::processGroupPropertiesReply(LLMessageSystem* msg, void** data)
-{
- LL_PROFILE_ZONE_SCOPED;
-
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupPropertiesReply" << LL_ENDL;
- if (!msg)
- {
- LL_ERRS() << "Can't access the messaging system" << LL_ENDL;
- return;
- }
- LLUUID agent_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
- if (gAgent.getID() != agent_id)
- {
- LL_WARNS() << "Got group properties reply for another agent!" << LL_ENDL;
- return;
- }
-
- LLUUID group_id;
- std::string name;
- std::string charter;
- bool show_in_list = false;
- LLUUID founder_id;
- U64 powers_mask = GP_NO_POWERS;
- S32 money = 0;
- std::string member_title;
- LLUUID insignia_id;
- LLUUID owner_role;
- U32 membership_fee = 0;
- bool open_enrollment = false;
- S32 num_group_members = 0;
- S32 num_group_roles = 0;
- bool allow_publish = false;
- bool mature = false;
-
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_FounderID, founder_id);
- msg->getStringFast(_PREHASH_GroupData, _PREHASH_Name, name );
- msg->getStringFast(_PREHASH_GroupData, _PREHASH_Charter, charter );
- msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_ShowInList, show_in_list );
- msg->getStringFast(_PREHASH_GroupData, _PREHASH_MemberTitle, member_title );
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_InsigniaID, insignia_id );
- msg->getU64Fast(_PREHASH_GroupData, _PREHASH_PowersMask, powers_mask );
- msg->getU32Fast(_PREHASH_GroupData, _PREHASH_MembershipFee, membership_fee );
- msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_OpenEnrollment, open_enrollment );
- msg->getS32Fast(_PREHASH_GroupData, _PREHASH_GroupMembershipCount, num_group_members);
- msg->getS32(_PREHASH_GroupData, "GroupRolesCount", num_group_roles);
- msg->getS32Fast(_PREHASH_GroupData, _PREHASH_Money, money);
- msg->getBOOL("GroupData", "AllowPublish", allow_publish);
- msg->getBOOL("GroupData", "MaturePublish", mature);
- msg->getUUID(_PREHASH_GroupData, "OwnerRole", owner_role);
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->createGroupData(group_id);
-
- group_datap->mName = name;
- group_datap->mCharter = charter;
- group_datap->mShowInList = show_in_list;
- group_datap->mInsigniaID = insignia_id;
- group_datap->mFounderID = founder_id;
- group_datap->mMembershipFee = membership_fee;
- group_datap->mOpenEnrollment = open_enrollment;
- group_datap->mAllowPublish = allow_publish;
- group_datap->mMaturePublish = mature;
- group_datap->mOwnerRole = owner_role;
- group_datap->mMemberCount = num_group_members;
- group_datap->mRoleCount = num_group_roles + 1; // Add the everyone role.
-
- group_datap->mGroupPropertiesDataComplete = true;
- group_datap->mChanged = true;
-
- properties_request_map_t::iterator request = LLGroupMgr::getInstance()->mPropRequests.find(group_id);
- if (request != LLGroupMgr::getInstance()->mPropRequests.end())
- {
- LLGroupMgr::getInstance()->mPropRequests.erase(request);
- }
- else
- {
- LL_DEBUGS("GrpMgr") << "GroupPropertyResponse received with no pending request. Response was slow." << LL_ENDL;
- }
- LLGroupMgr::getInstance()->notifyObservers(GC_PROPERTIES);
-}
-
-// static
-void LLGroupMgr::processGroupRoleDataReply(LLMessageSystem* msg, void** data)
-{
- LL_PROFILE_ZONE_SCOPED;
-
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupRoleDataReply" << LL_ENDL;
- LLUUID agent_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
- if (gAgent.getID() != agent_id)
- {
- LL_WARNS() << "Got group role data reply for another agent!" << LL_ENDL;
- return;
- }
-
- LLUUID group_id;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
-
- LLUUID request_id;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_RequestID, request_id);
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!group_datap || (group_datap->mRoleDataRequestID != request_id))
- {
- LL_WARNS() << "processGroupPropertiesReply: Received incorrect (stale?) group or request id" << LL_ENDL;
- return;
- }
-
- msg->getS32(_PREHASH_GroupData, "RoleCount", group_datap->mRoleCount );
-
- std::string name;
- std::string title;
- std::string desc;
- U64 powers = 0;
- U32 member_count = 0;
- LLUUID role_id;
-
- U32 num_blocks = msg->getNumberOfBlocks("RoleData");
- U32 i = 0;
- for (i=0; i< num_blocks; ++i)
- {
- msg->getUUID("RoleData", "RoleID", role_id, i );
-
- msg->getString("RoleData","Name",name,i);
- msg->getString("RoleData","Title",title,i);
- msg->getString("RoleData","Description",desc,i);
- msg->getU64("RoleData","Powers",powers,i);
- msg->getU32("RoleData","Members",member_count,i);
-
- //there are 3 predifined roles - Owners, Officers, Everyone
- //there names are defined in lldatagroups.cpp
- //lets change names from server to localized strings
- if(name == "Everyone")
- {
- name = LLTrans::getString("group_role_everyone");
- }
- else if(name == "Officers")
- {
- name = LLTrans::getString("group_role_officers");
- }
- else if(name == "Owners")
- {
- name = LLTrans::getString("group_role_owners");
- }
-
-
-
- LL_DEBUGS("GrpMgr") << "Adding role data: " << name << " {" << role_id << "}" << LL_ENDL;
- LLGroupRoleData* rd = new LLGroupRoleData(role_id,name,title,desc,powers,member_count);
- group_datap->mRoles[role_id] = rd;
- }
-
- if (group_datap->mRoles.size() == (U32)group_datap->mRoleCount)
- {
- group_datap->mRoleDataComplete = true;
- group_datap->mRoleDataRequestID.setNull();
- // We don't want to make role-member data requests until we have all the role data
- if (group_datap->mPendingRoleMemberRequest)
- {
- group_datap->mPendingRoleMemberRequest = false;
- LLGroupMgr::getInstance()->sendGroupRoleMembersRequest(group_datap->mID);
- }
- }
-
- group_datap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_ROLE_DATA);
-}
-
-// static
-void LLGroupMgr::processGroupRoleMembersReply(LLMessageSystem* msg, void** data)
-{
- LL_PROFILE_ZONE_SCOPED;
-
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupRoleMembersReply" << LL_ENDL;
- LLUUID agent_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
- if (gAgent.getID() != agent_id)
- {
- LL_WARNS() << "Got group role members reply for another agent!" << LL_ENDL;
- return;
- }
-
- LLUUID request_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_RequestID, request_id);
-
- LLUUID group_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_GroupID, group_id );
-
- U32 total_pairs;
- msg->getU32(_PREHASH_AgentData, "TotalPairs", total_pairs);
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!group_datap || (group_datap->mRoleMembersRequestID != request_id))
- {
- LL_WARNS() << "processGroupRoleMembersReply: Received incorrect (stale?) group or request id" << LL_ENDL;
- return;
- }
-
- U32 num_blocks = msg->getNumberOfBlocks("MemberData");
- U32 i;
- LLUUID member_id;
- LLUUID role_id;
- LLGroupRoleData* rd = NULL;
- LLGroupMemberData* md = NULL;
-
- LLGroupMgrGroupData::role_list_t::iterator ri;
- LLGroupMgrGroupData::member_list_t::iterator mi;
-
- // If total_pairs == 0, there are no members in any custom roles.
- if (total_pairs > 0)
- {
- for (i = 0;i < num_blocks; ++i)
- {
- msg->getUUID("MemberData","RoleID",role_id,i);
- msg->getUUID("MemberData","MemberID",member_id,i);
-
- if (role_id.notNull() && member_id.notNull() )
- {
- rd = NULL;
- ri = group_datap->mRoles.find(role_id);
- if (ri != group_datap->mRoles.end())
- {
- rd = ri->second;
- }
-
- md = NULL;
- mi = group_datap->mMembers.find(member_id);
- if (mi != group_datap->mMembers.end())
- {
- md = mi->second;
- }
-
- if (rd && md)
- {
- LL_DEBUGS("GrpMgr") << "Adding role-member pair: " << role_id << ", " << member_id << LL_ENDL;
- rd->addMember(member_id);
- md->addRole(role_id,rd);
- }
- else
- {
- if (!rd) LL_WARNS() << "Received role data for unknown role " << role_id << " in group " << group_id << LL_ENDL;
- if (!md) LL_WARNS() << "Received role data for unknown member " << member_id << " in group " << group_id << LL_ENDL;
- }
- }
- }
-
- group_datap->mReceivedRoleMemberPairs += num_blocks;
- }
-
- if (group_datap->mReceivedRoleMemberPairs == total_pairs)
- {
- // Add role data for the 'everyone' role to all members
- LLGroupRoleData* everyone = group_datap->mRoles[LLUUID::null];
- if (!everyone)
- {
- LL_WARNS() << "Everyone role not found!" << LL_ENDL;
- }
- else
- {
- for (LLGroupMgrGroupData::member_list_t::iterator mi = group_datap->mMembers.begin();
- mi != group_datap->mMembers.end(); ++mi)
- {
- LLGroupMemberData* data = mi->second;
- if (data)
- {
- data->addRole(LLUUID::null,everyone);
- }
- }
- }
-
- group_datap->mRoleMemberDataComplete= true;
- group_datap->mRoleMembersRequestID.setNull();
- }
-
- group_datap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_ROLE_MEMBER_DATA);
-
- if (group_datap->mPendingBanRequest)
- {
- group_datap->banMemberById(group_datap->mPendingBanMemberID);
- }
-}
-
-// static
-void LLGroupMgr::processGroupTitlesReply(LLMessageSystem* msg, void** data)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupTitlesReply" << LL_ENDL;
- LLUUID agent_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
- if (gAgent.getID() != agent_id)
- {
- LL_WARNS() << "Got group properties reply for another agent!" << LL_ENDL;
- return;
- }
-
- LLUUID group_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_GroupID, group_id );
- LLUUID request_id;
- msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_RequestID, request_id);
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!group_datap || (group_datap->mTitlesRequestID != request_id))
- {
- LL_WARNS() << "processGroupTitlesReply: Received incorrect (stale?) group" << LL_ENDL;
- return;
- }
-
- LLGroupTitle title;
-
- S32 i = 0;
- S32 blocks = msg->getNumberOfBlocksFast(_PREHASH_GroupData);
- for (i=0; i<blocks; ++i)
- {
- msg->getString("GroupData","Title",title.mTitle,i);
- msg->getUUID("GroupData","RoleID",title.mRoleID,i);
- msg->getBOOL("GroupData","Selected",title.mSelected,i);
-
- if (!title.mTitle.empty())
- {
- LL_DEBUGS("GrpMgr") << "LLGroupMgr adding title: " << title.mTitle << ", " << title.mRoleID << ", " << (title.mSelected ? 'Y' : 'N') << LL_ENDL;
- group_datap->mTitles.push_back(title);
- }
- }
-
- group_datap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_TITLES);
-}
-
-// static
-void LLGroupMgr::processEjectGroupMemberReply(LLMessageSystem* msg, void ** data)
-{
- LL_DEBUGS("GrpMgr") << "processEjectGroupMemberReply" << LL_ENDL;
- LLUUID group_id;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
- bool success;
- msg->getBOOLFast(_PREHASH_EjectData, _PREHASH_Success, success);
-
- // If we had a failure, the group panel needs to be updated.
- if (!success)
- {
- LLGroupActions::refresh(group_id);
- }
-}
-
-// static
-void LLGroupMgr::processJoinGroupReply(LLMessageSystem* msg, void ** data)
-{
- LL_DEBUGS("GrpMgr") << "processJoinGroupReply" << LL_ENDL;
- LLUUID group_id;
- bool success;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
- msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_Success, success);
-
- if (success)
- {
- // refresh all group information
- gAgent.sendAgentDataUpdateRequest();
-
- LLGroupMgr::getInstance()->clearGroupData(group_id);
- // refresh the floater for this group, if any.
- LLGroupActions::refresh(group_id);
- }
-}
-
-// static
-void LLGroupMgr::processLeaveGroupReply(LLMessageSystem* msg, void ** data)
-{
- LL_DEBUGS("GrpMgr") << "processLeaveGroupReply" << LL_ENDL;
- LLUUID group_id;
- bool success;
- msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
- msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_Success, success);
-
- if (success)
- {
- // refresh all group information
- gAgent.sendAgentDataUpdateRequest();
-
- LLGroupMgr::getInstance()->clearGroupData(group_id);
- // close the floater for this group, if any.
- LLGroupActions::closeGroup(group_id);
- }
-}
-
-// static
-void LLGroupMgr::processCreateGroupReply(LLMessageSystem* msg, void ** data)
-{
- LLUUID group_id;
- bool success;
- std::string message;
-
- msg->getUUIDFast(_PREHASH_ReplyData, _PREHASH_GroupID, group_id );
-
- msg->getBOOLFast(_PREHASH_ReplyData, _PREHASH_Success, success );
- msg->getStringFast(_PREHASH_ReplyData, _PREHASH_Message, message );
-
- if (success)
- {
- // refresh all group information
- gAgent.sendAgentDataUpdateRequest();
-
- // HACK! We haven't gotten the agent group update yet, so ... um ... fake it.
- // This is so when we go to modify the group we will be able to do so.
- // This isn't actually too bad because real data will come down in 2 or 3 miliseconds and replace this.
- LLGroupData gd;
- gd.mAcceptNotices = true;
- gd.mListInProfile = true;
- gd.mContribution = 0;
- gd.mID = group_id;
- gd.mName = "new group";
- gd.mPowers = GP_ALL_POWERS;
-
- gAgent.mGroups.push_back(gd);
-
- LLPanelGroupCreate::refreshCreatedGroup(group_id);
- //FIXME
- //LLFloaterGroupInfo::closeCreateGroup();
- //LLFloaterGroupInfo::showFromUUID(group_id,"roles_tab");
- }
- else
- {
- // *TODO: Translate
- LLSD args;
- args["MESSAGE"] = message;
- LLNotificationsUtil::add("UnableToCreateGroup", args);
- }
-}
-
-LLGroupMgrGroupData* LLGroupMgr::createGroupData(const LLUUID& id)
-{
- LLGroupMgrGroupData* group_datap = NULL;
-
- group_map_t::iterator existing_group = LLGroupMgr::getInstance()->mGroups.find(id);
- if (existing_group == LLGroupMgr::getInstance()->mGroups.end())
- {
- group_datap = new LLGroupMgrGroupData(id);
- LLGroupMgr::getInstance()->addGroup(group_datap);
- }
- else
- {
- group_datap = existing_group->second;
- }
-
- if (group_datap)
- {
- group_datap->setAccessed();
- }
-
- return group_datap;
-}
-
-bool LLGroupMgr::hasPendingPropertyRequest(const LLUUID & id)
-{
- properties_request_map_t::iterator existing_req = LLGroupMgr::getInstance()->mPropRequests.find(id);
- if (existing_req != LLGroupMgr::getInstance()->mPropRequests.end())
- {
- if (gFrameTime - existing_req->second < MIN_GROUP_PROPERTY_REQUEST_FREQ)
- {
- return true;
- }
- else
- {
- LLGroupMgr::getInstance()->mPropRequests.erase(existing_req);
- }
- }
- return false;
-}
-
-void LLGroupMgr::addPendingPropertyRequest(const LLUUID& id)
-{
- LLGroupMgr::getInstance()->mPropRequests[id] = gFrameTime;
-}
-
-void LLGroupMgr::notifyObservers(LLGroupChange gc)
-{
- for (group_map_t::iterator gi = mGroups.begin(); gi != mGroups.end(); ++gi)
- {
- LLUUID group_id = gi->first;
- if (gi->second->mChanged)
- {
- // notify LLGroupMgrObserver
- // Copy the map because observers may remove themselves on update
- observer_multimap_t observers = mObservers;
-
- // find all observers for this group id
- observer_multimap_t::iterator oi = observers.lower_bound(group_id);
- observer_multimap_t::iterator end = observers.upper_bound(group_id);
- for (; oi != end; ++oi)
- {
- oi->second->changed(gc);
- }
- gi->second->mChanged = false;
-
-
- // notify LLParticularGroupObserver
- observer_map_t::iterator obs_it = mParticularObservers.find(group_id);
- if(obs_it == mParticularObservers.end())
- return;
-
- observer_set_t& obs = obs_it->second;
- for (observer_set_t::iterator ob_it = obs.begin(); ob_it != obs.end(); ++ob_it)
- {
- (*ob_it)->changed(group_id, gc);
- }
- }
- }
-}
-
-void LLGroupMgr::addGroup(LLGroupMgrGroupData* group_datap)
-{
- while (mGroups.size() >= MAX_CACHED_GROUPS)
- {
- // LRU: Remove the oldest un-observed group from cache until group size is small enough
-
- F32 oldest_access = LLFrameTimer::getTotalSeconds();
- group_map_t::iterator oldest_gi = mGroups.end();
-
- for (group_map_t::iterator gi = mGroups.begin(); gi != mGroups.end(); ++gi )
- {
- observer_multimap_t::iterator oi = mObservers.find(gi->first);
- if (oi == mObservers.end())
- {
- if (gi->second
- && (gi->second->getAccessTime() < oldest_access))
- {
- oldest_access = gi->second->getAccessTime();
- oldest_gi = gi;
- }
- }
- }
-
- if (oldest_gi != mGroups.end())
- {
- delete oldest_gi->second;
- mGroups.erase(oldest_gi);
- }
- else
- {
- // All groups must be currently open, none to remove.
- // Just add the new group anyway, but get out of this loop as it
- // will never drop below max_cached_groups.
- break;
- }
- }
-
- mGroups[group_datap->getID()] = group_datap;
-}
-
-
-void LLGroupMgr::sendGroupPropertiesRequest(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupPropertiesRequest" << LL_ENDL;
- // This will happen when we get the reply
- //LLGroupMgrGroupData* group_datap = createGroupData(group_id);
-
- if (LLGroupMgr::getInstance()->hasPendingPropertyRequest(group_id))
- {
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupPropertiesRequest suppressed repeat for " << group_id << LL_ENDL;
- return;
- }
- LLGroupMgr::getInstance()->addPendingPropertyRequest(group_id);
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupProfileRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- gAgent.sendReliableMessage();
-}
-
-void LLGroupMgr::sendGroupMembersRequest(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupMembersRequest" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
- if (group_datap->mMemberRequestID.isNull())
- {
- group_datap->removeMemberData();
- group_datap->mMemberRequestID.generate();
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupMembersRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- msg->addUUID("RequestID",group_datap->mMemberRequestID);
- gAgent.sendReliableMessage();
- }
-}
-
-
-void LLGroupMgr::sendGroupRoleDataRequest(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleDataRequest" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
- if (group_datap->mRoleDataRequestID.isNull())
- {
- group_datap->removeRoleData();
- group_datap->mRoleDataRequestID.generate();
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupRoleDataRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- msg->addUUID("RequestID",group_datap->mRoleDataRequestID);
- gAgent.sendReliableMessage();
- }
-}
-
-void LLGroupMgr::sendGroupRoleMembersRequest(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleMembersRequest" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
-
- if (group_datap->mRoleMembersRequestID.isNull())
- {
- // Don't send the request if we don't have all the member or role data
- if (!group_datap->isMemberDataComplete()
- || !group_datap->isRoleDataComplete())
- {
- // *TODO: KLW FIXME: Should we start a member or role data request?
- LL_INFOS("GrpMgr") << " Pending: " << (group_datap->mPendingRoleMemberRequest ? "Y" : "N")
- << " MemberDataComplete: " << (group_datap->mMemberDataComplete ? "Y" : "N")
- << " RoleDataComplete: " << (group_datap->mRoleDataComplete ? "Y" : "N") << LL_ENDL;
- group_datap->mPendingRoleMemberRequest = true;
- return;
- }
-
- group_datap->removeRoleMemberData();
- group_datap->mRoleMembersRequestID.generate();
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupRoleMembersRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- msg->addUUID("RequestID",group_datap->mRoleMembersRequestID);
- gAgent.sendReliableMessage();
- }
-}
-
-void LLGroupMgr::sendGroupTitlesRequest(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupTitlesRequest" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
-
- group_datap->mTitles.clear();
- group_datap->mTitlesRequestID.generate();
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupTitlesRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->addUUID("GroupID",group_id);
- msg->addUUID("RequestID",group_datap->mTitlesRequestID);
-
- gAgent.sendReliableMessage();
-}
-
-void LLGroupMgr::sendGroupTitleUpdate(const LLUUID& group_id, const LLUUID& title_role_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupTitleUpdate" << LL_ENDL;
-
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("GroupTitleUpdate");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->addUUID("GroupID",group_id);
- msg->addUUID("TitleRoleID",title_role_id);
-
- gAgent.sendReliableMessage();
-
- // Save the change locally
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
- for (std::vector<LLGroupTitle>::iterator iter = group_datap->mTitles.begin();
- iter != group_datap->mTitles.end(); ++iter)
- {
- if (iter->mRoleID == title_role_id)
- {
- iter->mSelected = true;
- }
- else if (iter->mSelected)
- {
- iter->mSelected = false;
- }
- }
-}
-
-// static
-void LLGroupMgr::sendCreateGroupRequest(const std::string& name,
- const std::string& charter,
- U8 show_in_list,
- const LLUUID& insignia,
- S32 membership_fee,
- bool open_enrollment,
- bool allow_publish,
- bool mature_publish)
-{
- LLMessageSystem* msg = gMessageSystem;
- msg->newMessage("CreateGroupRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
-
- msg->nextBlock("GroupData");
- msg->addString("Name",name);
- msg->addString("Charter",charter);
- msg->addBOOL("ShowInList",show_in_list);
- msg->addUUID("InsigniaID",insignia);
- msg->addS32("MembershipFee",membership_fee);
- msg->addBOOL("OpenEnrollment",open_enrollment);
- msg->addBOOL("AllowPublish",allow_publish);
- msg->addBOOL("MaturePublish",mature_publish);
-
- gAgent.sendReliableMessage();
-}
-
-void LLGroupMgr::sendUpdateGroupInfo(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendUpdateGroupInfo" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
-
- LLMessageSystem* msg = gMessageSystem;
-
- msg->newMessageFast(_PREHASH_UpdateGroupInfo);
- msg->nextBlockFast(_PREHASH_AgentData);
- msg->addUUIDFast(_PREHASH_AgentID,gAgent.getID());
- msg->addUUIDFast(_PREHASH_SessionID,gAgent.getSessionID());
-
- msg->nextBlockFast(_PREHASH_GroupData);
- msg->addUUIDFast(_PREHASH_GroupID,group_datap->getID());
- msg->addStringFast(_PREHASH_Charter,group_datap->mCharter);
- msg->addBOOLFast(_PREHASH_ShowInList,group_datap->mShowInList);
- msg->addUUIDFast(_PREHASH_InsigniaID,group_datap->mInsigniaID);
- msg->addS32Fast(_PREHASH_MembershipFee,group_datap->mMembershipFee);
- msg->addBOOLFast(_PREHASH_OpenEnrollment,group_datap->mOpenEnrollment);
- msg->addBOOLFast(_PREHASH_AllowPublish,group_datap->mAllowPublish);
- msg->addBOOLFast(_PREHASH_MaturePublish,group_datap->mMaturePublish);
-
- gAgent.sendReliableMessage();
-
- // Not expecting a response, so let anyone else watching know the data has changed.
- group_datap->mChanged = true;
- notifyObservers(GC_PROPERTIES);
-}
-
-void LLGroupMgr::sendGroupRoleMemberChanges(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleMemberChanges" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = createGroupData(group_id);
-
- if (group_datap->mRoleMemberChanges.empty()) return;
-
- LLMessageSystem* msg = gMessageSystem;
-
- bool start_message = true;
- for (LLGroupMgrGroupData::change_map_t::const_iterator citer = group_datap->mRoleMemberChanges.begin();
- citer != group_datap->mRoleMemberChanges.end(); ++citer)
- {
- if (start_message)
- {
- msg->newMessage("GroupRoleChanges");
- msg->nextBlockFast(_PREHASH_AgentData);
- msg->addUUIDFast(_PREHASH_AgentID,gAgent.getID());
- msg->addUUIDFast(_PREHASH_SessionID,gAgent.getSessionID());
- msg->addUUIDFast(_PREHASH_GroupID,group_id);
- start_message = false;
- }
- msg->nextBlock("RoleChange");
- msg->addUUID("RoleID",citer->second.mRole);
- msg->addUUID("MemberID",citer->second.mMember);
- msg->addU32("Change",(U32)citer->second.mChange);
-
- if (msg->isSendFullFast())
- {
- gAgent.sendReliableMessage();
- start_message = true;
- }
- }
-
- if (!start_message)
- {
- gAgent.sendReliableMessage();
- }
-
- group_datap->mRoleMemberChanges.clear();
-
- // Not expecting a response, so let anyone else watching know the data has changed.
- group_datap->mChanged = true;
- notifyObservers(GC_ROLE_MEMBER_DATA);
-}
-
-//static
-void LLGroupMgr::sendGroupMemberJoin(const LLUUID& group_id)
-{
-
- LLUIUsage::instance().logCommand("Group.Join");
-
- LLMessageSystem *msg = gMessageSystem;
-
- msg->newMessageFast(_PREHASH_JoinGroupRequest);
- msg->nextBlockFast(_PREHASH_AgentData);
- msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID() );
- msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID());
- msg->nextBlockFast(_PREHASH_GroupData);
- msg->addUUIDFast(_PREHASH_GroupID, group_id);
-
- gAgent.sendReliableMessage();
-}
-
-// member_role_pairs is <member_id,role_id>
-// static
-void LLGroupMgr::sendGroupMemberInvites(const LLUUID& group_id, std::map<LLUUID,LLUUID>& member_role_pairs)
-{
- bool start_message = true;
- LLMessageSystem* msg = gMessageSystem;
-
- for (std::map<LLUUID,LLUUID>::iterator it = member_role_pairs.begin();
- it != member_role_pairs.end(); ++it)
- {
- if (start_message)
- {
- msg->newMessage("InviteGroupRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- start_message = false;
- }
-
- msg->nextBlock("InviteData");
- msg->addUUID("InviteeID",(*it).first);
- msg->addUUID("RoleID",(*it).second);
-
- if (msg->isSendFull())
- {
- gAgent.sendReliableMessage();
- start_message = true;
- }
- }
-
- if (!start_message)
- {
- gAgent.sendReliableMessage();
- }
-}
-
-//static
-void LLGroupMgr::sendGroupMemberEjects(const LLUUID& group_id,
- uuid_vec_t& member_ids)
-{
- bool start_message = true;
- LLMessageSystem* msg = gMessageSystem;
-
- LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!group_datap) return;
-
- for (uuid_vec_t::iterator it = member_ids.begin();
- it != member_ids.end(); ++it)
- {
- LLUUID& ejected_member_id = (*it);
-
- // Can't use 'eject' to leave a group.
- if (ejected_member_id == gAgent.getID()) continue;
-
- // Make sure they are in the group, and we need the member data
- LLGroupMgrGroupData::member_list_t::iterator mit = group_datap->mMembers.find(ejected_member_id);
- if (mit != group_datap->mMembers.end())
- {
- // Add them to the message
- if (start_message)
- {
- msg->newMessage("EjectGroupMemberRequest");
- msg->nextBlock("AgentData");
- msg->addUUID("AgentID",gAgent.getID());
- msg->addUUID("SessionID",gAgent.getSessionID());
- msg->nextBlock("GroupData");
- msg->addUUID("GroupID",group_id);
- start_message = false;
- }
-
- msg->nextBlock("EjectData");
- msg->addUUID("EjecteeID",ejected_member_id);
-
- if (msg->isSendFull())
- {
- gAgent.sendReliableMessage();
- start_message = true;
- }
-
- LLGroupMemberData* member_data = (*mit).second;
-
- // Clean up groupmgr
- for (LLGroupMemberData::role_list_t::iterator rit = member_data->roleBegin();
- rit != member_data->roleEnd(); ++rit)
- {
- if ((*rit).first.notNull() && (*rit).second!=0)
- {
- (*rit).second->removeMember(ejected_member_id);
- }
- }
-
- group_datap->mMembers.erase(ejected_member_id);
-
- // member_data was introduced and is used here instead of (*mit).second to avoid crash because of invalid iterator
- // It becomes invalid after line with erase above. EXT-4778
- delete member_data;
- }
- }
-
- if (!start_message)
- {
- gAgent.sendReliableMessage();
- }
-
- group_datap->mMemberVersion.generate();
-}
-
-void LLGroupMgr::getGroupBanRequestCoro(std::string url, LLUUID groupId)
-{
- LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
- LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
- httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
- LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
-
- std::string finalUrl = url + "?group_id=" + groupId.asString();
-
- LLSD result = httpAdapter->getAndSuspend(httpRequest, finalUrl);
-
- LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
- LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
-
- if (!status)
- {
- LL_WARNS("GrpMgr") << "Error receiving group member data " << LL_ENDL;
- return;
- }
-
- if (result.has("ban_list"))
- {
- result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
- // group ban data received
- processGroupBanRequest(result);
- }
-}
-
-void LLGroupMgr::postGroupBanRequestCoro(std::string url, LLUUID groupId,
- U32 action, uuid_vec_t banList, bool update)
-{
- LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
- LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
- httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
- LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
- LLCore::HttpHeaders::ptr_t httpHeaders(new LLCore::HttpHeaders);
- LLCore::HttpOptions::ptr_t httpOptions(new LLCore::HttpOptions);
-
- httpOptions->setFollowRedirects(false);
-
- httpHeaders->append(HTTP_OUT_HEADER_CONTENT_TYPE, HTTP_CONTENT_LLSD_XML);
-
-
- std::string finalUrl = url + "?group_id=" + groupId.asString();
-
- LLSD postData = LLSD::emptyMap();
- postData["ban_action"] = (LLSD::Integer)action;
- // Add our list of potential banned residents to the list
- postData["ban_ids"] = LLSD::emptyArray();
- LLSD banEntry;
-
- uuid_vec_t::const_iterator it = banList.begin();
- for (; it != banList.end(); ++it)
- {
- banEntry = (*it);
- postData["ban_ids"].append(banEntry);
- }
-
- LL_WARNS() << "post: " << ll_pretty_print_sd(postData) << LL_ENDL;
-
- LLSD result = httpAdapter->postAndSuspend(httpRequest, finalUrl, postData, httpOptions, httpHeaders);
-
- LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
- LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
-
- if (!status)
- {
- LL_WARNS("GrpMgr") << "Error posting group member data " << LL_ENDL;
- return;
- }
-
- if (result.has("ban_list"))
- {
- result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
- // group ban data received
- processGroupBanRequest(result);
- }
-
- if (update)
- {
- getGroupBanRequestCoro(url, groupId);
- }
-}
-
-void LLGroupMgr::sendGroupBanRequest( EBanRequestType request_type,
- const LLUUID& group_id,
- U32 ban_action, /* = BAN_NO_ACTION */
- const std::vector<LLUUID> &ban_list) /* = std::vector<LLUUID>() */
-{
- LLViewerRegion* currentRegion = gAgent.getRegion();
- if(!currentRegion)
- {
- LL_WARNS("GrpMgr") << "Agent does not have a current region. Uh-oh!" << LL_ENDL;
- return;
- }
-
- // Check to make sure we have our capabilities
- if(!currentRegion->capabilitiesReceived())
- {
- LL_WARNS("GrpMgr") << " Capabilities not received!" << LL_ENDL;
- return;
- }
-
- // Get our capability
- std::string cap_url = currentRegion->getCapability("GroupAPIv1");
- if(cap_url.empty())
- {
- return;
- }
-
- U32 action = ban_action & ~BAN_UPDATE;
- bool update = ((ban_action & BAN_UPDATE) == BAN_UPDATE);
-
- switch (request_type)
- {
- case REQUEST_GET:
- LLCoros::instance().launch("LLGroupMgr::getGroupBanRequestCoro",
- boost::bind(&LLGroupMgr::getGroupBanRequestCoro, this, cap_url, group_id));
- break;
- case REQUEST_POST:
- LLCoros::instance().launch("LLGroupMgr::postGroupBanRequestCoro",
- boost::bind(&LLGroupMgr::postGroupBanRequestCoro, this, cap_url, group_id,
- action, ban_list, update));
- break;
- case REQUEST_PUT:
- case REQUEST_DEL:
- break;
- }
-}
-
-void LLGroupMgr::processGroupBanRequest(const LLSD& content)
-{
- // Did we get anything in content?
- if(!content.size())
- {
- LL_WARNS("GrpMgr") << "No group member data received." << LL_ENDL;
- return;
- }
-
- LLUUID group_id = content["group_id"].asUUID();
-
- LLGroupMgrGroupData* gdatap = LLGroupMgr::getInstance()->getGroupData(group_id);
- if (!gdatap)
- return;
-
- gdatap->clearBanList();
- LLSD::map_const_iterator i = content["ban_list"].beginMap();
- LLSD::map_const_iterator iEnd = content["ban_list"].endMap();
- for(;i != iEnd; ++i)
- {
- const LLUUID ban_id(i->first);
- LLSD ban_entry(i->second);
-
- LLGroupBanData ban_data;
- if(ban_entry.has("ban_date"))
- {
- ban_data.mBanDate = ban_entry["ban_date"].asDate();
- // TODO: Ban Reason
- }
-
- gdatap->createBanEntry(ban_id, ban_data);
- }
-
- gdatap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_BANLIST);
-}
-
-void LLGroupMgr::groupMembersRequestCoro(std::string url, LLUUID groupId)
-{
- LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
- LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
- httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
- LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
- LLCore::HttpOptions::ptr_t httpOpts = LLCore::HttpOptions::ptr_t(new LLCore::HttpOptions);
-
- mMemberRequestInFlight = true;
-
- LLSD postData = LLSD::emptyMap();
- postData["group_id"] = groupId;
-
- LLSD result = httpAdapter->postAndSuspend(httpRequest, url, postData, httpOpts);
-
- LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
- LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
-
- if (!status)
- {
- LL_WARNS("GrpMgr") << "Error receiving group member data " << LL_ENDL;
- mMemberRequestInFlight = false;
- return;
- }
-
- result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
- LLGroupMgr::processCapGroupMembersRequest(result);
- mMemberRequestInFlight = false;
-}
-
-void LLGroupMgr::sendCapGroupMembersRequest(const LLUUID& group_id)
-{
- static U32 lastGroupMemberRequestFrame = 0;
-
- // Have we requested the information already this frame?
- // Todo: make this per group, we can invite to one group and simultaneously be checking another one
- if ((lastGroupMemberRequestFrame == gFrameCount) || (mMemberRequestInFlight))
- return;
-
- LLViewerRegion* currentRegion = gAgent.getRegion();
- // Thank you FS:Ansariel!
- if(!currentRegion)
- {
- LL_WARNS("GrpMgr") << "Agent does not have a current region. Uh-oh!" << LL_ENDL;
- return;
- }
-
- // Check to make sure we have our capabilities
- if(!currentRegion->capabilitiesReceived())
- {
- LL_WARNS("GrpMgr") << " Capabilities not received!" << LL_ENDL;
- return;
- }
-
- // Get our capability
- std::string cap_url = currentRegion->getCapability("GroupMemberData");
-
- // Thank you FS:Ansariel!
- if(cap_url.empty())
- {
- LL_INFOS("GrpMgr") << "Region has no GroupMemberData capability. Falling back to UDP fetch." << LL_ENDL;
- sendGroupMembersRequest(group_id);
- return;
- }
-
- LLGroupMgrGroupData* group_datap = createGroupData(group_id); //make sure group exists
- group_datap->mMemberRequestID.generate(); // mark as pending
-
- lastGroupMemberRequestFrame = gFrameCount;
-
- LLCoros::instance().launch("LLGroupMgr::groupMembersRequestCoro",
- boost::bind(&LLGroupMgr::groupMembersRequestCoro, this, cap_url, group_id));
-}
-
-
-void LLGroupMgr::processCapGroupMembersRequest(const LLSD& content)
-{
- // Did we get anything in content?
- if(!content.size())
- {
- LL_DEBUGS("GrpMgr") << "No group member data received." << LL_ENDL;
- return;
- }
-
- LLUUID group_id = content["group_id"].asUUID();
-
- LLGroupMgrGroupData* group_datap = getGroupData(group_id);
- if(!group_datap)
- {
- LL_WARNS("GrpMgr") << "Received incorrect, possibly stale, group or request id" << LL_ENDL;
- return;
- }
-
- // If we have no members, there's no reason to do anything else
- S32 num_members = content["member_count"];
- if (num_members < 1)
- {
- LL_INFOS("GrpMgr") << "Received empty group members list for group id: " << group_id.asString() << LL_ENDL;
- // Set mMemberDataComplete for correct handling of empty responses. See MAINT-5237
- group_datap->mMemberDataComplete = true;
- group_datap->mChanged = true;
- LLGroupMgr::getInstance()->notifyObservers(GC_MEMBER_DATA);
- return;
- }
-
- group_datap->mMemberCount = num_members;
-
- LLSD member_list = content["members"];
- LLSD titles = content["titles"];
- LLSD defaults = content["defaults"];
-
- std::string online_status;
- std::string title;
- S32 contribution;
- U64 member_powers;
- // If this is changed to a bool, make sure to change the LLGroupMemberData constructor
- bool is_owner;
-
- // Compute this once, rather than every time.
- U64 default_powers = llstrtou64(defaults["default_powers"].asString().c_str(), NULL, 16);
-
- LLSD::map_const_iterator member_iter_start = member_list.beginMap();
- LLSD::map_const_iterator member_iter_end = member_list.endMap();
- for( ; member_iter_start != member_iter_end; ++member_iter_start)
- {
- // Reset defaults
- online_status = "unknown";
- title = titles[0].asString();
- contribution = 0;
- member_powers = default_powers;
- is_owner = false;
-
- const LLUUID member_id(member_iter_start->first);
- LLSD member_info = member_iter_start->second;
-
- if(member_info.has("last_login"))
- {
- online_status = member_info["last_login"].asString();
- if(online_status == "Online")
- online_status = LLTrans::getString("group_member_status_online");
- else
- formatDateString(online_status);
- }
-
- if(member_info.has("title"))
- title = titles[member_info["title"].asInteger()].asString();
-
- if(member_info.has("powers"))
- member_powers = llstrtou64(member_info["powers"].asString().c_str(), NULL, 16);
-
- if(member_info.has("donated_square_meters"))
- contribution = member_info["donated_square_meters"];
-
- if(member_info.has("owner"))
- is_owner = true;
-
- LLGroupMemberData* data = new LLGroupMemberData(member_id,
- contribution,
- member_powers,
- title,
- online_status,
- is_owner);
-
- LLGroupMemberData* member_old = group_datap->mMembers[member_id];
- if (member_old && group_datap->mRoleMemberDataComplete)
- {
- LLGroupMemberData::role_list_t::iterator rit = member_old->roleBegin();
- LLGroupMemberData::role_list_t::iterator end = member_old->roleEnd();
-
- for ( ; rit != end; ++rit)
- {
- data->addRole((*rit).first,(*rit).second);
- }
- }
- else
- {
- group_datap->mRoleMemberDataComplete = false;
- }
-
- group_datap->mMembers[member_id] = data;
- }
-
- group_datap->mMemberVersion.generate();
-
- // Technically, we have this data, but to prevent completely overhauling
- // this entire system (it would be nice, but I don't have the time),
- // I'm going to be dumb and just call services I most likely don't need
- // with the thought being that the system might need it to be done.
- //
- // TODO:
- // Refactor to reduce multiple calls for data we already have.
- if(group_datap->mTitles.size() < 1)
- sendGroupTitlesRequest(group_id);
-
-
- group_datap->mMemberDataComplete = true;
- group_datap->mMemberRequestID.setNull();
- // Make the role-member data request
- if (group_datap->mPendingRoleMemberRequest || !group_datap->mRoleMemberDataComplete)
- {
- group_datap->mPendingRoleMemberRequest = false;
- sendGroupRoleMembersRequest(group_id);
- }
-
- group_datap->mChanged = true;
- notifyObservers(GC_MEMBER_DATA);
-
-}
-
-
-void LLGroupMgr::sendGroupRoleChanges(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleChanges" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = getGroupData(group_id);
-
- if (group_datap && group_datap->pendingRoleChanges())
- {
- group_datap->sendRoleChanges();
-
- // Not expecting a response, so let anyone else watching know the data has changed.
- group_datap->mChanged = true;
- notifyObservers(GC_ROLE_DATA);
- }
-}
-
-void LLGroupMgr::cancelGroupRoleChanges(const LLUUID& group_id)
-{
- LL_DEBUGS("GrpMgr") << "LLGroupMgr::cancelGroupRoleChanges" << LL_ENDL;
- LLGroupMgrGroupData* group_datap = getGroupData(group_id);
-
- if (group_datap) group_datap->cancelRoleChanges();
-}
-
-//static
-bool LLGroupMgr::parseRoleActions(const std::string& xml_filename)
-{
- LLXMLNodePtr root;
-
- bool success = LLUICtrlFactory::getLayeredXMLNode(xml_filename, root);
-
- if (!success || !root || !root->hasName( "role_actions" ))
- {
- LL_ERRS() << "Problem reading UI role_actions file: " << xml_filename << LL_ENDL;
- return false;
- }
-
- LLXMLNodeList role_list;
-
- root->getChildren("action_set", role_list, false);
-
- for (LLXMLNodeList::iterator role_iter = role_list.begin(); role_iter != role_list.end(); ++role_iter)
- {
- LLXMLNodePtr action_set = role_iter->second;
-
- LLRoleActionSet* role_action_set = new LLRoleActionSet();
- LLRoleAction* role_action_data = new LLRoleAction();
-
- // name=
- std::string action_set_name;
- if (action_set->getAttributeString("name", action_set_name))
- {
- LL_DEBUGS("GrpMgr") << "Loading action set " << action_set_name << LL_ENDL;
- role_action_data->mName = action_set_name;
- }
- else
- {
- LL_WARNS() << "Unable to parse action set with no name" << LL_ENDL;
- delete role_action_set;
- delete role_action_data;
- continue;
- }
- // description=
- std::string set_description;
- if (action_set->getAttributeString("description", set_description))
- {
- role_action_data->mDescription = set_description;
- }
- // long description=
- std::string set_longdescription;
- if (action_set->getAttributeString("longdescription", set_longdescription))
- {
- role_action_data->mLongDescription = set_longdescription;
- }
-
- // power mask=
- U64 set_power_mask = 0;
-
- LLXMLNodeList action_list;
- LLXMLNodeList::iterator action_iter;
-
- action_set->getChildren("action", action_list, false);
-
- for (action_iter = action_list.begin(); action_iter != action_list.end(); ++action_iter)
- {
- LLXMLNodePtr action = action_iter->second;
-
- LLRoleAction* role_action = new LLRoleAction();
-
- // name=
- std::string action_name;
- if (action->getAttributeString("name", action_name))
- {
- LL_DEBUGS("GrpMgr") << "Loading action " << action_name << LL_ENDL;
- role_action->mName = action_name;
- }
- else
- {
- LL_WARNS() << "Unable to parse action with no name" << LL_ENDL;
- delete role_action;
- continue;
- }
- // description=
- std::string description;
- if (action->getAttributeString("description", description))
- {
- role_action->mDescription = description;
- }
- // long description=
- std::string longdescription;
- if (action->getAttributeString("longdescription", longdescription))
- {
- role_action->mLongDescription = longdescription;
- }
- // description=
- S32 power_bit = 0;
- if (action->getAttributeS32("value", power_bit))
- {
- if (0 <= power_bit && power_bit < 64)
- {
- role_action->mPowerBit = 0x1LL << power_bit;
- }
- }
-
- set_power_mask |= role_action->mPowerBit;
-
- role_action_set->mActions.push_back(role_action);
- }
-
- role_action_data->mPowerBit = set_power_mask;
- role_action_set->mActionSetData = role_action_data;
-
- LLGroupMgr::getInstance()->mRoleActionSets.push_back(role_action_set);
- }
- return true;
-}
-
-// static
-void LLGroupMgr::debugClearAllGroups(void*)
-{
- LLGroupMgr::getInstance()->clearGroups();
- LLGroupMgr::parseRoleActions("role_actions.xml");
-}
-
-
+/**
+ * @file llgroupmgr.cpp
+ * @brief LLGroupMgr class implementation
+ *
+ * $LicenseInfo:firstyear=2004&license=viewerlgpl$
+ * Second Life Viewer Source Code
+ * Copyright (C) 2010, Linden Research, Inc.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation;
+ * version 2.1 of the License only.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ * Linden Research, Inc., 945 Battery Street, San Francisco, CA 94111 USA
+ * $/LicenseInfo$
+ */
+
+/**
+ * Manager for aggregating all client knowledge for specific groups
+ * Keeps a cache of group information.
+ */
+
+#include "llviewerprecompiledheaders.h"
+
+#include "llgroupmgr.h"
+
+#include <vector>
+#include <algorithm>
+
+#include "llappviewer.h"
+#include "llagent.h"
+#include "llavatarnamecache.h"
+#include "llui.h"
+#include "message.h"
+#include "roles_constants.h"
+#include "lltransactiontypes.h"
+#include "llstatusbar.h"
+#include "llviewerwindow.h"
+#include "llpanelgroupcreate.h"
+#include "llgroupactions.h"
+#include "llnotificationsutil.h"
+#include "lluictrlfactory.h"
+#include "lltrans.h"
+#include "llviewerregion.h"
+#include <boost/regex.hpp>
+#include "llcorehttputil.h"
+#include "lluiusage.h"
+
+
+#if LL_MSVC
+#pragma warning(push)
+// disable boost::lexical_cast warning
+#pragma warning (disable:4702)
+#endif
+
+#include <boost/lexical_cast.hpp>
+
+#if LL_MSVC
+#pragma warning(pop) // Restore all warnings to the previous state
+#endif
+
+const U32 MAX_CACHED_GROUPS = 20;
+
+//
+// LLRoleActionSet
+//
+LLRoleActionSet::LLRoleActionSet()
+: mActionSetData(NULL)
+{ }
+
+LLRoleActionSet::~LLRoleActionSet()
+{
+ delete mActionSetData;
+ std::for_each(mActions.begin(), mActions.end(), DeletePointer());
+ mActions.clear();
+}
+
+//
+// LLGroupMemberData
+//
+
+LLGroupMemberData::LLGroupMemberData(const LLUUID& id,
+ S32 contribution,
+ U64 agent_powers,
+ const std::string& title,
+ const std::string& online_status,
+ bool is_owner) :
+ mID(id),
+ mContribution(contribution),
+ mAgentPowers(agent_powers),
+ mTitle(title),
+ mOnlineStatus(online_status),
+ mIsOwner(is_owner)
+{
+}
+
+LLGroupMemberData::~LLGroupMemberData()
+{
+}
+
+void LLGroupMemberData::addRole(const LLUUID& role, LLGroupRoleData* rd)
+{
+ mRolesList[role] = rd;
+}
+
+bool LLGroupMemberData::removeRole(const LLUUID& role)
+{
+ role_list_t::iterator it = mRolesList.find(role);
+
+ if (it != mRolesList.end())
+ {
+ mRolesList.erase(it);
+ return true;
+ }
+
+ return false;
+}
+
+//
+// LLGroupRoleData
+//
+
+LLGroupRoleData::LLGroupRoleData(const LLUUID& role_id,
+ const std::string& role_name,
+ const std::string& role_title,
+ const std::string& role_desc,
+ const U64 role_powers,
+ const S32 member_count) :
+ mRoleID(role_id),
+ mMemberCount(member_count),
+ mMembersNeedsSort(false)
+{
+ mRoleData.mRoleName = role_name;
+ mRoleData.mRoleTitle = role_title;
+ mRoleData.mRoleDescription = role_desc;
+ mRoleData.mRolePowers = role_powers;
+ mRoleData.mChangeType = RC_UPDATE_NONE;
+}
+
+LLGroupRoleData::LLGroupRoleData(const LLUUID& role_id,
+ LLRoleData role_data,
+ const S32 member_count) :
+ mRoleID(role_id),
+ mRoleData(role_data),
+ mMemberCount(member_count),
+ mMembersNeedsSort(false)
+{
+
+}
+
+LLGroupRoleData::~LLGroupRoleData()
+{
+}
+
+S32 LLGroupRoleData::getMembersInRole(uuid_vec_t members,
+ bool needs_sort)
+{
+ if (mRoleID.isNull())
+ {
+ // This is the everyone role, just return the size of members,
+ // because everyone is in the everyone role.
+ return members.size();
+ }
+
+ // Sort the members list, if needed.
+ if (mMembersNeedsSort)
+ {
+ std::sort(mMemberIDs.begin(), mMemberIDs.end());
+ mMembersNeedsSort = false;
+ }
+ if (needs_sort)
+ {
+ // Sort the members parameter.
+ std::sort(members.begin(), members.end());
+ }
+
+ // Return the number of members in the intersection.
+ S32 max_size = llmin( members.size(), mMemberIDs.size() );
+ uuid_vec_t in_role( max_size );
+ uuid_vec_t::iterator in_role_end;
+ in_role_end = std::set_intersection(mMemberIDs.begin(), mMemberIDs.end(),
+ members.begin(), members.end(),
+ in_role.begin());
+ return in_role_end - in_role.begin();
+}
+
+void LLGroupRoleData::addMember(const LLUUID& member)
+{
+ mMembersNeedsSort = true;
+ mMemberIDs.push_back(member);
+}
+
+bool LLGroupRoleData::removeMember(const LLUUID& member)
+{
+ uuid_vec_t::iterator it = std::find(mMemberIDs.begin(),mMemberIDs.end(),member);
+
+ if (it != mMemberIDs.end())
+ {
+ mMembersNeedsSort = true;
+ mMemberIDs.erase(it);
+ return true;
+ }
+
+ return false;
+}
+
+void LLGroupRoleData::clearMembers()
+{
+ mMembersNeedsSort = false;
+ mMemberIDs.clear();
+}
+
+
+//
+// LLGroupMgrGroupData
+//
+
+LLGroupMgrGroupData::LLGroupMgrGroupData(const LLUUID& id) :
+ mID(id),
+ mShowInList(true),
+ mOpenEnrollment(false),
+ mMembershipFee(0),
+ mAllowPublish(false),
+ mListInProfile(false),
+ mMaturePublish(false),
+ mChanged(false),
+ mMemberCount(0),
+ mRoleCount(0),
+ mReceivedRoleMemberPairs(0),
+ mMemberDataComplete(false),
+ mRoleDataComplete(false),
+ mRoleMemberDataComplete(false),
+ mGroupPropertiesDataComplete(false),
+ mPendingRoleMemberRequest(false),
+ mAccessTime(0.0f),
+ mPendingBanRequest(false)
+{
+ mMemberVersion.generate();
+}
+
+void LLGroupMgrGroupData::setAccessed()
+{
+ mAccessTime = (F32)LLFrameTimer::getTotalSeconds();
+}
+
+bool LLGroupMgrGroupData::getRoleData(const LLUUID& role_id, LLRoleData& role_data)
+{
+ role_data_map_t::const_iterator it;
+
+ // Do we have changes for it?
+ it = mRoleChanges.find(role_id);
+ if (it != mRoleChanges.end())
+ {
+ if ((*it).second.mChangeType == RC_DELETE) return false;
+
+ role_data = (*it).second;
+ return true;
+ }
+
+ // Ok, no changes, hasn't been deleted, isn't a new role, just find the role.
+ role_list_t::const_iterator rit = mRoles.find(role_id);
+ if (rit != mRoles.end())
+ {
+ role_data = (*rit).second->getRoleData();
+ return true;
+ }
+
+ // This role must not exist.
+ return false;
+}
+
+
+void LLGroupMgrGroupData::setRoleData(const LLUUID& role_id, LLRoleData role_data)
+{
+ // If this is a newly created group, we need to change the data in the created list.
+ role_data_map_t::iterator it;
+ it = mRoleChanges.find(role_id);
+ if (it != mRoleChanges.end())
+ {
+ if ((*it).second.mChangeType == RC_CREATE)
+ {
+ role_data.mChangeType = RC_CREATE;
+ mRoleChanges[role_id] = role_data;
+ return;
+ }
+ else if ((*it).second.mChangeType == RC_DELETE)
+ {
+ // Don't do anything for a role being deleted.
+ return;
+ }
+ }
+
+ // Not a new role, so put it in the changes list.
+ LLRoleData old_role_data;
+ role_list_t::iterator rit = mRoles.find(role_id);
+ if (rit != mRoles.end())
+ {
+ bool data_change = ( ((*rit).second->mRoleData.mRoleDescription != role_data.mRoleDescription)
+ || ((*rit).second->mRoleData.mRoleName != role_data.mRoleName)
+ || ((*rit).second->mRoleData.mRoleTitle != role_data.mRoleTitle) );
+ bool powers_change = ((*rit).second->mRoleData.mRolePowers != role_data.mRolePowers);
+
+ if (!data_change && !powers_change)
+ {
+ // We are back to the original state, the changes have been 'undone' so take out the change.
+ mRoleChanges.erase(role_id);
+ return;
+ }
+
+ if (data_change && powers_change)
+ {
+ role_data.mChangeType = RC_UPDATE_ALL;
+ }
+ else if (data_change)
+ {
+ role_data.mChangeType = RC_UPDATE_DATA;
+ }
+ else
+ {
+ role_data.mChangeType = RC_UPDATE_POWERS;
+ }
+
+ mRoleChanges[role_id] = role_data;
+ }
+ else
+ {
+ LL_WARNS() << "Change being made to non-existant role " << role_id << LL_ENDL;
+ }
+}
+
+bool LLGroupMgrGroupData::pendingRoleChanges()
+{
+ return (!mRoleChanges.empty());
+}
+
+// This is a no-op if the role has already been created.
+void LLGroupMgrGroupData::createRole(const LLUUID& role_id, LLRoleData role_data)
+{
+ if (mRoleChanges.find(role_id) != mRoleChanges.end())
+ {
+ LL_WARNS() << "create role for existing role! " << role_id << LL_ENDL;
+ }
+ else
+ {
+ role_data.mChangeType = RC_CREATE;
+ mRoleChanges[role_id] = role_data;
+ }
+}
+
+void LLGroupMgrGroupData::deleteRole(const LLUUID& role_id)
+{
+ role_data_map_t::iterator it;
+
+ // If this was a new role, just discard it.
+ it = mRoleChanges.find(role_id);
+ if (it != mRoleChanges.end()
+ && (*it).second.mChangeType == RC_CREATE)
+ {
+ mRoleChanges.erase(it);
+ return;
+ }
+
+ LLRoleData rd;
+ rd.mChangeType = RC_DELETE;
+ mRoleChanges[role_id] = rd;
+}
+
+void LLGroupMgrGroupData::addRolePower(const LLUUID &role_id, U64 power)
+{
+ LLRoleData rd;
+ if (getRoleData(role_id,rd))
+ {
+ rd.mRolePowers |= power;
+ setRoleData(role_id,rd);
+ }
+ else
+ {
+ LL_WARNS() << "addRolePower: no role data found for " << role_id << LL_ENDL;
+ }
+}
+
+void LLGroupMgrGroupData::removeRolePower(const LLUUID &role_id, U64 power)
+{
+ LLRoleData rd;
+ if (getRoleData(role_id,rd))
+ {
+ rd.mRolePowers &= ~power;
+ setRoleData(role_id,rd);
+ }
+ else
+ {
+ LL_WARNS() << "removeRolePower: no role data found for " << role_id << LL_ENDL;
+ }
+}
+
+U64 LLGroupMgrGroupData::getRolePowers(const LLUUID& role_id)
+{
+ LLRoleData rd;
+ if (getRoleData(role_id,rd))
+ {
+ return rd.mRolePowers;
+ }
+ else
+ {
+ LL_WARNS() << "getRolePowers: no role data found for " << role_id << LL_ENDL;
+ return GP_NO_POWERS;
+ }
+}
+
+void LLGroupMgrGroupData::removeData()
+{
+ // Remove member data first, because removeRoleData will walk the member list
+ removeMemberData();
+ removeRoleData();
+}
+
+void LLGroupMgrGroupData::removeMemberData()
+{
+ for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
+ {
+ delete mi->second;
+ }
+ mMembers.clear();
+ mMemberDataComplete = false;
+ mMemberVersion.generate();
+}
+
+void LLGroupMgrGroupData::removeRoleData()
+{
+ for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
+ {
+ LLGroupMemberData* data = mi->second;
+ if (data)
+ {
+ data->clearRoles();
+ }
+ }
+
+ for (role_list_t::iterator ri = mRoles.begin(); ri != mRoles.end(); ++ri)
+ {
+ LLGroupRoleData* data = ri->second;
+ delete data;
+ }
+ mRoles.clear();
+ mReceivedRoleMemberPairs = 0;
+ mRoleDataComplete = false;
+ mRoleMemberDataComplete= false;
+}
+
+void LLGroupMgrGroupData::removeRoleMemberData()
+{
+ for (member_list_t::iterator mi = mMembers.begin(); mi != mMembers.end(); ++mi)
+ {
+ LLGroupMemberData* data = mi->second;
+ if (data)
+ {
+ data->clearRoles();
+ }
+ }
+
+ for (role_list_t::iterator ri = mRoles.begin(); ri != mRoles.end(); ++ri)
+ {
+ LLGroupRoleData* data = ri->second;
+ if (data)
+ {
+ data->clearMembers();
+ }
+ }
+
+ mReceivedRoleMemberPairs = 0;
+ mRoleMemberDataComplete= false;
+}
+
+LLGroupMgrGroupData::~LLGroupMgrGroupData()
+{
+ removeData();
+}
+
+bool LLGroupMgrGroupData::changeRoleMember(const LLUUID& role_id,
+ const LLUUID& member_id,
+ LLRoleMemberChangeType rmc)
+{
+ role_list_t::iterator ri = mRoles.find(role_id);
+ member_list_t::iterator mi = mMembers.find(member_id);
+
+ if (ri == mRoles.end()
+ || mi == mMembers.end() )
+ {
+ if (ri == mRoles.end()) LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't find role " << role_id << LL_ENDL;
+ if (mi == mMembers.end()) LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't find member " << member_id << LL_ENDL;
+ return false;
+ }
+
+ LLGroupRoleData* grd = ri->second;
+ LLGroupMemberData* gmd = mi->second;
+
+ if (!grd || !gmd)
+ {
+ LL_WARNS() << "LLGroupMgrGroupData::changeRoleMember couldn't get member or role data." << LL_ENDL;
+ return false;
+ }
+
+ if (RMC_ADD == rmc)
+ {
+ LL_INFOS() << " adding member to role." << LL_ENDL;
+ grd->addMember(member_id);
+ gmd->addRole(role_id,grd);
+
+ //TODO move this into addrole function
+ //see if they added someone to the owner role and update isOwner
+ gmd->mIsOwner = (role_id == mOwnerRole) ? true : gmd->mIsOwner;
+ }
+ else if (RMC_REMOVE == rmc)
+ {
+ LL_INFOS() << " removing member from role." << LL_ENDL;
+ grd->removeMember(member_id);
+ gmd->removeRole(role_id);
+
+ //see if they removed someone from the owner role and update isOwner
+ gmd->mIsOwner = (role_id == mOwnerRole) ? false : gmd->mIsOwner;
+ }
+
+ lluuid_pair role_member;
+ role_member.first = role_id;
+ role_member.second = member_id;
+
+ change_map_t::iterator it = mRoleMemberChanges.find(role_member);
+ if (it != mRoleMemberChanges.end())
+ {
+ // There was already a role change for this role_member
+ if (it->second.mChange == rmc)
+ {
+ // Already recorded this change? Weird.
+ LL_INFOS() << "Received duplicate change for "
+ << " role: " << role_id << " member " << member_id
+ << " change " << (rmc == RMC_ADD ? "ADD" : "REMOVE") << LL_ENDL;
+ }
+ else
+ {
+ // The only two operations (add and remove) currently cancel each other out
+ // If that changes this will need more logic
+ if (rmc == RMC_NONE)
+ {
+ LL_WARNS() << "changeRoleMember: existing entry with 'RMC_NONE' change! This shouldn't happen." << LL_ENDL;
+ LLRoleMemberChange rc(role_id,member_id,rmc);
+ mRoleMemberChanges[role_member] = rc;
+ }
+ else
+ {
+ mRoleMemberChanges.erase(it);
+ }
+ }
+ }
+ else
+ {
+ LLRoleMemberChange rc(role_id,member_id,rmc);
+ mRoleMemberChanges[role_member] = rc;
+ }
+
+ recalcAgentPowers(member_id);
+
+ mChanged = true;
+ return true;
+}
+
+void LLGroupMgrGroupData::recalcAllAgentPowers()
+{
+ LLGroupMemberData* gmd;
+
+ for (member_list_t::iterator mit = mMembers.begin();
+ mit != mMembers.end(); ++mit)
+ {
+ gmd = mit->second;
+ if (!gmd) continue;
+
+ gmd->mAgentPowers = 0;
+ for (LLGroupMemberData::role_list_t::iterator it = gmd->mRolesList.begin();
+ it != gmd->mRolesList.end(); ++it)
+ {
+ LLGroupRoleData* grd = (*it).second;
+ if (!grd) continue;
+
+ gmd->mAgentPowers |= grd->mRoleData.mRolePowers;
+ }
+ }
+}
+
+void LLGroupMgrGroupData::recalcAgentPowers(const LLUUID& agent_id)
+{
+ member_list_t::iterator mi = mMembers.find(agent_id);
+ if (mi == mMembers.end()) return;
+
+ LLGroupMemberData* gmd = mi->second;
+
+ if (!gmd) return;
+
+ gmd->mAgentPowers = 0;
+ for (LLGroupMemberData::role_list_t::iterator it = gmd->mRolesList.begin();
+ it != gmd->mRolesList.end(); ++it)
+ {
+ LLGroupRoleData* grd = (*it).second;
+ if (!grd) continue;
+
+ gmd->mAgentPowers |= grd->mRoleData.mRolePowers;
+ }
+}
+
+bool LLGroupMgrGroupData::isSingleMemberNotOwner()
+{
+ return mMembers.size() == 1 && !mMembers.begin()->second->isOwner();
+}
+
+bool packRoleUpdateMessageBlock(LLMessageSystem* msg,
+ const LLUUID& group_id,
+ const LLUUID& role_id,
+ const LLRoleData& role_data,
+ bool start_message)
+{
+ if (start_message)
+ {
+ msg->newMessage("GroupRoleUpdate");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->addUUID("GroupID",group_id);
+ start_message = false;
+ }
+
+ msg->nextBlock("RoleData");
+ msg->addUUID("RoleID",role_id);
+ msg->addString("Name", role_data.mRoleName);
+ msg->addString("Description", role_data.mRoleDescription);
+ msg->addString("Title", role_data.mRoleTitle);
+ msg->addU64("Powers", role_data.mRolePowers);
+ msg->addU8("UpdateType", (U8)role_data.mChangeType);
+
+ if (msg->isSendFullFast())
+ {
+ gAgent.sendReliableMessage();
+ start_message = true;
+ }
+
+ return start_message;
+}
+
+void LLGroupMgrGroupData::sendRoleChanges()
+{
+ // Commit changes locally
+ LLGroupRoleData* grd;
+ role_list_t::iterator role_it;
+ LLMessageSystem* msg = gMessageSystem;
+ bool start_message = true;
+
+ bool need_role_cleanup = false;
+ bool need_role_data = false;
+ bool need_power_recalc = false;
+
+ // Apply all changes
+ for (role_data_map_t::iterator iter = mRoleChanges.begin();
+ iter != mRoleChanges.end(); )
+ {
+ role_data_map_t::iterator it = iter++; // safely incrament iter
+ const LLUUID& role_id = (*it).first;
+ const LLRoleData& role_data = (*it).second;
+
+ // Commit to local data set
+ role_it = mRoles.find((*it).first);
+ if ( (mRoles.end() == role_it
+ && RC_CREATE != role_data.mChangeType)
+ || (mRoles.end() != role_it
+ && RC_CREATE == role_data.mChangeType))
+ {
+ continue;
+ }
+
+ // NOTE: role_it is valid EXCEPT for the RC_CREATE case
+ switch (role_data.mChangeType)
+ {
+ case RC_CREATE:
+ {
+ // NOTE: role_it is NOT valid in this case
+ grd = new LLGroupRoleData(role_id, role_data, 0);
+ mRoles[role_id] = grd;
+ need_role_data = true;
+ break;
+ }
+ case RC_DELETE:
+ {
+ LLGroupRoleData* group_role_data = (*role_it).second;
+ delete group_role_data;
+ mRoles.erase(role_it);
+ need_role_cleanup = true;
+ need_power_recalc = true;
+ break;
+ }
+ case RC_UPDATE_ALL:
+ // fall through
+ case RC_UPDATE_POWERS:
+ need_power_recalc = true;
+ // fall through
+ case RC_UPDATE_DATA:
+ // fall through
+ default:
+ {
+ LLGroupRoleData* group_role_data = (*role_it).second;
+ group_role_data->setRoleData(role_data); // NOTE! might modify mRoleChanges!
+ break;
+ }
+ }
+
+ // Update dataserver
+ start_message = packRoleUpdateMessageBlock(msg,getID(),role_id,role_data,start_message);
+ }
+
+ if (!start_message)
+ {
+ gAgent.sendReliableMessage();
+ }
+
+ // If we delete a role then all the role-member pairs are invalid!
+ if (need_role_cleanup)
+ {
+ removeRoleMemberData();
+ }
+
+ // If we create a new role, then we need to re-fetch all the role data.
+ if (need_role_data)
+ {
+ LLGroupMgr::getInstance()->sendGroupRoleDataRequest(getID());
+ }
+
+ // Clean up change lists
+ mRoleChanges.clear();
+
+ // Recalculate all the agent powers because role powers have now changed.
+ if (need_power_recalc)
+ {
+ recalcAllAgentPowers();
+ }
+}
+
+void LLGroupMgrGroupData::cancelRoleChanges()
+{
+ // Clear out all changes!
+ mRoleChanges.clear();
+}
+
+void LLGroupMgrGroupData::createBanEntry(const LLUUID& ban_id, const LLGroupBanData& ban_data)
+{
+ mBanList[ban_id] = ban_data;
+}
+
+void LLGroupMgrGroupData::removeBanEntry(const LLUUID& ban_id)
+{
+ mBanList.erase(ban_id);
+}
+
+void LLGroupMgrGroupData::banMemberById(const LLUUID& participant_uuid)
+{
+ if (!mMemberDataComplete ||
+ !mRoleDataComplete ||
+ !(mRoleMemberDataComplete && mMembers.size()))
+ {
+ LL_WARNS() << "No Role-Member data yet, setting ban request to pending." << LL_ENDL;
+ mPendingBanRequest = true;
+ mPendingBanMemberID = participant_uuid;
+
+ if (!mMemberDataComplete || !mMembers.size())
+ {
+ LLGroupMgr::getInstance()->sendCapGroupMembersRequest(mID);
+ }
+
+ if (!mRoleDataComplete)
+ {
+ LLGroupMgr::getInstance()->sendGroupRoleDataRequest(mID);
+ }
+
+ return;
+ }
+
+ LLGroupMgrGroupData::member_list_t::iterator mi = mMembers.find((participant_uuid));
+ if (mi == mMembers.end())
+ {
+ if (!mPendingBanRequest)
+ {
+ mPendingBanRequest = true;
+ mPendingBanMemberID = participant_uuid;
+ LLGroupMgr::getInstance()->sendCapGroupMembersRequest(mID); // member isn't in members list, request reloading
+ }
+ else
+ {
+ mPendingBanRequest = false;
+ }
+
+ return;
+ }
+
+ mPendingBanRequest = false;
+
+ LLGroupMemberData* member_data = (*mi).second;
+ if (member_data && member_data->isInRole(mOwnerRole))
+ {
+ return; // can't ban group owner
+ }
+
+ std::vector<LLUUID> ids;
+ ids.push_back(participant_uuid);
+
+ LLGroupBanData ban_data;
+ createBanEntry(participant_uuid, ban_data);
+ LLGroupMgr::getInstance()->sendGroupBanRequest(LLGroupMgr::REQUEST_POST, mID, LLGroupMgr::BAN_CREATE, ids);
+ LLGroupMgr::getInstance()->sendGroupMemberEjects(mID, ids);
+ LLGroupMgr::getInstance()->sendGroupMembersRequest(mID);
+ LLSD args;
+ LLAvatarName av_name;
+ LLAvatarNameCache::get(participant_uuid, &av_name);
+ args["AVATAR_NAME"] = av_name.getUserName();
+ args["GROUP_NAME"] = mName;
+ LLNotifications::instance().add(LLNotification::Params("EjectAvatarFromGroup").substitutions(args));
+}
+
+//
+// LLGroupMgr
+//
+
+LLGroupMgr::LLGroupMgr():
+ mMemberRequestInFlight(false)
+{
+}
+
+LLGroupMgr::~LLGroupMgr()
+{
+ clearGroups();
+}
+
+void LLGroupMgr::clearGroups()
+{
+ std::for_each(mRoleActionSets.begin(), mRoleActionSets.end(), DeletePointer());
+ mRoleActionSets.clear();
+ std::for_each(mGroups.begin(), mGroups.end(), DeletePairedPointer());
+ mGroups.clear();
+ mObservers.clear();
+}
+
+void LLGroupMgr::clearGroupData(const LLUUID& group_id)
+{
+ group_map_t::iterator iter = mGroups.find(group_id);
+ if (iter != mGroups.end())
+ {
+ delete (*iter).second;
+ mGroups.erase(iter);
+ }
+}
+
+void LLGroupMgr::addObserver(LLGroupMgrObserver* observer)
+{
+ if( observer->getID() != LLUUID::null )
+ mObservers.insert(std::pair<LLUUID, LLGroupMgrObserver*>(observer->getID(), observer));
+}
+
+void LLGroupMgr::addObserver(const LLUUID& group_id, LLParticularGroupObserver* observer)
+{
+ if(group_id.notNull() && observer)
+ {
+ mParticularObservers[group_id].insert(observer);
+ }
+}
+
+void LLGroupMgr::removeObserver(LLGroupMgrObserver* observer)
+{
+ if (!observer)
+ {
+ return;
+ }
+ observer_multimap_t::iterator it;
+ it = mObservers.find(observer->getID());
+ while (it != mObservers.end())
+ {
+ if (it->second == observer)
+ {
+ mObservers.erase(it);
+ break;
+ }
+ else
+ {
+ ++it;
+ }
+ }
+}
+
+void LLGroupMgr::removeObserver(const LLUUID& group_id, LLParticularGroupObserver* observer)
+{
+ if(group_id.isNull() || !observer)
+ {
+ return;
+ }
+
+ observer_map_t::iterator obs_it = mParticularObservers.find(group_id);
+ if(obs_it == mParticularObservers.end())
+ return;
+
+ obs_it->second.erase(observer);
+
+ if (obs_it->second.size() == 0)
+ mParticularObservers.erase(obs_it);
+}
+
+LLGroupMgrGroupData* LLGroupMgr::getGroupData(const LLUUID& id)
+{
+ group_map_t::iterator gi = mGroups.find(id);
+
+ if (gi != mGroups.end())
+ {
+ return gi->second;
+ }
+ return NULL;
+}
+
+// Helper function for LLGroupMgr::processGroupMembersReply
+// This reformats date strings from MM/DD/YYYY to YYYY/MM/DD ( e.g. 1/27/2008 -> 2008/1/27 )
+// so that the sorter can sort by year before month before day.
+static void formatDateString(std::string &date_string)
+{
+ using namespace boost;
+ cmatch result;
+ const regex expression("([0-9]{1,2})/([0-9]{1,2})/([0-9]{4})");
+ if (regex_match(date_string.c_str(), result, expression))
+ {
+ // convert matches to integers so that we can pad them with zeroes on Linux
+ S32 year = boost::lexical_cast<S32>(result[3]);
+ S32 month = boost::lexical_cast<S32>(result[1]);
+ S32 day = boost::lexical_cast<S32>(result[2]);
+
+ // ISO 8601 date format
+ date_string = llformat("%04d/%02d/%02d", year, month, day);
+ }
+}
+
+// static
+void LLGroupMgr::processGroupMembersReply(LLMessageSystem* msg, void** data)
+{
+ LL_PROFILE_ZONE_SCOPED;
+
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupMembersReply" << LL_ENDL;
+ LLUUID agent_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
+ if (gAgent.getID() != agent_id)
+ {
+ LL_WARNS() << "Got group members reply for another agent!" << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
+
+ LLUUID request_id;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_RequestID, request_id);
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!group_datap || (group_datap->mMemberRequestID != request_id))
+ {
+ LL_WARNS() << "processGroupMembersReply: Received incorrect (stale?) group or request id" << LL_ENDL;
+ return;
+ }
+
+ msg->getS32(_PREHASH_GroupData, "MemberCount", group_datap->mMemberCount );
+
+ if (group_datap->mMemberCount > 0)
+ {
+ S32 contribution = 0;
+ std::string online_status;
+ std::string title;
+ U64 agent_powers = 0;
+ bool is_owner = false;
+
+ S32 num_members = msg->getNumberOfBlocksFast(_PREHASH_MemberData);
+ for (S32 i = 0; i < num_members; i++)
+ {
+ LLUUID member_id;
+
+ msg->getUUIDFast(_PREHASH_MemberData, _PREHASH_AgentID, member_id, i );
+ msg->getS32(_PREHASH_MemberData, _PREHASH_Contribution, contribution, i);
+ msg->getU64(_PREHASH_MemberData, "AgentPowers", agent_powers, i);
+ msg->getStringFast(_PREHASH_MemberData, _PREHASH_OnlineStatus, online_status, i);
+ msg->getString(_PREHASH_MemberData, "Title", title, i);
+ msg->getBOOL(_PREHASH_MemberData,"IsOwner",is_owner,i);
+
+ if (member_id.notNull())
+ {
+ if (online_status == "Online")
+ {
+ static std::string localized_online(LLTrans::getString("group_member_status_online"));
+ online_status = localized_online;
+ }
+ else
+ {
+ formatDateString(online_status); // reformat for sorting, e.g. 12/25/2008 -> 2008/12/25
+ }
+
+ //LL_INFOS() << "Member " << member_id << " has powers " << std::hex << agent_powers << std::dec << LL_ENDL;
+ LLGroupMemberData* newdata = new LLGroupMemberData(member_id,
+ contribution,
+ agent_powers,
+ title,
+ online_status,
+ is_owner);
+#if LL_DEBUG
+ LLGroupMgrGroupData::member_list_t::iterator mit = group_datap->mMembers.find(member_id);
+ if (mit != group_datap->mMembers.end())
+ {
+ LL_INFOS() << " *** Received duplicate member data for agent " << member_id << LL_ENDL;
+ }
+#endif
+ group_datap->mMembers[member_id] = newdata;
+ }
+ else
+ {
+ LL_INFOS() << "Received null group member data." << LL_ENDL;
+ }
+ }
+
+ //if group members are loaded while titles are missing, load the titles.
+ if(group_datap->mTitles.size() < 1)
+ {
+ LLGroupMgr::getInstance()->sendGroupTitlesRequest(group_id);
+ }
+ }
+
+ group_datap->mMemberVersion.generate();
+
+ if (group_datap->mMembers.size() == (U32)group_datap->mMemberCount)
+ {
+ group_datap->mMemberDataComplete = true;
+ group_datap->mMemberRequestID.setNull();
+ // We don't want to make role-member data requests until we have all the members
+ if (group_datap->mPendingRoleMemberRequest)
+ {
+ group_datap->mPendingRoleMemberRequest = false;
+ LLGroupMgr::getInstance()->sendGroupRoleMembersRequest(group_datap->mID);
+ }
+ }
+
+ group_datap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_MEMBER_DATA);
+}
+
+//static
+void LLGroupMgr::processGroupPropertiesReply(LLMessageSystem* msg, void** data)
+{
+ LL_PROFILE_ZONE_SCOPED;
+
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupPropertiesReply" << LL_ENDL;
+ if (!msg)
+ {
+ LL_ERRS() << "Can't access the messaging system" << LL_ENDL;
+ return;
+ }
+ LLUUID agent_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
+ if (gAgent.getID() != agent_id)
+ {
+ LL_WARNS() << "Got group properties reply for another agent!" << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id;
+ std::string name;
+ std::string charter;
+ bool show_in_list = false;
+ LLUUID founder_id;
+ U64 powers_mask = GP_NO_POWERS;
+ S32 money = 0;
+ std::string member_title;
+ LLUUID insignia_id;
+ LLUUID owner_role;
+ U32 membership_fee = 0;
+ bool open_enrollment = false;
+ S32 num_group_members = 0;
+ S32 num_group_roles = 0;
+ bool allow_publish = false;
+ bool mature = false;
+
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_FounderID, founder_id);
+ msg->getStringFast(_PREHASH_GroupData, _PREHASH_Name, name );
+ msg->getStringFast(_PREHASH_GroupData, _PREHASH_Charter, charter );
+ msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_ShowInList, show_in_list );
+ msg->getStringFast(_PREHASH_GroupData, _PREHASH_MemberTitle, member_title );
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_InsigniaID, insignia_id );
+ msg->getU64Fast(_PREHASH_GroupData, _PREHASH_PowersMask, powers_mask );
+ msg->getU32Fast(_PREHASH_GroupData, _PREHASH_MembershipFee, membership_fee );
+ msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_OpenEnrollment, open_enrollment );
+ msg->getS32Fast(_PREHASH_GroupData, _PREHASH_GroupMembershipCount, num_group_members);
+ msg->getS32(_PREHASH_GroupData, "GroupRolesCount", num_group_roles);
+ msg->getS32Fast(_PREHASH_GroupData, _PREHASH_Money, money);
+ msg->getBOOL("GroupData", "AllowPublish", allow_publish);
+ msg->getBOOL("GroupData", "MaturePublish", mature);
+ msg->getUUID(_PREHASH_GroupData, "OwnerRole", owner_role);
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->createGroupData(group_id);
+
+ group_datap->mName = name;
+ group_datap->mCharter = charter;
+ group_datap->mShowInList = show_in_list;
+ group_datap->mInsigniaID = insignia_id;
+ group_datap->mFounderID = founder_id;
+ group_datap->mMembershipFee = membership_fee;
+ group_datap->mOpenEnrollment = open_enrollment;
+ group_datap->mAllowPublish = allow_publish;
+ group_datap->mMaturePublish = mature;
+ group_datap->mOwnerRole = owner_role;
+ group_datap->mMemberCount = num_group_members;
+ group_datap->mRoleCount = num_group_roles + 1; // Add the everyone role.
+
+ group_datap->mGroupPropertiesDataComplete = true;
+ group_datap->mChanged = true;
+
+ properties_request_map_t::iterator request = LLGroupMgr::getInstance()->mPropRequests.find(group_id);
+ if (request != LLGroupMgr::getInstance()->mPropRequests.end())
+ {
+ LLGroupMgr::getInstance()->mPropRequests.erase(request);
+ }
+ else
+ {
+ LL_DEBUGS("GrpMgr") << "GroupPropertyResponse received with no pending request. Response was slow." << LL_ENDL;
+ }
+ LLGroupMgr::getInstance()->notifyObservers(GC_PROPERTIES);
+}
+
+// static
+void LLGroupMgr::processGroupRoleDataReply(LLMessageSystem* msg, void** data)
+{
+ LL_PROFILE_ZONE_SCOPED;
+
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupRoleDataReply" << LL_ENDL;
+ LLUUID agent_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
+ if (gAgent.getID() != agent_id)
+ {
+ LL_WARNS() << "Got group role data reply for another agent!" << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id );
+
+ LLUUID request_id;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_RequestID, request_id);
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!group_datap || (group_datap->mRoleDataRequestID != request_id))
+ {
+ LL_WARNS() << "processGroupPropertiesReply: Received incorrect (stale?) group or request id" << LL_ENDL;
+ return;
+ }
+
+ msg->getS32(_PREHASH_GroupData, "RoleCount", group_datap->mRoleCount );
+
+ std::string name;
+ std::string title;
+ std::string desc;
+ U64 powers = 0;
+ U32 member_count = 0;
+ LLUUID role_id;
+
+ U32 num_blocks = msg->getNumberOfBlocks("RoleData");
+ U32 i = 0;
+ for (i=0; i< num_blocks; ++i)
+ {
+ msg->getUUID("RoleData", "RoleID", role_id, i );
+
+ msg->getString("RoleData","Name",name,i);
+ msg->getString("RoleData","Title",title,i);
+ msg->getString("RoleData","Description",desc,i);
+ msg->getU64("RoleData","Powers",powers,i);
+ msg->getU32("RoleData","Members",member_count,i);
+
+ //there are 3 predifined roles - Owners, Officers, Everyone
+ //there names are defined in lldatagroups.cpp
+ //lets change names from server to localized strings
+ if(name == "Everyone")
+ {
+ name = LLTrans::getString("group_role_everyone");
+ }
+ else if(name == "Officers")
+ {
+ name = LLTrans::getString("group_role_officers");
+ }
+ else if(name == "Owners")
+ {
+ name = LLTrans::getString("group_role_owners");
+ }
+
+
+
+ LL_DEBUGS("GrpMgr") << "Adding role data: " << name << " {" << role_id << "}" << LL_ENDL;
+ LLGroupRoleData* rd = new LLGroupRoleData(role_id,name,title,desc,powers,member_count);
+ group_datap->mRoles[role_id] = rd;
+ }
+
+ if (group_datap->mRoles.size() == (U32)group_datap->mRoleCount)
+ {
+ group_datap->mRoleDataComplete = true;
+ group_datap->mRoleDataRequestID.setNull();
+ // We don't want to make role-member data requests until we have all the role data
+ if (group_datap->mPendingRoleMemberRequest)
+ {
+ group_datap->mPendingRoleMemberRequest = false;
+ LLGroupMgr::getInstance()->sendGroupRoleMembersRequest(group_datap->mID);
+ }
+ }
+
+ group_datap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_ROLE_DATA);
+}
+
+// static
+void LLGroupMgr::processGroupRoleMembersReply(LLMessageSystem* msg, void** data)
+{
+ LL_PROFILE_ZONE_SCOPED;
+
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupRoleMembersReply" << LL_ENDL;
+ LLUUID agent_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
+ if (gAgent.getID() != agent_id)
+ {
+ LL_WARNS() << "Got group role members reply for another agent!" << LL_ENDL;
+ return;
+ }
+
+ LLUUID request_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_RequestID, request_id);
+
+ LLUUID group_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_GroupID, group_id );
+
+ U32 total_pairs;
+ msg->getU32(_PREHASH_AgentData, "TotalPairs", total_pairs);
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!group_datap || (group_datap->mRoleMembersRequestID != request_id))
+ {
+ LL_WARNS() << "processGroupRoleMembersReply: Received incorrect (stale?) group or request id" << LL_ENDL;
+ return;
+ }
+
+ U32 num_blocks = msg->getNumberOfBlocks("MemberData");
+ U32 i;
+ LLUUID member_id;
+ LLUUID role_id;
+ LLGroupRoleData* rd = NULL;
+ LLGroupMemberData* md = NULL;
+
+ LLGroupMgrGroupData::role_list_t::iterator ri;
+ LLGroupMgrGroupData::member_list_t::iterator mi;
+
+ // If total_pairs == 0, there are no members in any custom roles.
+ if (total_pairs > 0)
+ {
+ for (i = 0;i < num_blocks; ++i)
+ {
+ msg->getUUID("MemberData","RoleID",role_id,i);
+ msg->getUUID("MemberData","MemberID",member_id,i);
+
+ if (role_id.notNull() && member_id.notNull() )
+ {
+ rd = NULL;
+ ri = group_datap->mRoles.find(role_id);
+ if (ri != group_datap->mRoles.end())
+ {
+ rd = ri->second;
+ }
+
+ md = NULL;
+ mi = group_datap->mMembers.find(member_id);
+ if (mi != group_datap->mMembers.end())
+ {
+ md = mi->second;
+ }
+
+ if (rd && md)
+ {
+ LL_DEBUGS("GrpMgr") << "Adding role-member pair: " << role_id << ", " << member_id << LL_ENDL;
+ rd->addMember(member_id);
+ md->addRole(role_id,rd);
+ }
+ else
+ {
+ if (!rd) LL_WARNS() << "Received role data for unknown role " << role_id << " in group " << group_id << LL_ENDL;
+ if (!md) LL_WARNS() << "Received role data for unknown member " << member_id << " in group " << group_id << LL_ENDL;
+ }
+ }
+ }
+
+ group_datap->mReceivedRoleMemberPairs += num_blocks;
+ }
+
+ if (group_datap->mReceivedRoleMemberPairs == total_pairs)
+ {
+ // Add role data for the 'everyone' role to all members
+ LLGroupRoleData* everyone = group_datap->mRoles[LLUUID::null];
+ if (!everyone)
+ {
+ LL_WARNS() << "Everyone role not found!" << LL_ENDL;
+ }
+ else
+ {
+ for (LLGroupMgrGroupData::member_list_t::iterator mi = group_datap->mMembers.begin();
+ mi != group_datap->mMembers.end(); ++mi)
+ {
+ LLGroupMemberData* data = mi->second;
+ if (data)
+ {
+ data->addRole(LLUUID::null,everyone);
+ }
+ }
+ }
+
+ group_datap->mRoleMemberDataComplete= true;
+ group_datap->mRoleMembersRequestID.setNull();
+ }
+
+ group_datap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_ROLE_MEMBER_DATA);
+
+ if (group_datap->mPendingBanRequest)
+ {
+ group_datap->banMemberById(group_datap->mPendingBanMemberID);
+ }
+}
+
+// static
+void LLGroupMgr::processGroupTitlesReply(LLMessageSystem* msg, void** data)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::processGroupTitlesReply" << LL_ENDL;
+ LLUUID agent_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_AgentID, agent_id );
+ if (gAgent.getID() != agent_id)
+ {
+ LL_WARNS() << "Got group properties reply for another agent!" << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_GroupID, group_id );
+ LLUUID request_id;
+ msg->getUUIDFast(_PREHASH_AgentData, _PREHASH_RequestID, request_id);
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!group_datap || (group_datap->mTitlesRequestID != request_id))
+ {
+ LL_WARNS() << "processGroupTitlesReply: Received incorrect (stale?) group" << LL_ENDL;
+ return;
+ }
+
+ LLGroupTitle title;
+
+ S32 i = 0;
+ S32 blocks = msg->getNumberOfBlocksFast(_PREHASH_GroupData);
+ for (i=0; i<blocks; ++i)
+ {
+ msg->getString("GroupData","Title",title.mTitle,i);
+ msg->getUUID("GroupData","RoleID",title.mRoleID,i);
+ msg->getBOOL("GroupData","Selected",title.mSelected,i);
+
+ if (!title.mTitle.empty())
+ {
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr adding title: " << title.mTitle << ", " << title.mRoleID << ", " << (title.mSelected ? 'Y' : 'N') << LL_ENDL;
+ group_datap->mTitles.push_back(title);
+ }
+ }
+
+ group_datap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_TITLES);
+}
+
+// static
+void LLGroupMgr::processEjectGroupMemberReply(LLMessageSystem* msg, void ** data)
+{
+ LL_DEBUGS("GrpMgr") << "processEjectGroupMemberReply" << LL_ENDL;
+ LLUUID group_id;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
+ bool success;
+ msg->getBOOLFast(_PREHASH_EjectData, _PREHASH_Success, success);
+
+ // If we had a failure, the group panel needs to be updated.
+ if (!success)
+ {
+ LLGroupActions::refresh(group_id);
+ }
+}
+
+// static
+void LLGroupMgr::processJoinGroupReply(LLMessageSystem* msg, void ** data)
+{
+ LL_DEBUGS("GrpMgr") << "processJoinGroupReply" << LL_ENDL;
+ LLUUID group_id;
+ bool success;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
+ msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_Success, success);
+
+ if (success)
+ {
+ // refresh all group information
+ gAgent.sendAgentDataUpdateRequest();
+
+ LLGroupMgr::getInstance()->clearGroupData(group_id);
+ // refresh the floater for this group, if any.
+ LLGroupActions::refresh(group_id);
+ }
+}
+
+// static
+void LLGroupMgr::processLeaveGroupReply(LLMessageSystem* msg, void ** data)
+{
+ LL_DEBUGS("GrpMgr") << "processLeaveGroupReply" << LL_ENDL;
+ LLUUID group_id;
+ bool success;
+ msg->getUUIDFast(_PREHASH_GroupData, _PREHASH_GroupID, group_id);
+ msg->getBOOLFast(_PREHASH_GroupData, _PREHASH_Success, success);
+
+ if (success)
+ {
+ // refresh all group information
+ gAgent.sendAgentDataUpdateRequest();
+
+ LLGroupMgr::getInstance()->clearGroupData(group_id);
+ // close the floater for this group, if any.
+ LLGroupActions::closeGroup(group_id);
+ }
+}
+
+// static
+void LLGroupMgr::processCreateGroupReply(LLMessageSystem* msg, void ** data)
+{
+ LLUUID group_id;
+ bool success;
+ std::string message;
+
+ msg->getUUIDFast(_PREHASH_ReplyData, _PREHASH_GroupID, group_id );
+
+ msg->getBOOLFast(_PREHASH_ReplyData, _PREHASH_Success, success );
+ msg->getStringFast(_PREHASH_ReplyData, _PREHASH_Message, message );
+
+ if (success)
+ {
+ // refresh all group information
+ gAgent.sendAgentDataUpdateRequest();
+
+ // HACK! We haven't gotten the agent group update yet, so ... um ... fake it.
+ // This is so when we go to modify the group we will be able to do so.
+ // This isn't actually too bad because real data will come down in 2 or 3 miliseconds and replace this.
+ LLGroupData gd;
+ gd.mAcceptNotices = true;
+ gd.mListInProfile = true;
+ gd.mContribution = 0;
+ gd.mID = group_id;
+ gd.mName = "new group";
+ gd.mPowers = GP_ALL_POWERS;
+
+ gAgent.mGroups.push_back(gd);
+
+ LLPanelGroupCreate::refreshCreatedGroup(group_id);
+ //FIXME
+ //LLFloaterGroupInfo::closeCreateGroup();
+ //LLFloaterGroupInfo::showFromUUID(group_id,"roles_tab");
+ }
+ else
+ {
+ // *TODO: Translate
+ LLSD args;
+ args["MESSAGE"] = message;
+ LLNotificationsUtil::add("UnableToCreateGroup", args);
+ }
+}
+
+LLGroupMgrGroupData* LLGroupMgr::createGroupData(const LLUUID& id)
+{
+ LLGroupMgrGroupData* group_datap = NULL;
+
+ group_map_t::iterator existing_group = LLGroupMgr::getInstance()->mGroups.find(id);
+ if (existing_group == LLGroupMgr::getInstance()->mGroups.end())
+ {
+ group_datap = new LLGroupMgrGroupData(id);
+ LLGroupMgr::getInstance()->addGroup(group_datap);
+ }
+ else
+ {
+ group_datap = existing_group->second;
+ }
+
+ if (group_datap)
+ {
+ group_datap->setAccessed();
+ }
+
+ return group_datap;
+}
+
+bool LLGroupMgr::hasPendingPropertyRequest(const LLUUID & id)
+{
+ properties_request_map_t::iterator existing_req = LLGroupMgr::getInstance()->mPropRequests.find(id);
+ if (existing_req != LLGroupMgr::getInstance()->mPropRequests.end())
+ {
+ if (gFrameTime - existing_req->second < MIN_GROUP_PROPERTY_REQUEST_FREQ)
+ {
+ return true;
+ }
+ else
+ {
+ LLGroupMgr::getInstance()->mPropRequests.erase(existing_req);
+ }
+ }
+ return false;
+}
+
+void LLGroupMgr::addPendingPropertyRequest(const LLUUID& id)
+{
+ LLGroupMgr::getInstance()->mPropRequests[id] = gFrameTime;
+}
+
+void LLGroupMgr::notifyObservers(LLGroupChange gc)
+{
+ for (group_map_t::iterator gi = mGroups.begin(); gi != mGroups.end(); ++gi)
+ {
+ LLUUID group_id = gi->first;
+ if (gi->second->mChanged)
+ {
+ // notify LLGroupMgrObserver
+ // Copy the map because observers may remove themselves on update
+ observer_multimap_t observers = mObservers;
+
+ // find all observers for this group id
+ observer_multimap_t::iterator oi = observers.lower_bound(group_id);
+ observer_multimap_t::iterator end = observers.upper_bound(group_id);
+ for (; oi != end; ++oi)
+ {
+ oi->second->changed(gc);
+ }
+ gi->second->mChanged = false;
+
+
+ // notify LLParticularGroupObserver
+ observer_map_t::iterator obs_it = mParticularObservers.find(group_id);
+ if(obs_it == mParticularObservers.end())
+ return;
+
+ observer_set_t& obs = obs_it->second;
+ for (observer_set_t::iterator ob_it = obs.begin(); ob_it != obs.end(); ++ob_it)
+ {
+ (*ob_it)->changed(group_id, gc);
+ }
+ }
+ }
+}
+
+void LLGroupMgr::addGroup(LLGroupMgrGroupData* group_datap)
+{
+ while (mGroups.size() >= MAX_CACHED_GROUPS)
+ {
+ // LRU: Remove the oldest un-observed group from cache until group size is small enough
+
+ F32 oldest_access = LLFrameTimer::getTotalSeconds();
+ group_map_t::iterator oldest_gi = mGroups.end();
+
+ for (group_map_t::iterator gi = mGroups.begin(); gi != mGroups.end(); ++gi )
+ {
+ observer_multimap_t::iterator oi = mObservers.find(gi->first);
+ if (oi == mObservers.end())
+ {
+ if (gi->second
+ && (gi->second->getAccessTime() < oldest_access))
+ {
+ oldest_access = gi->second->getAccessTime();
+ oldest_gi = gi;
+ }
+ }
+ }
+
+ if (oldest_gi != mGroups.end())
+ {
+ delete oldest_gi->second;
+ mGroups.erase(oldest_gi);
+ }
+ else
+ {
+ // All groups must be currently open, none to remove.
+ // Just add the new group anyway, but get out of this loop as it
+ // will never drop below max_cached_groups.
+ break;
+ }
+ }
+
+ mGroups[group_datap->getID()] = group_datap;
+}
+
+
+void LLGroupMgr::sendGroupPropertiesRequest(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupPropertiesRequest" << LL_ENDL;
+ // This will happen when we get the reply
+ //LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+
+ if (LLGroupMgr::getInstance()->hasPendingPropertyRequest(group_id))
+ {
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupPropertiesRequest suppressed repeat for " << group_id << LL_ENDL;
+ return;
+ }
+ LLGroupMgr::getInstance()->addPendingPropertyRequest(group_id);
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupProfileRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ gAgent.sendReliableMessage();
+}
+
+void LLGroupMgr::sendGroupMembersRequest(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupMembersRequest" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+ if (group_datap->mMemberRequestID.isNull())
+ {
+ group_datap->removeMemberData();
+ group_datap->mMemberRequestID.generate();
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupMembersRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ msg->addUUID("RequestID",group_datap->mMemberRequestID);
+ gAgent.sendReliableMessage();
+ }
+}
+
+
+void LLGroupMgr::sendGroupRoleDataRequest(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleDataRequest" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+ if (group_datap->mRoleDataRequestID.isNull())
+ {
+ group_datap->removeRoleData();
+ group_datap->mRoleDataRequestID.generate();
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupRoleDataRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ msg->addUUID("RequestID",group_datap->mRoleDataRequestID);
+ gAgent.sendReliableMessage();
+ }
+}
+
+void LLGroupMgr::sendGroupRoleMembersRequest(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleMembersRequest" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+
+ if (group_datap->mRoleMembersRequestID.isNull())
+ {
+ // Don't send the request if we don't have all the member or role data
+ if (!group_datap->isMemberDataComplete()
+ || !group_datap->isRoleDataComplete())
+ {
+ // *TODO: KLW FIXME: Should we start a member or role data request?
+ LL_INFOS("GrpMgr") << " Pending: " << (group_datap->mPendingRoleMemberRequest ? "Y" : "N")
+ << " MemberDataComplete: " << (group_datap->mMemberDataComplete ? "Y" : "N")
+ << " RoleDataComplete: " << (group_datap->mRoleDataComplete ? "Y" : "N") << LL_ENDL;
+ group_datap->mPendingRoleMemberRequest = true;
+ return;
+ }
+
+ group_datap->removeRoleMemberData();
+ group_datap->mRoleMembersRequestID.generate();
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupRoleMembersRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ msg->addUUID("RequestID",group_datap->mRoleMembersRequestID);
+ gAgent.sendReliableMessage();
+ }
+}
+
+void LLGroupMgr::sendGroupTitlesRequest(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupTitlesRequest" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+
+ group_datap->mTitles.clear();
+ group_datap->mTitlesRequestID.generate();
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupTitlesRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->addUUID("GroupID",group_id);
+ msg->addUUID("RequestID",group_datap->mTitlesRequestID);
+
+ gAgent.sendReliableMessage();
+}
+
+void LLGroupMgr::sendGroupTitleUpdate(const LLUUID& group_id, const LLUUID& title_role_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupTitleUpdate" << LL_ENDL;
+
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("GroupTitleUpdate");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->addUUID("GroupID",group_id);
+ msg->addUUID("TitleRoleID",title_role_id);
+
+ gAgent.sendReliableMessage();
+
+ // Save the change locally
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+ for (std::vector<LLGroupTitle>::iterator iter = group_datap->mTitles.begin();
+ iter != group_datap->mTitles.end(); ++iter)
+ {
+ if (iter->mRoleID == title_role_id)
+ {
+ iter->mSelected = true;
+ }
+ else if (iter->mSelected)
+ {
+ iter->mSelected = false;
+ }
+ }
+}
+
+// static
+void LLGroupMgr::sendCreateGroupRequest(const std::string& name,
+ const std::string& charter,
+ U8 show_in_list,
+ const LLUUID& insignia,
+ S32 membership_fee,
+ bool open_enrollment,
+ bool allow_publish,
+ bool mature_publish)
+{
+ LLMessageSystem* msg = gMessageSystem;
+ msg->newMessage("CreateGroupRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+
+ msg->nextBlock("GroupData");
+ msg->addString("Name",name);
+ msg->addString("Charter",charter);
+ msg->addBOOL("ShowInList",show_in_list);
+ msg->addUUID("InsigniaID",insignia);
+ msg->addS32("MembershipFee",membership_fee);
+ msg->addBOOL("OpenEnrollment",open_enrollment);
+ msg->addBOOL("AllowPublish",allow_publish);
+ msg->addBOOL("MaturePublish",mature_publish);
+
+ gAgent.sendReliableMessage();
+}
+
+void LLGroupMgr::sendUpdateGroupInfo(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendUpdateGroupInfo" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+
+ LLMessageSystem* msg = gMessageSystem;
+
+ msg->newMessageFast(_PREHASH_UpdateGroupInfo);
+ msg->nextBlockFast(_PREHASH_AgentData);
+ msg->addUUIDFast(_PREHASH_AgentID,gAgent.getID());
+ msg->addUUIDFast(_PREHASH_SessionID,gAgent.getSessionID());
+
+ msg->nextBlockFast(_PREHASH_GroupData);
+ msg->addUUIDFast(_PREHASH_GroupID,group_datap->getID());
+ msg->addStringFast(_PREHASH_Charter,group_datap->mCharter);
+ msg->addBOOLFast(_PREHASH_ShowInList,group_datap->mShowInList);
+ msg->addUUIDFast(_PREHASH_InsigniaID,group_datap->mInsigniaID);
+ msg->addS32Fast(_PREHASH_MembershipFee,group_datap->mMembershipFee);
+ msg->addBOOLFast(_PREHASH_OpenEnrollment,group_datap->mOpenEnrollment);
+ msg->addBOOLFast(_PREHASH_AllowPublish,group_datap->mAllowPublish);
+ msg->addBOOLFast(_PREHASH_MaturePublish,group_datap->mMaturePublish);
+
+ gAgent.sendReliableMessage();
+
+ // Not expecting a response, so let anyone else watching know the data has changed.
+ group_datap->mChanged = true;
+ notifyObservers(GC_PROPERTIES);
+}
+
+void LLGroupMgr::sendGroupRoleMemberChanges(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleMemberChanges" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id);
+
+ if (group_datap->mRoleMemberChanges.empty()) return;
+
+ LLMessageSystem* msg = gMessageSystem;
+
+ bool start_message = true;
+ for (LLGroupMgrGroupData::change_map_t::const_iterator citer = group_datap->mRoleMemberChanges.begin();
+ citer != group_datap->mRoleMemberChanges.end(); ++citer)
+ {
+ if (start_message)
+ {
+ msg->newMessage("GroupRoleChanges");
+ msg->nextBlockFast(_PREHASH_AgentData);
+ msg->addUUIDFast(_PREHASH_AgentID,gAgent.getID());
+ msg->addUUIDFast(_PREHASH_SessionID,gAgent.getSessionID());
+ msg->addUUIDFast(_PREHASH_GroupID,group_id);
+ start_message = false;
+ }
+ msg->nextBlock("RoleChange");
+ msg->addUUID("RoleID",citer->second.mRole);
+ msg->addUUID("MemberID",citer->second.mMember);
+ msg->addU32("Change",(U32)citer->second.mChange);
+
+ if (msg->isSendFullFast())
+ {
+ gAgent.sendReliableMessage();
+ start_message = true;
+ }
+ }
+
+ if (!start_message)
+ {
+ gAgent.sendReliableMessage();
+ }
+
+ group_datap->mRoleMemberChanges.clear();
+
+ // Not expecting a response, so let anyone else watching know the data has changed.
+ group_datap->mChanged = true;
+ notifyObservers(GC_ROLE_MEMBER_DATA);
+}
+
+//static
+void LLGroupMgr::sendGroupMemberJoin(const LLUUID& group_id)
+{
+
+ LLUIUsage::instance().logCommand("Group.Join");
+
+ LLMessageSystem *msg = gMessageSystem;
+
+ msg->newMessageFast(_PREHASH_JoinGroupRequest);
+ msg->nextBlockFast(_PREHASH_AgentData);
+ msg->addUUIDFast(_PREHASH_AgentID, gAgent.getID() );
+ msg->addUUIDFast(_PREHASH_SessionID, gAgent.getSessionID());
+ msg->nextBlockFast(_PREHASH_GroupData);
+ msg->addUUIDFast(_PREHASH_GroupID, group_id);
+
+ gAgent.sendReliableMessage();
+}
+
+// member_role_pairs is <member_id,role_id>
+// static
+void LLGroupMgr::sendGroupMemberInvites(const LLUUID& group_id, std::map<LLUUID,LLUUID>& member_role_pairs)
+{
+ bool start_message = true;
+ LLMessageSystem* msg = gMessageSystem;
+
+ for (std::map<LLUUID,LLUUID>::iterator it = member_role_pairs.begin();
+ it != member_role_pairs.end(); ++it)
+ {
+ if (start_message)
+ {
+ msg->newMessage("InviteGroupRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ start_message = false;
+ }
+
+ msg->nextBlock("InviteData");
+ msg->addUUID("InviteeID",(*it).first);
+ msg->addUUID("RoleID",(*it).second);
+
+ if (msg->isSendFull())
+ {
+ gAgent.sendReliableMessage();
+ start_message = true;
+ }
+ }
+
+ if (!start_message)
+ {
+ gAgent.sendReliableMessage();
+ }
+}
+
+//static
+void LLGroupMgr::sendGroupMemberEjects(const LLUUID& group_id,
+ uuid_vec_t& member_ids)
+{
+ bool start_message = true;
+ LLMessageSystem* msg = gMessageSystem;
+
+ LLGroupMgrGroupData* group_datap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!group_datap) return;
+
+ for (uuid_vec_t::iterator it = member_ids.begin();
+ it != member_ids.end(); ++it)
+ {
+ LLUUID& ejected_member_id = (*it);
+
+ // Can't use 'eject' to leave a group.
+ if (ejected_member_id == gAgent.getID()) continue;
+
+ // Make sure they are in the group, and we need the member data
+ LLGroupMgrGroupData::member_list_t::iterator mit = group_datap->mMembers.find(ejected_member_id);
+ if (mit != group_datap->mMembers.end())
+ {
+ // Add them to the message
+ if (start_message)
+ {
+ msg->newMessage("EjectGroupMemberRequest");
+ msg->nextBlock("AgentData");
+ msg->addUUID("AgentID",gAgent.getID());
+ msg->addUUID("SessionID",gAgent.getSessionID());
+ msg->nextBlock("GroupData");
+ msg->addUUID("GroupID",group_id);
+ start_message = false;
+ }
+
+ msg->nextBlock("EjectData");
+ msg->addUUID("EjecteeID",ejected_member_id);
+
+ if (msg->isSendFull())
+ {
+ gAgent.sendReliableMessage();
+ start_message = true;
+ }
+
+ LLGroupMemberData* member_data = (*mit).second;
+
+ // Clean up groupmgr
+ for (LLGroupMemberData::role_list_t::iterator rit = member_data->roleBegin();
+ rit != member_data->roleEnd(); ++rit)
+ {
+ if ((*rit).first.notNull() && (*rit).second!=0)
+ {
+ (*rit).second->removeMember(ejected_member_id);
+ }
+ }
+
+ group_datap->mMembers.erase(ejected_member_id);
+
+ // member_data was introduced and is used here instead of (*mit).second to avoid crash because of invalid iterator
+ // It becomes invalid after line with erase above. EXT-4778
+ delete member_data;
+ }
+ }
+
+ if (!start_message)
+ {
+ gAgent.sendReliableMessage();
+ }
+
+ group_datap->mMemberVersion.generate();
+}
+
+void LLGroupMgr::getGroupBanRequestCoro(std::string url, LLUUID groupId)
+{
+ LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
+ LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
+ httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
+ LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
+
+ std::string finalUrl = url + "?group_id=" + groupId.asString();
+
+ LLSD result = httpAdapter->getAndSuspend(httpRequest, finalUrl);
+
+ LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
+ LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
+
+ if (!status)
+ {
+ LL_WARNS("GrpMgr") << "Error receiving group member data " << LL_ENDL;
+ return;
+ }
+
+ if (result.has("ban_list"))
+ {
+ result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
+ // group ban data received
+ processGroupBanRequest(result);
+ }
+}
+
+void LLGroupMgr::postGroupBanRequestCoro(std::string url, LLUUID groupId,
+ U32 action, uuid_vec_t banList, bool update)
+{
+ LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
+ LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
+ httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
+ LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
+ LLCore::HttpHeaders::ptr_t httpHeaders(new LLCore::HttpHeaders);
+ LLCore::HttpOptions::ptr_t httpOptions(new LLCore::HttpOptions);
+
+ httpOptions->setFollowRedirects(false);
+
+ httpHeaders->append(HTTP_OUT_HEADER_CONTENT_TYPE, HTTP_CONTENT_LLSD_XML);
+
+
+ std::string finalUrl = url + "?group_id=" + groupId.asString();
+
+ LLSD postData = LLSD::emptyMap();
+ postData["ban_action"] = (LLSD::Integer)action;
+ // Add our list of potential banned residents to the list
+ postData["ban_ids"] = LLSD::emptyArray();
+ LLSD banEntry;
+
+ uuid_vec_t::const_iterator it = banList.begin();
+ for (; it != banList.end(); ++it)
+ {
+ banEntry = (*it);
+ postData["ban_ids"].append(banEntry);
+ }
+
+ LL_WARNS() << "post: " << ll_pretty_print_sd(postData) << LL_ENDL;
+
+ LLSD result = httpAdapter->postAndSuspend(httpRequest, finalUrl, postData, httpOptions, httpHeaders);
+
+ LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
+ LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
+
+ if (!status)
+ {
+ LL_WARNS("GrpMgr") << "Error posting group member data " << LL_ENDL;
+ return;
+ }
+
+ if (result.has("ban_list"))
+ {
+ result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
+ // group ban data received
+ processGroupBanRequest(result);
+ }
+
+ if (update)
+ {
+ getGroupBanRequestCoro(url, groupId);
+ }
+}
+
+void LLGroupMgr::sendGroupBanRequest( EBanRequestType request_type,
+ const LLUUID& group_id,
+ U32 ban_action, /* = BAN_NO_ACTION */
+ const std::vector<LLUUID> &ban_list) /* = std::vector<LLUUID>() */
+{
+ LLViewerRegion* currentRegion = gAgent.getRegion();
+ if(!currentRegion)
+ {
+ LL_WARNS("GrpMgr") << "Agent does not have a current region. Uh-oh!" << LL_ENDL;
+ return;
+ }
+
+ // Check to make sure we have our capabilities
+ if(!currentRegion->capabilitiesReceived())
+ {
+ LL_WARNS("GrpMgr") << " Capabilities not received!" << LL_ENDL;
+ return;
+ }
+
+ // Get our capability
+ std::string cap_url = currentRegion->getCapability("GroupAPIv1");
+ if(cap_url.empty())
+ {
+ return;
+ }
+
+ U32 action = ban_action & ~BAN_UPDATE;
+ bool update = ((ban_action & BAN_UPDATE) == BAN_UPDATE);
+
+ switch (request_type)
+ {
+ case REQUEST_GET:
+ LLCoros::instance().launch("LLGroupMgr::getGroupBanRequestCoro",
+ boost::bind(&LLGroupMgr::getGroupBanRequestCoro, this, cap_url, group_id));
+ break;
+ case REQUEST_POST:
+ LLCoros::instance().launch("LLGroupMgr::postGroupBanRequestCoro",
+ boost::bind(&LLGroupMgr::postGroupBanRequestCoro, this, cap_url, group_id,
+ action, ban_list, update));
+ break;
+ case REQUEST_PUT:
+ case REQUEST_DEL:
+ break;
+ }
+}
+
+void LLGroupMgr::processGroupBanRequest(const LLSD& content)
+{
+ // Did we get anything in content?
+ if(!content.size())
+ {
+ LL_WARNS("GrpMgr") << "No group member data received." << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id = content["group_id"].asUUID();
+
+ LLGroupMgrGroupData* gdatap = LLGroupMgr::getInstance()->getGroupData(group_id);
+ if (!gdatap)
+ return;
+
+ gdatap->clearBanList();
+ LLSD::map_const_iterator i = content["ban_list"].beginMap();
+ LLSD::map_const_iterator iEnd = content["ban_list"].endMap();
+ for(;i != iEnd; ++i)
+ {
+ const LLUUID ban_id(i->first);
+ LLSD ban_entry(i->second);
+
+ LLGroupBanData ban_data;
+ if(ban_entry.has("ban_date"))
+ {
+ ban_data.mBanDate = ban_entry["ban_date"].asDate();
+ // TODO: Ban Reason
+ }
+
+ gdatap->createBanEntry(ban_id, ban_data);
+ }
+
+ gdatap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_BANLIST);
+}
+
+void LLGroupMgr::groupMembersRequestCoro(std::string url, LLUUID groupId)
+{
+ LLCore::HttpRequest::policy_t httpPolicy(LLCore::HttpRequest::DEFAULT_POLICY_ID);
+ LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t
+ httpAdapter(new LLCoreHttpUtil::HttpCoroutineAdapter("groupMembersRequest", httpPolicy));
+ LLCore::HttpRequest::ptr_t httpRequest(new LLCore::HttpRequest);
+ LLCore::HttpOptions::ptr_t httpOpts = LLCore::HttpOptions::ptr_t(new LLCore::HttpOptions);
+
+ mMemberRequestInFlight = true;
+
+ LLSD postData = LLSD::emptyMap();
+ postData["group_id"] = groupId;
+
+ LLSD result = httpAdapter->postAndSuspend(httpRequest, url, postData, httpOpts);
+
+ LLSD httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
+ LLCore::HttpStatus status = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);
+
+ if (!status)
+ {
+ LL_WARNS("GrpMgr") << "Error receiving group member data " << LL_ENDL;
+ mMemberRequestInFlight = false;
+ return;
+ }
+
+ result.erase(LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS);
+ LLGroupMgr::processCapGroupMembersRequest(result);
+ mMemberRequestInFlight = false;
+}
+
+void LLGroupMgr::sendCapGroupMembersRequest(const LLUUID& group_id)
+{
+ static U32 lastGroupMemberRequestFrame = 0;
+
+ // Have we requested the information already this frame?
+ // Todo: make this per group, we can invite to one group and simultaneously be checking another one
+ if ((lastGroupMemberRequestFrame == gFrameCount) || (mMemberRequestInFlight))
+ return;
+
+ LLViewerRegion* currentRegion = gAgent.getRegion();
+ // Thank you FS:Ansariel!
+ if(!currentRegion)
+ {
+ LL_WARNS("GrpMgr") << "Agent does not have a current region. Uh-oh!" << LL_ENDL;
+ return;
+ }
+
+ // Check to make sure we have our capabilities
+ if(!currentRegion->capabilitiesReceived())
+ {
+ LL_WARNS("GrpMgr") << " Capabilities not received!" << LL_ENDL;
+ return;
+ }
+
+ // Get our capability
+ std::string cap_url = currentRegion->getCapability("GroupMemberData");
+
+ // Thank you FS:Ansariel!
+ if(cap_url.empty())
+ {
+ LL_INFOS("GrpMgr") << "Region has no GroupMemberData capability. Falling back to UDP fetch." << LL_ENDL;
+ sendGroupMembersRequest(group_id);
+ return;
+ }
+
+ LLGroupMgrGroupData* group_datap = createGroupData(group_id); //make sure group exists
+ group_datap->mMemberRequestID.generate(); // mark as pending
+
+ lastGroupMemberRequestFrame = gFrameCount;
+
+ LLCoros::instance().launch("LLGroupMgr::groupMembersRequestCoro",
+ boost::bind(&LLGroupMgr::groupMembersRequestCoro, this, cap_url, group_id));
+}
+
+
+void LLGroupMgr::processCapGroupMembersRequest(const LLSD& content)
+{
+ // Did we get anything in content?
+ if(!content.size())
+ {
+ LL_DEBUGS("GrpMgr") << "No group member data received." << LL_ENDL;
+ return;
+ }
+
+ LLUUID group_id = content["group_id"].asUUID();
+
+ LLGroupMgrGroupData* group_datap = getGroupData(group_id);
+ if(!group_datap)
+ {
+ LL_WARNS("GrpMgr") << "Received incorrect, possibly stale, group or request id" << LL_ENDL;
+ return;
+ }
+
+ // If we have no members, there's no reason to do anything else
+ S32 num_members = content["member_count"];
+ if (num_members < 1)
+ {
+ LL_INFOS("GrpMgr") << "Received empty group members list for group id: " << group_id.asString() << LL_ENDL;
+ // Set mMemberDataComplete for correct handling of empty responses. See MAINT-5237
+ group_datap->mMemberDataComplete = true;
+ group_datap->mChanged = true;
+ LLGroupMgr::getInstance()->notifyObservers(GC_MEMBER_DATA);
+ return;
+ }
+
+ group_datap->mMemberCount = num_members;
+
+ LLSD member_list = content["members"];
+ LLSD titles = content["titles"];
+ LLSD defaults = content["defaults"];
+
+ std::string online_status;
+ std::string title;
+ S32 contribution;
+ U64 member_powers;
+ // If this is changed to a bool, make sure to change the LLGroupMemberData constructor
+ bool is_owner;
+
+ // Compute this once, rather than every time.
+ U64 default_powers = llstrtou64(defaults["default_powers"].asString().c_str(), NULL, 16);
+
+ LLSD::map_const_iterator member_iter_start = member_list.beginMap();
+ LLSD::map_const_iterator member_iter_end = member_list.endMap();
+ for( ; member_iter_start != member_iter_end; ++member_iter_start)
+ {
+ // Reset defaults
+ online_status = "unknown";
+ title = titles[0].asString();
+ contribution = 0;
+ member_powers = default_powers;
+ is_owner = false;
+
+ const LLUUID member_id(member_iter_start->first);
+ LLSD member_info = member_iter_start->second;
+
+ if(member_info.has("last_login"))
+ {
+ online_status = member_info["last_login"].asString();
+ if(online_status == "Online")
+ online_status = LLTrans::getString("group_member_status_online");
+ else
+ formatDateString(online_status);
+ }
+
+ if(member_info.has("title"))
+ title = titles[member_info["title"].asInteger()].asString();
+
+ if(member_info.has("powers"))
+ member_powers = llstrtou64(member_info["powers"].asString().c_str(), NULL, 16);
+
+ if(member_info.has("donated_square_meters"))
+ contribution = member_info["donated_square_meters"];
+
+ if(member_info.has("owner"))
+ is_owner = true;
+
+ LLGroupMemberData* data = new LLGroupMemberData(member_id,
+ contribution,
+ member_powers,
+ title,
+ online_status,
+ is_owner);
+
+ LLGroupMemberData* member_old = group_datap->mMembers[member_id];
+ if (member_old && group_datap->mRoleMemberDataComplete)
+ {
+ LLGroupMemberData::role_list_t::iterator rit = member_old->roleBegin();
+ LLGroupMemberData::role_list_t::iterator end = member_old->roleEnd();
+
+ for ( ; rit != end; ++rit)
+ {
+ data->addRole((*rit).first,(*rit).second);
+ }
+ }
+ else
+ {
+ group_datap->mRoleMemberDataComplete = false;
+ }
+
+ group_datap->mMembers[member_id] = data;
+ }
+
+ group_datap->mMemberVersion.generate();
+
+ // Technically, we have this data, but to prevent completely overhauling
+ // this entire system (it would be nice, but I don't have the time),
+ // I'm going to be dumb and just call services I most likely don't need
+ // with the thought being that the system might need it to be done.
+ //
+ // TODO:
+ // Refactor to reduce multiple calls for data we already have.
+ if(group_datap->mTitles.size() < 1)
+ sendGroupTitlesRequest(group_id);
+
+
+ group_datap->mMemberDataComplete = true;
+ group_datap->mMemberRequestID.setNull();
+ // Make the role-member data request
+ if (group_datap->mPendingRoleMemberRequest || !group_datap->mRoleMemberDataComplete)
+ {
+ group_datap->mPendingRoleMemberRequest = false;
+ sendGroupRoleMembersRequest(group_id);
+ }
+
+ group_datap->mChanged = true;
+ notifyObservers(GC_MEMBER_DATA);
+
+}
+
+
+void LLGroupMgr::sendGroupRoleChanges(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::sendGroupRoleChanges" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = getGroupData(group_id);
+
+ if (group_datap && group_datap->pendingRoleChanges())
+ {
+ group_datap->sendRoleChanges();
+
+ // Not expecting a response, so let anyone else watching know the data has changed.
+ group_datap->mChanged = true;
+ notifyObservers(GC_ROLE_DATA);
+ }
+}
+
+void LLGroupMgr::cancelGroupRoleChanges(const LLUUID& group_id)
+{
+ LL_DEBUGS("GrpMgr") << "LLGroupMgr::cancelGroupRoleChanges" << LL_ENDL;
+ LLGroupMgrGroupData* group_datap = getGroupData(group_id);
+
+ if (group_datap) group_datap->cancelRoleChanges();
+}
+
+//static
+bool LLGroupMgr::parseRoleActions(const std::string& xml_filename)
+{
+ LLXMLNodePtr root;
+
+ bool success = LLUICtrlFactory::getLayeredXMLNode(xml_filename, root);
+
+ if (!success || !root || !root->hasName( "role_actions" ))
+ {
+ LL_ERRS() << "Problem reading UI role_actions file: " << xml_filename << LL_ENDL;
+ return false;
+ }
+
+ LLXMLNodeList role_list;
+
+ root->getChildren("action_set", role_list, false);
+
+ for (LLXMLNodeList::iterator role_iter = role_list.begin(); role_iter != role_list.end(); ++role_iter)
+ {
+ LLXMLNodePtr action_set = role_iter->second;
+
+ LLRoleActionSet* role_action_set = new LLRoleActionSet();
+ LLRoleAction* role_action_data = new LLRoleAction();
+
+ // name=
+ std::string action_set_name;
+ if (action_set->getAttributeString("name", action_set_name))
+ {
+ LL_DEBUGS("GrpMgr") << "Loading action set " << action_set_name << LL_ENDL;
+ role_action_data->mName = action_set_name;
+ }
+ else
+ {
+ LL_WARNS() << "Unable to parse action set with no name" << LL_ENDL;
+ delete role_action_set;
+ delete role_action_data;
+ continue;
+ }
+ // description=
+ std::string set_description;
+ if (action_set->getAttributeString("description", set_description))
+ {
+ role_action_data->mDescription = set_description;
+ }
+ // long description=
+ std::string set_longdescription;
+ if (action_set->getAttributeString("longdescription", set_longdescription))
+ {
+ role_action_data->mLongDescription = set_longdescription;
+ }
+
+ // power mask=
+ U64 set_power_mask = 0;
+
+ LLXMLNodeList action_list;
+ LLXMLNodeList::iterator action_iter;
+
+ action_set->getChildren("action", action_list, false);
+
+ for (action_iter = action_list.begin(); action_iter != action_list.end(); ++action_iter)
+ {
+ LLXMLNodePtr action = action_iter->second;
+
+ LLRoleAction* role_action = new LLRoleAction();
+
+ // name=
+ std::string action_name;
+ if (action->getAttributeString("name", action_name))
+ {
+ LL_DEBUGS("GrpMgr") << "Loading action " << action_name << LL_ENDL;
+ role_action->mName = action_name;
+ }
+ else
+ {
+ LL_WARNS() << "Unable to parse action with no name" << LL_ENDL;
+ delete role_action;
+ continue;
+ }
+ // description=
+ std::string description;
+ if (action->getAttributeString("description", description))
+ {
+ role_action->mDescription = description;
+ }
+ // long description=
+ std::string longdescription;
+ if (action->getAttributeString("longdescription", longdescription))
+ {
+ role_action->mLongDescription = longdescription;
+ }
+ // description=
+ S32 power_bit = 0;
+ if (action->getAttributeS32("value", power_bit))
+ {
+ if (0 <= power_bit && power_bit < 64)
+ {
+ role_action->mPowerBit = 0x1LL << power_bit;
+ }
+ }
+
+ set_power_mask |= role_action->mPowerBit;
+
+ role_action_set->mActions.push_back(role_action);
+ }
+
+ role_action_data->mPowerBit = set_power_mask;
+ role_action_set->mActionSetData = role_action_data;
+
+ LLGroupMgr::getInstance()->mRoleActionSets.push_back(role_action_set);
+ }
+ return true;
+}
+
+// static
+void LLGroupMgr::debugClearAllGroups(void*)
+{
+ LLGroupMgr::getInstance()->clearGroups();
+ LLGroupMgr::parseRoleActions("role_actions.xml");
+}
+
+
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-29 05:38:29 +0000