OpenSimulator GForge > Projects > realXtend Modules > SVN

Diff of /trunk/ModularRex/RexParts/ModrexObjects.cs

-revision 69, Fri Feb 13 11:43:04 2009 UTC
+revision 156, Wed May 20 07:05:03 2009 UTC
 Line 11
  using OpenSim.Region.Framework.Scenes;
  using OpenSim.Data.NHibernate;
  using OpenSim.Framework;
+ using ModularRex.NHibernate;
+ using OpenSim.Framework.Communications.Cache;
  namespace ModularRex.RexParts
  {
-Line 32
+Line 34
          {
              m_scenes.Add(scene);
+             scene.RegisterModuleInterface<ModrexObjects>(this);
              scene.EventManager.OnClientConnect += EventManager_OnClientConnect;
-             scene.m_sceneGraph.OnObjectDuplicate += SceneGraph_OnObjectDuplicate;
+             scene.SceneContents.OnObjectDuplicate += SceneGraph_OnObjectDuplicate;
-             scene.m_sceneGraph.OnObjectRemove += SceneGraph_OnObjectRemove;
+             scene.SceneContents.OnObjectRemove += SceneGraph_OnObjectRemove;
+             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 63
+Line 67
          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 74
+Line 79
              }
          }
+         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 = parameters[1];
+                 RexObjectProperties props = GetObject(primID);
+                 props.RexData = data;
+             }
+             else
+             {
+                 m_log.Warn("[REXOBJS] unexpected number of parameters");
+             }
+         }
          void SceneGraph_OnObjectDuplicate(EntityBase original, EntityBase clone)
          {
              RexObjectProperties origprops = GetObject(original.UUID);
-Line 110
+Line 132
                  scene.ForEachScenePresence(
                      delegate(ScenePresence avatar)
                      {
-                         RexClientView rex;
+                         RexClientViewBase rex;
                          if (avatar.ClientView.TryGet(out rex))
                          {
                              rex.SendRexObjectProperties(id,props);
-Line 119
+Line 141
              }
          }
-         private void SendPreloadAssetsToUser(RexClientView user)
+         private void SendPreloadAssetsToUser(RexClientViewBase user)
          {
              try
              {
-Line 148
+Line 170
              }
          }
-         void SendAllPropertiesToUser(RexClientView user)
+         void SendAllPropertiesToUser(RexClientViewBase user)
          {
              SendPreloadAssetsToUser(user);
-Line 158
+Line 180
              }
          }
-         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 284
+Line 306
              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)
-                     ((IRexPhysicsActor)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].AssetCache.GetAsset(assetid, true);
+             AssetBase tempmodel = m_scenes[0].AssetService.Get(assetid.ToString());
              if (tempmodel == null)
-                 m_scenes[0].AssetCache.GetAsset(assetid, false);
+                 m_scenes[0].AssetService.Get(assetid.ToString());
              if (tempmodel != null)
-                 return(byte)(tempmodel.Metadata.Type);
+                 return(byte)(tempmodel.Type);
              else
                  return 0;
          }
-Line 353
+Line 375
              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 375
+Line 403
              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.69
 


changed lines


 
Added in v.156
 Legend:



Removed from v.69
 


changed lines


 
Added in v.156
-Removed from v.69
+Added in v.156

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

realXtend Modules

Diff of /trunk/ModularRex/RexParts/ModrexObjects.cs