From 2c81e41c8a884ece643f3079349b033d03b6b774 Mon Sep 17 00:00:00 2001 From: Justin Clarke Casey Date: Wed, 22 Apr 2009 18:15:43 +0000 Subject: * Fission OGS1UserServices into user service and OGS1 user data plugin components * Make OGS1UserServices inherit from UserManagerBase * This allows grid mode regions to use the same user data plugin infrastructure as grid servers and standalone OpenSims --- .../Hypergrid/HGCommunicationsGridMode.cs | 11 +- .../Communications/Hypergrid/HGUserServices.cs | 33 +- .../Communications/Local/LocalUserServices.cs | 2 +- .../Communications/OGS1/CommunicationsOGS1.cs | 4 + .../Communications/OGS1/OGS1UserDataPlugin.cs | 760 ++++++++++++++++++++ .../Region/Communications/OGS1/OGS1UserServices.cs | 762 +-------------------- 6 files changed, 798 insertions(+), 774 deletions(-) create mode 100644 OpenSim/Region/Communications/OGS1/OGS1UserDataPlugin.cs (limited to 'OpenSim/Region/Communications') diff --git a/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs b/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs index 2ef0fd3..1268237 100644 --- a/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs +++ b/OpenSim/Region/Communications/Hypergrid/HGCommunicationsGridMode.cs @@ -31,6 +31,7 @@ using OpenSim.Framework; using OpenSim.Framework.Communications; using OpenSim.Framework.Communications.Cache; using OpenSim.Framework.Servers; +using OpenSim.Region.Communications.OGS1; using OpenSim.Region.Framework.Scenes; namespace OpenSim.Region.Communications.Hypergrid @@ -51,7 +52,6 @@ namespace OpenSim.Region.Communications.Hypergrid IAssetCache assetCache, SceneManager sman, LibraryRootFolder libraryRootFolder) : base(serversInfo, httpServer, assetCache, false, libraryRootFolder) { - // From constructor at CommunicationsOGS1 HGGridServices gridInterComms = new HGGridServicesGridMode(serversInfo, httpServer, assetCache, sman, m_userProfileCacheService); m_gridService = gridInterComms; @@ -63,12 +63,15 @@ namespace OpenSim.Region.Communications.Hypergrid AddSecureInventoryService(invService); m_defaultInventoryHost = invService.Host; if (SecureInventoryService != null) - m_log.Info("[HG] SecureInventoryService."); + m_log.Info("[HG]: SecureInventoryService."); else - m_log.Info("[HG] Non-secureInventoryService."); - + m_log.Info("[HG]: Non-secureInventoryService."); HGUserServices userServices = new HGUserServices(this); + // This plugin arrangement could eventually be configurable rather than hardcoded here. + OGS1UserDataPlugin userDataPlugin = new OGS1UserDataPlugin(this); + userServices.AddPlugin(userDataPlugin); + m_userService = userServices; m_messageService = userServices; m_avatarService = (IAvatarService)m_userService; diff --git a/OpenSim/Region/Communications/Hypergrid/HGUserServices.cs b/OpenSim/Region/Communications/Hypergrid/HGUserServices.cs index 370ef12..357d8a6 100644 --- a/OpenSim/Region/Communications/Hypergrid/HGUserServices.cs +++ b/OpenSim/Region/Communications/Hypergrid/HGUserServices.cs @@ -59,6 +59,7 @@ namespace OpenSim.Region.Communications.Hypergrid // Constructor called when running in standalone public HGUserServices(LocalUserServices local) + : base(null) { m_localUserServices = local; } @@ -101,30 +102,12 @@ namespace OpenSim.Region.Communications.Hypergrid base.LogOffUser(userid, regionid, regionhandle, position, lookat); } - /// - /// Logs off a user on the user server (deprecated as of 2008-08-27) - /// - /// UUID of the user - /// UUID of the Region - /// regionhandle - /// final position x - /// final position y - /// final position z - public override void LogOffUser(UUID userid, UUID regionid, ulong regionhandle, float posx, float posy, float posz) - { - string url = string.Empty; - if ((m_localUserServices != null) && !IsForeignUser(userid, out url)) - m_localUserServices.LogOffUser(userid, regionid, regionhandle, posx, posy, posz); - else - base.LogOffUser(userid, regionid, regionhandle, posx, posy, posz); - } - public override UserProfileData GetUserProfile(string firstName, string lastName) { if (m_localUserServices != null) return m_localUserServices.GetUserProfile(firstName, lastName); - return GetUserProfile(firstName + " " + lastName); + return base.GetUserProfile(firstName, lastName); } public override List GenerateAgentPickerRequestResponse(UUID queryID, string query) @@ -140,18 +123,6 @@ namespace OpenSim.Region.Communications.Hypergrid /// /// /// null if the request fails - public override UserProfileData GetUserProfile(string name) - { - // This doesn't exist in LocalUserServices - - return base.GetUserProfile(name); - } - - /// - /// Get a user profile from the user server - /// - /// - /// null if the request fails public override UserProfileData GetUserProfile(UUID avatarID) { //string url = string.Empty; diff --git a/OpenSim/Region/Communications/Local/LocalUserServices.cs b/OpenSim/Region/Communications/Local/LocalUserServices.cs index a239033..eb60610 100644 --- a/OpenSim/Region/Communications/Local/LocalUserServices.cs +++ b/OpenSim/Region/Communications/Local/LocalUserServices.cs @@ -80,6 +80,6 @@ namespace OpenSim.Region.Communications.Local throw new Exception("[LOCAL USER SERVICES]: Unknown master user UUID. Possible reason: UserServer is not running."); } return data; - } + } } } diff --git a/OpenSim/Region/Communications/OGS1/CommunicationsOGS1.cs b/OpenSim/Region/Communications/OGS1/CommunicationsOGS1.cs index f32b160..ee8562f 100644 --- a/OpenSim/Region/Communications/OGS1/CommunicationsOGS1.cs +++ b/OpenSim/Region/Communications/OGS1/CommunicationsOGS1.cs @@ -55,7 +55,11 @@ namespace OpenSim.Region.Communications.OGS1 m_defaultInventoryHost = invService.Host; } + // This plugin arrangement could eventually be configurable rather than hardcoded here. OGS1UserServices userServices = new OGS1UserServices(this); + OGS1UserDataPlugin userDataPlugin = new OGS1UserDataPlugin(this); + userServices.AddPlugin(userDataPlugin); + m_userService = userServices; m_messageService = userServices; m_avatarService = (IAvatarService)m_userService; diff --git a/OpenSim/Region/Communications/OGS1/OGS1UserDataPlugin.cs b/OpenSim/Region/Communications/OGS1/OGS1UserDataPlugin.cs new file mode 100644 index 0000000..f543451 --- /dev/null +++ b/OpenSim/Region/Communications/OGS1/OGS1UserDataPlugin.cs @@ -0,0 +1,760 @@ +/* + * 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 OpenSim 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; +using System.Collections.Generic; +using System.Net; +using System.Reflection; +using System.Text.RegularExpressions; +using System.Xml.Serialization; +using log4net; +using Nwc.XmlRpc; +using OpenMetaverse; +using OpenSim.Data; +using OpenSim.Framework; +using OpenSim.Framework.Communications; +using OpenSim.Framework.Communications.Clients; + +namespace OpenSim.Region.Communications.OGS1 +{ + public class OGS1UserDataPlugin : IUserDataPlugin + { + private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + + protected CommunicationsManager m_commsManager; + + public OGS1UserDataPlugin(CommunicationsManager commsManager) + { + m_log.DebugFormat("[OGS1 USER SERVICES]: {0} initialized", Name); + m_commsManager = commsManager; + } + + public string Version { get { return "0.1"; } } + public string Name { get { return "Open Grid Services 1 (OGS1) User Data Plugin"; } } + public void Initialise() {} + + public void Initialise(string connect) {} + + public void Dispose() {} + + // Arguably the presence of these means that IUserDataPlugin could be fissioned + public UserAgentData GetUserAgent(string name) { return null; } + public UserAgentData GetAgentByName(string name) { return null; } + public UserAgentData GetAgentByName(string fname, string lname) { return null; } + public void StoreWebLoginKey(UUID agentID, UUID webLoginKey) {} + public void AddNewUserProfile(UserProfileData user) {} + public void AddNewUserAgent(UserAgentData agent) {} + public bool MoneyTransferRequest(UUID from, UUID to, uint amount) { return false; } + public bool InventoryTransferRequest(UUID from, UUID to, UUID inventory) { return false; } + public void ResetAttachments(UUID userID) {} + public void LogoutUsers(UUID regionID) {} + + public UserProfileData GetUserByUri(Uri uri) + { + WebRequest request = WebRequest.Create(uri); + + WebResponse webResponse = request.GetResponse(); + + XmlSerializer deserializer = new XmlSerializer(typeof(XmlRpcResponse)); + XmlRpcResponse xmlRpcResponse = (XmlRpcResponse)deserializer.Deserialize(webResponse.GetResponseStream()); + + Hashtable respData = (Hashtable)xmlRpcResponse.Value; + + return ConvertXMLRPCDataToUserProfile(respData); + } + +// public Uri GetUserUri(UserProfileData userProfile) +// { +// throw new NotImplementedException(); +// } + + public virtual UserAgentData GetAgentByUUID(UUID userId) + { + try + { + Hashtable param = new Hashtable(); + param["avatar_uuid"] = userId.ToString(); + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_agent_by_uuid", parameters); + + XmlRpcResponse resp = req.Send(GetUserServerURL(userId), 6000); + Hashtable respData = (Hashtable)resp.Value; + if (respData.Contains("error_type")) + { + //m_log.Warn("[GRID]: " + + // "Error sent by user server when trying to get agent: (" + + // (string) respData["error_type"] + + // "): " + (string)respData["error_desc"]); + return null; + } + UUID sessionid = UUID.Zero; + + UserAgentData userAgent = new UserAgentData(); + userAgent.Handle = Convert.ToUInt64((string)respData["handle"]); + UUID.TryParse((string)respData["sessionid"], out sessionid); + userAgent.SessionID = sessionid; + + if ((string)respData["agent_online"] == "TRUE") + { + userAgent.AgentOnline = true; + } + else + { + userAgent.AgentOnline = false; + } + + return userAgent; + } + catch (Exception e) + { + m_log.ErrorFormat( + "[OGS1 USER SERVICES]: Error when trying to fetch agent data by uuid from remote user server: {0}", + e); + } + + return null; + } + + public virtual UserProfileData GetUserByName(string firstName, string lastName) + { + return GetUserProfile(firstName + " " + lastName); + } + + public virtual List GeneratePickerResults(UUID queryID, string query) + { + List pickerlist = new List(); + Regex objAlphaNumericPattern = new Regex("[^a-zA-Z0-9 ]"); + try + { + Hashtable param = new Hashtable(); + param["queryid"] = (string)queryID.ToString(); + param["avquery"] = objAlphaNumericPattern.Replace(query, String.Empty); + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_avatar_picker_avatar", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); + Hashtable respData = (Hashtable)resp.Value; + pickerlist = ConvertXMLRPCDataToAvatarPickerList(queryID, respData); + } + catch (WebException e) + { + m_log.Warn("[OGS1 USER SERVICES]: Error when trying to fetch Avatar Picker Response: " + + e.Message); + // Return Empty picker list (no results) + } + return pickerlist; + } + + /// + /// Get a user profile from the user server + /// + /// + /// null if the request fails + protected virtual UserProfileData GetUserProfile(string name) + { + try + { + Hashtable param = new Hashtable(); + param["avatar_name"] = name; + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_user_by_name", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 30000); + Hashtable respData = (Hashtable)resp.Value; + + return ConvertXMLRPCDataToUserProfile(respData); + } + catch (WebException e) + { + m_log.ErrorFormat( + "[OGS1 USER SERVICES]: Error when trying to fetch profile data by name from remote user server: {0}", + e); + } + + return null; + } + + /// + /// Get a user profile from the user server + /// + /// + /// null if the request fails + public virtual UserProfileData GetUserByUUID(UUID avatarID) + { + try + { + Hashtable param = new Hashtable(); + param["avatar_uuid"] = avatarID.ToString(); + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_user_by_uuid", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 30000); + Hashtable respData = (Hashtable)resp.Value; + + return ConvertXMLRPCDataToUserProfile(respData); + } + catch (Exception e) + { + m_log.ErrorFormat( + "[OGS1 USER SERVICES]: Error when trying to fetch profile data by uuid from remote user server: {0}", + e); + } + + return null; + } + + public virtual bool UpdateUserProfile(UserProfileData userProfile) + { + m_log.Debug("[OGS1 USER SERVICES]: Asking UserServer to update profile."); + + Hashtable param = new Hashtable(); + param["avatar_uuid"] = userProfile.ID.ToString(); + //param["AllowPublish"] = userProfile.ToString(); + param["FLImageID"] = userProfile.FirstLifeImage.ToString(); + param["ImageID"] = userProfile.Image.ToString(); + //param["MaturePublish"] = MaturePublish.ToString(); + param["AboutText"] = userProfile.AboutText; + param["FLAboutText"] = userProfile.FirstLifeAboutText; + //param["ProfileURL"] = userProfile.ProfileURL.ToString(); + + param["home_region"] = userProfile.HomeRegion.ToString(); + param["home_region_id"] = userProfile.HomeRegionID.ToString(); + + param["home_pos_x"] = userProfile.HomeLocationX.ToString(); + param["home_pos_y"] = userProfile.HomeLocationY.ToString(); + param["home_pos_z"] = userProfile.HomeLocationZ.ToString(); + param["home_look_x"] = userProfile.HomeLookAtX.ToString(); + param["home_look_y"] = userProfile.HomeLookAtY.ToString(); + param["home_look_z"] = userProfile.HomeLookAtZ.ToString(); + param["user_flags"] = userProfile.UserFlags.ToString(); + param["god_level"] = userProfile.GodLevel.ToString(); + param["custom_type"] = userProfile.CustomType.ToString(); + param["partner"] = userProfile.Partner.ToString(); + + IList parameters = new ArrayList(); + parameters.Add(param); + + XmlRpcRequest req = new XmlRpcRequest("update_user_profile", parameters); + XmlRpcResponse resp = req.Send(GetUserServerURL(userProfile.ID), 3000); + Hashtable respData = (Hashtable)resp.Value; + if (respData != null) + { + if (respData.Contains("returnString")) + { + if (((string)respData["returnString"]).ToUpper() != "TRUE") + { + m_log.Warn("[GRID]: Unable to update user profile, User Server Reported an issue"); + return false; + } + } + else + { + m_log.Warn("[GRID]: Unable to update user profile, UserServer didn't understand me!"); + return false; + } + } + else + { + m_log.Warn("[GRID]: Unable to update user profile, UserServer didn't understand me!"); + return false; + } + + return true; + } + + /// + /// Adds a new friend to the database for XUser + /// + /// The agent that who's friends list is being added to + /// The agent that being added to the friends list of the friends list owner + /// A uint bit vector for set perms that the friend being added has; 0 = none, 1=This friend can see when they sign on, 2 = map, 4 edit objects + public virtual void AddNewUserFriend(UUID friendlistowner, UUID friend, uint perms) + { + try + { + Hashtable param = new Hashtable(); + param["ownerID"] = friendlistowner.Guid.ToString(); + param["friendID"] = friend.Guid.ToString(); + param["friendPerms"] = perms.ToString(); + IList parameters = new ArrayList(); + parameters.Add(param); + + XmlRpcRequest req = new XmlRpcRequest("add_new_user_friend", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); + Hashtable respData = (Hashtable)resp.Value; + if (respData != null) + { + if (respData.Contains("returnString")) + { + if ((string)respData["returnString"] == "TRUE") + { + + } + else + { + m_log.Warn("[GRID]: Unable to add new friend, User Server Reported an issue"); + } + } + else + { + m_log.Warn("[GRID]: Unable to add new friend, UserServer didn't understand me!"); + } + } + else + { + m_log.Warn("[GRID]: Unable to add new friend, UserServer didn't understand me!"); + + } + } + catch (WebException e) + { + m_log.Warn("[GRID]: Error when trying to AddNewUserFriend: " + + e.Message); + + } + } + + /// + /// Delete friend on friendlistowner's friendlist. + /// + /// The agent that who's friends list is being updated + /// The Ex-friend agent + public virtual void RemoveUserFriend(UUID friendlistowner, UUID friend) + { + try + { + Hashtable param = new Hashtable(); + param["ownerID"] = friendlistowner.Guid.ToString(); + param["friendID"] = friend.Guid.ToString(); + + IList parameters = new ArrayList(); + parameters.Add(param); + + XmlRpcRequest req = new XmlRpcRequest("remove_user_friend", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); + Hashtable respData = (Hashtable)resp.Value; + if (respData != null) + { + if (respData.Contains("returnString")) + { + if ((string)respData["returnString"] == "TRUE") + { + + } + else + { + m_log.Warn("[GRID]: Unable to remove friend, User Server Reported an issue"); + } + } + else + { + m_log.Warn("[GRID]: Unable to remove friend, UserServer didn't understand me!"); + } + } + else + { + m_log.Warn("[GRID]: Unable to remove friend, UserServer didn't understand me!"); + + } + } + catch (WebException e) + { + m_log.Warn("[GRID]: Error when trying to RemoveUserFriend: " + + e.Message); + + } + } + + /// + /// Update permissions for friend on friendlistowner's friendlist. + /// + /// The agent that who's friends list is being updated + /// The agent that is getting or loosing permissions + /// A uint bit vector for set perms that the friend being added has; 0 = none, 1=This friend can see when they sign on, 2 = map, 4 edit objects + public virtual void UpdateUserFriendPerms(UUID friendlistowner, UUID friend, uint perms) + { + try + { + Hashtable param = new Hashtable(); + param["ownerID"] = friendlistowner.Guid.ToString(); + param["friendID"] = friend.Guid.ToString(); + param["friendPerms"] = perms.ToString(); + IList parameters = new ArrayList(); + parameters.Add(param); + + XmlRpcRequest req = new XmlRpcRequest("update_user_friend_perms", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); + Hashtable respData = (Hashtable)resp.Value; + if (respData != null) + { + if (respData.Contains("returnString")) + { + if ((string)respData["returnString"] == "TRUE") + { + + } + else + { + m_log.Warn("[GRID]: Unable to update_user_friend_perms, User Server Reported an issue"); + } + } + else + { + m_log.Warn("[GRID]: Unable to update_user_friend_perms, UserServer didn't understand me!"); + } + } + else + { + m_log.Warn("[GRID]: Unable to update_user_friend_perms, UserServer didn't understand me!"); + + } + } + catch (WebException e) + { + m_log.Warn("[GRID]: Error when trying to update_user_friend_perms: " + + e.Message); + } + } + /// + /// Returns a list of FriendsListItems that describe the friends and permissions in the friend relationship for UUID friendslistowner + /// + /// The agent that we're retreiving the friends Data. + public virtual List GetUserFriendList(UUID friendlistowner) + { + List buddylist = new List(); + + try + { + Hashtable param = new Hashtable(); + param["ownerID"] = friendlistowner.Guid.ToString(); + + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_user_friend_list", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 8000); + Hashtable respData = (Hashtable)resp.Value; + + if (respData != null && respData.Contains("avcount")) + { + buddylist = ConvertXMLRPCDataToFriendListItemList(respData); + } + + } + catch (WebException e) + { + m_log.Warn("[OGS1 USER SERVICES]: Error when trying to fetch Avatar's friends list: " + + e.Message); + // Return Empty list (no friends) + } + return buddylist; + } + + public virtual Dictionary GetFriendRegionInfos(List uuids) + { + Dictionary result = new Dictionary(); + + // ask MessageServer about the current on-/offline status and regions the friends are in + ArrayList parameters = new ArrayList(); + Hashtable map = new Hashtable(); + + ArrayList list = new ArrayList(); + foreach (UUID uuid in uuids) + { + list.Add(uuid.ToString()); + list.Add(uuid.ToString()); + } + map["uuids"] = list; + + map["recv_key"] = m_commsManager.NetworkServersInfo.UserRecvKey; + map["send_key"] = m_commsManager.NetworkServersInfo.UserSendKey; + + parameters.Add(map); + + try + { + XmlRpcRequest req = new XmlRpcRequest("get_presence_info_bulk", parameters); + XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.MessagingURL, 8000); + Hashtable respData = resp != null ? (Hashtable)resp.Value : null; + + if (respData == null || respData.ContainsKey("faultMessage")) + { + m_log.WarnFormat("[OGS1 USER SERVICES]: Contacting MessagingServer about user-regions resulted in error: {0}", + respData == null ? "" : respData["faultMessage"]); + } + else if (!respData.ContainsKey("count")) + { + m_log.WarnFormat("[OGS1 USER SERVICES]: Wrong format in response for MessagingServer request get_presence_info_bulk: missing 'count' field"); + } + else + { + int count = (int)respData["count"]; + m_log.DebugFormat("[OGS1 USER SERVICES]: Request returned {0} results.", count); + for (int i = 0; i < count; ++i) + { + if (respData.ContainsKey("uuid_" + i) && respData.ContainsKey("isOnline_" + i) && respData.ContainsKey("regionHandle_" + i)) + { + UUID uuid; + if (UUID.TryParse((string)respData["uuid_" + i], out uuid)) + { + FriendRegionInfo info = new FriendRegionInfo(); + info.isOnline = (bool)respData["isOnline_" + i]; + if (info.isOnline) + { + // TODO remove this after the next protocol update (say, r7800?) + info.regionHandle = Convert.ToUInt64(respData["regionHandle_" + i]); + + // accept missing id + if (respData.ContainsKey("regionID_" + i)) + UUID.TryParse((string)respData["regionID_" + i], out info.regionID); + } + + result.Add(uuid, info); + } + } + else + { + m_log.WarnFormat("[OGS1 USER SERVICES]: Response to get_presence_info_bulk contained an error in entry {0}", i); + } + } + } + } + catch (WebException e) + { + m_log.ErrorFormat("[OGS1 USER SERVICES]: Network problems when trying to fetch friend infos: {0}", e.Message); + } + + m_log.DebugFormat("[OGS1 USER SERVICES]: Returning {0} entries", result.Count); + + return result; + } + + public virtual AvatarAppearance GetUserAppearance(UUID user) + { + AvatarAppearance appearance = null; + + try + { + Hashtable param = new Hashtable(); + param["owner"] = user.ToString(); + + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("get_avatar_appearance", parameters); + XmlRpcResponse resp = req.Send(GetUserServerURL(user), 8000); + Hashtable respData = (Hashtable)resp.Value; + + return ConvertXMLRPCDataToAvatarAppearance(respData); + } + catch (WebException e) + { + m_log.ErrorFormat("[OGS1 USER SERVICES]: Network problems when trying to fetch appearance for avatar {0}, {1}", user, e.Message); + } + + return appearance; + } + + public virtual void UpdateUserAppearance(UUID user, AvatarAppearance appearance) + { + try + { + Hashtable param = appearance.ToHashTable(); + param["owner"] = user.ToString(); + + IList parameters = new ArrayList(); + parameters.Add(param); + XmlRpcRequest req = new XmlRpcRequest("update_avatar_appearance", parameters); + XmlRpcResponse resp = req.Send(GetUserServerURL(user), 8000); + Hashtable respData = (Hashtable)resp.Value; + + if (respData != null) + { + if (respData.Contains("returnString")) + { + if ((string)respData["returnString"] == "TRUE") + { + + } + else + { + m_log.Warn("[GRID]: Unable to update_user_appearance, User Server Reported an issue"); + } + } + else + { + m_log.Warn("[GRID]: Unable to update_user_appearance, UserServer didn't understand me!"); + } + } + else + { + m_log.Warn("[GRID]: Unable to update_user_appearance, UserServer didn't understand me!"); + } + } + catch (WebException e) + { + m_log.Warn("[OGS1 USER SERVICES]: Error when trying to update Avatar's appearance: " + + e.Message); + // Return Empty list (no friends) + } + } + + protected virtual string GetUserServerURL(UUID userID) + { + return m_commsManager.NetworkServersInfo.UserURL; + } + + protected UserProfileData ConvertXMLRPCDataToUserProfile(Hashtable data) + { + if (data.Contains("error_type")) + { + m_log.Warn("[GRID]: " + + "Error sent by user server when trying to get user profile: (" + + data["error_type"] + + "): " + data["error_desc"]); + return null; + } + + UserProfileData userData = new UserProfileData(); + userData.FirstName = (string)data["firstname"]; + userData.SurName = (string)data["lastname"]; + userData.ID = new UUID((string)data["uuid"]); + userData.Created = Convert.ToInt32(data["profile_created"]); + userData.UserInventoryURI = (string)data["server_inventory"]; + userData.UserAssetURI = (string)data["server_asset"]; + userData.FirstLifeAboutText = (string)data["profile_firstlife_about"]; + userData.FirstLifeImage = new UUID((string)data["profile_firstlife_image"]); + userData.CanDoMask = Convert.ToUInt32((string)data["profile_can_do"]); + userData.WantDoMask = Convert.ToUInt32(data["profile_want_do"]); + userData.AboutText = (string)data["profile_about"]; + userData.Image = new UUID((string)data["profile_image"]); + userData.LastLogin = Convert.ToInt32((string)data["profile_lastlogin"]); + userData.HomeRegion = Convert.ToUInt64((string)data["home_region"]); + if (data.Contains("home_region_id")) + userData.HomeRegionID = new UUID((string)data["home_region_id"]); + else + userData.HomeRegionID = UUID.Zero; + userData.HomeLocation = + new Vector3((float)Convert.ToDecimal((string)data["home_coordinates_x"]), + (float)Convert.ToDecimal((string)data["home_coordinates_y"]), + (float)Convert.ToDecimal((string)data["home_coordinates_z"])); + userData.HomeLookAt = + new Vector3((float)Convert.ToDecimal((string)data["home_look_x"]), + (float)Convert.ToDecimal((string)data["home_look_y"]), + (float)Convert.ToDecimal((string)data["home_look_z"])); + if (data.Contains("user_flags")) + userData.UserFlags = Convert.ToInt32((string)data["user_flags"]); + if (data.Contains("god_level")) + userData.GodLevel = Convert.ToInt32((string)data["god_level"]); + + if (data.Contains("custom_type")) + userData.CustomType = (string)data["custom_type"]; + else + userData.CustomType = ""; + if (userData.CustomType == null) + userData.CustomType = ""; + + if (data.Contains("partner")) + userData.Partner = new UUID((string)data["partner"]); + else + userData.Partner = UUID.Zero; + + return userData; + } + + protected AvatarAppearance ConvertXMLRPCDataToAvatarAppearance(Hashtable data) + { + if (data != null) + { + if (data.Contains("error_type")) + { + m_log.Warn("[GRID]: " + + "Error sent by user server when trying to get user appearance: (" + + data["error_type"] + + "): " + data["error_desc"]); + return null; + } + else + { + return new AvatarAppearance(data); + } + } + else + { + m_log.Error("[GRID]: The avatar appearance is null, something bad happenend"); + return null; + } + } + + protected List ConvertXMLRPCDataToAvatarPickerList(UUID queryID, Hashtable data) + { + List pickerlist = new List(); + int pickercount = Convert.ToInt32((string)data["avcount"]); + UUID respqueryID = new UUID((string)data["queryid"]); + if (queryID == respqueryID) + { + for (int i = 0; i < pickercount; i++) + { + AvatarPickerAvatar apicker = new AvatarPickerAvatar(); + UUID avatarID = new UUID((string)data["avatarid" + i.ToString()]); + string firstname = (string)data["firstname" + i.ToString()]; + string lastname = (string)data["lastname" + i.ToString()]; + apicker.AvatarID = avatarID; + apicker.firstName = firstname; + apicker.lastName = lastname; + pickerlist.Add(apicker); + } + } + else + { + m_log.Warn("[OGS1 USER SERVICES]: Got invalid queryID from userServer"); + } + return pickerlist; + } + + protected List ConvertXMLRPCDataToFriendListItemList(Hashtable data) + { + List buddylist = new List(); + int buddycount = Convert.ToInt32((string)data["avcount"]); + + + for (int i = 0; i < buddycount; i++) + { + FriendListItem buddylistitem = new FriendListItem(); + + buddylistitem.FriendListOwner = new UUID((string)data["ownerID" + i.ToString()]); + buddylistitem.Friend = new UUID((string)data["friendID" + i.ToString()]); + buddylistitem.FriendListOwnerPerms = (uint)Convert.ToInt32((string)data["ownerPerms" + i.ToString()]); + buddylistitem.FriendPerms = (uint)Convert.ToInt32((string)data["friendPerms" + i.ToString()]); + + buddylist.Add(buddylistitem); + } + + return buddylist; + } + } +} diff --git a/OpenSim/Region/Communications/OGS1/OGS1UserServices.cs b/OpenSim/Region/Communications/OGS1/OGS1UserServices.cs index 1836328..5f77107 100644 --- a/OpenSim/Region/Communications/OGS1/OGS1UserServices.cs +++ b/OpenSim/Region/Communications/OGS1/OGS1UserServices.cs @@ -35,229 +35,36 @@ using System.Xml.Serialization; using log4net; using Nwc.XmlRpc; using OpenMetaverse; +using OpenSim.Data; using OpenSim.Framework; using OpenSim.Framework.Communications; using OpenSim.Framework.Communications.Clients; namespace OpenSim.Region.Communications.OGS1 -{ - public class OGS1UserServices : IUserService, IAvatarService, IMessagingService +{ + public class OGS1UserServices : UserManagerBase { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); - + protected CommunicationsManager m_commsManager; - + public OGS1UserServices(CommunicationsManager commsManager) + : base(commsManager.InterServiceInventoryService) { m_commsManager = commsManager; } - - public OGS1UserServices() - { - } - - public UserProfileData ConvertXMLRPCDataToUserProfile(Hashtable data) - { - if (data.Contains("error_type")) - { - m_log.Warn("[GRID]: " + - "Error sent by user server when trying to get user profile: (" + - data["error_type"] + - "): " + data["error_desc"]); - return null; - } - - UserProfileData userData = new UserProfileData(); - userData.FirstName = (string)data["firstname"]; - userData.SurName = (string)data["lastname"]; - userData.ID = new UUID((string)data["uuid"]); - userData.Created = Convert.ToInt32(data["profile_created"]); - userData.UserInventoryURI = (string)data["server_inventory"]; - userData.UserAssetURI = (string)data["server_asset"]; - userData.FirstLifeAboutText = (string)data["profile_firstlife_about"]; - userData.FirstLifeImage = new UUID((string)data["profile_firstlife_image"]); - userData.CanDoMask = Convert.ToUInt32((string)data["profile_can_do"]); - userData.WantDoMask = Convert.ToUInt32(data["profile_want_do"]); - userData.AboutText = (string)data["profile_about"]; - userData.Image = new UUID((string)data["profile_image"]); - userData.LastLogin = Convert.ToInt32((string)data["profile_lastlogin"]); - userData.HomeRegion = Convert.ToUInt64((string)data["home_region"]); - if (data.Contains("home_region_id")) - userData.HomeRegionID = new UUID((string)data["home_region_id"]); - else - userData.HomeRegionID = UUID.Zero; - userData.HomeLocation = - new Vector3((float)Convert.ToDecimal((string)data["home_coordinates_x"]), - (float)Convert.ToDecimal((string)data["home_coordinates_y"]), - (float)Convert.ToDecimal((string)data["home_coordinates_z"])); - userData.HomeLookAt = - new Vector3((float)Convert.ToDecimal((string)data["home_look_x"]), - (float)Convert.ToDecimal((string)data["home_look_y"]), - (float)Convert.ToDecimal((string)data["home_look_z"])); - if (data.Contains("user_flags")) - userData.UserFlags = Convert.ToInt32((string)data["user_flags"]); - if (data.Contains("god_level")) - userData.GodLevel = Convert.ToInt32((string)data["god_level"]); - - if (data.Contains("custom_type")) - userData.CustomType = (string)data["custom_type"]; - else - userData.CustomType = ""; - if (userData.CustomType == null) - userData.CustomType = ""; - - if (data.Contains("partner")) - userData.Partner = new UUID((string)data["partner"]); - else - userData.Partner = UUID.Zero; - - return userData; - } - - public UserProfileData GetUserProfile(Uri uri) + + public override void ClearUserAgent(UUID avatarID) { - WebRequest request = WebRequest.Create(uri); - - WebResponse webResponse = request.GetResponse(); - - XmlSerializer deserializer = new XmlSerializer(typeof(XmlRpcResponse)); - XmlRpcResponse xmlRpcResponse = (XmlRpcResponse)deserializer.Deserialize(webResponse.GetResponseStream()); - - Hashtable respData = (Hashtable)xmlRpcResponse.Value; - - return ConvertXMLRPCDataToUserProfile(respData); - } - - public Uri GetUserUri(UserProfileData userProfile) - { - throw new NotImplementedException(); - } - - /// - /// Get a user agent from the user server - /// - /// - /// null if the request fails - public virtual UserAgentData GetAgentByUUID(UUID userId) - { - try - { - Hashtable param = new Hashtable(); - param["avatar_uuid"] = userId.ToString(); - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_agent_by_uuid", parameters); - - XmlRpcResponse resp = req.Send(GetUserServerURL(userId), 6000); - Hashtable respData = (Hashtable)resp.Value; - if (respData.Contains("error_type")) - { - //m_log.Warn("[GRID]: " + - // "Error sent by user server when trying to get agent: (" + - // (string) respData["error_type"] + - // "): " + (string)respData["error_desc"]); - return null; - } - UUID sessionid = UUID.Zero; - - UserAgentData userAgent = new UserAgentData(); - userAgent.Handle = Convert.ToUInt64((string)respData["handle"]); - UUID.TryParse((string)respData["sessionid"], out sessionid); - userAgent.SessionID = sessionid; - - if ((string)respData["agent_online"] == "TRUE") - { - userAgent.AgentOnline = true; - } - else - { - userAgent.AgentOnline = false; - } - - return userAgent; - } - catch (Exception e) - { - m_log.ErrorFormat( - "[OGS1 USER SERVICES]: Error when trying to fetch agent data by uuid from remote user server: {0}", - e); - } - - return null; - } - - public AvatarAppearance ConvertXMLRPCDataToAvatarAppearance(Hashtable data) - { - if (data != null) - { - if (data.Contains("error_type")) - { - m_log.Warn("[GRID]: " + - "Error sent by user server when trying to get user appearance: (" + - data["error_type"] + - "): " + data["error_desc"]); - return null; - } - else - { - return new AvatarAppearance(data); - } - } - else - { - m_log.Error("[GRID]: The avatar appearance is null, something bad happenend"); - return null; - } - } - - public List ConvertXMLRPCDataToAvatarPickerList(UUID queryID, Hashtable data) - { - List pickerlist = new List(); - int pickercount = Convert.ToInt32((string)data["avcount"]); - UUID respqueryID = new UUID((string)data["queryid"]); - if (queryID == respqueryID) - { - for (int i = 0; i < pickercount; i++) - { - AvatarPickerAvatar apicker = new AvatarPickerAvatar(); - UUID avatarID = new UUID((string)data["avatarid" + i.ToString()]); - string firstname = (string)data["firstname" + i.ToString()]; - string lastname = (string)data["lastname" + i.ToString()]; - apicker.AvatarID = avatarID; - apicker.firstName = firstname; - apicker.lastName = lastname; - pickerlist.Add(apicker); - } - } - else - { - m_log.Warn("[OGS1 USER SERVICES]: Got invalid queryID from userServer"); - } - return pickerlist; + // TODO: implement + // It may be possible to use the UserManagerBase implementation. } - - public List ConvertXMLRPCDataToFriendListItemList(Hashtable data) + + protected virtual string GetUserServerURL(UUID userID) { - List buddylist = new List(); - int buddycount = Convert.ToInt32((string)data["avcount"]); - - - for (int i = 0; i < buddycount; i++) - { - FriendListItem buddylistitem = new FriendListItem(); - - buddylistitem.FriendListOwner = new UUID((string)data["ownerID" + i.ToString()]); - buddylistitem.Friend = new UUID((string)data["friendID" + i.ToString()]); - buddylistitem.FriendListOwnerPerms = (uint)Convert.ToInt32((string)data["ownerPerms" + i.ToString()]); - buddylistitem.FriendPerms = (uint)Convert.ToInt32((string)data["friendPerms" + i.ToString()]); - - buddylist.Add(buddylistitem); - } - - - return buddylist; + return m_commsManager.NetworkServersInfo.UserURL; } - + /// /// Logs off a user on the user server /// @@ -266,7 +73,7 @@ namespace OpenSim.Region.Communications.OGS1 /// regionhandle /// final position /// final lookat - public virtual void LogOffUser(UUID userid, UUID regionid, ulong regionhandle, Vector3 position, Vector3 lookat) + public override void LogOffUser(UUID userid, UUID regionid, ulong regionhandle, Vector3 position, Vector3 lookat) { Hashtable param = new Hashtable(); param["avatar_uuid"] = userid.Guid.ToString(); @@ -290,123 +97,15 @@ namespace OpenSim.Region.Communications.OGS1 catch (WebException) { m_log.Warn("[LOGOFF]: Unable to notify grid server of user logoff"); - } - } - - /// - /// Logs off a user on the user server (deprecated as of 2008-08-27) - /// - /// UUID of the user - /// UUID of the Region - /// regionhandle - /// final position x - /// final position y - /// final position z - public virtual void LogOffUser(UUID userid, UUID regionid, ulong regionhandle, float posx, float posy, float posz) - { - LogOffUser(userid, regionid, regionhandle, new Vector3(posx, posy, posz), new Vector3()); - } - - public virtual UserProfileData GetUserProfile(string firstName, string lastName) - { - return GetUserProfile(firstName + " " + lastName); - } - - public virtual List GenerateAgentPickerRequestResponse(UUID queryID, string query) - { - List pickerlist = new List(); - Regex objAlphaNumericPattern = new Regex("[^a-zA-Z0-9 ]"); - try - { - Hashtable param = new Hashtable(); - param["queryid"] = (string)queryID.ToString(); - param["avquery"] = objAlphaNumericPattern.Replace(query, String.Empty); - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_avatar_picker_avatar", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); - Hashtable respData = (Hashtable)resp.Value; - pickerlist = ConvertXMLRPCDataToAvatarPickerList(queryID, respData); - } - catch (WebException e) - { - m_log.Warn("[OGS1 USER SERVICES]: Error when trying to fetch Avatar Picker Response: " + - e.Message); - // Return Empty picker list (no results) - } - return pickerlist; - } - - /// - /// Get a user profile from the user server - /// - /// - /// null if the request fails - public virtual UserProfileData GetUserProfile(string name) - { - try - { - Hashtable param = new Hashtable(); - param["avatar_name"] = name; - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_user_by_name", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 30000); - Hashtable respData = (Hashtable)resp.Value; - - return ConvertXMLRPCDataToUserProfile(respData); - } - catch (WebException e) - { - m_log.ErrorFormat( - "[OGS1 USER SERVICES]: Error when trying to fetch profile data by name from remote user server: {0}", - e); - } - - return null; - } - - /// - /// Get a user profile from the user server - /// - /// - /// null if the request fails - public virtual UserProfileData GetUserProfile(UUID avatarID) - { - try - { - Hashtable param = new Hashtable(); - param["avatar_uuid"] = avatarID.ToString(); - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_user_by_uuid", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 30000); - Hashtable respData = (Hashtable)resp.Value; - - return ConvertXMLRPCDataToUserProfile(respData); - } - catch (Exception e) - { - m_log.ErrorFormat( - "[OGS1 USER SERVICES]: Error when trying to fetch profile data by uuid from remote user server: {0}", - e); - } - - return null; - } - - - public virtual void ClearUserAgent(UUID avatarID) - { - // TODO: implement + } } - + /// /// Retrieve the user information for the given master uuid. /// /// /// - public virtual UserProfileData SetupMasterUser(string firstName, string lastName) + public override UserProfileData SetupMasterUser(string firstName, string lastName) { return SetupMasterUser(firstName, lastName, String.Empty); } @@ -416,7 +115,7 @@ namespace OpenSim.Region.Communications.OGS1 /// /// /// - public virtual UserProfileData SetupMasterUser(string firstName, string lastName, string password) + public override UserProfileData SetupMasterUser(string firstName, string lastName, string password) { UserProfileData profile = GetUserProfile(firstName, lastName); return profile; @@ -427,7 +126,7 @@ namespace OpenSim.Region.Communications.OGS1 /// /// /// - public virtual UserProfileData SetupMasterUser(UUID uuid) + public override UserProfileData SetupMasterUser(UUID uuid) { UserProfileData data = GetUserProfile(uuid); @@ -439,424 +138,11 @@ namespace OpenSim.Region.Communications.OGS1 return data; } - - public virtual UUID AddUserProfile(string firstName, string lastName, string pass, uint regX, uint regY) - { - throw new Exception("The method or operation is not implemented."); - } - - public virtual bool ResetUserPassword(string firstName, string lastName, string newPassword) - { - throw new Exception("The method or operation is not implemented."); - } - - public virtual bool UpdateUserProfile(UserProfileData userProfile) - { - m_log.Debug("[OGS1 USER SERVICES]: Asking UserServer to update profile."); - Hashtable param = new Hashtable(); - param["avatar_uuid"] = userProfile.ID.ToString(); - //param["AllowPublish"] = userProfile.ToString(); - param["FLImageID"] = userProfile.FirstLifeImage.ToString(); - param["ImageID"] = userProfile.Image.ToString(); - //param["MaturePublish"] = MaturePublish.ToString(); - param["AboutText"] = userProfile.AboutText; - param["FLAboutText"] = userProfile.FirstLifeAboutText; - //param["ProfileURL"] = userProfile.ProfileURL.ToString(); - - param["home_region"] = userProfile.HomeRegion.ToString(); - param["home_region_id"] = userProfile.HomeRegionID.ToString(); - - param["home_pos_x"] = userProfile.HomeLocationX.ToString(); - param["home_pos_y"] = userProfile.HomeLocationY.ToString(); - param["home_pos_z"] = userProfile.HomeLocationZ.ToString(); - param["home_look_x"] = userProfile.HomeLookAtX.ToString(); - param["home_look_y"] = userProfile.HomeLookAtY.ToString(); - param["home_look_z"] = userProfile.HomeLookAtZ.ToString(); - param["user_flags"] = userProfile.UserFlags.ToString(); - param["god_level"] = userProfile.GodLevel.ToString(); - param["custom_type"] = userProfile.CustomType.ToString(); - param["partner"] = userProfile.Partner.ToString(); - - IList parameters = new ArrayList(); - parameters.Add(param); - - XmlRpcRequest req = new XmlRpcRequest("update_user_profile", parameters); - XmlRpcResponse resp = req.Send(GetUserServerURL(userProfile.ID), 3000); - Hashtable respData = (Hashtable)resp.Value; - if (respData != null) - { - if (respData.Contains("returnString")) - { - if (((string)respData["returnString"]).ToUpper() != "TRUE") - { - m_log.Warn("[GRID]: Unable to update user profile, User Server Reported an issue"); - return false; - } - } - else - { - m_log.Warn("[GRID]: Unable to update user profile, UserServer didn't understand me!"); - return false; - } - } - else - { - m_log.Warn("[GRID]: Unable to update user profile, UserServer didn't understand me!"); - return false; - } - - return true; - } - - #region IUserServices Friend Methods - /// - /// Adds a new friend to the database for XUser - /// - /// The agent that who's friends list is being added to - /// The agent that being added to the friends list of the friends list owner - /// A uint bit vector for set perms that the friend being added has; 0 = none, 1=This friend can see when they sign on, 2 = map, 4 edit objects - public virtual void AddNewUserFriend(UUID friendlistowner, UUID friend, uint perms) - { - try - { - Hashtable param = new Hashtable(); - param["ownerID"] = friendlistowner.Guid.ToString(); - param["friendID"] = friend.Guid.ToString(); - param["friendPerms"] = perms.ToString(); - IList parameters = new ArrayList(); - parameters.Add(param); - - XmlRpcRequest req = new XmlRpcRequest("add_new_user_friend", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); - Hashtable respData = (Hashtable)resp.Value; - if (respData != null) - { - if (respData.Contains("returnString")) - { - if ((string)respData["returnString"] == "TRUE") - { - - } - else - { - m_log.Warn("[GRID]: Unable to add new friend, User Server Reported an issue"); - } - } - else - { - m_log.Warn("[GRID]: Unable to add new friend, UserServer didn't understand me!"); - } - } - else - { - m_log.Warn("[GRID]: Unable to add new friend, UserServer didn't understand me!"); - - } - } - catch (WebException e) - { - m_log.Warn("[GRID]: Error when trying to AddNewUserFriend: " + - e.Message); - - } - - } - - /// - /// Delete friend on friendlistowner's friendlist. - /// - /// The agent that who's friends list is being updated - /// The Ex-friend agent - public virtual void RemoveUserFriend(UUID friendlistowner, UUID friend) - { - try - { - Hashtable param = new Hashtable(); - param["ownerID"] = friendlistowner.Guid.ToString(); - param["friendID"] = friend.Guid.ToString(); - - IList parameters = new ArrayList(); - parameters.Add(param); - - XmlRpcRequest req = new XmlRpcRequest("remove_user_friend", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); - Hashtable respData = (Hashtable)resp.Value; - if (respData != null) - { - if (respData.Contains("returnString")) - { - if ((string)respData["returnString"] == "TRUE") - { - - } - else - { - m_log.Warn("[GRID]: Unable to remove friend, User Server Reported an issue"); - } - } - else - { - m_log.Warn("[GRID]: Unable to remove friend, UserServer didn't understand me!"); - } - } - else - { - m_log.Warn("[GRID]: Unable to remove friend, UserServer didn't understand me!"); - - } - } - catch (WebException e) - { - m_log.Warn("[GRID]: Error when trying to RemoveUserFriend: " + - e.Message); - - } - } - - /// - /// Update permissions for friend on friendlistowner's friendlist. - /// - /// The agent that who's friends list is being updated - /// The agent that is getting or loosing permissions - /// A uint bit vector for set perms that the friend being added has; 0 = none, 1=This friend can see when they sign on, 2 = map, 4 edit objects - public virtual void UpdateUserFriendPerms(UUID friendlistowner, UUID friend, uint perms) - { - try - { - Hashtable param = new Hashtable(); - param["ownerID"] = friendlistowner.Guid.ToString(); - param["friendID"] = friend.Guid.ToString(); - param["friendPerms"] = perms.ToString(); - IList parameters = new ArrayList(); - parameters.Add(param); - - XmlRpcRequest req = new XmlRpcRequest("update_user_friend_perms", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 3000); - Hashtable respData = (Hashtable)resp.Value; - if (respData != null) - { - if (respData.Contains("returnString")) - { - if ((string)respData["returnString"] == "TRUE") - { - - } - else - { - m_log.Warn("[GRID]: Unable to update_user_friend_perms, User Server Reported an issue"); - } - } - else - { - m_log.Warn("[GRID]: Unable to update_user_friend_perms, UserServer didn't understand me!"); - } - } - else - { - m_log.Warn("[GRID]: Unable to update_user_friend_perms, UserServer didn't understand me!"); - - } - } - catch (WebException e) - { - m_log.Warn("[GRID]: Error when trying to update_user_friend_perms: " + - e.Message); - } - } - /// - /// Returns a list of FriendsListItems that describe the friends and permissions in the friend relationship for UUID friendslistowner - /// - /// The agent that we're retreiving the friends Data. - public virtual List GetUserFriendList(UUID friendlistowner) - { - List buddylist = new List(); - - try - { - Hashtable param = new Hashtable(); - param["ownerID"] = friendlistowner.Guid.ToString(); - - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_user_friend_list", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.UserURL, 8000); - Hashtable respData = (Hashtable)resp.Value; - - if (respData != null && respData.Contains("avcount")) - { - buddylist = ConvertXMLRPCDataToFriendListItemList(respData); - } - - } - catch (WebException e) - { - m_log.Warn("[OGS1 USER SERVICES]: Error when trying to fetch Avatar's friends list: " + - e.Message); - // Return Empty list (no friends) - } - return buddylist; - } - - public virtual Dictionary GetFriendRegionInfos(List uuids) - { - Dictionary result = new Dictionary(); - - // ask MessageServer about the current on-/offline status and regions the friends are in - ArrayList parameters = new ArrayList(); - Hashtable map = new Hashtable(); - - ArrayList list = new ArrayList(); - foreach (UUID uuid in uuids) - { - list.Add(uuid.ToString()); - list.Add(uuid.ToString()); - } - map["uuids"] = list; - - map["recv_key"] = m_commsManager.NetworkServersInfo.UserRecvKey; - map["send_key"] = m_commsManager.NetworkServersInfo.UserSendKey; - - parameters.Add(map); - - try - { - XmlRpcRequest req = new XmlRpcRequest("get_presence_info_bulk", parameters); - XmlRpcResponse resp = req.Send(m_commsManager.NetworkServersInfo.MessagingURL, 8000); - Hashtable respData = resp != null ? (Hashtable)resp.Value : null; - - if (respData == null || respData.ContainsKey("faultMessage")) - { - m_log.WarnFormat("[OGS1 USER SERVICES]: Contacting MessagingServer about user-regions resulted in error: {0}", - respData == null ? "" : respData["faultMessage"]); - } - else if (!respData.ContainsKey("count")) - { - m_log.WarnFormat("[OGS1 USER SERVICES]: Wrong format in response for MessagingServer request get_presence_info_bulk: missing 'count' field"); - } - else - { - int count = (int)respData["count"]; - m_log.DebugFormat("[OGS1 USER SERVICES]: Request returned {0} results.", count); - for (int i = 0; i < count; ++i) - { - if (respData.ContainsKey("uuid_" + i) && respData.ContainsKey("isOnline_" + i) && respData.ContainsKey("regionHandle_" + i)) - { - UUID uuid; - if (UUID.TryParse((string)respData["uuid_" + i], out uuid)) - { - FriendRegionInfo info = new FriendRegionInfo(); - info.isOnline = (bool)respData["isOnline_" + i]; - if (info.isOnline) - { - // TODO remove this after the next protocol update (say, r7800?) - info.regionHandle = Convert.ToUInt64(respData["regionHandle_" + i]); - - // accept missing id - if (respData.ContainsKey("regionID_" + i)) - UUID.TryParse((string)respData["regionID_" + i], out info.regionID); - } - - result.Add(uuid, info); - } - } - else - { - m_log.WarnFormat("[OGS1 USER SERVICES]: Response to get_presence_info_bulk contained an error in entry {0}", i); - } - } - } - } - catch (WebException e) - { - m_log.ErrorFormat("[OGS1 USER SERVICES]: Network problems when trying to fetch friend infos: {0}", e.Message); - } - - m_log.DebugFormat("[OGS1 USER SERVICES]: Returning {0} entries", result.Count); - return result; - } - - #endregion - - /// Appearance - public virtual AvatarAppearance GetUserAppearance(UUID user) - { - AvatarAppearance appearance = null; - - try - { - Hashtable param = new Hashtable(); - param["owner"] = user.ToString(); - - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("get_avatar_appearance", parameters); - XmlRpcResponse resp = req.Send(GetUserServerURL(user), 8000); - Hashtable respData = (Hashtable)resp.Value; - - return ConvertXMLRPCDataToAvatarAppearance(respData); - } - catch (WebException e) - { - m_log.ErrorFormat("[OGS1 USER SERVICES]: Network problems when trying to fetch appearance for avatar {0}, {1}", user, e.Message); - } - - return appearance; - } - - public virtual void UpdateUserAppearance(UUID user, AvatarAppearance appearance) - { - try - { - Hashtable param = appearance.ToHashTable(); - param["owner"] = user.ToString(); - - IList parameters = new ArrayList(); - parameters.Add(param); - XmlRpcRequest req = new XmlRpcRequest("update_avatar_appearance", parameters); - XmlRpcResponse resp = req.Send(GetUserServerURL(user), 8000); - Hashtable respData = (Hashtable)resp.Value; - - if (respData != null) - { - if (respData.Contains("returnString")) - { - if ((string)respData["returnString"] == "TRUE") - { - - } - else - { - m_log.Warn("[GRID]: Unable to update_user_appearance, User Server Reported an issue"); - } - } - else - { - m_log.Warn("[GRID]: Unable to update_user_appearance, UserServer didn't understand me!"); - } - } - else - { - m_log.Warn("[GRID]: Unable to update_user_appearance, UserServer didn't understand me!"); - } - } - catch (WebException e) - { - m_log.Warn("[OGS1 USER SERVICES]: Error when trying to update Avatar's appearance: " + - e.Message); - // Return Empty list (no friends) - } - } - - public virtual bool VerifySession(UUID userID, UUID sessionID) + + public override bool VerifySession(UUID userID, UUID sessionID) { m_log.DebugFormat("[OGS1 USER SERVICES]: Verifying user session for " + userID); return AuthClient.VerifySession(GetUserServerURL(userID), userID, sessionID); - } - - protected virtual string GetUserServerURL(UUID userID) - { - return m_commsManager.NetworkServersInfo.UserURL; - } - + } } -} +} \ No newline at end of file -- cgit v1.1