123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275 |
- using System;
- using System.Collections.Generic;
- using System.Reflection;
- using System.Threading;
- using log4net;
- using OpenMetaverse;
- using OpenSim.Framework;
- using OpenSim.Framework.Communications.Cache;
- using OpenSim.Framework.Communications.Clients;
- using OpenSim.Region.Framework.Scenes.Serialization;
- namespace OpenSim.Region.Framework.Scenes.Hypergrid
- {
- public class HGAssetMapper
- {
- #region Fields
- private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
-
- private Dictionary<string, InventoryClient> m_inventoryServers = new Dictionary<string, InventoryClient>();
- private Scene m_scene;
- #endregion
- #region Constructor
- public HGAssetMapper(Scene scene)
- {
- m_scene = scene;
- }
- #endregion
- #region Internal functions
- private string UserAssetURL(UUID userID)
- {
- CachedUserInfo uinfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(userID);
- if (uinfo != null)
- return (uinfo.UserProfile.UserAssetURI == "") ? null : uinfo.UserProfile.UserAssetURI;
- return null;
- }
- private string UserInventoryURL(UUID userID)
- {
- CachedUserInfo uinfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(userID);
- if (uinfo != null)
- return (uinfo.UserProfile.UserInventoryURI == "") ? null : uinfo.UserProfile.UserInventoryURI;
- return null;
- }
- private bool IsLocalUser(UUID userID)
- {
- CachedUserInfo uinfo = m_scene.CommsManager.UserProfileCacheService.GetUserDetails(userID);
- if (uinfo != null)
- {
- if (HGNetworkServersInfo.Singleton.IsLocalUser(uinfo.UserProfile))
- {
- m_log.Debug("[HGScene]: Home user " + uinfo.UserProfile.FirstName + " " + uinfo.UserProfile.SurName);
- return true;
- }
- }
- m_log.Debug("[HGScene]: Foreign user " + uinfo.UserProfile.FirstName + " " + uinfo.UserProfile.SurName);
- return false;
- }
- public AssetBase FetchAsset(string url, UUID assetID)
- {
- AssetBase asset = m_scene.AssetService.Get(url + "/" + assetID.ToString());
- if (asset != null)
- {
- m_log.Debug("[HGScene]: Asset made it to asset cache. " + asset.Name + " " + assetID);
- return asset;
- }
- return null;
- }
- public bool PostAsset(string url, AssetBase asset)
- {
- if (asset != null)
- {
-
- if (!asset.Temporary || asset.Local)
- {
-
-
-
-
-
- AssetBase asset1 = new AssetBase();
- Copy(asset, asset1);
- try
- {
- asset1.ID = url + "/" + asset.ID;
- }
- catch
- {
- m_log.Warn("[HGScene]: Oops.");
- }
- m_scene.AssetService.Store(asset1);
- }
- return true;
- }
- else
- m_log.Warn("[HGScene]: Tried to post asset to remote server, but asset not in local cache.");
- return false;
- }
- private void Copy(AssetBase from, AssetBase to)
- {
- to.Data = from.Data;
- to.Description = from.Description;
- to.FullID = from.FullID;
- to.ID = from.ID;
- to.Local = from.Local;
- to.Name = from.Name;
- to.Temporary = from.Temporary;
- to.Type = from.Type;
- }
-
-
-
-
-
-
-
-
- #endregion
- #region Public interface
- public void Get(UUID assetID, UUID ownerID)
- {
- if (!IsLocalUser(ownerID))
- {
-
-
- string userAssetURL = UserAssetURL(ownerID);
- if (userAssetURL != null)
- {
- m_log.Debug("[HGScene]: Fetching object " + assetID + " to asset server " + userAssetURL);
- AssetBase asset = FetchAsset(userAssetURL, assetID);
- if (asset != null)
- {
- m_log.Debug("[HGScene]: Successfully fetched item from remote asset server " + userAssetURL);
-
- Dictionary<UUID, int> ids = new Dictionary<UUID, int>();
- HGUuidGatherer uuidGatherer = new HGUuidGatherer(this, m_scene.AssetService, userAssetURL);
- uuidGatherer.GatherAssetUuids(asset.FullID, (AssetType)asset.Type, ids);
- foreach (UUID uuid in ids.Keys)
- FetchAsset(userAssetURL, uuid);
- }
- else
- m_log.Warn("[HGScene]: Could not fetch asset from remote asset server " + userAssetURL);
- }
- else
- m_log.Warn("[HGScene]: Unable to locate foreign user's asset server");
- }
- }
- public InventoryItemBase Get(InventoryItemBase item, UUID rootFolder, CachedUserInfo userInfo)
- {
- InventoryClient invCli = null;
- string inventoryURL = UserInventoryURL(item.Owner);
- if (!m_inventoryServers.TryGetValue(inventoryURL, out invCli))
- {
- m_log.Debug("[HGScene]: Starting new InventorytClient for " + inventoryURL);
- invCli = new InventoryClient(inventoryURL);
- m_inventoryServers.Add(inventoryURL, invCli);
- }
- item = invCli.GetInventoryItem(item);
- if (item != null)
- {
-
- item.Folder = rootFolder;
-
- lock (userInfo.RootFolder.Items)
- {
- userInfo.RootFolder.Items[item.ID] = item;
- }
- }
- return item;
- }
- public void Post(UUID assetID, UUID ownerID)
- {
- if (!IsLocalUser(ownerID))
- {
-
-
- string userAssetURL = UserAssetURL(ownerID);
- if (userAssetURL != null)
- {
- m_log.Debug("[HGScene]: Posting object " + assetID + " to asset server " + userAssetURL);
- AssetBase asset = m_scene.AssetService.Get(assetID.ToString());
- if (asset != null)
- {
- Dictionary<UUID, int> ids = new Dictionary<UUID, int>();
- HGUuidGatherer uuidGatherer = new HGUuidGatherer(this, m_scene.AssetService, string.Empty);
- uuidGatherer.GatherAssetUuids(asset.FullID, (AssetType)asset.Type, ids);
- foreach (UUID uuid in ids.Keys)
- {
- asset = m_scene.AssetService.Get(uuid.ToString());
- if (asset != null)
- m_log.DebugFormat("[HGScene]: Posting {0} {1}", asset.Type.ToString(), asset.Name);
- else
- m_log.DebugFormat("[HGScene]: Could not find asset {0}", uuid);
- PostAsset(userAssetURL, asset);
- }
- if (ids.Count > 0)
- m_log.DebugFormat("[HGScene]: Successfully posted item {0} to remote asset server {1}", assetID, userAssetURL);
- else
- m_log.WarnFormat("[HGScene]: Could not post asset {0} to remote asset server {1}", assetID, userAssetURL);
- }
- else
- m_log.Debug("[HGScene]: Something wrong with asset, it could not be found");
- }
- else
- m_log.Warn("[HGScene]: Unable to locate foreign user's asset server");
- }
- }
- #endregion
- }
- }
|