3 files changed, 305 insertions, 0 deletions

diff --git a/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
new file mode 100644
index 0000000..1d455c6
--- /dev/null
+++ b/OpenSim/Server/Handlers/Simulation/AgentHandlers.cs
@@ -0,0 +1,182 @@
+using System;
+using System.IO;
+using System.Reflection;
+using System.Net;
+using System.Text;
+
+using OpenSim.Server.Base;
+using OpenSim.Services.Interfaces;
+using OpenSim.Framework;
+using OpenSim.Framework.Servers.HttpServer;
+
+using OpenMetaverse;
+using OpenMetaverse.StructuredData;
+using Nini.Config;
+using log4net;
+
+
+namespace OpenSim.Server.Handlers.Simulation
+{
+    public class AgentGetHandler : BaseStreamHandler
+    {
+        private ISimulationService m_SimulationService;
+        private IAuthenticationService m_AuthenticationService;
+
+        public AgentGetHandler(ISimulationService service, IAuthenticationService authentication) :
+                base("GET", "/agent")
+        {
+            m_SimulationService = service;
+            m_AuthenticationService = authentication;
+        }
+
+        public override byte[] Handle(string path, Stream request,
+                OSHttpRequest httpRequest, OSHttpResponse httpResponse)
+        {
+            // Not implemented yet
+            httpResponse.StatusCode = (int)HttpStatusCode.NotImplemented;
+            return new byte[] { };
+        }
+    }
+
+    public class AgentPostHandler : BaseStreamHandler
+    {
+        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+        private ISimulationService m_SimulationService;
+        private IAuthenticationService m_AuthenticationService;
+        private bool m_AllowForeignGuests;
+
+        public AgentPostHandler(ISimulationService service, IAuthenticationService authentication, bool foreignGuests) :
+            base("POST", "/agent")
+        {
+            m_SimulationService = service;
+            m_AuthenticationService = authentication;
+            m_AllowForeignGuests = foreignGuests;
+        }
+
+        public override byte[] Handle(string path, Stream request,
+                OSHttpRequest httpRequest, OSHttpResponse httpResponse)
+        {
+            byte[] result = new byte[0];
+
+            UUID agentID;
+            string action;
+            ulong regionHandle;
+            if (!Utils.GetParams(path, out agentID, out regionHandle, out action))
+            {
+                m_log.InfoFormat("[AgentPostHandler]: Invalid parameters for agent message {0}", path);
+                httpResponse.StatusCode = (int)HttpStatusCode.BadRequest;
+                httpResponse.StatusDescription = "Invalid parameters for agent message " + path;
+
+                return result;
+            }
+
+            if (m_AuthenticationService != null)
+            {
+                // Authentication
+                string authority = string.Empty;
+                string authToken = string.Empty;
+                if (!Utils.GetAuthentication(httpRequest, out authority, out authToken))
+                {
+                    m_log.InfoFormat("[AgentPostHandler]: Authentication failed for agent message {0}", path);
+                    httpResponse.StatusCode = (int)HttpStatusCode.Unauthorized;
+                    return result;
+                }
+                if (!m_AuthenticationService.VerifyKey(agentID, authToken))
+                {
+                    m_log.InfoFormat("[AgentPostHandler]: Authentication failed for agent message {0}", path);
+                    httpResponse.StatusCode = (int)HttpStatusCode.Forbidden;
+                    return result;
+                }
+                m_log.DebugFormat("[AgentPostHandler]: Authentication succeeded for {0}", agentID);
+            }
+
+            OSDMap args = Util.GetOSDMap(request, (int)httpRequest.ContentLength);
+            if (args == null)
+            {
+                httpResponse.StatusCode = (int)HttpStatusCode.BadRequest;
+                httpResponse.StatusDescription = "Unable to retrieve data";
+                m_log.DebugFormat("[AgentPostHandler]: Unable to retrieve data for post {0}", path);
+                return result;
+            }
+
+            // retrieve the regionhandle
+            ulong regionhandle = 0;
+            if (args["destination_handle"] != null)
+                UInt64.TryParse(args["destination_handle"].AsString(), out regionhandle);
+
+            AgentCircuitData aCircuit = new AgentCircuitData();
+            try
+            {
+                aCircuit.UnpackAgentCircuitData(args);
+            }
+            catch (Exception ex)
+            {
+                m_log.InfoFormat("[AgentPostHandler]: exception on unpacking CreateAgent message {0}", ex.Message);
+                httpResponse.StatusCode = (int)HttpStatusCode.BadRequest;
+                httpResponse.StatusDescription = "Problems with data deserialization";
+                return result;
+            }
+
+            string reason = string.Empty;
+
+            // We need to clean up a few things in the user service before I can do this
+            //if (m_AllowForeignGuests)
+            //    m_regionClient.AdjustUserInformation(aCircuit);
+
+            // Finally!
+            bool success = m_SimulationService.CreateAgent(regionhandle, aCircuit, out reason);
+
+            OSDMap resp = new OSDMap(1);
+
+            resp["success"] = OSD.FromBoolean(success);
+
+            httpResponse.StatusCode = (int)HttpStatusCode.OK;
+
+            return Encoding.UTF8.GetBytes(OSDParser.SerializeJsonString(resp));
+
+        }
+    }
+
+    public class AgentPutHandler : BaseStreamHandler
+    {
+        private ISimulationService m_SimulationService;
+        private IAuthenticationService m_AuthenticationService;
+
+        public AgentPutHandler(ISimulationService service, IAuthenticationService authentication) :
+            base("PUT", "/agent")
+        {
+            m_SimulationService = service;
+            m_AuthenticationService = authentication;
+        }
+
+        public override byte[] Handle(string path, Stream request,
+                OSHttpRequest httpRequest, OSHttpResponse httpResponse)
+        {
+            // Not implemented yet
+            httpResponse.StatusCode = (int)HttpStatusCode.NotImplemented;
+            return new byte[] { };
+        }
+    }
+
+    public class AgentDeleteHandler : BaseStreamHandler
+    {
+        private ISimulationService m_SimulationService;
+        private IAuthenticationService m_AuthenticationService;
+
+        public AgentDeleteHandler(ISimulationService service, IAuthenticationService authentication) :
+            base("DELETE", "/agent")
+        {
+            m_SimulationService = service;
+            m_AuthenticationService = authentication;
+        }
+
+        public override byte[] Handle(string path, Stream request,
+                OSHttpRequest httpRequest, OSHttpResponse httpResponse)
+        {
+            // Not implemented yet
+            httpResponse.StatusCode = (int)HttpStatusCode.NotImplemented;
+            return new byte[] { };
+        }
+    }
+
+}
diff --git a/OpenSim/Server/Handlers/Simulation/SimulationServiceInConnector.cs b/OpenSim/Server/Handlers/Simulation/SimulationServiceInConnector.cs
new file mode 100644
index 0000000..80b22b0
--- /dev/null
+++ b/OpenSim/Server/Handlers/Simulation/SimulationServiceInConnector.cs
@@ -0,0 +1,53 @@
+using System;
+using Nini.Config;
+using OpenSim.Server.Base;
+using OpenSim.Services.Interfaces;
+using OpenSim.Framework;
+using OpenSim.Framework.Servers.HttpServer;
+using OpenSim.Server.Handlers.Base;
+
+namespace OpenSim.Server.Handlers.Simulation
+{
+    public class SimulationServiceInConnector : ServiceConnector
+    {
+        private ISimulationService m_SimulationService;
+        private IAuthenticationService m_AuthenticationService;
+
+        public SimulationServiceInConnector(IConfigSource config, IHttpServer server, IScene scene) :
+                base(config, server)
+        {
+            IConfig serverConfig = config.Configs["SimulationService"];
+            if (serverConfig == null)
+                throw new Exception("No section 'SimulationService' in config file");
+
+            bool authentication = serverConfig.GetBoolean("RequireAuthentication", false);
+
+            if (authentication)
+                m_AuthenticationService = scene.RequestModuleInterface<IAuthenticationService>();
+
+            bool foreignGuests = serverConfig.GetBoolean("AllowForeignGuests", false);
+
+            //string simService = serverConfig.GetString("LocalServiceModule",
+            //        String.Empty);
+
+            //if (simService == String.Empty)
+            //    throw new Exception("No SimulationService in config file");
+
+            //Object[] args = new Object[] { config };
+            m_SimulationService = scene.RequestModuleInterface<ISimulationService>();
+                    //ServerUtils.LoadPlugin<ISimulationService>(simService, args);
+            if (m_SimulationService == null)
+                throw new Exception("No Local ISimulationService Module");
+
+
+
+            //System.Console.WriteLine("XXXXXXXXXXXXXXXXXXX m_AssetSetvice == null? " + ((m_AssetService == null) ? "yes" : "no"));
+            server.AddStreamHandler(new AgentGetHandler(m_SimulationService, m_AuthenticationService));
+            server.AddStreamHandler(new AgentPostHandler(m_SimulationService, m_AuthenticationService, foreignGuests));
+            server.AddStreamHandler(new AgentPutHandler(m_SimulationService, m_AuthenticationService));
+            server.AddStreamHandler(new AgentDeleteHandler(m_SimulationService, m_AuthenticationService));
+            //server.AddStreamHandler(new ObjectPostHandler(m_SimulationService, authentication));
+            //server.AddStreamHandler(new NeighborPostHandler(m_SimulationService, authentication));
+        }
+    }
+}
diff --git a/OpenSim/Server/Handlers/Simulation/Utils.cs b/OpenSim/Server/Handlers/Simulation/Utils.cs
new file mode 100644
index 0000000..581622c
--- /dev/null
+++ b/OpenSim/Server/Handlers/Simulation/Utils.cs
@@ -0,0 +1,70 @@
+using System;
+using System.Collections;
+using System.Net;
+
+using OpenSim.Framework;
+using OpenSim.Framework.Servers.HttpServer;
+using OpenSim.Services.Interfaces;
+using OpenMetaverse;
+
+namespace OpenSim.Server.Handlers.Simulation
+{
+    public class Utils
+    {
+        /// <summary>
+        /// Extract the param from an uri.
+        /// </summary>
+        /// <param name="uri">Something like this: /uuid/ or /uuid/handle/release</param>
+        /// <param name="uri">uuid on uuid field</param>
+        /// <param name="action">optional action</param>
+        public static bool GetParams(string path, out UUID uuid, out ulong regionHandle, out string action)
+        {
+            uuid = UUID.Zero;
+            action = "";
+            regionHandle = 0;
+
+            path = path.Trim(new char[] { '/' });
+            string[] parts = path.Split('/');
+            if (parts.Length <= 1)
+            {
+                return false;
+            }
+            else
+            {
+                if (!UUID.TryParse(parts[0], out uuid))
+                    return false;
+
+                if (parts.Length >= 2)
+                    UInt64.TryParse(parts[1], out regionHandle);
+                if (parts.Length >= 3)
+                    action = parts[2];
+
+                return true;
+            }
+        }
+
+        public static bool GetAuthentication(OSHttpRequest httpRequest, out string authority, out string authKey)
+        {
+            authority = string.Empty;
+            authKey = string.Empty;
+
+            Uri authUri;
+
+            string auth = httpRequest.Headers["authentication"];
+            // Authentication keys look like this:
+            // http://orgrid.org:8002/<uuid>
+            if ((auth != null) && (!string.Empty.Equals(auth)) && auth != "None")
+            {
+                if (Uri.TryCreate(auth, UriKind.Absolute, out authUri))
+                {
+                    authority = authUri.Authority;
+                    authKey = authUri.PathAndQuery.Trim('/');
+                    return true;
+                }
+            }
+
+            return false;
+        }
+
+    }
+}