123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294 |
- using Nini.Config;
- using log4net;
- using System;
- using System.Reflection;
- using System.IO;
- using System.Net;
- using System.Text;
- using System.Text.RegularExpressions;
- using System.Xml;
- using System.Xml.Serialization;
- using System.Collections.Generic;
- using OpenSim.Server.Base;
- using OpenSim.Services.Interfaces;
- using OpenSim.Framework;
- using OpenSim.Framework.Servers.HttpServer;
- using OpenSim.Framework.ServiceAuth;
- using OpenMetaverse;
- namespace OpenSim.Server.Handlers.Presence
- {
- public class PresenceServerPostHandler : BaseStreamHandler
- {
- private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
- private IPresenceService m_PresenceService;
- public PresenceServerPostHandler(IPresenceService service, IServiceAuth auth) :
- base("POST", "/presence", auth)
- {
- m_PresenceService = service;
- }
- protected override byte[] ProcessRequest(string path, Stream requestData,
- IOSHttpRequest httpRequest, IOSHttpResponse httpResponse)
- {
- StreamReader sr = new StreamReader(requestData);
- string body = sr.ReadToEnd();
- sr.Close();
- body = body.Trim();
-
- string method = string.Empty;
- try
- {
- Dictionary<string, object> request =
- ServerUtils.ParseQueryString(body);
- if (!request.ContainsKey("METHOD"))
- return FailureResult();
- method = request["METHOD"].ToString();
- switch (method)
- {
- case "login":
- return LoginAgent(request);
- case "logout":
- return LogoutAgent(request);
- case "logoutregion":
- return LogoutRegionAgents(request);
- case "report":
- return Report(request);
- case "getagent":
- return GetAgent(request);
- case "getagents":
- return GetAgents(request);
- }
- m_log.DebugFormat("[PRESENCE HANDLER]: unknown method request: {0}", method);
- }
- catch (Exception e)
- {
- m_log.DebugFormat("[PRESENCE HANDLER]: Exception in method {0}: {1}", method, e);
- }
- return FailureResult();
- }
- byte[] LoginAgent(Dictionary<string, object> request)
- {
- string user = String.Empty;
- UUID session = UUID.Zero;
- UUID ssession = UUID.Zero;
- if (!request.ContainsKey("UserID") || !request.ContainsKey("SessionID"))
- return FailureResult();
- user = request["UserID"].ToString();
- if (!UUID.TryParse(request["SessionID"].ToString(), out session))
- return FailureResult();
- if (request.ContainsKey("SecureSessionID"))
-
- UUID.TryParse(request["SecureSessionID"].ToString(), out ssession);
- if (m_PresenceService.LoginAgent(user, session, ssession))
- return SuccessResult();
- return FailureResult();
- }
- byte[] LogoutAgent(Dictionary<string, object> request)
- {
- UUID session = UUID.Zero;
- if (!request.ContainsKey("SessionID"))
- return FailureResult();
- if (!UUID.TryParse(request["SessionID"].ToString(), out session))
- return FailureResult();
- if (m_PresenceService.LogoutAgent(session))
- return SuccessResult();
- return FailureResult();
- }
- byte[] LogoutRegionAgents(Dictionary<string, object> request)
- {
- UUID region = UUID.Zero;
- if (!request.ContainsKey("RegionID"))
- return FailureResult();
- if (!UUID.TryParse(request["RegionID"].ToString(), out region))
- return FailureResult();
- if (m_PresenceService.LogoutRegionAgents(region))
- return SuccessResult();
- return FailureResult();
- }
-
- byte[] Report(Dictionary<string, object> request)
- {
- UUID session = UUID.Zero;
- UUID region = UUID.Zero;
- if (!request.ContainsKey("SessionID") || !request.ContainsKey("RegionID"))
- return FailureResult();
- if (!UUID.TryParse(request["SessionID"].ToString(), out session))
- return FailureResult();
- if (!UUID.TryParse(request["RegionID"].ToString(), out region))
- return FailureResult();
- if (m_PresenceService.ReportAgent(session, region))
- {
- return SuccessResult();
- }
- return FailureResult();
- }
- byte[] GetAgent(Dictionary<string, object> request)
- {
- UUID session = UUID.Zero;
- if (!request.ContainsKey("SessionID"))
- return FailureResult();
- if (!UUID.TryParse(request["SessionID"].ToString(), out session))
- return FailureResult();
- PresenceInfo pinfo = m_PresenceService.GetAgent(session);
- Dictionary<string, object> result = new Dictionary<string, object>();
- if (pinfo == null)
- result["result"] = "null";
- else
- result["result"] = pinfo.ToKeyValuePairs();
- string xmlString = ServerUtils.BuildXmlResponse(result);
-
- return Util.UTF8NoBomEncoding.GetBytes(xmlString);
- }
- byte[] GetAgents(Dictionary<string, object> request)
- {
- string[] userIDs;
- if (!request.ContainsKey("uuids"))
- {
- m_log.DebugFormat("[PRESENCE HANDLER]: GetAgents called without required uuids argument");
- return FailureResult();
- }
- if (!(request["uuids"] is List<string>))
- {
- m_log.DebugFormat("[PRESENCE HANDLER]: GetAgents input argument was of unexpected type {0}", request["uuids"].GetType().ToString());
- return FailureResult();
- }
- userIDs = ((List<string>)request["uuids"]).ToArray();
- PresenceInfo[] pinfos = m_PresenceService.GetAgents(userIDs);
- Dictionary<string, object> result = new Dictionary<string, object>();
- if ((pinfos == null) || ((pinfos != null) && (pinfos.Length == 0)))
- result["result"] = "null";
- else
- {
- int i = 0;
- foreach (PresenceInfo pinfo in pinfos)
- {
- Dictionary<string, object> rinfoDict = pinfo.ToKeyValuePairs();
- result["presence" + i] = rinfoDict;
- i++;
- }
- }
- string xmlString = ServerUtils.BuildXmlResponse(result);
-
-
- return Util.UTF8NoBomEncoding.GetBytes(xmlString);
- }
- private byte[] SuccessResult()
- {
- XmlDocument doc = new XmlDocument();
- XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration,
- "", "");
- doc.AppendChild(xmlnode);
- XmlElement rootElement = doc.CreateElement("", "ServerResponse",
- "");
- doc.AppendChild(rootElement);
- XmlElement result = doc.CreateElement("", "result", "");
- result.AppendChild(doc.CreateTextNode("Success"));
- rootElement.AppendChild(result);
- return Util.DocToBytes(doc);
- }
- private byte[] FailureResult()
- {
- XmlDocument doc = new XmlDocument();
- XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration,
- "", "");
- doc.AppendChild(xmlnode);
- XmlElement rootElement = doc.CreateElement("", "ServerResponse",
- "");
- doc.AppendChild(rootElement);
- XmlElement result = doc.CreateElement("", "result", "");
- result.AppendChild(doc.CreateTextNode("Failure"));
- rootElement.AppendChild(result);
- return Util.DocToBytes(doc);
- }
- }
- }
|