OpenSimulator GForge > Projects > realXtend Modules > SVN

Diff of /branches/taiga-0.1/ModularRex/RexParts/ModrexObjects.cs

-revision 57, Fri Feb  6 08:28:47 2009 UTC
+revision 339, Wed Mar  3 08:36:42 2010 UTC
 Line 7
  using ModularRex.RexNetwork;
  using Nini.Config;
  using OpenMetaverse;
- using OpenSim.Region.Environment.Interfaces;
+ using OpenSim.Region.Framework.Interfaces;
- using OpenSim.Region.Environment.Scenes;
+ using OpenSim.Region.Framework.Scenes;
- using OpenSim.Data.NHibernate;
  using OpenSim.Framework;
+ using ModularRex.NHibernate;
+ using OpenSim.Framework.Communications.Cache;
  namespace ModularRex.RexParts
  {
-     public class ModrexObjects : IRegionModule, IRexObjectPropertiesEventManager
+     public class ModrexObjects : IRegionModule, IRexObjectPropertiesEventManager, IModrexObjectsProvider
      {
          private static readonly ILog m_log =
              LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
-Line 32
+Line 33
          {
              m_scenes.Add(scene);
+             scene.RegisterModuleInterface<ModrexObjects>(this);
+             scene.RegisterModuleInterface<IModrexObjectsProvider>(this);
              scene.EventManager.OnClientConnect += EventManager_OnClientConnect;
+             scene.SceneContents.OnObjectDuplicate += SceneGraph_OnObjectDuplicate;
+             scene.SceneContents.OnObjectRemove += SceneGraph_OnObjectRemove;
+             scene.EventManager.OnObjectBeingRemovedFromScene += EventManager_OnObjectBeingRemovedFromScene;
+             scene.AddCommand(this, "modreximport", "load 0.4 rex database <connstring>", "conn string example: SQLiteDialect;SQLite20Driver;Data Source=beneath_the_waves.db;Version=3", HandleLoadRexLegacyData);
              if (m_db == null)
              {
-Line 59
+Line 66
              }
          }
+         void EventManager_OnObjectBeingRemovedFromScene(SceneObjectGroup obj)
+         {
+             if (RexObjectPropertiesCache.ContainsKey(obj.UUID))
+             {
+                 RexObjectPropertiesCache.Remove(obj.UUID);
+             }
+         }
          void EventManager_OnClientConnect(OpenSim.Framework.Client.IClientCore client)
          {
-             RexClientView rcv;
+             RexClientViewBase rcv;
              if (client.TryGet(out rcv))
              {
                  rcv.OnRexObjectProperties += rcv_OnRexObjectProperties;
+                 rcv.OnPrimFreeData += rcv_OnPrimFreeData;
                  //rcv.OnChatFromClient += rcv_OnChatFromClient;
                  // Send them the current Scene.
-Line 72
+Line 88
              }
          }
+         private void rcv_OnPrimFreeData(IClientAPI sender, List<string> parameters)
+         {
+             m_log.Info("[REXOBJS] Received Prim free data");
+             if (parameters.Count >= 2)
+             {
+                 UUID primID = new UUID(parameters[0]);
+                 string data = String.Empty;
+                 if(parameters.Count == 2)
+                 {
+                     data = parameters[1];
+                 }else
+                 {
+                     for (int i = 1; i < parameters.Count; i++)
+                     {
+                         data += parameters[i];
+                     }
+                 }
+                 RexObjectProperties props = GetObject(primID);
+                 props.RexData = data;
+                 SendPrimFreeDataToAllUsers(primID, data);
+             }
+             else
+             {
+                 m_log.Warn("[REXOBJS] unexpected number of parameters");
+             }
+         }
+         void SendPrimFreeDataToAllUsers(UUID id, string data)
+         {
+             foreach (Scene scene in m_scenes)
+             {
+                 scene.ForEachScenePresence(
+                     delegate(ScenePresence avatar)
+                     {
+                         RexClientViewBase rex;
+                         if (avatar.ClientView.TryGet(out rex))
+                         {
+                             rex.SendRexPrimFreeData(id, data);
+                         }
+                     });
+             }
+         }
+         void SceneGraph_OnObjectDuplicate(EntityBase original, EntityBase clone)
+         {
+             RexObjectProperties origprops = GetObject(original.UUID);
+             RexObjectProperties cloneprops = GetObject(clone.UUID);
+             cloneprops.SetRexPrimDataFromObject(origprops);
+         }
+         void SceneGraph_OnObjectRemove(EntityBase obj)
+         {
+             //this object group was removed from scene, but part is not necessarily removed from all groups
+             //DeleteObject(obj.UUID);
+         }
          //void rcv_OnChatFromClient(object sender, OpenSim.Framework.OSChatMessage e)
          //{
          //    if (e.Message.StartsWith("/rexobj "))
-Line 94
+Line 170
                  scene.ForEachScenePresence(
                      delegate(ScenePresence avatar)
                      {
-                         RexClientView rex;
+                         RexClientViewBase rex;
                          if (avatar.ClientView.TryGet(out rex))
                          {
                              rex.SendRexObjectProperties(id,props);
-Line 103
+Line 179
              }
          }
-         void SendAllPropertiesToUser(RexClientView user)
+         private void SendPreloadAssetsToUser(RexClientViewBase user)
+         {
+             try
+             {
+                 Scene ourScene = null;
+                 foreach (Scene s in m_scenes)
+                 {
+                     if (user.Scene.RegionInfo.RegionHandle == s.RegionInfo.RegionHandle)
+                         ourScene = s;
+                 }
+                 if (ourScene != null)
+                 {
+                     if (ourScene.Modules.ContainsKey("RexAssetPreload"))
+                     {
+                         RexAssetPreload module = (RexAssetPreload)ourScene.Modules["RexAssetPreload"];
+                         if (module.PreloadAssetDictionary.Count > 0)
+                         {
+                             user.SendRexPreloadAssets(module.PreloadAssetDictionary);
+                         }
+                     }
+                 }
+             }
+             catch (Exception e)
+             {
+                 m_log.Error("[MODREXOBJECTS]: Sending preload assets failed.", e);
+             }
+         }
+         public void SendAllPropertiesToUser(RexClientViewBase user)
          {
+             SendPreloadAssetsToUser(user);
              foreach (RexObjectProperties p in GetObjects())
              {
                  user.SendRexObjectProperties(p.ParentObjectID, p);
+                 if (p.RexData.Length > 0) //send rex data also if exists
+                 {
+                     user.SendRexPrimFreeData(p.ParentObjectID, p.RexData);
+                 }
              }
          }
-         void rcv_OnRexObjectProperties(RexClientView sender, UUID id, RexObjectProperties props)
+         void rcv_OnRexObjectProperties(IClientAPI sender, UUID id, RexObjectProperties props)
          {
              m_log.Info("[REXOBJS] Received RexObjData for " + id);
              if (props.ParentObjectID == UUID.Zero)
-Line 166
+Line 277
              //    return;
              RexObjectProperties p = GetObject(id);
-             SceneObjectPart sop = m_scenes[0].GetSceneObjectPart(id);
+             SceneObjectPart sop = null;// = m_scenes[0].GetSceneObjectPart(id);
+             foreach (Scene scene in m_scenes)
+             {
+                 SceneObjectPart part = scene.GetSceneObjectPart(id);
+                 if (part != null)
+                 {
+                     sop = part;
+                     break;
+                 }
+             }
              if (sop == null)
              {
                  m_log.Error("[REXOBJS] TriggerOnChangeCollisionMesh, no SceneObjectPart for id:" + id.ToString());
                  return;
              }
-             if (sop.ParentGroup != null && sop.PhysActor != null)
+             if (sop.ParentGroup != null && sop.PhysActor is IRexPhysicsActor)
              {
                  if (p.RexCollisionMeshUUID != UUID.Zero)
                      RexUpdateCollisionMesh(id);
                  else
-                     sop.PhysActor.SetCollisionMesh(null, "", false);
+                     ((IRexPhysicsActor)sop.PhysActor).SetCollisionMesh(null, "", false);
              }
          }
-Line 189
+Line 310
              //    return;
              RexObjectProperties p = GetObject(id);
-             SceneObjectPart sop = m_scenes[0].GetSceneObjectPart(id);
+             SceneObjectPart sop = null;
+             foreach (Scene s in m_scenes)
+             {
+                 SceneObjectPart part = s.GetSceneObjectPart(id);
+                 if (part != null)
+                 {
+                     sop = part;
+                     break;
+                 }
+             }
              if (sop == null)
              {
                  m_log.Error("[REXOBJS] TriggerOnChangeScaleToPrim, no SceneObjectPart for id:" + id.ToString());
                  return;
              }
-             if (sop.ParentGroup != null && sop.PhysActor != null)
+             if (sop.ParentGroup != null && sop.PhysActor is IRexPhysicsActor)
              {
-                 sop.PhysActor.SetBoundsScaling(p.RexScaleToPrim);
+                 ((IRexPhysicsActor)sop.PhysActor).SetBoundsScaling(p.RexScaleToPrim);
                  sop.ParentGroup.Scene.PhysicsScene.AddPhysicsActorTaint(sop.PhysActor);
              }
          }
-Line 207
+Line 338
          {
              RexObjectProperties props = GetObject(id);
-             m_db.StoreObject(props);
+             //instead of saving right away, set timer to save after a sec.
+             //m_db.StoreObject(props);
              SendPropertiesToAllUsers(id,props);
+             props.ScheduleSave();
          }
          public void TriggerOnChangeRexObjectMetaData(UUID id)
-Line 228
+Line 361
              //    return;
              RexObjectProperties p = GetObject(id);
-             SceneObjectPart sop = m_scenes[0].GetSceneObjectPart(id);
+             SceneObjectPart sop = null;// m_scenes[0].GetSceneObjectPart(id);
+             foreach (Scene s in m_scenes)
+             {
+                 SceneObjectPart part = s.GetSceneObjectPart(id);
+                 if (part != null)
+                 {
+                     sop = part;
+                     break;
+                 }
+             }
              if (sop == null)
              {
                  m_log.Error("[REXOBJS] RexUpdateCollisionMesh, no SceneObjectPart for id:" + id.ToString());
                  return;
              }
-             if (p.RexCollisionMeshUUID != UUID.Zero && sop.PhysActor != null)
+             if (p.RexCollisionMeshUUID != UUID.Zero && sop.PhysActor is IRexPhysicsActor)
              {
-                 AssetBase tempmodel = sop.ParentGroup.Scene.AssetCache.GetAsset(p.RexCollisionMeshUUID, false);
+                 AssetBase tempmodel = sop.ParentGroup.Scene.AssetService.Get(p.RexCollisionMeshUUID.ToString());
                  if (tempmodel != null)
-                     sop.PhysActor.SetCollisionMesh(tempmodel.Data, tempmodel.Metadata.Name, p.RexScaleToPrim);
+                     ((IRexPhysicsActor)sop.PhysActor).SetCollisionMesh(tempmodel.Data, tempmodel.Name, p.RexScaleToPrim);
              }
          }
+         public byte GetAssetType(UUID assetid)
+         {
+             AssetBase tempmodel = m_scenes[0].AssetService.Get(assetid.ToString());
+             if (tempmodel == null)
+                 m_scenes[0].AssetService.Get(assetid.ToString());
+             if (tempmodel != null)
+                 return(byte)(tempmodel.Type);
+             else
+                 return 0;
+         }
+         public void TriggerOnSaveObject(UUID id)
+         {
+             RexObjectProperties props = GetObject(id);
+             m_db.StoreObject(props);
+         }
          #endregion
-Line 259
+Line 421
              {
                  foreach (EntityBase e in s.Entities)
                  {
-                     RexObjectProperties p = LoadObject(e.UUID);
+                     if (e is SceneObjectGroup && !RexObjectPropertiesCache.ContainsKey(e.UUID))
-                     p.ParentObjectID = e.UUID;
+                     {
+                         SceneObjectGroup oGroup = (SceneObjectGroup)e;
+                         foreach (SceneObjectPart part in oGroup.GetParts())
+                         {
+                             RexObjectProperties p = LoadObject(part.UUID);
+                             p.ParentObjectID = part.UUID;
                      p.SetRexEventManager(this);
-                     RexObjectPropertiesCache.Add(e.UUID,p);
+                             if(!RexObjectPropertiesCache.ContainsKey(part.UUID))
+                                 RexObjectPropertiesCache.Add(part.UUID, p);
                      // Since loaded objects have their properties already set, any initialization that needs to be done should be here.
                      if(p.RexCollisionMeshUUID != UUID.Zero)
-                         TriggerOnChangeCollisionMesh(e.UUID);
+                                 TriggerOnChangeCollisionMesh(part.UUID);
                      if (p.RexClassName.Length > 0)
                      {
-                         SceneObjectPart sop = m_scenes[0].GetSceneObjectPart(p.ParentObjectID);
+                                 part.SetScriptEvents(p.ParentObjectID, (int)scriptEvents.touch_start);
-                         if (sop != null)
+                             }
-                             sop.SetScriptEvents(p.ParentObjectID, (int)scriptEvents.touch_start);
+                             TriggerOnChangeRexObjectProperties(part.UUID);
+                         }
                      }
                  }
              }
-Line 294
+Line 465
              RexObjectProperties props = RexObjectPropertiesCache[id];
              if (props == null)
              {
+                 //Objects that are not in the scene can't be found from cache.
+                 //So before we create new properties, we try to find them from db
+                 props = m_db.LoadObject(id);
+                 if (props == null)
+                 {
                  props = new RexObjectProperties(id, this);
+                 }
                  RexObjectPropertiesCache.Add(id, props);
              }
              return props;
-Line 310
+Line 487
              if (RexObjectPropertiesCache.ContainsKey(id))
              {
                  RexObjectPropertiesCache.Remove(id);
+                 m_db.RemoveObject(id);
                  return true;
              }
              return false;
          }
          #endregion
+         public void HandleLoadRexLegacyData(string module, string[] args)
+         {
+             NHibernateRexLegacyData legacydata = new NHibernateRexLegacyData();
+             legacydata.Initialise(args[1]);
+             if(!legacydata.Inizialized)
+             {
+                 m_log.Info("[MODREXOBJECTS]: Legacy database failed to initialize.");
+                 return;
+             }
+             List<RexLegacyPrimData> rexprimdata = legacydata.LoadAllRexPrimData();
+             m_log.Info("[MODREXOBJECTS]: Legacy rexprimdata objects loaded:" + rexprimdata.Count.ToString());
+             List<RexLegacyPrimMaterialData> rexprimmaterialdata = legacydata.LoadAllRexPrimMaterialData();
+             m_log.Info("[MODREXOBJECTS]: Legacy rexprimmaterialdata objects loaded:" + rexprimmaterialdata.Count.ToString());
+             foreach (RexLegacyPrimData prim in rexprimdata)
+             {
+                 RexObjectProperties p = GetObject(prim.UUID);
+                 p.SetRexPrimDataFromLegacyData(prim);
+             }
+             foreach (RexLegacyPrimMaterialData primmat in rexprimmaterialdata)
+             {
+                 RexObjectProperties p = GetObject(primmat.UUID);
+                 p.RexMaterials.AddMaterial((uint)primmat.MaterialIndex,primmat.MaterialUUID);
+             }
+         }
      }
  }

 Legend:



Removed from v.57
 


changed lines


 
Added in v.339
 Legend:



Removed from v.57
 


changed lines


 
Added in v.339
-Removed from v.57
+Added in v.339

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

realXtend Modules

Diff of /branches/taiga-0.1/ModularRex/RexParts/ModrexObjects.cs