OpenSimulator GForge > Projects > realXtend Modules > SVN

Diff of /branches/os-udp/ModularRex/RexNetwork/ClientViews/RexClientViewBase.cs

-trunk/ModularRex/RexNetwork/RexClientView.cs
revision 115, Mon Apr 20 08:59:54 2009 UTC
+branches/os-udp/ModularRex/RexNetwork/ClientViews/RexClientViewBase.cs
revision 228, Tue Oct 13 08:09:55 2009 UTC
 Line 13
  using OpenSim.Framework.Communications.Cache;
  using OpenSim.Region.ClientStack;
  using OpenSim.Region.ClientStack.LindenUDP;
+ using ModularRex.RexNetwork.RexLogin;
+ using System.Timers;
+ using System.Text;
  namespace ModularRex.RexNetwork
  {
-Line 23
+Line 26
      /// In the case whereby functionality uses the same packets but differs
      /// between Rex and LL, you can use a override on those specific functions
      /// to overload the request.
+     ///
+     /// This class acts as a base class for legacy client and new rex-ng client (Bob)
      /// </summary>
-     public class RexClientView : LLClientView, IClientRexFaceExpression, IClientRexAppearance, IClientMediaURL, IRexClientCore
+     public class RexClientViewBase : LLClientView, IClientRexFaceExpression, IClientRexAppearance, IClientMediaURL, IRexClientCore
      {
          private static readonly ILog m_log =
              LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
-Line 35
+Line 40
          private string m_rexAvatarURL;
          private string m_rexAvatarURLOverride;
          private string m_rexAuthURL;
-         private string m_rexSkypeURL;
          private float m_RexCharacterSpeedMod = 1.0f;
          private float m_RexVertMovementSpeedMod = 1.0f;
-         private bool m_RexWalkDisabled = false;
-         private bool m_RexFlyDisabled = false;
          public event RexAppearanceDelegate OnRexAppearance;
          public event RexGenericMessageDelegate OnRexFaceExpression;
-Line 51
+Line 53
          public event ReceiveRexMediaURL OnReceiveRexMediaURL;
          public event RexGenericMessageDelegate OnPrimFreeData;
-         public RexClientView(EndPoint remoteEP, IScene scene, IAssetCache assetCache,
+         public RexClientViewBase(EndPoint remoteEP, IScene scene,
-                              LLPacketServer packServer, AuthenticateResponse authenSessions, UUID agentId,
+                              LLUDPServer udpServer, LLUDPClient udpClient, AuthenticateResponse authenSessions, UUID agentId,
-                              UUID sessionId, uint circuitCode, EndPoint proxyEP, ClientStackUserSettings userSettings)
+                              UUID sessionId, uint circuitCode)
-             : base(remoteEP, scene, assetCache, packServer, authenSessions, agentId,
+             : base(remoteEP, scene, udpServer, udpClient, authenSessions, agentId,
-                    sessionId, circuitCode, proxyEP, userSettings)
+                    sessionId, circuitCode)
          {
              // Rex communication now occurs via GenericMessage
              // We have a special handler here below.
              AddGenericPacketHandlers();
+             RegisterInterfaces();
-             OnBinaryGenericMessage += RexClientView_BinaryGenericMessage;
-             OnGenericMessage += RealXtendClientView_OnGenericMessage;
          }
-         public RexClientView(EndPoint remoteEP, IScene scene, AssetCache assetCache,
+         public RexClientViewBase(EndPoint remoteEP, IScene scene,
-                              LLPacketServer packServer, AuthenticateResponse authenSessions, UUID agentId,
+                              LLUDPServer udpServer, LLUDPClient udpClient, AuthenticateResponse authenSessions, UUID agentId,
-                              UUID sessionId, uint circuitCode, EndPoint proxyEP, string rexAvatarURL, string rexAuthURL, ClientStackUserSettings userSettings)
+                              UUID sessionId, uint circuitCode, string rexAvatarURL, string rexAuthURL)
-             : base(remoteEP, scene, assetCache, packServer, authenSessions, agentId,
+             : base(remoteEP, scene, udpServer, udpClient, authenSessions, agentId,
-                    sessionId, circuitCode, proxyEP, userSettings)
+                    sessionId, circuitCode)
          {
              // Rex communication now occurs via GenericMessage
              // We need to register GenericMessage handlers
              AddGenericPacketHandlers();
+             RegisterInterfaces();
-             OnBinaryGenericMessage += RexClientView_BinaryGenericMessage;
              RexAvatarURL = rexAvatarURL;
              RexAuthURL = rexAuthURL;
-Line 84
+Line 83
          private void AddGenericPacketHandlers()
          {
+             OnBinaryGenericMessage += RexClientView_BinaryGenericMessage;
+             OnGenericMessage += RealXtendClientView_OnGenericMessage;
              AddGenericPacketHandler("RexAppearance", RealXtendClientView_OnGenericMessage);
              AddGenericPacketHandler("RexFaceExpression", RealXtendClientView_OnGenericMessage);
              AddGenericPacketHandler("RexAvatarProp", RealXtendClientView_OnGenericMessage);
-Line 98
+Line 100
              m_genericMessageHandlers.Add("rexfaceexpression", OnRexFaceExpression);
              m_genericMessageHandlers.Add("rexavatarprop", OnRexAvatarProperties);
              m_genericMessageHandlers.Add("rexmediaurl", TriggerOnReceivedRexMediaURL);
-             m_genericMessageHandlers.Add("rexdata", TriggerOnPrimFreeData);
+             //m_genericMessageHandlers.Add("rexdata", TriggerOnPrimFreeData);
          }
+         /// <summary>
+         /// Converts the Generic Message byte data to UTF8 string List and triggers the OnPrimFreeData
+         /// </summary>
+         /// <param name="sender">The sender.</param>
+         /// <param name="method">The name of the method.</param>
+         /// <param name="args">Generic message data in bytes</param>
+         private void HandleRexPrimFreeData(object sender, string method, byte[][] args)
+         {
+             //parse byte data to strings
+             List<string> sargs = new List<string>();
+             foreach (byte[] arg in args)
+             {
+                 string s = FieldToUTF8String(arg);
+                 sargs.Add(s);
+             }
+             TriggerOnPrimFreeData(this, sargs);
+         }
+         /// <summary>
+                 /// Convert a variable length field (byte array) to a UTF8 string
+                 /// </summary>
+                 /// <param name="bytes">The byte array to convert to a string</param>
+                 /// <returns>A UTF8 string</returns>
+         protected static string FieldToUTF8String(byte[] bytes)
+         {
+             if (bytes.Length > 0 && bytes[bytes.Length - 1] == 0x00)
+                 return UTF8Encoding.UTF8.GetString(bytes, 0, bytes.Length - 1);
+             else
+                 return UTF8Encoding.UTF8.GetString(bytes);
+         }
          /// <summary>
          /// Registers interfaces for IClientCore,
          /// every time you make a new Rex-specific
          /// Interface. Make sure to register it here.
          /// </summary>
-         protected override void RegisterInterfaces()
+         protected void RegisterInterfaces()
          {
              RegisterInterface<IClientRexAppearance>(this);
              RegisterInterface<IClientRexFaceExpression>(this);
-Line 118
+Line 151
              // Register our own class 'as-is' so it can be
              // used via IClientCore.Get<RexClientView>()...
              RegisterInterface(this);
-             base.RegisterInterfaces();
          }
          #region Properties
-Line 176
+Line 207
              }
          }
-         /// <summary>
-         /// Skype username of the avatar
-         /// eg: Skypeuser
-         /// </summary>
-         public string RexSkypeURL
-         {
-             get { return m_rexSkypeURL; }
-             set { m_rexSkypeURL = value; }
-         }
          /// <summary>
          /// The full Rex Username of this account
          /// Eg: user@hostname.com:10001
-Line 222
+Line 242
              set
              {
                  m_rexAuthURL = value;
-                 // Request Agent Properties Asynchronously
-                 ThreadPool.QueueUserWorkItem(RequestProperties);
              }
          }
-Line 240
+Line 257
              set { m_RexVertMovementSpeedMod = value; }
          }
-         public bool RexWalkDisabled
-         {
-             get { return m_RexWalkDisabled; }
-             set { m_RexWalkDisabled = value; }
-         }
-         public bool RexFlyDisabled
-         {
-             get { return m_RexFlyDisabled; }
-             set { m_RexFlyDisabled = value; }
-         }
          #endregion
-         private void RexClientView_BinaryGenericMessage(Object sender, string method, byte[][] args)
+         protected void RexClientView_BinaryGenericMessage(Object sender, string method, byte[][] args)
          {
              if(method == "RexPrimData".ToLower())
              {
                  HandleRexPrimData(args);
                  return;
              }
+             else if (method == "rexdata")
+             {
+                 HandleRexPrimFreeData(sender, method, args);
+                 return;
+             }
          }
+         /// <summary>
+         /// Handles the rex prim byte data, converts it to RexObjectProperties and triggers OnRexObjectProperties
+         /// </summary>
+         /// <param name="args">Rex prim data as bytes.</param>
          private void HandleRexPrimData(byte[][] args)
          {
              int rpdLen = 0;
-Line 298
+Line 312
                  idx += arg.Length;
              }
+             //by default message doesn't contain URIs. However, with NG-client situation can be quite different
+             TriggerOnRexObjectProperties(this, id, new RexObjectProperties(rpdArray, false));
+         }
+         protected void TriggerOnRexObjectProperties(RexClientViewBase client, UUID id, RexObjectProperties robject)
+         {
              if (OnRexObjectProperties != null)
-                 OnRexObjectProperties(this, id, new RexObjectProperties(rpdArray));
+             {
+                 OnRexObjectProperties(client, id, robject);
+             }
          }
          /// <summary>
-Line 344
+Line 366
              {
                  if (OnRexStartUp != null)
                  {
-                     OnRexStartUp(this, AgentId, args[0]);
+                     OnRexStartUp(this, AgentId, args[1]);
                      return;
                  }
              }
              if (method == "rexprimdata")
                  return;
+             if (method == "rexdata")
+                 return;
              m_log.Warn("[REXCLIENT] Unhandled GenericMessage (" + method + ") {");
              foreach (string s in args)
-Line 403
+Line 427
              }
          }
-         public void SendRexObjectProperties(UUID id, RexObjectProperties x)
+         public virtual void SendRexObjectProperties(UUID id, RexObjectProperties x)
          {
              GenericMessagePacket gmp = new GenericMessagePacket();
              gmp.MethodData.Method = Utils.StringToBytes("RexPrimData");
-             byte[] temprexprimdata = x.GetRexPrimDataToBytes();
+             byte[] temprexprimdata = x.GetRexPrimDataToBytes(false);
              int numlines = 0;
              int i = 0;
-Line 443
+Line 467
              // m_log.Warn("[REXDEBUG]: SendRexPrimData " + vPrimId.ToString());
              OutPacket(gmp, ThrottleOutPacketType.Task);
          }
          /// <summary>
-Line 497
+Line 520
              SendGenericMessage("RexFaceExpression", expressionData);
          }
-         public void SendRexAppearance(UUID agentID, string avatarURL)
+         public void SendRexAppearance(UUID agentID, string avatarURL, bool overrideUsed)
          {
              List<string> pack = new List<string>();
              pack.Add(avatarURL);
              pack.Add(agentID.ToString());
+             pack.Add(overrideUsed.ToString());
              SendGenericMessage("RexAppearance", pack);
          }
          /// <summary>
-         /// Requests properties about this agent from their
-         /// authentication server. This should be run in
-         /// an async thread.
-         ///
-         /// Note that this particular function may set the
-         /// avatars appearance which may in turn call
-         /// additional modules and functions elsewhere.
-         /// </summary>
-         /// <param name="o"></param>
-         private void RequestProperties(object o)
-         {
-             m_log.Info("[REXCLIENT] Resolving avatar...");
-             Hashtable ReqVals = new Hashtable();
-             ReqVals["avatar_account"] = RexAccount;
-             ReqVals["AuthenticationAddress"] = RexAuthURL;
-             ArrayList SendParams = new ArrayList();
-             SendParams.Add(ReqVals);
-             XmlRpcRequest req = new XmlRpcRequest("get_user_by_account", SendParams);
-             m_log.Info("[REXCLIENT] Sending XMLRPC Request to http://" + RexAuthURL);
-             XmlRpcResponse authreply = req.Send("http://" + RexAuthURL, 9000);
-             //m_log.Info(authreply.ToString());
-             if (!((Hashtable)authreply.Value).ContainsKey("error_type"))
-             {
-             string rexAsAddress = ((Hashtable)authreply.Value)["as_address"].ToString();
-             //string rexSkypeURL = ((Hashtable)authreply.Value)["skype_url"].ToString();
-             UUID userID = new UUID(((Hashtable) authreply.Value)["uuid"].ToString());
-                 // Sanity check
-                 if (userID == AgentId)
-                 {
-                     RexAvatarURL = rexAsAddress;
-                     //RexSkypeURL = rexSkypeURL;
-                 }
-             }
-             else
-             {
-                 m_log.Warn("[REXCLIENT]: User not found");
-             }
-         }
-         /// <summary>
          /// Sends Fog parameters to client. Only works underwater.
          /// </summary>
          /// <param name="start">meters from camera where the fog starts</param>
-Line 965
+Line 943
              SendGenericMessage("RexCSEffect", pack);
          }
+         public void SendRexPrimFreeData(UUID primID, string rexData)
+         {
+             List<string> pack = new List<string>();
+             int numlines = 0;
+             int i = 0;
+             //count number of lines. 200chars/line
+             while (i <= rexData.Length)
+             {
+                 numlines++;
+                 i += 200;
+             }
+             pack.Add(primID.ToString());
+             string sline = "";
+             for (i = 0; i < numlines; i++) //cut the data to 200 char fields and add to packet
+             {
+                 if ((rexData.Length - i * 200) < 200)
+                     sline = rexData.Substring(i * 200, rexData.Length - i * 200);
+                 else
+                     sline = rexData.Substring(i * 200, 200);
+                 pack.Add(sline);
+             }
+             SendGenericMessage("RexData", pack);
+         }
          public override void InformClientOfNeighbour(ulong neighbourHandle, IPEndPoint neighbourExternalEndPoint)
          {
+             IRexUDPPort module = m_scene.RequestModuleInterface<IRexUDPPort>();
+             if (module != null)
+             {
+                 int udpport = module.GetPort(neighbourHandle);
              m_log.DebugFormat("[REXCLIENT]: Informing Client About Neighbour {0}", neighbourExternalEndPoint);
-             base.InformClientOfNeighbour(neighbourHandle, new IPEndPoint(neighbourExternalEndPoint.Address, neighbourExternalEndPoint.Port-2000));
+                 base.InformClientOfNeighbour(neighbourHandle, new IPEndPoint(neighbourExternalEndPoint.Address, udpport));
+             }
+             else
+             {
+                 base.InformClientOfNeighbour(neighbourHandle, neighbourExternalEndPoint);
+             }
          }
          public override void CrossRegion(ulong newRegionHandle, Vector3 pos, Vector3 lookAt, IPEndPoint externalIPEndPoint,
                                  string capsURL)
          {
+             IRexUDPPort module = m_scene.RequestModuleInterface<IRexUDPPort>();
+             if (module != null)
+             {
+                 int udpport = module.GetPort(newRegionHandle);
              m_log.DebugFormat("[REXCLIENT]: Crossing client to region {0}", externalIPEndPoint);
-             base.CrossRegion(newRegionHandle, pos, lookAt, new IPEndPoint(externalIPEndPoint.Address, externalIPEndPoint.Port - 2000), capsURL);
+                 base.CrossRegion(newRegionHandle, pos, lookAt, new IPEndPoint(externalIPEndPoint.Address, udpport), capsURL);
+             }
+             else
+             {
+                 base.CrossRegion(newRegionHandle, pos, lookAt, externalIPEndPoint, capsURL);
+             }
          }
          public override void SendRegionTeleport(ulong regionHandle, byte simAccess, IPEndPoint newRegionEndPoint, uint locationID,
                                         uint flags, string capsURL)
          {
+             IRexUDPPort module = m_scene.RequestModuleInterface<IRexUDPPort>();
+             if (module != null)
+             {
+                 int udpport = module.GetPort(regionHandle);
              m_log.DebugFormat("[REXCLIENT]: Sending region teleport to client {0}", newRegionEndPoint);
-             base.SendRegionTeleport(regionHandle, simAccess, new IPEndPoint(newRegionEndPoint.Address, newRegionEndPoint.Port - 2000), locationID, flags, capsURL);
+                 base.SendRegionTeleport(regionHandle, simAccess, new IPEndPoint(newRegionEndPoint.Address, udpport), locationID, flags, capsURL);
+             }
+             else
+             {
+                 base.SendRegionTeleport(regionHandle, simAccess, newRegionEndPoint, locationID, flags, capsURL);
+             }
          }
+         #region Avatar terse update
+         protected override void InitNewClient()
+         {
+             m_avatarTerseUpdateTimer = new System.Timers.Timer(m_avatarTerseUpdateRate);
+             m_avatarTerseUpdateTimer.Elapsed += new ElapsedEventHandler(ProcessAvatarTerseUpdates);
+             m_avatarTerseUpdateTimer.AutoReset = false;
+             base.InitNewClient();
+         }
+         protected System.Timers.Timer m_avatarTerseUpdateTimer;
+         protected List<ImprovedTerseObjectUpdatePacket.ObjectDataBlock> m_avatarTerseUpdates = new List<ImprovedTerseObjectUpdatePacket.ObjectDataBlock>();
+         /// <summary>
+         /// Send a terse positional/rotation/velocity update about an avatar
+         /// to the client.  This avatar can be that of the client itself.
+         /// </summary>
+         public override void SendAvatarTerseUpdate(ulong regionHandle,
+                 ushort timeDilation, uint localID, Vector3 position,
+                 Vector3 velocity, Quaternion rotation, UUID agentid)
+         {
+             if (rotation.X == rotation.Y &&
+                 rotation.Y == rotation.Z &&
+                 rotation.Z == rotation.W && rotation.W == 0)
+                 rotation = Quaternion.Identity;
+             position.Z = (float)(position.Z - 0.15);
+             ImprovedTerseObjectUpdatePacket.ObjectDataBlock terseBlock =
+                 RexCreateAvatarImprovedBlock(localID, position, velocity, rotation);
+                 //CreateAvatarImprovedBlock(localID, position, velocity, rotation);
+             lock (m_avatarTerseUpdates)
+             {
+                 m_avatarTerseUpdates.Add(terseBlock);
+                 // If packet is full or own movement packet, send it.
+                 if (m_avatarTerseUpdates.Count >= m_avatarTerseUpdatesPerPacket)
+                 {
+                     ProcessAvatarTerseUpdates(this, null);
+                 }
+                 else if (m_avatarTerseUpdates.Count == 1)
+                 {
+                     m_avatarTerseUpdateTimer.Start();
+                 }
+             }
+         }
+         protected void ProcessAvatarTerseUpdates(object sender, ElapsedEventArgs e)
+         {
+             lock (m_avatarTerseUpdates)
+             {
+                 ImprovedTerseObjectUpdatePacket terse = (ImprovedTerseObjectUpdatePacket)PacketPool.Instance.GetPacket(PacketType.ImprovedTerseObjectUpdate);
+                 terse.RegionData = new ImprovedTerseObjectUpdatePacket.RegionDataBlock();
+                 terse.RegionData.RegionHandle = Scene.RegionInfo.RegionHandle;
+                 terse.RegionData.TimeDilation =
+                         (ushort)(Scene.TimeDilation * ushort.MaxValue);
+                 int max = m_avatarTerseUpdatesPerPacket;
+                 if (max > m_avatarTerseUpdates.Count)
+                     max = m_avatarTerseUpdates.Count;
+                 int count = 0;
+                 int size = 0;
+                 byte[] zerobuffer = new byte[1024];
+                 byte[] blockbuffer = new byte[1024];
+                 for (count = 0; count < max; count++)
+                 {
+                     int length = 0;
+                     m_avatarTerseUpdates[count].ToBytes(blockbuffer, ref length);
+                     length = Helpers.ZeroEncode(blockbuffer, length, zerobuffer);
+                     if (size + length > m_packetMTU)
+                         break;
+                     size += length;
+                 }
+                 terse.ObjectData = new ImprovedTerseObjectUpdatePacket.ObjectDataBlock[count];
+                 for (int i = 0; i < count; i++)
+                 {
+                     terse.ObjectData[i] = m_avatarTerseUpdates[0];
+                     m_avatarTerseUpdates.RemoveAt(0);
+                 }
+                 terse.Header.Reliable = false;
+                 terse.Header.Zerocoded = true;
+                 OutPacket(terse, ThrottleOutPacketType.Task);
+                 if (m_avatarTerseUpdates.Count == 0)
+                     m_avatarTerseUpdateTimer.Stop();
+             }
+         }
+         /// <summary>
+         /// Creates compressed avatar terse update block. This is about half smaller than the orginal SL
+         /// </summary>
+         /// <param name="localID"></param>
+         /// <param name="pos"></param>
+         /// <param name="velocity"></param>
+         /// <param name="rotation"></param>
+         /// <returns></returns>
+         protected ImprovedTerseObjectUpdatePacket.ObjectDataBlock RexCreateAvatarImprovedBlock(uint localID, Vector3 pos,
+                                                                                             Vector3 velocity,
+                                                                                             Quaternion rotation)
+         {
+             byte[] bytes = new byte[30];
+             int i = 0;
+             ImprovedTerseObjectUpdatePacket.ObjectDataBlock dat = PacketPool.GetDataBlock<ImprovedTerseObjectUpdatePacket.ObjectDataBlock>();
+             dat.TextureEntry = new byte[0];
+             uint ID = localID;
+             bytes[i++] = (byte)(ID % 256);
+             bytes[i++] = (byte)((ID >> 8) % 256);
+             bytes[i++] = (byte)((ID >> 16) % 256);
+             bytes[i++] = (byte)((ID >> 24) % 256);
+             // pos
+             byte[] pb = pos.GetBytes();
+             Array.Copy(pb, 0, bytes, i, pb.Length);
+             i += 12;
+             // velocity
+             velocity = velocity / 128.0f;
+             velocity.X += 1;
+             velocity.Y += 1;
+             velocity.Z += 1;
+             ushort InternVelocityX = (ushort)(32768 * velocity.X);
+             ushort InternVelocityY = (ushort)(32768 * velocity.Y);
+             ushort InternVelocityZ = (ushort)(32768 * velocity.Z);
+             bytes[i++] = (byte)(InternVelocityX % 256);
+             bytes[i++] = (byte)((InternVelocityX >> 8) % 256);
+             bytes[i++] = (byte)(InternVelocityY % 256);
+             bytes[i++] = (byte)((InternVelocityY >> 8) % 256);
+             bytes[i++] = (byte)(InternVelocityZ % 256);
+             bytes[i++] = (byte)((InternVelocityZ >> 8) % 256);
+             //rotation
+             ushort rw = (ushort)(32768 * (rotation.W + 1));
+             ushort rx = (ushort)(32768 * (rotation.X + 1));
+             ushort ry = (ushort)(32768 * (rotation.Y + 1));
+             ushort rz = (ushort)(32768 * (rotation.Z + 1));
+             //rot
+             bytes[i++] = (byte)(rx % 256);
+             bytes[i++] = (byte)((rx >> 8) % 256);
+             bytes[i++] = (byte)(ry % 256);
+             bytes[i++] = (byte)((ry >> 8) % 256);
+             bytes[i++] = (byte)(rz % 256);
+             bytes[i++] = (byte)((rz >> 8) % 256);
+             bytes[i++] = (byte)(rw % 256);
+             bytes[i++] = (byte)((rw >> 8) % 256);
+             dat.Data = bytes;
+             return (dat);
+         }
+         #endregion
      }
  }

 Legend:



Removed from v.115
 


changed lines


 
Added in v.228
 Legend:



Removed from v.115
 


changed lines


 
Added in v.228
-Removed from v.115
+Added in v.228

	ViewVC Help
Powered by ViewVC 1.0.0

MyGforge Home

realXtend Modules

Diff of /branches/os-udp/ModularRex/RexNetwork/ClientViews/RexClientViewBase.cs