/* Copyright (c) OpenGrid project, http://osgrid.org/ * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are met: * * Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * Neither the name of the <organization> nor the * names of its contributors may be used to endorse or promote products * derived from this software without specific prior written permission. * * THIS SOFTWARE IS PROVIDED BY <copyright holder> ``AS IS'' AND ANY * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE * DISCLAIMED. IN NO EVENT SHALL <copyright holder> BE LIABLE FOR ANY * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. */ using System; using System.Text; using Nwc.XmlRpc; using System.Threading; using System.Text.RegularExpressions; using System.Net; using System.IO; using System.Collections; using System.Collections.Generic; using libsecondlife; using OpenSim.Framework.Sims; using OpenSim.Framework.Console; namespace OpenGridServices.GridServer { public class GridHTTPServer { public Thread HTTPD; public HttpListener Listener; public GridHTTPServer() { MainConsole.Instance.WriteLine("Starting up HTTP Server"); HTTPD = new Thread(new ThreadStart(StartHTTP)); HTTPD.Start(); } public void StartHTTP() { MainConsole.Instance.WriteLine("GridHttp.cs:StartHTTP() - Spawned main thread OK"); Listener = new HttpListener(); Listener.Prefixes.Add("http://+:8001/sims/"); Listener.Prefixes.Add("http://+:8001/gods/"); Listener.Prefixes.Add("http://+:8001/highestuuid/"); Listener.Prefixes.Add("http://+:8001/uuidblocks/"); Listener.Start(); MainConsole.Instance.WriteLine("GridHttp.cs:StartHTTP() - Successfully bound to port 8001"); HttpListenerContext context; while(true) { context = Listener.GetContext(); ThreadPool.QueueUserWorkItem(new WaitCallback(HandleRequest), context); } } static string ParseXMLRPC(string requestBody, string referrer) { try{ XmlRpcRequest request = (XmlRpcRequest)(new XmlRpcRequestDeserializer()).Deserialize(requestBody); Hashtable requestData = (Hashtable)request.Params[0]; switch(request.MethodName) { case "simulator_login": if(!(referrer=="simulator")) { XmlRpcResponse ErrorResp = new XmlRpcResponse(); Hashtable ErrorRespData = new Hashtable(); ErrorRespData["error"]="Only simulators can login with this method"; ErrorResp.Value=ErrorRespData; return(Regex.Replace(XmlRpcResponseSerializer.Singleton.Serialize(ErrorResp),"utf-16","utf-8")); } if(!((string)requestData["authkey"]==OpenGrid_Main.thegrid.SimRecvKey)) { XmlRpcResponse ErrorResp = new XmlRpcResponse(); Hashtable ErrorRespData = new Hashtable(); ErrorRespData["error"]="invalid key"; ErrorResp.Value=ErrorRespData; return(Regex.Replace(XmlRpcResponseSerializer.Singleton.Serialize(ErrorResp),"utf-16","utf-8")); } SimProfileBase TheSim = OpenGrid_Main.thegrid._regionmanager.GetProfileByLLUUID(new LLUUID((string)requestData["UUID"])); XmlRpcResponse SimLoginResp = new XmlRpcResponse(); Hashtable SimLoginRespData = new Hashtable(); ArrayList SimNeighboursData = new ArrayList(); SimProfileBase neighbour; Hashtable NeighbourBlock; for(int x=-1; x<2; x++) for(int y=-1; y<2; y++) { if(OpenGrid_Main.thegrid._regionmanager.GetProfileByHandle(Helpers.UIntsToLong((uint)((TheSim.RegionLocX+x)*256), (uint)(TheSim.RegionLocY+y)*256))!=null) { neighbour=OpenGrid_Main.thegrid._regionmanager.GetProfileByHandle(Helpers.UIntsToLong((uint)((TheSim.RegionLocX+x)*256), (uint)(TheSim.RegionLocY+y)*256)); NeighbourBlock = new Hashtable(); NeighbourBlock["sim_ip"] = neighbour.sim_ip; NeighbourBlock["sim_port"] = neighbour.sim_port.ToString(); NeighbourBlock["region_locx"] = neighbour.RegionLocX.ToString(); NeighbourBlock["region_locy"] = neighbour.RegionLocY.ToString(); NeighbourBlock["UUID"] = neighbour.UUID.ToString(); SimNeighboursData.Add(NeighbourBlock); } } SimLoginRespData["region_locx"]=TheSim.RegionLocX.ToString(); SimLoginRespData["region_locy"]=TheSim.RegionLocY.ToString(); SimLoginRespData["regionname"]=TheSim.regionname; SimLoginRespData["estate_id"]="1"; SimLoginRespData["neighbours"]=SimNeighboursData; SimLoginRespData["asset_url"]=OpenGrid_Main.thegrid.DefaultAssetServer; SimLoginRespData["asset_sendkey"]=OpenGrid_Main.thegrid.AssetSendKey; SimLoginRespData["asset_recvkey"]=OpenGrid_Main.thegrid.AssetRecvKey; SimLoginRespData["user_url"]=OpenGrid_Main.thegrid.DefaultUserServer; SimLoginRespData["user_sendkey"]=OpenGrid_Main.thegrid.UserSendKey; SimLoginRespData["user_recvkey"]=OpenGrid_Main.thegrid.UserRecvKey; SimLoginRespData["authkey"]=OpenGrid_Main.thegrid.SimSendKey; SimLoginResp.Value=SimLoginRespData; return(Regex.Replace(XmlRpcResponseSerializer.Singleton.Serialize(SimLoginResp),"utf-16","utf-8")); break; } } catch(Exception e) { Console.WriteLine(e.ToString()); } return ""; } static string ParseREST(string requestBody, string requestURL, string HTTPmethod) { char[] splitter = {'/'}; string[] rest_params = requestURL.Split(splitter); string req_type = rest_params[0]; // First part of the URL is the type of request - string respstring; switch(req_type) { case "sims": LLUUID UUID = new LLUUID((string)rest_params[1]); SimProfileBase TheSim = OpenGrid_Main.thegrid._regionmanager.GetProfileByLLUUID(UUID); if(!(TheSim==null)) { switch(HTTPmethod) { case "GET": respstring="<authkey>" + OpenGrid_Main.thegrid.SimSendKey + "</authkey>"; respstring+="<sim>"; respstring+="<uuid>" + TheSim.UUID.ToString() + "</uuid>"; respstring+="<regionname>" + TheSim.regionname + "</regionname>"; respstring+="<sim_ip>" + TheSim.sim_ip + "</sim_ip>"; respstring+="<sim_port>" + TheSim.sim_port.ToString() + "</sim_port>"; respstring+="<region_locx>" + TheSim.RegionLocX.ToString() + "</region_locx>"; respstring+="<region_locy>" + TheSim.RegionLocY.ToString() + "</region_locy>"; respstring+="<estate_id>1</estate_id>"; respstring+="</sim>"; break; } } break; case "highestuuid": break; } return ""; } static void HandleRequest(Object stateinfo) { HttpListenerContext context=(HttpListenerContext)stateinfo; HttpListenerRequest request = context.Request; HttpListenerResponse response = context.Response; response.KeepAlive=false; response.SendChunked=false; System.IO.Stream body = request.InputStream; System.Text.Encoding encoding = System.Text.Encoding.UTF8; System.IO.StreamReader reader = new System.IO.StreamReader(body, encoding); string requestBody = reader.ReadToEnd(); body.Close(); reader.Close(); // TODO: AUTHENTICATION!!!!!!!!! MUST ADD!!!!!!!!!! SCRIPT KIDDIES LOVE LACK OF IT!!!!!!!!!! string responseString=""; switch(request.ContentType) { case "text/xml": // must be XML-RPC, so pass to the XML-RPC parser responseString=ParseXMLRPC(requestBody,request.Headers["Referer"]); response.AddHeader("Content-type","text/xml"); break; case null: // must be REST or invalid crap, so pass to the REST parser responseString=ParseREST(request.Url.OriginalString,requestBody,request.HttpMethod); break; } byte[] buffer = System.Text.Encoding.UTF8.GetBytes(responseString); System.IO.Stream output = response.OutputStream; response.SendChunked=false; response.ContentLength64=buffer.Length; output.Write(buffer,0,buffer.Length); output.Close(); } } }