/* * 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 log4net; using System; using System.Collections.Generic; using System.Reflection; using Nini.Config; using OpenSim.Framework; using OpenSim.Framework.Statistics; using OpenSim.Services.Connectors; using OpenSim.Region.Framework.Interfaces; using OpenSim.Region.Framework.Scenes; using OpenSim.Services.Interfaces; using OpenMetaverse; namespace OpenSim.Region.CoreModules.ServiceConnectorsOut.Inventory { public class RemoteInventoryServicesConnector : BaseInventoryConnector, ISharedRegionModule, IInventoryService { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); private bool m_Enabled = false; private bool m_Initialized = false; private Scene m_Scene; private InventoryServicesConnector m_RemoteConnector; public Type ReplaceableInterface { get { return null; } } public string Name { get { return "RemoteInventoryServicesConnector"; } } public RemoteInventoryServicesConnector() { } public RemoteInventoryServicesConnector(IConfigSource source) { Init(source); } protected override void Init(IConfigSource source) { m_RemoteConnector = new InventoryServicesConnector(source); base.Init(source); } #region ISharedRegionModule public void Initialise(IConfigSource source) { IConfig moduleConfig = source.Configs["Modules"]; if (moduleConfig != null) { string name = moduleConfig.GetString("InventoryServices", ""); if (name == Name) { Init(source); m_Enabled = true; m_log.Info("[INVENTORY CONNECTOR]: Remote inventory enabled"); } } } public void PostInitialise() { } public void Close() { } public void AddRegion(Scene scene) { if (!m_Enabled) return; if (!m_Initialized) { m_Scene = scene; // ugh! scene.CommsManager.UserProfileCacheService.SetInventoryService(this); scene.CommsManager.UserService.SetInventoryService(this); m_Initialized = true; } scene.RegisterModuleInterface(this); m_cache.AddRegion(scene); } public void RemoveRegion(Scene scene) { if (!m_Enabled) return; m_cache.RemoveRegion(scene); } public void RegionLoaded(Scene scene) { if (!m_Enabled) return; m_log.InfoFormat("[INVENTORY CONNECTOR]: Enabled remote inventory for region {0}", scene.RegionInfo.RegionName); } #endregion ISharedRegionModule #region IInventoryService public override bool CreateUserInventory(UUID user) { return false; } public override List GetInventorySkeleton(UUID userId) { return new List(); } public override InventoryCollection GetUserInventory(UUID userID) { return null; } public override void GetUserInventory(UUID userID, InventoryReceiptCallback callback) { UUID sessionID = GetSessionID(userID); try { m_RemoteConnector.GetUserInventory(userID.ToString(), sessionID, callback); } catch (Exception e) { if (StatsManager.SimExtraStats != null) StatsManager.SimExtraStats.AddInventoryServiceRetrievalFailure(); m_log.ErrorFormat("[INVENTORY CONNECTOR]: Request inventory operation failed, {0} {1}", e.Source, e.Message); } } // inherited. See base class // public InventoryFolderBase GetFolderForType(UUID userID, AssetType type) public override Dictionary GetSystemFolders(UUID userID) { UUID sessionID = GetSessionID(userID); return m_RemoteConnector.GetSystemFolders(userID.ToString(), sessionID); } public override InventoryCollection GetFolderContent(UUID userID, UUID folderID) { UUID sessionID = GetSessionID(userID); try { return m_RemoteConnector.GetFolderContent(userID.ToString(), folderID, sessionID); } catch (Exception e) { m_log.ErrorFormat("[INVENTORY CONNECTOR]: GetFolderContent operation failed, {0} {1}", e.Source, e.Message); } InventoryCollection nullCollection = new InventoryCollection(); nullCollection.Folders = new List(); nullCollection.Items = new List(); nullCollection.UserID = userID; return nullCollection; } public override List GetFolderItems(UUID userID, UUID folderID) { return new List(); } public override bool AddFolder(InventoryFolderBase folder) { if (folder == null) return false; UUID sessionID = GetSessionID(folder.Owner); return m_RemoteConnector.AddFolder(folder.Owner.ToString(), folder, sessionID); } public override bool UpdateFolder(InventoryFolderBase folder) { if (folder == null) return false; UUID sessionID = GetSessionID(folder.Owner); return m_RemoteConnector.UpdateFolder(folder.Owner.ToString(), folder, sessionID); } public override bool MoveFolder(InventoryFolderBase folder) { if (folder == null) return false; UUID sessionID = GetSessionID(folder.Owner); return m_RemoteConnector.MoveFolder(folder.Owner.ToString(), folder, sessionID); } public override bool PurgeFolder(InventoryFolderBase folder) { if (folder == null) return false; UUID sessionID = GetSessionID(folder.Owner); return m_RemoteConnector.PurgeFolder(folder.Owner.ToString(), folder, sessionID); } // public bool AddItem(InventoryItemBase item) inherited // Uses AddItemPlain protected override bool AddItemPlain(InventoryItemBase item) { if (item == null) return false; UUID sessionID = GetSessionID(item.Owner); return m_RemoteConnector.AddItem(item.Owner.ToString(), item, sessionID); } public override bool UpdateItem(InventoryItemBase item) { if (item == null) return false; UUID sessionID = GetSessionID(item.Owner); return m_RemoteConnector.UpdateItem(item.Owner.ToString(), item, sessionID); } public override bool DeleteItem(InventoryItemBase item) { if (item == null) return false; UUID sessionID = GetSessionID(item.Owner); return m_RemoteConnector.DeleteItem(item.Owner.ToString(), item, sessionID); } public override InventoryItemBase GetItem(InventoryItemBase item) { if (item == null) return null; UUID sessionID = GetSessionID(item.Owner); return m_RemoteConnector.QueryItem(item.Owner.ToString(), item, sessionID); } public override InventoryFolderBase GetFolder(InventoryFolderBase folder) { if (folder == null) return null; UUID sessionID = GetSessionID(folder.Owner); return m_RemoteConnector.QueryFolder(folder.Owner.ToString(), folder, sessionID); } public override bool HasInventoryForUser(UUID userID) { return false; } public override List GetActiveGestures(UUID userId) { return new List(); } public override int GetAssetPermissions(UUID userID, UUID assetID) { UUID sessionID = GetSessionID(userID); return m_RemoteConnector.GetAssetPermissions(userID.ToString(), assetID, sessionID); } #endregion private UUID GetSessionID(UUID userID) { ScenePresence sp = m_Scene.GetScenePresence(userID); if (sp != null) return sp.ControllingClient.SessionId; return UUID.Zero; } } }