mirror of
https://github.com/opensim/opensim.git
synced 2026-07-19 22:26:13 +08:00
3a6f312484
This was because the "session ID" when the message template was copied was always replaced with the group ID, whereas a notice requires this to be the notice ID. Instead just copy the "session ID" as is - other callers already have this set properly so replacing with group ID was redundant anyway. Relates to http://opensimulator.org/mantis/view.php?id=7037
1555 lines
66 KiB
C#
1555 lines
66 KiB
C#
/*
|
|
* Copyright (c) Contributors, http://opensimulator.org/
|
|
* See CONTRIBUTORS.TXT for a full list of copyright holders.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions are met:
|
|
* * Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* * Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* * Neither the name of the OpenSimulator Project nor the
|
|
* names of its contributors may be used to endorse or promote products
|
|
* derived from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
|
|
* EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
|
|
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
|
* DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
|
|
* DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
|
|
* (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
|
|
* LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
|
|
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
|
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Reflection;
|
|
using System.Timers;
|
|
using log4net;
|
|
using Mono.Addins;
|
|
using Nini.Config;
|
|
using OpenMetaverse;
|
|
using OpenMetaverse.StructuredData;
|
|
using OpenSim.Framework;
|
|
using OpenSim.Framework.Communications;
|
|
using OpenSim.Region.Framework.Interfaces;
|
|
using OpenSim.Region.Framework.Scenes;
|
|
using OpenSim.Services.Interfaces;
|
|
using System.Text;
|
|
using DirFindFlags = OpenMetaverse.DirectoryManager.DirFindFlags;
|
|
|
|
namespace OpenSim.Region.OptionalModules.Avatar.XmlRpcGroups
|
|
{
|
|
[Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule", Id = "GroupsModule")]
|
|
public class GroupsModule : ISharedRegionModule, IGroupsModule
|
|
{
|
|
/// <summary>
|
|
/// ; To use this module, you must specify the following in your OpenSim.ini
|
|
/// [GROUPS]
|
|
/// Enabled = true
|
|
///
|
|
/// Module = GroupsModule
|
|
/// NoticesEnabled = true
|
|
/// DebugEnabled = true
|
|
///
|
|
/// GroupsServicesConnectorModule = XmlRpcGroupsServicesConnector
|
|
/// XmlRpcServiceURL = http://osflotsam.org/xmlrpc.php
|
|
/// XmlRpcServiceReadKey = 1234
|
|
/// XmlRpcServiceWriteKey = 1234
|
|
///
|
|
/// MessagingModule = GroupsMessagingModule
|
|
/// MessagingEnabled = true
|
|
///
|
|
/// ; Disables HTTP Keep-Alive for Groups Module HTTP Requests, work around for
|
|
/// ; a problem discovered on some Windows based region servers. Only disable
|
|
/// ; if you see a large number (dozens) of the following Exceptions:
|
|
/// ; System.Net.WebException: The request was aborted: The request was canceled.
|
|
///
|
|
/// XmlRpcDisableKeepAlive = false
|
|
/// </summary>
|
|
|
|
private static readonly ILog m_log =
|
|
LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
|
|
|
|
private List<Scene> m_sceneList = new List<Scene>();
|
|
|
|
private IMessageTransferModule m_msgTransferModule;
|
|
|
|
private IGroupsMessagingModule m_groupsMessagingModule;
|
|
|
|
private IGroupsServicesConnector m_groupData;
|
|
|
|
// Configuration settings
|
|
private bool m_groupsEnabled = false;
|
|
private bool m_groupNoticesEnabled = true;
|
|
private bool m_debugEnabled = false;
|
|
private int m_levelGroupCreate = 0;
|
|
|
|
#region Region Module interfaceBase Members
|
|
|
|
public void Initialise(IConfigSource config)
|
|
{
|
|
IConfig groupsConfig = config.Configs["Groups"];
|
|
|
|
if (groupsConfig == null)
|
|
{
|
|
// Do not run this module by default.
|
|
return;
|
|
}
|
|
else
|
|
{
|
|
m_groupsEnabled = groupsConfig.GetBoolean("Enabled", false);
|
|
if (!m_groupsEnabled)
|
|
{
|
|
return;
|
|
}
|
|
|
|
if (groupsConfig.GetString("Module", "Default") != Name)
|
|
{
|
|
m_groupsEnabled = false;
|
|
|
|
return;
|
|
}
|
|
|
|
m_log.InfoFormat("[GROUPS]: Initializing {0}", this.Name);
|
|
|
|
m_groupNoticesEnabled = groupsConfig.GetBoolean("NoticesEnabled", true);
|
|
m_debugEnabled = groupsConfig.GetBoolean("DebugEnabled", false);
|
|
m_levelGroupCreate = groupsConfig.GetInt("LevelGroupCreate", 0);
|
|
}
|
|
}
|
|
|
|
public void AddRegion(Scene scene)
|
|
{
|
|
if (m_groupsEnabled)
|
|
{
|
|
scene.RegisterModuleInterface<IGroupsModule>(this);
|
|
scene.AddCommand(
|
|
"Debug",
|
|
this,
|
|
"debug groups verbose",
|
|
"debug groups verbose <true|false>",
|
|
"This setting turns on very verbose groups debugging",
|
|
HandleDebugGroupsVerbose);
|
|
}
|
|
}
|
|
|
|
private void HandleDebugGroupsVerbose(object modules, string[] args)
|
|
{
|
|
if (args.Length < 4)
|
|
{
|
|
MainConsole.Instance.Output("Usage: debug groups verbose <true|false>");
|
|
return;
|
|
}
|
|
|
|
bool verbose = false;
|
|
if (!bool.TryParse(args[3], out verbose))
|
|
{
|
|
MainConsole.Instance.Output("Usage: debug groups verbose <true|false>");
|
|
return;
|
|
}
|
|
|
|
m_debugEnabled = verbose;
|
|
|
|
MainConsole.Instance.OutputFormat("{0} verbose logging set to {1}", Name, m_debugEnabled);
|
|
}
|
|
|
|
public void RegionLoaded(Scene scene)
|
|
{
|
|
if (!m_groupsEnabled)
|
|
return;
|
|
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
if (m_groupData == null)
|
|
{
|
|
m_groupData = scene.RequestModuleInterface<IGroupsServicesConnector>();
|
|
|
|
// No Groups Service Connector, then nothing works...
|
|
if (m_groupData == null)
|
|
{
|
|
m_groupsEnabled = false;
|
|
m_log.Error("[GROUPS]: Could not get IGroupsServicesConnector");
|
|
Close();
|
|
return;
|
|
}
|
|
}
|
|
|
|
if (m_msgTransferModule == null)
|
|
{
|
|
m_msgTransferModule = scene.RequestModuleInterface<IMessageTransferModule>();
|
|
|
|
// No message transfer module, no notices, group invites, rejects, ejects, etc
|
|
if (m_msgTransferModule == null)
|
|
{
|
|
m_groupsEnabled = false;
|
|
m_log.Warn("[GROUPS]: Could not get IMessageTransferModule");
|
|
}
|
|
}
|
|
|
|
if (m_groupsMessagingModule == null)
|
|
{
|
|
m_groupsMessagingModule = scene.RequestModuleInterface<IGroupsMessagingModule>();
|
|
|
|
// No message transfer module, no notices, group invites, rejects, ejects, etc
|
|
if (m_groupsMessagingModule == null)
|
|
m_log.Warn("[GROUPS]: Could not get IGroupsMessagingModule");
|
|
}
|
|
|
|
lock (m_sceneList)
|
|
{
|
|
m_sceneList.Add(scene);
|
|
}
|
|
|
|
scene.EventManager.OnNewClient += OnNewClient;
|
|
scene.EventManager.OnIncomingInstantMessage += OnGridInstantMessage;
|
|
// The InstantMessageModule itself doesn't do this,
|
|
// so lets see if things explode if we don't do it
|
|
// scene.EventManager.OnClientClosed += OnClientClosed;
|
|
|
|
}
|
|
|
|
public void RemoveRegion(Scene scene)
|
|
{
|
|
if (!m_groupsEnabled)
|
|
return;
|
|
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
lock (m_sceneList)
|
|
{
|
|
m_sceneList.Remove(scene);
|
|
}
|
|
}
|
|
|
|
public void Close()
|
|
{
|
|
if (!m_groupsEnabled)
|
|
return;
|
|
|
|
if (m_debugEnabled) m_log.Debug("[GROUPS]: Shutting down Groups module.");
|
|
}
|
|
|
|
public Type ReplaceableInterface
|
|
{
|
|
get { return null; }
|
|
}
|
|
|
|
public string Name
|
|
{
|
|
get { return "GroupsModule"; }
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region ISharedRegionModule Members
|
|
|
|
public void PostInitialise()
|
|
{
|
|
// NoOp
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region EventHandlers
|
|
private void OnNewClient(IClientAPI client)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
client.OnUUIDGroupNameRequest += HandleUUIDGroupNameRequest;
|
|
client.OnAgentDataUpdateRequest += OnAgentDataUpdateRequest;
|
|
client.OnRequestAvatarProperties += OnRequestAvatarProperties;
|
|
|
|
// Used for Notices and Group Invites/Accept/Reject
|
|
client.OnInstantMessage += OnInstantMessage;
|
|
|
|
// Send client their groups information.
|
|
SendAgentGroupDataUpdate(client, client.AgentId);
|
|
}
|
|
|
|
private void OnRequestAvatarProperties(IClientAPI remoteClient, UUID avatarID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
//GroupMembershipData[] avatarGroups = m_groupData.GetAgentGroupMemberships(GetRequestingAgentID(remoteClient), avatarID).ToArray();
|
|
GroupMembershipData[] avatarGroups = GetProfileListedGroupMemberships(remoteClient, avatarID);
|
|
remoteClient.SendAvatarGroupsReply(avatarID, avatarGroups);
|
|
}
|
|
|
|
/*
|
|
* This becomes very problematic in a shared module. In a shared module you may have more then one
|
|
* reference to IClientAPI's, one for 0 or 1 root connections, and 0 or more child connections.
|
|
* The OnClientClosed event does not provide anything to indicate which one of those should be closed
|
|
* nor does it provide what scene it was from so that the specific reference can be looked up.
|
|
* The InstantMessageModule.cs does not currently worry about unregistering the handles,
|
|
* and it should be an issue, since it's the client that references us not the other way around
|
|
* , so as long as we don't keep a reference to the client laying around, the client can still be GC'ed
|
|
private void OnClientClosed(UUID AgentId)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
lock (m_ActiveClients)
|
|
{
|
|
if (m_ActiveClients.ContainsKey(AgentId))
|
|
{
|
|
IClientAPI client = m_ActiveClients[AgentId];
|
|
client.OnUUIDGroupNameRequest -= HandleUUIDGroupNameRequest;
|
|
client.OnAgentDataUpdateRequest -= OnAgentDataUpdateRequest;
|
|
client.OnDirFindQuery -= OnDirFindQuery;
|
|
client.OnInstantMessage -= OnInstantMessage;
|
|
|
|
m_ActiveClients.Remove(AgentId);
|
|
}
|
|
else
|
|
{
|
|
if (m_debugEnabled) m_log.WarnFormat("[GROUPS]: Client closed that wasn't registered here.");
|
|
}
|
|
|
|
|
|
}
|
|
}
|
|
*/
|
|
|
|
private void OnAgentDataUpdateRequest(IClientAPI remoteClient, UUID dataForAgentID, UUID sessionID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
UUID activeGroupID = UUID.Zero;
|
|
string activeGroupTitle = string.Empty;
|
|
string activeGroupName = string.Empty;
|
|
ulong activeGroupPowers = (ulong)GroupPowers.None;
|
|
|
|
GroupMembershipData membership = m_groupData.GetAgentActiveMembership(GetRequestingAgentID(remoteClient), dataForAgentID);
|
|
if (membership != null)
|
|
{
|
|
activeGroupID = membership.GroupID;
|
|
activeGroupTitle = membership.GroupTitle;
|
|
activeGroupPowers = membership.GroupPowers;
|
|
}
|
|
|
|
SendAgentDataUpdate(remoteClient, dataForAgentID, activeGroupID, activeGroupName, activeGroupPowers, activeGroupTitle);
|
|
|
|
SendScenePresenceUpdate(dataForAgentID, activeGroupTitle);
|
|
}
|
|
|
|
private void HandleUUIDGroupNameRequest(UUID GroupID, IClientAPI remoteClient)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
string GroupName;
|
|
|
|
GroupRecord group = m_groupData.GetGroupRecord(GetRequestingAgentID(remoteClient), GroupID, null);
|
|
if (group != null)
|
|
{
|
|
GroupName = group.GroupName;
|
|
}
|
|
else
|
|
{
|
|
GroupName = "Unknown";
|
|
}
|
|
|
|
remoteClient.SendGroupNameReply(GroupID, GroupName);
|
|
}
|
|
|
|
private void OnInstantMessage(IClientAPI remoteClient, GridInstantMessage im)
|
|
{
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: {0} called for {1}, message type {2}",
|
|
System.Reflection.MethodBase.GetCurrentMethod().Name, remoteClient.Name, (InstantMessageDialog)im.dialog);
|
|
|
|
// Group invitations
|
|
if ((im.dialog == (byte)InstantMessageDialog.GroupInvitationAccept) || (im.dialog == (byte)InstantMessageDialog.GroupInvitationDecline))
|
|
{
|
|
UUID inviteID = new UUID(im.imSessionID);
|
|
GroupInviteInfo inviteInfo = m_groupData.GetAgentToGroupInvite(GetRequestingAgentID(remoteClient), inviteID);
|
|
|
|
if (inviteInfo == null)
|
|
{
|
|
if (m_debugEnabled) m_log.WarnFormat("[GROUPS]: Received an Invite IM for an invite that does not exist {0}.", inviteID);
|
|
return;
|
|
}
|
|
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: Invite is for Agent {0} to Group {1}.", inviteInfo.AgentID, inviteInfo.GroupID);
|
|
|
|
UUID fromAgentID = new UUID(im.fromAgentID);
|
|
if ((inviteInfo != null) && (fromAgentID == inviteInfo.AgentID))
|
|
{
|
|
// Accept
|
|
if (im.dialog == (byte)InstantMessageDialog.GroupInvitationAccept)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: Received an accept invite notice.");
|
|
|
|
// and the sessionid is the role
|
|
m_groupData.AddAgentToGroup(GetRequestingAgentID(remoteClient), inviteInfo.AgentID, inviteInfo.GroupID, inviteInfo.RoleID);
|
|
|
|
GridInstantMessage msg = new GridInstantMessage();
|
|
msg.imSessionID = UUID.Zero.Guid;
|
|
msg.fromAgentID = UUID.Zero.Guid;
|
|
msg.toAgentID = inviteInfo.AgentID.Guid;
|
|
msg.timestamp = (uint)Util.UnixTimeSinceEpoch();
|
|
msg.fromAgentName = "Groups";
|
|
msg.message = string.Format("You have been added to the group.");
|
|
msg.dialog = (byte)OpenMetaverse.InstantMessageDialog.MessageBox;
|
|
msg.fromGroup = false;
|
|
msg.offline = (byte)0;
|
|
msg.ParentEstateID = 0;
|
|
msg.Position = Vector3.Zero;
|
|
msg.RegionID = UUID.Zero.Guid;
|
|
msg.binaryBucket = new byte[0];
|
|
|
|
OutgoingInstantMessage(msg, inviteInfo.AgentID);
|
|
|
|
UpdateAllClientsWithGroupInfo(inviteInfo.AgentID);
|
|
|
|
// TODO: If the inviter is still online, they need an agent dataupdate
|
|
// and maybe group membership updates for the invitee
|
|
|
|
m_groupData.RemoveAgentToGroupInvite(GetRequestingAgentID(remoteClient), inviteID);
|
|
}
|
|
|
|
// Reject
|
|
if (im.dialog == (byte)InstantMessageDialog.GroupInvitationDecline)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: Received a reject invite notice.");
|
|
m_groupData.RemoveAgentToGroupInvite(GetRequestingAgentID(remoteClient), inviteID);
|
|
}
|
|
}
|
|
}
|
|
|
|
// Group notices
|
|
if ((im.dialog == (byte)InstantMessageDialog.GroupNotice))
|
|
{
|
|
if (!m_groupNoticesEnabled)
|
|
{
|
|
return;
|
|
}
|
|
|
|
UUID GroupID = new UUID(im.toAgentID);
|
|
if (m_groupData.GetGroupRecord(GetRequestingAgentID(remoteClient), GroupID, null) != null)
|
|
{
|
|
UUID NoticeID = UUID.Random();
|
|
string Subject = im.message.Substring(0, im.message.IndexOf('|'));
|
|
string Message = im.message.Substring(Subject.Length + 1);
|
|
|
|
InventoryItemBase item = null;
|
|
bool hasAttachment = false;
|
|
UUID itemID = UUID.Zero; //Assignment to quiet compiler
|
|
UUID ownerID = UUID.Zero; //Assignment to quiet compiler
|
|
byte[] bucket;
|
|
|
|
if (im.binaryBucket.Length >= 1 && im.binaryBucket[0] > 0)
|
|
{
|
|
string binBucket = OpenMetaverse.Utils.BytesToString(im.binaryBucket);
|
|
binBucket = binBucket.Remove(0, 14).Trim();
|
|
|
|
OSDMap binBucketOSD = (OSDMap)OSDParser.DeserializeLLSDXml(binBucket);
|
|
if (binBucketOSD is OSD)
|
|
{
|
|
OSDMap binBucketMap = (OSDMap)binBucketOSD;
|
|
|
|
itemID = binBucketMap["item_id"].AsUUID();
|
|
ownerID = binBucketMap["owner_id"].AsUUID();
|
|
|
|
//Attempt to get the details of the attached item.
|
|
//If sender doesn't own the attachment, the item
|
|
//variable will be set to null and attachment will
|
|
//not be included with the group notice.
|
|
Scene scene = (Scene)remoteClient.Scene;
|
|
item = new InventoryItemBase(itemID, ownerID);
|
|
item = scene.InventoryService.GetItem(item);
|
|
|
|
if (item != null)
|
|
{
|
|
//Got item details so include the attachment.
|
|
hasAttachment = true;
|
|
}
|
|
}
|
|
else
|
|
{
|
|
m_log.DebugFormat("[Groups]: Received OSD with unexpected type: {0}", binBucketOSD.GetType());
|
|
}
|
|
}
|
|
|
|
if (hasAttachment)
|
|
{
|
|
//Bucket contains information about attachment.
|
|
//
|
|
//Byte offset and description of bucket data:
|
|
//0: 1 byte indicating if attachment is present
|
|
//1: 1 byte indicating the type of attachment
|
|
//2: 16 bytes - Group UUID
|
|
//18: 16 bytes - UUID of the attachment owner
|
|
//34: 16 bytes - UUID of the attachment
|
|
//50: variable - Name of the attachment
|
|
//??: NUL byte to terminate the attachment name
|
|
byte[] name = Encoding.UTF8.GetBytes(item.Name);
|
|
bucket = new byte[51 + name.Length];//3 bytes, 3 UUIDs, and name
|
|
bucket[0] = 1; //Has attachment flag
|
|
bucket[1] = (byte)item.InvType; //Type of Attachment
|
|
GroupID.ToBytes(bucket, 2);
|
|
ownerID.ToBytes(bucket, 18);
|
|
itemID.ToBytes(bucket, 34);
|
|
name.CopyTo(bucket, 50);
|
|
}
|
|
else
|
|
{
|
|
bucket = new byte[19];
|
|
bucket[0] = 0; //Has attachment flag
|
|
bucket[1] = 0; //Type of attachment
|
|
GroupID.ToBytes(bucket, 2);
|
|
bucket[18] = 0; //NUL terminate name of attachment
|
|
}
|
|
|
|
m_groupData.AddGroupNotice(GetRequestingAgentID(remoteClient), GroupID, NoticeID, im.fromAgentName, Subject, Message, bucket);
|
|
if (OnNewGroupNotice != null)
|
|
{
|
|
OnNewGroupNotice(GroupID, NoticeID);
|
|
}
|
|
|
|
if (m_debugEnabled)
|
|
{
|
|
foreach (GroupMembersData member in m_groupData.GetGroupMembers(GetRequestingAgentID(remoteClient), GroupID))
|
|
{
|
|
if (m_debugEnabled)
|
|
{
|
|
UserAccount targetUser
|
|
= m_sceneList[0].UserAccountService.GetUserAccount(
|
|
remoteClient.Scene.RegionInfo.ScopeID, member.AgentID);
|
|
|
|
if (targetUser != null)
|
|
{
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: Prepping group notice {0} for agent: {1} who Accepts Notices ({2})",
|
|
NoticeID, targetUser.FirstName + " " + targetUser.LastName, member.AcceptNotices);
|
|
}
|
|
else
|
|
{
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: Prepping group notice {0} for agent: {1} who Accepts Notices ({2})",
|
|
NoticeID, member.AgentID, member.AcceptNotices);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
GridInstantMessage msg
|
|
= CreateGroupNoticeIM(UUID.Zero, NoticeID, (byte)OpenMetaverse.InstantMessageDialog.GroupNotice);
|
|
|
|
if (m_groupsMessagingModule != null)
|
|
m_groupsMessagingModule.SendMessageToGroup(
|
|
msg, GroupID, remoteClient.AgentId, gmd => gmd.AcceptNotices);
|
|
}
|
|
}
|
|
|
|
if (im.dialog == (byte)InstantMessageDialog.GroupNoticeInventoryAccepted)
|
|
{
|
|
//Is bucket large enough to hold UUID of the attachment?
|
|
if (im.binaryBucket.Length < 16)
|
|
return;
|
|
|
|
UUID noticeID = new UUID(im.imSessionID);
|
|
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat("[GROUPS]: Requesting notice {0} for {1}", noticeID, remoteClient.AgentId);
|
|
|
|
GroupNoticeInfo notice = m_groupData.GetGroupNotice(GetRequestingAgentID(remoteClient), noticeID);
|
|
if (notice != null)
|
|
{
|
|
UUID giver = new UUID(notice.BinaryBucket, 18);
|
|
UUID attachmentUUID = new UUID(notice.BinaryBucket, 34);
|
|
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat("[Groups]: Giving inventory from {0} to {1}", giver, remoteClient.AgentId);
|
|
|
|
string message;
|
|
InventoryItemBase itemCopy = ((Scene)(remoteClient.Scene)).GiveInventoryItem(remoteClient.AgentId,
|
|
giver, attachmentUUID, out message);
|
|
|
|
if (itemCopy == null)
|
|
{
|
|
remoteClient.SendAgentAlertMessage(message, false);
|
|
return;
|
|
}
|
|
|
|
remoteClient.SendInventoryItemCreateUpdate(itemCopy, 0);
|
|
}
|
|
else
|
|
{
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: Could not find notice {0} for {1} on GroupNoticeInventoryAccepted.",
|
|
noticeID, remoteClient.AgentId);
|
|
}
|
|
}
|
|
|
|
// Interop, received special 210 code for ejecting a group member
|
|
// this only works within the comms servers domain, and won't work hypergrid
|
|
// TODO:FIXME: Use a presence server of some kind to find out where the
|
|
// client actually is, and try contacting that region directly to notify them,
|
|
// or provide the notification via xmlrpc update queue
|
|
if ((im.dialog == 210))
|
|
{
|
|
// This is sent from the region that the ejectee was ejected from
|
|
// if it's being delivered here, then the ejectee is here
|
|
// so we need to send local updates to the agent.
|
|
|
|
UUID ejecteeID = new UUID(im.toAgentID);
|
|
|
|
im.dialog = (byte)InstantMessageDialog.MessageFromAgent;
|
|
OutgoingInstantMessage(im, ejecteeID);
|
|
|
|
IClientAPI ejectee = GetActiveClient(ejecteeID);
|
|
if (ejectee != null)
|
|
{
|
|
UUID groupID = new UUID(im.imSessionID);
|
|
ejectee.SendAgentDropGroup(groupID);
|
|
}
|
|
}
|
|
}
|
|
|
|
private void OnGridInstantMessage(GridInstantMessage msg)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Trigger the above event handler
|
|
OnInstantMessage(null, msg);
|
|
|
|
// If a message from a group arrives here, it may need to be forwarded to a local client
|
|
if (msg.fromGroup == true)
|
|
{
|
|
switch (msg.dialog)
|
|
{
|
|
case (byte)InstantMessageDialog.GroupInvitation:
|
|
case (byte)InstantMessageDialog.GroupNotice:
|
|
UUID toAgentID = new UUID(msg.toAgentID);
|
|
IClientAPI localClient = GetActiveClient(toAgentID);
|
|
if (localClient != null)
|
|
{
|
|
localClient.SendInstantMessage(msg);
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region IGroupsModule Members
|
|
|
|
public event NewGroupNotice OnNewGroupNotice;
|
|
|
|
public GroupRecord GetGroupRecord(UUID GroupID)
|
|
{
|
|
return m_groupData.GetGroupRecord(UUID.Zero, GroupID, null);
|
|
}
|
|
|
|
public GroupRecord GetGroupRecord(string name)
|
|
{
|
|
return m_groupData.GetGroupRecord(UUID.Zero, UUID.Zero, name);
|
|
}
|
|
|
|
public void ActivateGroup(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
m_groupData.SetAgentActiveGroup(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
// Changing active group changes title, active powers, all kinds of things
|
|
// anyone who is in any region that can see this client, should probably be
|
|
// updated with new group info. At a minimum, they should get ScenePresence
|
|
// updated with new title.
|
|
UpdateAllClientsWithGroupInfo(GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
/// <summary>
|
|
/// Get the Role Titles for an Agent, for a specific group
|
|
/// </summary>
|
|
public List<GroupTitlesData> GroupTitlesRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
|
|
List<GroupRolesData> agentRoles = m_groupData.GetAgentGroupRoles(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID);
|
|
GroupMembershipData agentMembership = m_groupData.GetAgentGroupMembership(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
List<GroupTitlesData> titles = new List<GroupTitlesData>();
|
|
foreach (GroupRolesData role in agentRoles)
|
|
{
|
|
GroupTitlesData title = new GroupTitlesData();
|
|
title.Name = role.Name;
|
|
if (agentMembership != null)
|
|
{
|
|
title.Selected = agentMembership.ActiveRole == role.RoleID;
|
|
}
|
|
title.UUID = role.RoleID;
|
|
|
|
titles.Add(title);
|
|
}
|
|
|
|
return titles;
|
|
}
|
|
|
|
public List<GroupMembersData> GroupMembersRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: GroupMembersRequest called for {0} from client {1}", groupID, remoteClient.Name);
|
|
|
|
List<GroupMembersData> data = m_groupData.GetGroupMembers(GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
if (m_debugEnabled)
|
|
{
|
|
foreach (GroupMembersData member in data)
|
|
{
|
|
m_log.DebugFormat("[GROUPS]: Member({0}) - IsOwner({1})", member.AgentID, member.IsOwner);
|
|
}
|
|
}
|
|
|
|
return data;
|
|
|
|
}
|
|
|
|
public List<GroupRolesData> GroupRoleDataRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
List<GroupRolesData> data = m_groupData.GetGroupRoles(GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
return data;
|
|
}
|
|
|
|
public List<GroupRoleMembersData> GroupRoleMembersRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
List<GroupRoleMembersData> data = m_groupData.GetGroupRoleMembers(GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
if (m_debugEnabled)
|
|
{
|
|
foreach (GroupRoleMembersData member in data)
|
|
{
|
|
m_log.DebugFormat("[GROUPS]: Member({0}) - Role({1})", member.MemberID, member.RoleID);
|
|
}
|
|
}
|
|
return data;
|
|
}
|
|
|
|
public GroupProfileData GroupProfileRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
GroupProfileData profile = new GroupProfileData();
|
|
|
|
|
|
GroupRecord groupInfo = m_groupData.GetGroupRecord(GetRequestingAgentID(remoteClient), groupID, null);
|
|
if (groupInfo != null)
|
|
{
|
|
profile.AllowPublish = groupInfo.AllowPublish;
|
|
profile.Charter = groupInfo.Charter;
|
|
profile.FounderID = groupInfo.FounderID;
|
|
profile.GroupID = groupID;
|
|
profile.GroupMembershipCount = m_groupData.GetGroupMembers(GetRequestingAgentID(remoteClient), groupID).Count;
|
|
profile.GroupRolesCount = m_groupData.GetGroupRoles(GetRequestingAgentID(remoteClient), groupID).Count;
|
|
profile.InsigniaID = groupInfo.GroupPicture;
|
|
profile.MaturePublish = groupInfo.MaturePublish;
|
|
profile.MembershipFee = groupInfo.MembershipFee;
|
|
profile.Money = 0; // TODO: Get this from the currency server?
|
|
profile.Name = groupInfo.GroupName;
|
|
profile.OpenEnrollment = groupInfo.OpenEnrollment;
|
|
profile.OwnerRole = groupInfo.OwnerRoleID;
|
|
profile.ShowInList = groupInfo.ShowInList;
|
|
}
|
|
|
|
GroupMembershipData memberInfo = m_groupData.GetAgentGroupMembership(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID);
|
|
if (memberInfo != null)
|
|
{
|
|
profile.MemberTitle = memberInfo.GroupTitle;
|
|
profile.PowersMask = memberInfo.GroupPowers;
|
|
}
|
|
|
|
return profile;
|
|
}
|
|
|
|
public GroupMembershipData[] GetMembershipData(UUID agentID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
return m_groupData.GetAgentGroupMemberships(UUID.Zero, agentID).ToArray();
|
|
}
|
|
|
|
public GroupMembershipData GetMembershipData(UUID groupID, UUID agentID)
|
|
{
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat(
|
|
"[GROUPS]: {0} called with groupID={1}, agentID={2}",
|
|
System.Reflection.MethodBase.GetCurrentMethod().Name, groupID, agentID);
|
|
|
|
return m_groupData.GetAgentGroupMembership(UUID.Zero, agentID, groupID);
|
|
}
|
|
|
|
public void UpdateGroupInfo(IClientAPI remoteClient, UUID groupID, string charter, bool showInList, UUID insigniaID, int membershipFee, bool openEnrollment, bool allowPublish, bool maturePublish)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Note: Permissions checking for modification rights is handled by the Groups Server/Service
|
|
m_groupData.UpdateGroup(GetRequestingAgentID(remoteClient), groupID, charter, showInList, insigniaID, membershipFee, openEnrollment, allowPublish, maturePublish);
|
|
}
|
|
|
|
public void SetGroupAcceptNotices(IClientAPI remoteClient, UUID groupID, bool acceptNotices, bool listInProfile)
|
|
{
|
|
// Note: Permissions checking for modification rights is handled by the Groups Server/Service
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
m_groupData.SetAgentGroupInfo(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID, acceptNotices, listInProfile);
|
|
}
|
|
|
|
public UUID CreateGroup(IClientAPI remoteClient, string name, string charter, bool showInList, UUID insigniaID, int membershipFee, bool openEnrollment, bool allowPublish, bool maturePublish)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
if (m_groupData.GetGroupRecord(GetRequestingAgentID(remoteClient), UUID.Zero, name) != null)
|
|
{
|
|
remoteClient.SendCreateGroupReply(UUID.Zero, false, "A group with the same name already exists.");
|
|
return UUID.Zero;
|
|
}
|
|
|
|
// check user level
|
|
ScenePresence avatar = null;
|
|
Scene scene = (Scene)remoteClient.Scene;
|
|
scene.TryGetScenePresence(remoteClient.AgentId, out avatar);
|
|
|
|
if (avatar != null)
|
|
{
|
|
if (avatar.UserLevel < m_levelGroupCreate)
|
|
{
|
|
remoteClient.SendCreateGroupReply(UUID.Zero, false, "You have got insufficient permissions to create a group.");
|
|
return UUID.Zero;
|
|
}
|
|
}
|
|
|
|
// check funds
|
|
// is there is a money module present ?
|
|
IMoneyModule money = scene.RequestModuleInterface<IMoneyModule>();
|
|
if (money != null)
|
|
{
|
|
// do the transaction, that is if the agent has got sufficient funds
|
|
if (!money.AmountCovered(remoteClient.AgentId, money.GroupCreationCharge)) {
|
|
remoteClient.SendCreateGroupReply(UUID.Zero, false, "You have got insufficient funds to create a group.");
|
|
return UUID.Zero;
|
|
}
|
|
money.ApplyCharge(GetRequestingAgentID(remoteClient), money.GroupCreationCharge, MoneyTransactionType.GroupCreate);
|
|
}
|
|
UUID groupID = m_groupData.CreateGroup(GetRequestingAgentID(remoteClient), name, charter, showInList, insigniaID, membershipFee, openEnrollment, allowPublish, maturePublish, GetRequestingAgentID(remoteClient));
|
|
|
|
remoteClient.SendCreateGroupReply(groupID, true, "Group created successfullly");
|
|
|
|
// Update the founder with new group information.
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
|
|
return groupID;
|
|
}
|
|
|
|
public GroupNoticeData[] GroupNoticesListRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// ToDo: check if agent is a member of group and is allowed to see notices?
|
|
|
|
return m_groupData.GetGroupNotices(GetRequestingAgentID(remoteClient), groupID).ToArray();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Get the title of the agent's current role.
|
|
/// </summary>
|
|
public string GetGroupTitle(UUID avatarID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
GroupMembershipData membership = m_groupData.GetAgentActiveMembership(UUID.Zero, avatarID);
|
|
if (membership != null)
|
|
{
|
|
return membership.GroupTitle;
|
|
}
|
|
return string.Empty;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Change the current Active Group Role for Agent
|
|
/// </summary>
|
|
public void GroupTitleUpdate(IClientAPI remoteClient, UUID groupID, UUID titleRoleID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
m_groupData.SetAgentActiveGroupRole(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID, titleRoleID);
|
|
|
|
// TODO: Not sure what all is needed here, but if the active group role change is for the group
|
|
// the client currently has set active, then we need to do a scene presence update too
|
|
// if (m_groupData.GetAgentActiveMembership(GetRequestingAgentID(remoteClient)).GroupID == GroupID)
|
|
|
|
UpdateAllClientsWithGroupInfo(GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
|
|
public void GroupRoleUpdate(IClientAPI remoteClient, UUID groupID, UUID roleID, string name, string description, string title, ulong powers, byte updateType)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Security Checks are handled in the Groups Service.
|
|
|
|
switch ((OpenMetaverse.GroupRoleUpdate)updateType)
|
|
{
|
|
case OpenMetaverse.GroupRoleUpdate.Create:
|
|
m_groupData.AddGroupRole(GetRequestingAgentID(remoteClient), groupID, UUID.Random(), name, description, title, powers);
|
|
break;
|
|
|
|
case OpenMetaverse.GroupRoleUpdate.Delete:
|
|
m_groupData.RemoveGroupRole(GetRequestingAgentID(remoteClient), groupID, roleID);
|
|
break;
|
|
|
|
case OpenMetaverse.GroupRoleUpdate.UpdateAll:
|
|
case OpenMetaverse.GroupRoleUpdate.UpdateData:
|
|
case OpenMetaverse.GroupRoleUpdate.UpdatePowers:
|
|
if (m_debugEnabled)
|
|
{
|
|
GroupPowers gp = (GroupPowers)powers;
|
|
m_log.DebugFormat("[GROUPS]: Role ({0}) updated with Powers ({1}) ({2})", name, powers.ToString(), gp.ToString());
|
|
}
|
|
m_groupData.UpdateGroupRole(GetRequestingAgentID(remoteClient), groupID, roleID, name, description, title, powers);
|
|
break;
|
|
|
|
case OpenMetaverse.GroupRoleUpdate.NoUpdate:
|
|
default:
|
|
// No Op
|
|
break;
|
|
|
|
}
|
|
|
|
// TODO: This update really should send out updates for everyone in the role that just got changed.
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
public void GroupRoleChanges(IClientAPI remoteClient, UUID groupID, UUID roleID, UUID memberID, uint changes)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
// Todo: Security check
|
|
|
|
switch (changes)
|
|
{
|
|
case 0:
|
|
// Add
|
|
m_groupData.AddAgentToGroupRole(GetRequestingAgentID(remoteClient), memberID, groupID, roleID);
|
|
|
|
break;
|
|
case 1:
|
|
// Remove
|
|
m_groupData.RemoveAgentFromGroupRole(GetRequestingAgentID(remoteClient), memberID, groupID, roleID);
|
|
|
|
break;
|
|
default:
|
|
m_log.ErrorFormat("[GROUPS]: {0} does not understand changes == {1}", System.Reflection.MethodBase.GetCurrentMethod().Name, changes);
|
|
break;
|
|
}
|
|
|
|
// TODO: This update really should send out updates for everyone in the role that just got changed.
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
public void GroupNoticeRequest(IClientAPI remoteClient, UUID groupNoticeID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
GroupNoticeInfo data = m_groupData.GetGroupNotice(GetRequestingAgentID(remoteClient), groupNoticeID);
|
|
|
|
if (data != null)
|
|
{
|
|
GridInstantMessage msg = CreateGroupNoticeIM(remoteClient.AgentId, groupNoticeID, (byte)InstantMessageDialog.GroupNoticeRequested);
|
|
|
|
OutgoingInstantMessage(msg, GetRequestingAgentID(remoteClient));
|
|
}
|
|
}
|
|
|
|
public GridInstantMessage CreateGroupNoticeIM(UUID agentID, UUID groupNoticeID, byte dialog)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
GridInstantMessage msg = new GridInstantMessage();
|
|
byte[] bucket;
|
|
|
|
msg.imSessionID = groupNoticeID.Guid;
|
|
msg.toAgentID = agentID.Guid;
|
|
msg.dialog = dialog;
|
|
msg.fromGroup = true;
|
|
msg.offline = (byte)0;
|
|
msg.ParentEstateID = 0;
|
|
msg.Position = Vector3.Zero;
|
|
msg.RegionID = UUID.Zero.Guid;
|
|
|
|
GroupNoticeInfo info = m_groupData.GetGroupNotice(agentID, groupNoticeID);
|
|
if (info != null)
|
|
{
|
|
msg.fromAgentID = info.GroupID.Guid;
|
|
msg.timestamp = info.noticeData.Timestamp;
|
|
msg.fromAgentName = info.noticeData.FromName;
|
|
msg.message = info.noticeData.Subject + "|" + info.Message;
|
|
|
|
if (info.BinaryBucket[0] > 0)
|
|
{
|
|
//32 is due to not needing space for two of the UUIDs.
|
|
//(Don't need UUID of attachment or its owner in IM)
|
|
//50 offset gets us to start of attachment name.
|
|
//We are skipping the attachment flag, type, and
|
|
//the three UUID fields at the start of the bucket.
|
|
bucket = new byte[info.BinaryBucket.Length-32];
|
|
bucket[0] = 1; //Has attachment
|
|
bucket[1] = info.BinaryBucket[1];
|
|
Array.Copy(info.BinaryBucket, 50,
|
|
bucket, 18, info.BinaryBucket.Length-50);
|
|
}
|
|
else
|
|
{
|
|
bucket = new byte[19];
|
|
bucket[0] = 0; //No attachment
|
|
bucket[1] = 0; //Attachment type
|
|
bucket[18] = 0; //NUL terminate name
|
|
}
|
|
|
|
info.GroupID.ToBytes(bucket, 2);
|
|
msg.binaryBucket = bucket;
|
|
}
|
|
else
|
|
{
|
|
if (m_debugEnabled)
|
|
m_log.DebugFormat("[GROUPS]: Group Notice {0} not found, composing empty message.", groupNoticeID);
|
|
|
|
msg.fromAgentID = UUID.Zero.Guid;
|
|
msg.timestamp = (uint)Util.UnixTimeSinceEpoch();
|
|
msg.fromAgentName = string.Empty;
|
|
msg.message = string.Empty;
|
|
msg.binaryBucket = new byte[0];
|
|
}
|
|
|
|
return msg;
|
|
}
|
|
|
|
public void SendAgentGroupDataUpdate(IClientAPI remoteClient)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Send agent information about his groups
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
public void JoinGroupRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Should check to see if OpenEnrollment, or if there's an outstanding invitation
|
|
m_groupData.AddAgentToGroup(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID, UUID.Zero);
|
|
|
|
remoteClient.SendJoinGroupReply(groupID, true);
|
|
|
|
// Should this send updates to everyone in the group?
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
public void LeaveGroupRequest(IClientAPI remoteClient, UUID groupID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
m_groupData.RemoveAgentFromGroup(GetRequestingAgentID(remoteClient), GetRequestingAgentID(remoteClient), groupID);
|
|
|
|
remoteClient.SendLeaveGroupReply(groupID, true);
|
|
|
|
remoteClient.SendAgentDropGroup(groupID);
|
|
|
|
// SL sends out notifcations to the group messaging session that the person has left
|
|
// Should this also update everyone who is in the group?
|
|
SendAgentGroupDataUpdate(remoteClient, GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
public void EjectGroupMemberRequest(IClientAPI remoteClient, UUID groupID, UUID ejecteeID)
|
|
{
|
|
EjectGroupMember(remoteClient, GetRequestingAgentID(remoteClient), groupID, ejecteeID);
|
|
}
|
|
|
|
public void EjectGroupMember(IClientAPI remoteClient, UUID agentID, UUID groupID, UUID ejecteeID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// Todo: Security check?
|
|
m_groupData.RemoveAgentFromGroup(agentID, ejecteeID, groupID);
|
|
|
|
string agentName;
|
|
RegionInfo regionInfo;
|
|
|
|
// remoteClient provided or just agentID?
|
|
if (remoteClient != null)
|
|
{
|
|
agentName = remoteClient.Name;
|
|
regionInfo = remoteClient.Scene.RegionInfo;
|
|
remoteClient.SendEjectGroupMemberReply(agentID, groupID, true);
|
|
}
|
|
else
|
|
{
|
|
IClientAPI client = GetActiveClient(agentID);
|
|
|
|
if (client != null)
|
|
{
|
|
agentName = client.Name;
|
|
regionInfo = client.Scene.RegionInfo;
|
|
client.SendEjectGroupMemberReply(agentID, groupID, true);
|
|
}
|
|
else
|
|
{
|
|
regionInfo = m_sceneList[0].RegionInfo;
|
|
UserAccount acc = m_sceneList[0].UserAccountService.GetUserAccount(regionInfo.ScopeID, agentID);
|
|
|
|
if (acc != null)
|
|
{
|
|
agentName = acc.FirstName + " " + acc.LastName;
|
|
}
|
|
else
|
|
{
|
|
agentName = "Unknown member";
|
|
}
|
|
}
|
|
}
|
|
|
|
GroupRecord groupInfo = m_groupData.GetGroupRecord(agentID, groupID, null);
|
|
|
|
UserAccount account = m_sceneList[0].UserAccountService.GetUserAccount(regionInfo.ScopeID, ejecteeID);
|
|
if ((groupInfo == null) || (account == null))
|
|
{
|
|
return;
|
|
}
|
|
|
|
// Send Message to Ejectee
|
|
GridInstantMessage msg = new GridInstantMessage();
|
|
|
|
msg.imSessionID = UUID.Zero.Guid;
|
|
msg.fromAgentID = agentID.Guid;
|
|
// msg.fromAgentID = info.GroupID;
|
|
msg.toAgentID = ejecteeID.Guid;
|
|
//msg.timestamp = (uint)Util.UnixTimeSinceEpoch();
|
|
msg.timestamp = 0;
|
|
msg.fromAgentName = agentName;
|
|
msg.message = string.Format("You have been ejected from '{1}' by {0}.", agentName, groupInfo.GroupName);
|
|
msg.dialog = (byte)OpenMetaverse.InstantMessageDialog.MessageFromAgent;
|
|
msg.fromGroup = false;
|
|
msg.offline = (byte)0;
|
|
msg.ParentEstateID = 0;
|
|
msg.Position = Vector3.Zero;
|
|
msg.RegionID = regionInfo.RegionID.Guid;
|
|
msg.binaryBucket = new byte[0];
|
|
OutgoingInstantMessage(msg, ejecteeID);
|
|
|
|
// Message to ejector
|
|
// Interop, received special 210 code for ejecting a group member
|
|
// this only works within the comms servers domain, and won't work hypergrid
|
|
// TODO:FIXME: Use a presence server of some kind to find out where the
|
|
// client actually is, and try contacting that region directly to notify them,
|
|
// or provide the notification via xmlrpc update queue
|
|
|
|
msg = new GridInstantMessage();
|
|
msg.imSessionID = UUID.Zero.Guid;
|
|
msg.fromAgentID = agentID.Guid;
|
|
msg.toAgentID = agentID.Guid;
|
|
msg.timestamp = 0;
|
|
msg.fromAgentName = agentName;
|
|
if (account != null)
|
|
{
|
|
msg.message = string.Format("{2} has been ejected from '{1}' by {0}.", agentName, groupInfo.GroupName, account.FirstName + " " + account.LastName);
|
|
}
|
|
else
|
|
{
|
|
msg.message = string.Format("{2} has been ejected from '{1}' by {0}.", agentName, groupInfo.GroupName, "Unknown member");
|
|
}
|
|
msg.dialog = (byte)210; //interop
|
|
msg.fromGroup = false;
|
|
msg.offline = (byte)0;
|
|
msg.ParentEstateID = 0;
|
|
msg.Position = Vector3.Zero;
|
|
msg.RegionID = regionInfo.RegionID.Guid;
|
|
msg.binaryBucket = new byte[0];
|
|
OutgoingInstantMessage(msg, agentID);
|
|
|
|
|
|
// SL sends out messages to everyone in the group
|
|
// Who all should receive updates and what should they be updated with?
|
|
UpdateAllClientsWithGroupInfo(ejecteeID);
|
|
}
|
|
|
|
public void InviteGroupRequest(IClientAPI remoteClient, UUID groupID, UUID invitedAgentID, UUID roleID)
|
|
{
|
|
InviteGroup(remoteClient, GetRequestingAgentID(remoteClient), groupID, invitedAgentID, roleID);
|
|
}
|
|
|
|
public void InviteGroup(IClientAPI remoteClient, UUID agentID, UUID groupID, UUID invitedAgentID, UUID roleID)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
string agentName;
|
|
RegionInfo regionInfo;
|
|
|
|
// remoteClient provided or just agentID?
|
|
if (remoteClient != null)
|
|
{
|
|
agentName = remoteClient.Name;
|
|
regionInfo = remoteClient.Scene.RegionInfo;
|
|
}
|
|
else
|
|
{
|
|
IClientAPI client = GetActiveClient(agentID);
|
|
|
|
if (client != null)
|
|
{
|
|
agentName = client.Name;
|
|
regionInfo = client.Scene.RegionInfo;
|
|
}
|
|
else
|
|
{
|
|
regionInfo = m_sceneList[0].RegionInfo;
|
|
UserAccount account = m_sceneList[0].UserAccountService.GetUserAccount(regionInfo.ScopeID, agentID);
|
|
|
|
if (account != null)
|
|
{
|
|
agentName = account.FirstName + " " + account.LastName;
|
|
}
|
|
else
|
|
{
|
|
agentName = "Unknown member";
|
|
}
|
|
}
|
|
}
|
|
|
|
// Todo: Security check, probably also want to send some kind of notification
|
|
UUID InviteID = UUID.Random();
|
|
|
|
m_groupData.AddAgentToGroupInvite(agentID, InviteID, groupID, roleID, invitedAgentID);
|
|
|
|
// Check to see if the invite went through, if it did not then it's possible
|
|
// the remoteClient did not validate or did not have permission to invite.
|
|
GroupInviteInfo inviteInfo = m_groupData.GetAgentToGroupInvite(agentID, InviteID);
|
|
|
|
if (inviteInfo != null)
|
|
{
|
|
if (m_msgTransferModule != null)
|
|
{
|
|
Guid inviteUUID = InviteID.Guid;
|
|
|
|
GridInstantMessage msg = new GridInstantMessage();
|
|
|
|
msg.imSessionID = inviteUUID;
|
|
|
|
// msg.fromAgentID = agentID.Guid;
|
|
msg.fromAgentID = groupID.Guid;
|
|
msg.toAgentID = invitedAgentID.Guid;
|
|
//msg.timestamp = (uint)Util.UnixTimeSinceEpoch();
|
|
msg.timestamp = 0;
|
|
msg.fromAgentName = agentName;
|
|
msg.message = string.Format("{0} has invited you to join a group. There is no cost to join this group.", agentName);
|
|
msg.dialog = (byte)OpenMetaverse.InstantMessageDialog.GroupInvitation;
|
|
msg.fromGroup = true;
|
|
msg.offline = (byte)0;
|
|
msg.ParentEstateID = 0;
|
|
msg.Position = Vector3.Zero;
|
|
msg.RegionID = regionInfo.RegionID.Guid;
|
|
msg.binaryBucket = new byte[20];
|
|
|
|
OutgoingInstantMessage(msg, invitedAgentID);
|
|
}
|
|
}
|
|
}
|
|
|
|
public List<DirGroupsReplyData> FindGroups(IClientAPI remoteClient, string query)
|
|
{
|
|
return m_groupData.FindGroups(GetRequestingAgentID(remoteClient), query);
|
|
}
|
|
|
|
|
|
#endregion
|
|
|
|
#region Client/Update Tools
|
|
|
|
/// <summary>
|
|
/// Try to find an active IClientAPI reference for agentID giving preference to root connections
|
|
/// </summary>
|
|
private IClientAPI GetActiveClient(UUID agentID)
|
|
{
|
|
IClientAPI child = null;
|
|
|
|
// Try root avatar first
|
|
foreach (Scene scene in m_sceneList)
|
|
{
|
|
ScenePresence sp = scene.GetScenePresence(agentID);
|
|
if (sp != null)
|
|
{
|
|
if (!sp.IsChildAgent)
|
|
{
|
|
return sp.ControllingClient;
|
|
}
|
|
else
|
|
{
|
|
child = sp.ControllingClient;
|
|
}
|
|
}
|
|
}
|
|
|
|
// If we didn't find a root, then just return whichever child we found, or null if none
|
|
return child;
|
|
}
|
|
|
|
/// <summary>
|
|
/// Send 'remoteClient' the group membership 'data' for agent 'dataForAgentID'.
|
|
/// </summary>
|
|
private void SendGroupMembershipInfoViaCaps(IClientAPI remoteClient, UUID dataForAgentID, GroupMembershipData[] data)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
OSDArray AgentData = new OSDArray(1);
|
|
OSDMap AgentDataMap = new OSDMap(1);
|
|
AgentDataMap.Add("AgentID", OSD.FromUUID(dataForAgentID));
|
|
AgentData.Add(AgentDataMap);
|
|
|
|
OSDArray GroupData = new OSDArray(data.Length);
|
|
OSDArray NewGroupData = new OSDArray(data.Length);
|
|
|
|
foreach (GroupMembershipData membership in data)
|
|
{
|
|
if (GetRequestingAgentID(remoteClient) != dataForAgentID)
|
|
{
|
|
if (!membership.ListInProfile)
|
|
{
|
|
// If we're sending group info to remoteclient about another agent,
|
|
// filter out groups the other agent doesn't want to share.
|
|
continue;
|
|
}
|
|
}
|
|
|
|
OSDMap GroupDataMap = new OSDMap(6);
|
|
OSDMap NewGroupDataMap = new OSDMap(1);
|
|
|
|
GroupDataMap.Add("GroupID", OSD.FromUUID(membership.GroupID));
|
|
GroupDataMap.Add("GroupPowers", OSD.FromULong(membership.GroupPowers));
|
|
GroupDataMap.Add("AcceptNotices", OSD.FromBoolean(membership.AcceptNotices));
|
|
GroupDataMap.Add("GroupInsigniaID", OSD.FromUUID(membership.GroupPicture));
|
|
GroupDataMap.Add("Contribution", OSD.FromInteger(membership.Contribution));
|
|
GroupDataMap.Add("GroupName", OSD.FromString(membership.GroupName));
|
|
NewGroupDataMap.Add("ListInProfile", OSD.FromBoolean(membership.ListInProfile));
|
|
|
|
GroupData.Add(GroupDataMap);
|
|
NewGroupData.Add(NewGroupDataMap);
|
|
}
|
|
|
|
OSDMap llDataStruct = new OSDMap(3);
|
|
llDataStruct.Add("AgentData", AgentData);
|
|
llDataStruct.Add("GroupData", GroupData);
|
|
llDataStruct.Add("NewGroupData", NewGroupData);
|
|
|
|
if (m_debugEnabled)
|
|
{
|
|
m_log.InfoFormat("[GROUPS]: {0}", OSDParser.SerializeJsonString(llDataStruct));
|
|
}
|
|
|
|
IEventQueue queue = remoteClient.Scene.RequestModuleInterface<IEventQueue>();
|
|
|
|
if (queue != null)
|
|
{
|
|
queue.Enqueue(queue.BuildEvent("AgentGroupDataUpdate", llDataStruct), GetRequestingAgentID(remoteClient));
|
|
}
|
|
|
|
}
|
|
|
|
private void SendScenePresenceUpdate(UUID AgentID, string Title)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: Updating scene title for {0} with title: {1}", AgentID, Title);
|
|
|
|
ScenePresence presence = null;
|
|
|
|
foreach (Scene scene in m_sceneList)
|
|
{
|
|
presence = scene.GetScenePresence(AgentID);
|
|
if (presence != null)
|
|
{
|
|
if (presence.Grouptitle != Title)
|
|
{
|
|
presence.Grouptitle = Title;
|
|
|
|
if (! presence.IsChildAgent)
|
|
presence.SendAvatarDataToAllAgents();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Send updates to all clients who might be interested in groups data for dataForClientID
|
|
/// </summary>
|
|
private void UpdateAllClientsWithGroupInfo(UUID dataForClientID)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// TODO: Probably isn't nessesary to update every client in every scene.
|
|
// Need to examine client updates and do only what's nessesary.
|
|
lock (m_sceneList)
|
|
{
|
|
foreach (Scene scene in m_sceneList)
|
|
{
|
|
scene.ForEachClient(delegate(IClientAPI client) { SendAgentGroupDataUpdate(client, dataForClientID); });
|
|
}
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// Update remoteClient with group information about dataForAgentID
|
|
/// </summary>
|
|
private void SendAgentGroupDataUpdate(IClientAPI remoteClient, UUID dataForAgentID)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: {0} called for {1}", System.Reflection.MethodBase.GetCurrentMethod().Name, remoteClient.Name);
|
|
|
|
// TODO: All the client update functions need to be reexamined because most do too much and send too much stuff
|
|
|
|
OnAgentDataUpdateRequest(remoteClient, dataForAgentID, UUID.Zero);
|
|
|
|
// Need to send a group membership update to the client
|
|
// UDP version doesn't seem to behave nicely. But we're going to send it out here
|
|
// with an empty group membership to hopefully remove groups being displayed due
|
|
// to the core Groups Stub
|
|
remoteClient.SendGroupMembership(new GroupMembershipData[0]);
|
|
|
|
GroupMembershipData[] membershipArray = GetProfileListedGroupMemberships(remoteClient, dataForAgentID);
|
|
SendGroupMembershipInfoViaCaps(remoteClient, dataForAgentID, membershipArray);
|
|
remoteClient.SendAvatarGroupsReply(dataForAgentID, membershipArray);
|
|
|
|
if (remoteClient.AgentId == dataForAgentID)
|
|
remoteClient.RefreshGroupMembership();
|
|
}
|
|
|
|
/// <summary>
|
|
/// Get a list of groups memberships for the agent that are marked "ListInProfile"
|
|
/// (unless that agent has a godLike aspect, in which case get all groups)
|
|
/// </summary>
|
|
/// <param name="dataForAgentID"></param>
|
|
/// <returns></returns>
|
|
private GroupMembershipData[] GetProfileListedGroupMemberships(IClientAPI requestingClient, UUID dataForAgentID)
|
|
{
|
|
List<GroupMembershipData> membershipData = m_groupData.GetAgentGroupMemberships(requestingClient.AgentId, dataForAgentID);
|
|
GroupMembershipData[] membershipArray;
|
|
|
|
// cScene and property accessor 'isGod' are in support of the opertions to bypass 'hidden' group attributes for
|
|
// those with a GodLike aspect.
|
|
Scene cScene = (Scene)requestingClient.Scene;
|
|
bool isGod = cScene.Permissions.IsGod(requestingClient.AgentId);
|
|
|
|
if (isGod)
|
|
{
|
|
membershipArray = membershipData.ToArray();
|
|
}
|
|
else
|
|
{
|
|
if (requestingClient.AgentId != dataForAgentID)
|
|
{
|
|
Predicate<GroupMembershipData> showInProfile = delegate(GroupMembershipData membership)
|
|
{
|
|
return membership.ListInProfile;
|
|
};
|
|
|
|
membershipArray = membershipData.FindAll(showInProfile).ToArray();
|
|
}
|
|
else
|
|
{
|
|
membershipArray = membershipData.ToArray();
|
|
}
|
|
}
|
|
|
|
if (m_debugEnabled)
|
|
{
|
|
m_log.InfoFormat("[GROUPS]: Get group membership information for {0} requested by {1}", dataForAgentID, requestingClient.AgentId);
|
|
foreach (GroupMembershipData membership in membershipArray)
|
|
{
|
|
m_log.InfoFormat("[GROUPS]: {0} :: {1} - {2} - {3}", dataForAgentID, membership.GroupName, membership.GroupTitle, membership.GroupPowers);
|
|
}
|
|
}
|
|
|
|
return membershipArray;
|
|
}
|
|
|
|
|
|
private void SendAgentDataUpdate(IClientAPI remoteClient, UUID dataForAgentID, UUID activeGroupID, string activeGroupName, ulong activeGroupPowers, string activeGroupTitle)
|
|
{
|
|
if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
// TODO: All the client update functions need to be reexamined because most do too much and send too much stuff
|
|
UserAccount account = m_sceneList[0].UserAccountService.GetUserAccount(remoteClient.Scene.RegionInfo.ScopeID, dataForAgentID);
|
|
string firstname, lastname;
|
|
if (account != null)
|
|
{
|
|
firstname = account.FirstName;
|
|
lastname = account.LastName;
|
|
}
|
|
else
|
|
{
|
|
firstname = "Unknown";
|
|
lastname = "Unknown";
|
|
}
|
|
|
|
remoteClient.SendAgentDataUpdate(dataForAgentID, activeGroupID, firstname,
|
|
lastname, activeGroupPowers, activeGroupName,
|
|
activeGroupTitle);
|
|
}
|
|
|
|
#endregion
|
|
|
|
#region IM Backed Processes
|
|
|
|
private void OutgoingInstantMessage(GridInstantMessage msg, UUID msgTo)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: {0} called", System.Reflection.MethodBase.GetCurrentMethod().Name);
|
|
|
|
IClientAPI localClient = GetActiveClient(msgTo);
|
|
if (localClient != null)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: MsgTo ({0}) is local, delivering directly", localClient.Name);
|
|
localClient.SendInstantMessage(msg);
|
|
}
|
|
else if (m_msgTransferModule != null)
|
|
{
|
|
if (m_debugEnabled) m_log.InfoFormat("[GROUPS]: MsgTo ({0}) is not local, delivering via TransferModule", msgTo);
|
|
m_msgTransferModule.SendInstantMessage(msg, delegate(bool success) { if (m_debugEnabled) m_log.DebugFormat("[GROUPS]: Message Sent: {0}", success?"Succeeded":"Failed"); });
|
|
}
|
|
}
|
|
|
|
public void NotifyChange(UUID groupID)
|
|
{
|
|
// Notify all group members of a chnge in group roles and/or
|
|
// permissions
|
|
//
|
|
}
|
|
|
|
#endregion
|
|
|
|
private UUID GetRequestingAgentID(IClientAPI client)
|
|
{
|
|
UUID requestingAgentID = UUID.Zero;
|
|
if (client != null)
|
|
{
|
|
requestingAgentID = client.AgentId;
|
|
}
|
|
return requestingAgentID;
|
|
}
|
|
}
|
|
|
|
public class GroupNoticeInfo
|
|
{
|
|
public GroupNoticeData noticeData = new GroupNoticeData();
|
|
public UUID GroupID = UUID.Zero;
|
|
public string Message = string.Empty;
|
|
public byte[] BinaryBucket = new byte[0];
|
|
}
|
|
}
|