1 files changed, 232 insertions, 0 deletions

diff --git a/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs
new file mode 100644
index 0000000..b4dbaa1
--- /dev/null
+++ b/OpenSim/Region/CoreModules/Agent/AssetTransaction/AgentAssetsTransactions.cs
@@ -0,0 +1,232 @@
+/*
+ * 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 OpenMetaverse;
+using OpenSim.Framework;
+using OpenSim.Region.Framework.Scenes;
+using OpenSim.Framework.Communications.Cache;
+
+namespace OpenSim.Region.CoreModules.Agent.AssetTransaction
+{
+    /// <summary>
+    /// Manage asset transactions for a single agent.
+    /// </summary>
+    public class AgentAssetTransactions
+    {
+        private static readonly log4net.ILog m_log = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);
+
+        // Fields
+        private bool m_dumpAssetsToFile;
+        public AssetTransactionModule Manager;
+        public UUID UserID;
+        public Dictionary<UUID, AssetXferUploader> XferUploaders = new Dictionary<UUID, AssetXferUploader>();
+
+        // Methods
+        public AgentAssetTransactions(UUID agentID, AssetTransactionModule manager, bool dumpAssetsToFile)
+        {
+            UserID = agentID;
+            Manager = manager;
+            m_dumpAssetsToFile = dumpAssetsToFile;
+        }
+
+        public AssetXferUploader RequestXferUploader(UUID transactionID)
+        {
+            if (!XferUploaders.ContainsKey(transactionID))
+            {
+                AssetXferUploader uploader = new AssetXferUploader(this, m_dumpAssetsToFile);
+
+                lock (XferUploaders)
+                {
+                    XferUploaders.Add(transactionID, uploader);
+                }
+
+                return uploader;
+            }
+            return null;
+        }
+
+        public void HandleXfer(ulong xferID, uint packetID, byte[] data)
+        {
+            lock (XferUploaders)
+            {
+                foreach (AssetXferUploader uploader in XferUploaders.Values)
+                {
+                    if (uploader.XferID == xferID)
+                    {
+                        uploader.HandleXferPacket(xferID, packetID, data);
+                        break;
+                    }
+                }
+            }
+        }
+
+        public void RequestCreateInventoryItem(IClientAPI remoteClient, UUID transactionID, UUID folderID,
+                                               uint callbackID, string description, string name, sbyte invType,
+                                               sbyte type, byte wearableType, uint nextOwnerMask)
+        {
+            if (XferUploaders.ContainsKey(transactionID))
+            {
+                XferUploaders[transactionID].RequestCreateInventoryItem(remoteClient, transactionID, folderID,
+                                                                        callbackID, description, name, invType, type,
+                                                                        wearableType, nextOwnerMask);
+            }
+        }
+
+
+
+        /// <summary>
+        /// Get an uploaded asset.  If the data is successfully retrieved, the transaction will be removed.
+        /// </summary>
+        /// <param name="transactionID"></param>
+        /// <returns>The asset if the upload has completed, null if it has not.</returns>
+        public AssetBase GetTransactionAsset(UUID transactionID)
+        {
+            if (XferUploaders.ContainsKey(transactionID))
+            {
+                AssetXferUploader uploader = XferUploaders[transactionID];
+                AssetBase asset = uploader.GetAssetData();
+
+                lock (XferUploaders)
+                {
+                    XferUploaders.Remove(transactionID);
+                }
+
+                return asset;
+            }
+
+            return null;
+        }
+
+        //private void CreateItemFromUpload(AssetBase asset, IClientAPI ourClient, UUID inventoryFolderID, uint nextPerms, uint wearableType)
+        //{
+        //    Manager.MyScene.CommsManager.AssetCache.AddAsset(asset);
+        //    CachedUserInfo userInfo = Manager.MyScene.CommsManager.UserProfileCacheService.GetUserDetails(
+        //            ourClient.AgentId);
+
+        //    if (userInfo != null)
+        //    {
+        //        InventoryItemBase item = new InventoryItemBase();
+        //        item.Owner = ourClient.AgentId;
+        //        item.Creator = ourClient.AgentId;
+        //        item.ID = UUID.Random();
+        //        item.AssetID = asset.FullID;
+        //        item.Description = asset.Description;
+        //        item.Name = asset.Name;
+        //        item.AssetType = asset.Type;
+        //        item.InvType = asset.Type;
+        //        item.Folder = inventoryFolderID;
+        //        item.BasePermissions = 0x7fffffff;
+        //        item.CurrentPermissions = 0x7fffffff;
+        //        item.EveryOnePermissions = 0;
+        //        item.NextPermissions = nextPerms;
+        //        item.Flags = wearableType;
+        //        item.CreationDate = Util.UnixTimeSinceEpoch();
+
+        //        userInfo.AddItem(item);
+        //        ourClient.SendInventoryItemCreateUpdate(item);
+        //    }
+        //    else
+        //    {
+        //        m_log.ErrorFormat(
+        //            "[ASSET TRANSACTIONS]: Could not find user {0} for inventory item creation",
+        //            ourClient.AgentId);
+        //    }
+        //}
+
+        public void RequestUpdateTaskInventoryItem(
+           IClientAPI remoteClient, SceneObjectPart part, UUID transactionID, TaskInventoryItem item)
+        {
+            if (XferUploaders.ContainsKey(transactionID))
+            {
+                AssetBase asset = XferUploaders[transactionID].GetAssetData();
+                if (asset != null)
+                {
+                    m_log.DebugFormat(
+                        "[ASSET TRANSACTIONS]: Updating task item {0} in {1} with asset in transaction {2}",
+                        item.Name, part.Name, transactionID);
+
+                    asset.Metadata.Name = item.Name;
+                    asset.Metadata.Description = item.Description;
+                    asset.Metadata.Type = (sbyte)item.Type;
+                    item.AssetID = asset.Metadata.FullID;
+
+                    Manager.MyScene.CommsManager.AssetCache.AddAsset(asset);
+
+                    if (part.Inventory.UpdateInventoryItem(item))
+                        part.GetProperties(remoteClient);
+                }
+            }
+        }
+
+
+        public void RequestUpdateInventoryItem(IClientAPI remoteClient, UUID transactionID,
+                                               InventoryItemBase item)
+        {
+             if (XferUploaders.ContainsKey(transactionID))
+            {
+                CachedUserInfo userInfo = Manager.MyScene.CommsManager.UserProfileCacheService.GetUserDetails(
+                        remoteClient.AgentId);
+
+                if (userInfo != null)
+                {
+                    UUID assetID = UUID.Combine(transactionID, remoteClient.SecureSessionId);
+
+                    AssetBase asset
+                        = Manager.MyScene.CommsManager.AssetCache.GetAsset(
+                            assetID, (item.AssetType == (int)AssetType.Texture ? true : false));
+
+                    if (asset == null)
+                    {
+                        asset = GetTransactionAsset(transactionID);
+                    }
+
+                    if (asset != null && asset.Metadata.FullID == assetID)
+                    {
+                        // Assets never get updated, new ones get created
+                        asset.Metadata.FullID = UUID.Random();
+                        asset.Metadata.Name = item.Name;
+                        asset.Metadata.Description = item.Description;
+                        asset.Metadata.Type = (sbyte)item.AssetType;
+                        item.AssetID = asset.Metadata.FullID;
+
+                        Manager.MyScene.CommsManager.AssetCache.AddAsset(asset);
+                    }
+
+                    userInfo.UpdateItem(item);
+                }
+                else
+                {
+                   m_log.ErrorFormat(
+                        "[ASSET TRANSACTIONS]: Could not find user {0} for inventory item update",
+                       remoteClient.AgentId);
+                }
+            }
+        }
+    }
+}