123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461 |
- /*
- * 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.Collections.Generic;
- using System.Reflection;
- using log4net;
- using NHibernate;
- using NHibernate.Criterion;
- using OpenMetaverse;
- using OpenSim.Framework;
- namespace OpenSim.Data.NHibernate
- {
- /// <summary>
- /// A User storage interface for the DB4o database system
- /// </summary>
- public class NHibernateUserData : UserDataBase
- {
- private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
- private NHibernateManager manager;
- public NHibernateManager Manager
- {
- get
- {
- return manager;
- }
- }
- public override void Initialise()
- {
- m_log.Info("[NHibernateUserData]: " + Name + " cannot be default-initialized!");
- throw new PluginNotInitialisedException (Name);
- }
- public override void Initialise(string connect)
- {
- m_log.InfoFormat("[NHIBERNATE] Initializing NHibernateUserData");
- manager = new NHibernateManager(connect, "UserStore");
- }
- private bool ExistsUser(UUID uuid)
- {
- UserProfileData user = null;
- m_log.InfoFormat("[NHIBERNATE] ExistsUser; {0}", uuid);
- user = (UserProfileData)manager.Get(typeof(UserProfileData), uuid);
-
- if (user == null)
- {
- m_log.InfoFormat("[NHIBERNATE] User with given UUID does not exist {0} ", uuid);
- return false;
- }
- return true;
- }
- override public UserProfileData GetUserByUUID(UUID uuid)
- {
- UserProfileData user;
- m_log.InfoFormat("[NHIBERNATE] GetUserByUUID: {0} ", uuid);
-
- user = (UserProfileData)manager.Get(typeof(UserProfileData), uuid);
- if (user != null)
- {
- UserAgentData agent = GetAgentByUUID(uuid);
- if (agent != null)
- {
- user.CurrentAgent = agent;
- }
- }
- return user;
- }
- override public void AddNewUserProfile(UserProfileData profile)
- {
- if (profile.ID == UUID.Zero)
- {
- m_log.ErrorFormat("[NHIBERNATE] Attempted to add User {0} {1} with zero UUID, throwintg exception as this is programming error ", profile.FirstName, profile.SurName);
- return;
- }
- if (!ExistsUser(profile.ID))
- {
- m_log.InfoFormat("[NHIBERNATE] AddNewUserProfile {0}", profile.ID);
- manager.Insert(profile);
- // Agent should not be saved according to BasicUserTest.T015_UserPersistency()
- // SetAgentData(profile.ID, profile.CurrentAgent);
- }
- else
- {
- m_log.ErrorFormat("[NHIBERNATE] Attempted to add User {0} {1} that already exists, updating instead", profile.FirstName, profile.SurName);
- UpdateUserProfile(profile);
- }
- }
- /*
- private void SetAgentData(UUID uuid, UserAgentData agent)
- {
- UserAgentData old = (UserAgentData)manager.Load(typeof(UserAgentData), uuid);
- if (old != null)
- {
- m_log.InfoFormat("[NHIBERNATE] SetAgentData deleting old: {0} ",uuid);
- manager.Delete(old);
- }
- if (agent != null)
- {
- m_log.InfoFormat("[NHIBERNATE] SetAgentData: {0} ", agent.ProfileID);
- manager.Save(agent);
- }
- }
- */
-
- override public bool UpdateUserProfile(UserProfileData profile)
- {
- if (ExistsUser(profile.ID))
- {
- manager.Update(profile);
- // Agent should not be saved according to BasicUserTest.T015_UserPersistency()
- // SetAgentData(profile.ID, profile.CurrentAgent);
- return true;
- }
- else
- {
- m_log.ErrorFormat("[NHIBERNATE] Attempted to update User {0} {1} that doesn't exist, updating instead", profile.FirstName, profile.SurName);
- AddNewUserProfile(profile);
- return true;
- }
- }
- override public void AddNewUserAgent(UserAgentData agent)
- {
- if (agent.ProfileID == UUID.Zero)
- {
- m_log.ErrorFormat("[NHIBERNATE] Attempted to add new user agent with zero user id. Agent session id: {0}", agent.SessionID);
- return;
- }
- if (agent.SessionID == UUID.Zero)
- {
- m_log.ErrorFormat("[NHIBERNATE] Attempted to add new user agent with zero session id. User profile id: {0}", agent.SessionID);
- return;
- }
- UserAgentData old = (UserAgentData)manager.Get(typeof(UserAgentData), agent.ProfileID);
- if (old != null)
- {
- manager.Delete(old);
- }
-
- manager.Insert(agent);
-
- }
- public void UpdateUserAgent(UserAgentData agent)
- {
- m_log.InfoFormat("[NHIBERNATE] UpdateUserAgent: {0} ", agent.ProfileID);
- manager.Update(agent);
- }
- override public UserAgentData GetAgentByUUID(UUID uuid)
- {
- m_log.InfoFormat("[NHIBERNATE] GetAgentByUUID: {0} ", uuid);
- return (UserAgentData)manager.Get(typeof(UserAgentData), uuid);
- }
- override public UserProfileData GetUserByName(string fname, string lname)
- {
- m_log.InfoFormat("[NHIBERNATE] GetUserByName: {0} {1} ", fname, lname);
- ICriteria criteria = manager.GetSession().CreateCriteria(typeof(UserProfileData));
- criteria.Add(Expression.Eq("FirstName", fname));
- criteria.Add(Expression.Eq("SurName", lname));
- foreach (UserProfileData profile in criteria.List())
- {
- profile.CurrentAgent = GetAgentByUUID(profile.ID);
- return profile;
- }
- return null;
- }
- override public UserAgentData GetAgentByName(string fname, string lname)
- {
- return GetUserByName(fname, lname).CurrentAgent;
- }
- override public UserAgentData GetAgentByName(string name)
- {
- return GetAgentByName(name.Split(' ')[0], name.Split(' ')[1]);
- }
- override public List<AvatarPickerAvatar> GeneratePickerResults(UUID queryID, string query)
- {
- List<AvatarPickerAvatar> results = new List<AvatarPickerAvatar>();
- string[] querysplit;
- querysplit = query.Split(' ');
- if (querysplit.Length == 2)
- {
- ICriteria criteria = manager.GetSession().CreateCriteria(typeof(UserProfileData));
- criteria.Add(Expression.Like("FirstName", querysplit[0]));
- criteria.Add(Expression.Like("SurName", querysplit[1]));
- foreach (UserProfileData profile in criteria.List())
- {
- AvatarPickerAvatar user = new AvatarPickerAvatar();
- user.AvatarID = profile.ID;
- user.firstName = profile.FirstName;
- user.lastName = profile.SurName;
- results.Add(user);
- }
- }
- return results;
- }
- // TODO: actually implement these
- public override void StoreWebLoginKey(UUID agentID, UUID webLoginKey)
- {
- UserProfileData user=GetUserByUUID(agentID);
- user.WebLoginKey = webLoginKey;
- UpdateUserProfile(user);
- return;
- }
- public override void AddNewUserFriend(UUID ownerId, UUID friendId, uint perms)
- {
- if (!FriendRelationExists(ownerId,friendId))
- {
- manager.Insert(new UserFriend(UUID.Random(), ownerId, friendId, perms));
- }
- if (!FriendRelationExists(friendId, ownerId))
- {
- manager.Insert(new UserFriend(UUID.Random(), friendId, ownerId, perms));
- }
- return;
- }
- private bool FriendRelationExists(UUID ownerId, UUID friendId)
- {
- using (ISession session = manager.GetSession())
- {
- ICriteria criteria = session.CreateCriteria(typeof(UserFriend));
- criteria.Add(Expression.Eq("OwnerID", ownerId));
- criteria.Add(Expression.Eq("FriendID", friendId));
- return criteria.List().Count > 0;
- }
- }
-
- public override void RemoveUserFriend(UUID ownerId, UUID friendId)
- {
- using (ISession session = manager.GetSession())
- {
- using (ITransaction transaction = session.BeginTransaction())
- {
- {
- ICriteria criteria = session.CreateCriteria(typeof(UserFriend));
- criteria.Add(Expression.Eq("OwnerID", ownerId));
- criteria.Add(Expression.Eq("FriendID", friendId));
- foreach (UserFriend userFriend in criteria.List())
- {
- session.Delete(userFriend);
- }
- }
- {
- ICriteria criteria = session.CreateCriteria(typeof(UserFriend));
- criteria.Add(Expression.Eq("OwnerID", friendId));
- criteria.Add(Expression.Eq("FriendID", ownerId));
- foreach (UserFriend userFriend in criteria.List())
- {
- session.Delete(userFriend);
- }
- }
- transaction.Commit();
- }
- }
- return;
- }
- public override void UpdateUserFriendPerms(UUID ownerId, UUID friendId, uint perms)
- {
- using (ISession session = manager.GetSession())
- {
- using (ITransaction transaction = session.BeginTransaction())
- {
- {
- ICriteria criteria = session.CreateCriteria(typeof(UserFriend));
- criteria.Add(Expression.Eq("OwnerID", ownerId));
- criteria.Add(Expression.Eq("FriendID", friendId));
- foreach (UserFriend userFriend in criteria.List())
- {
- userFriend.FriendPermissions = perms;
- session.Update(userFriend);
- }
- }
- transaction.Commit();
- }
- }
- return;
- }
- public override List<FriendListItem> GetUserFriendList(UUID ownerId)
- {
- List<FriendListItem> friendList=new List<FriendListItem>();
- Dictionary<UUID, FriendListItem> friendListItemDictionary = new Dictionary<UUID, FriendListItem>();
- using (ISession session = manager.GetSession())
- {
- ICriteria criteria = session.CreateCriteria(typeof(UserFriend));
- criteria.Add(Expression.Or(
- Expression.Eq("OwnerID", ownerId),
- Expression.Eq("FriendID", ownerId)
- ));
- foreach (UserFriend userFriend in criteria.List())
- {
- if (userFriend.OwnerID == ownerId)
- {
- FriendListItem friendListItem = new FriendListItem();
- friendListItem.FriendListOwner = userFriend.OwnerID;
- friendListItem.Friend = userFriend.FriendID;
- friendListItem.FriendPerms = userFriend.FriendPermissions;
- friendListItemDictionary.Add(userFriend.FriendID, friendListItem);
- friendList.Add(friendListItem);
- }
- }
- // Reading permissions to other direction
- foreach (UserFriend userFriend in criteria.List())
- {
- if (userFriend.FriendID == ownerId)
- {
- //Ignore if there is no reverse relation existing.
- //if (friendListItemDictionary.ContainsKey(userFriend.OwnerID))
- {
- FriendListItem friendListItem = friendListItemDictionary[userFriend.OwnerID];
- friendListItem.FriendListOwnerPerms = userFriend.FriendPermissions;
- }
- }
- }
- }
- return friendList;
- }
- public override Dictionary<UUID, FriendRegionInfo> GetFriendRegionInfos (List<UUID> friendsIds)
- {
- Dictionary<UUID, FriendRegionInfo> friendRegionInfos=new Dictionary<UUID, FriendRegionInfo>();
- foreach (UUID friendId in friendsIds)
- {
- UserAgentData agent=GetAgentByUUID(friendId);
- if (agent != null)
- {
- FriendRegionInfo fri = new FriendRegionInfo();
- fri.isOnline = agent.AgentOnline;
- fri.regionHandle = agent.Handle;
- friendRegionInfos[friendId] = fri;
- }
- }
- return friendRegionInfos;
- }
- public override bool MoneyTransferRequest(UUID from, UUID to, uint amount) { return true; }
- public override bool InventoryTransferRequest(UUID from, UUID to, UUID inventory) { return true; }
- /// Appearance
- /// TODO: stubs for now to get us to a compiling state gently
- public override AvatarAppearance GetUserAppearance(UUID user)
- {
- return (AvatarAppearance)manager.Get(typeof(AvatarAppearance), user);
- }
- private bool ExistsAppearance(UUID uuid)
- {
- AvatarAppearance appearance = (AvatarAppearance)manager.Get(typeof(AvatarAppearance), uuid);
- if (appearance == null)
- {
- return false;
- }
- return true;
- }
- public override void UpdateUserAppearance(UUID user, AvatarAppearance appearance)
- {
- if (appearance == null)
- return;
- appearance.Owner = user;
- bool exists = ExistsAppearance(user);
- if (exists)
- {
- manager.Update(appearance);
- }
- else
- {
- manager.Insert(appearance);
- }
- }
- public override void ResetAttachments(UUID userID)
- {
- }
- public override void LogoutUsers(UUID regionID)
- {
- }
- public override string Name {
- get { return "NHibernate"; }
- }
- public override string Version {
- get { return "0.1"; }
- }
- public override void Dispose()
- {
- }
- }
- }
|