/*
* 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.Generic;
using libsecondlife;
namespace OpenSim.Framework.Communications.Cache
{
public class CachedUserInfo
{
private static readonly log4net.ILog m_log
= log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
private readonly CommunicationsManager m_parentCommsManager;
// FIXME: These need to be hidden behind accessors
public InventoryFolderImpl RootFolder = null;
public UserProfileData UserProfile = null;
///
/// Stores received folders for which we have not yet received the parents.
///
private IDictionary> pendingCategorizationFolders
= new Dictionary>();
public CachedUserInfo(CommunicationsManager commsManager)
{
m_parentCommsManager = commsManager;
}
///
/// Store a folder pending categorization when its parent is received.
///
///
private void AddPendingFolder(InventoryFolderImpl folder)
{
LLUUID parentFolderId = folder.parentID;
if (pendingCategorizationFolders.ContainsKey(parentFolderId))
{
pendingCategorizationFolders[parentFolderId].Add(folder);
}
else
{
IList folders = new List();
folders.Add(folder);
pendingCategorizationFolders[parentFolderId] = folders;
}
}
///
/// Add any pending folders which are children of parent
///
///
/// A
///
private void ResolvePendingFolders(InventoryFolderImpl parent)
{
if (pendingCategorizationFolders.ContainsKey(parent.folderID))
{
foreach (InventoryFolderImpl folder in pendingCategorizationFolders[parent.folderID])
{
// m_log.DebugFormat(
// "[INVENTORY CACHE]: Resolving pending received folder {0} {1} into {2} {3}",
// folder.name, folder.folderID, parent.name, parent.folderID);
if (!parent.SubFolders.ContainsKey(folder.folderID))
{
parent.SubFolders.Add(folder.folderID, folder);
}
}
}
}
///
/// Callback invoked when a folder is received from an async request to the inventory service.
///
///
///
public void FolderReceive(LLUUID userID, InventoryFolderImpl folderInfo)
{
// FIXME: Exceptions thrown upwards never appear on the console. Could fix further up if these
// are simply being swallowed
try
{
// m_log.DebugFormat(
// "[INVENTORY CACHE]: Received folder {0} {1} for user {2}",
// folderInfo.name, folderInfo.folderID, userID);
if (userID == UserProfile.UUID)
{
if (RootFolder == null)
{
if (folderInfo.parentID == LLUUID.Zero)
{
RootFolder = folderInfo;
}
}
else if (RootFolder.folderID == folderInfo.parentID)
{
if (!RootFolder.SubFolders.ContainsKey(folderInfo.folderID))
{
RootFolder.SubFolders.Add(folderInfo.folderID, folderInfo);
}
else
{
AddPendingFolder(folderInfo);
}
}
else
{
InventoryFolderImpl folder = RootFolder.HasSubFolder(folderInfo.parentID);
if (folder != null)
{
if (!folder.SubFolders.ContainsKey(folderInfo.folderID))
{
folder.SubFolders.Add(folderInfo.folderID, folderInfo);
}
}
else
{
AddPendingFolder(folderInfo);
}
}
ResolvePendingFolders(folderInfo);
}
}
catch (Exception e)
{
m_log.ErrorFormat("[INVENTORY CACHE] {0}", e);
}
}
///
/// Callback invoked when an item is received from an async request to the inventory service.
///
/// FIXME: We're assuming here that items are always received after all the folders have been
/// received.
///
///
///
public void ItemReceive(LLUUID userID, InventoryItemBase itemInfo)
{
if ((userID == UserProfile.UUID) && (RootFolder != null))
{
if (itemInfo.parentFolderID == RootFolder.folderID)
{
if (!RootFolder.Items.ContainsKey(itemInfo.inventoryID))
{
RootFolder.Items.Add(itemInfo.inventoryID, itemInfo);
}
}
else
{
InventoryFolderImpl folder = RootFolder.HasSubFolder(itemInfo.parentFolderID);
if (folder != null)
{
if (!folder.Items.ContainsKey(itemInfo.inventoryID))
{
folder.Items.Add(itemInfo.inventoryID, itemInfo);
}
}
}
}
}
public void AddItem(LLUUID userID, InventoryItemBase itemInfo)
{
if ((userID == UserProfile.UUID) && (RootFolder != null))
{
ItemReceive(userID, itemInfo);
m_parentCommsManager.InventoryService.AddNewInventoryItem(userID, itemInfo);
}
}
public void UpdateItem(LLUUID userID, InventoryItemBase itemInfo)
{
if ((userID == UserProfile.UUID) && (RootFolder != null))
{
m_parentCommsManager.InventoryService.AddNewInventoryItem(userID, itemInfo);
}
}
public bool DeleteItem(LLUUID userID, InventoryItemBase item)
{
bool result = false;
if ((userID == UserProfile.UUID) && (RootFolder != null))
{
result = RootFolder.DeleteItem(item.inventoryID);
if (result)
{
m_parentCommsManager.InventoryService.DeleteInventoryItem(userID, item);
}
}
return result;
}
}
}