MapAddServerConnector.cs 9.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256
  1. /*
  2. * Copyright (c) Contributors, http://opensimulator.org/
  3. * See CONTRIBUTORS.TXT for a full list of copyright holders.
  4. *
  5. * Redistribution and use in source and binary forms, with or without
  6. * modification, are permitted provided that the following conditions are met:
  7. * * Redistributions of source code must retain the above copyright
  8. * notice, this list of conditions and the following disclaimer.
  9. * * Redistributions in binary form must reproduce the above copyright
  10. * notice, this list of conditions and the following disclaimer in the
  11. * documentation and/or other materials provided with the distribution.
  12. * * Neither the name of the OpenSimulator Project nor the
  13. * names of its contributors may be used to endorse or promote products
  14. * derived from this software without specific prior written permission.
  15. *
  16. * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
  17. * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  18. * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  19. * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
  20. * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  21. * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  22. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  23. * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  24. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
  25. * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  26. */
  27. using System;
  28. using System.Collections.Generic;
  29. using System.IO;
  30. using System.Reflection;
  31. using System.Xml;
  32. using Nini.Config;
  33. using log4net;
  34. using OpenMetaverse;
  35. using OpenSim.Framework;
  36. using OpenSim.Server.Base;
  37. using OpenSim.Services.Interfaces;
  38. using OpenSim.Framework.Servers.HttpServer;
  39. using OpenSim.Server.Handlers.Base;
  40. using GridRegion = OpenSim.Services.Interfaces.GridRegion;
  41. namespace OpenSim.Server.Handlers.MapImage
  42. {
  43. public class MapAddServiceConnector : ServiceConnector
  44. {
  45. private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
  46. private IMapImageService m_MapService;
  47. private IGridService m_GridService;
  48. private string m_ConfigName = "MapImageService";
  49. public MapAddServiceConnector(IConfigSource config, IHttpServer server, string configName) :
  50. base(config, server, configName)
  51. {
  52. IConfig serverConfig = config.Configs[m_ConfigName];
  53. if (serverConfig == null)
  54. throw new Exception(String.Format("No section {0} in config file", m_ConfigName));
  55. string mapService = serverConfig.GetString("LocalServiceModule",
  56. String.Empty);
  57. if (mapService == String.Empty)
  58. throw new Exception("No LocalServiceModule in config file");
  59. Object[] args = new Object[] { config };
  60. m_MapService = ServerUtils.LoadPlugin<IMapImageService>(mapService, args);
  61. string gridService = serverConfig.GetString("GridService", String.Empty);
  62. if (gridService != string.Empty)
  63. m_GridService = ServerUtils.LoadPlugin<IGridService>(gridService, args);
  64. if (m_GridService != null)
  65. m_log.InfoFormat("[MAP IMAGE HANDLER]: GridService check is ON");
  66. else
  67. m_log.InfoFormat("[MAP IMAGE HANDLER]: GridService check is OFF");
  68. bool proxy = serverConfig.GetBoolean("HasProxy", false);
  69. server.AddStreamHandler(new MapServerPostHandler(m_MapService, m_GridService, proxy));
  70. }
  71. }
  72. class MapServerPostHandler : BaseStreamHandler
  73. {
  74. private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
  75. private IMapImageService m_MapService;
  76. private IGridService m_GridService;
  77. bool m_Proxy;
  78. public MapServerPostHandler(IMapImageService service, IGridService grid, bool proxy) :
  79. base("POST", "/map")
  80. {
  81. m_MapService = service;
  82. m_GridService = grid;
  83. m_Proxy = proxy;
  84. }
  85. protected override byte[] ProcessRequest(string path, Stream requestData, IOSHttpRequest httpRequest, IOSHttpResponse httpResponse)
  86. {
  87. // m_log.DebugFormat("[MAP SERVICE IMAGE HANDLER]: Received {0}", path);
  88. StreamReader sr = new StreamReader(requestData);
  89. string body = sr.ReadToEnd();
  90. sr.Close();
  91. body = body.Trim();
  92. try
  93. {
  94. Dictionary<string, object> request = ServerUtils.ParseQueryString(body);
  95. if (!request.ContainsKey("X") || !request.ContainsKey("Y") || !request.ContainsKey("DATA"))
  96. {
  97. httpResponse.StatusCode = (int)OSHttpStatusCode.ClientErrorBadRequest;
  98. return FailureResult("Bad request.");
  99. }
  100. int x = 0, y = 0;
  101. Int32.TryParse(request["X"].ToString(), out x);
  102. Int32.TryParse(request["Y"].ToString(), out y);
  103. m_log.DebugFormat("[MAP ADD SERVER CONNECTOR]: Received map data for region at {0}-{1}", x, y);
  104. // string type = "image/jpeg";
  105. //
  106. // if (request.ContainsKey("TYPE"))
  107. // type = request["TYPE"].ToString();
  108. if (m_GridService != null)
  109. {
  110. System.Net.IPAddress ipAddr = GetCallerIP(httpRequest);
  111. GridRegion r = m_GridService.GetRegionByPosition(UUID.Zero, x * (int)Constants.RegionSize, y * (int)Constants.RegionSize);
  112. if (r != null)
  113. {
  114. if (r.ExternalEndPoint.Address.ToString() != ipAddr.ToString())
  115. {
  116. m_log.WarnFormat("[MAP IMAGE HANDLER]: IP address {0} may be trying to impersonate region in IP {1}", ipAddr, r.ExternalEndPoint.Address);
  117. return FailureResult("IP address of caller does not match IP address of registered region");
  118. }
  119. }
  120. else
  121. {
  122. m_log.WarnFormat("[MAP IMAGE HANDLER]: IP address {0} may be rogue. Region not found at coordinates {1}-{2}",
  123. ipAddr, x, y);
  124. return FailureResult("Region not found at given coordinates");
  125. }
  126. }
  127. byte[] data = Convert.FromBase64String(request["DATA"].ToString());
  128. string reason = string.Empty;
  129. bool result = m_MapService.AddMapTile(x, y, data, out reason);
  130. if (result)
  131. return SuccessResult();
  132. else
  133. return FailureResult(reason);
  134. }
  135. catch (Exception e)
  136. {
  137. m_log.ErrorFormat("[MAP SERVICE IMAGE HANDLER]: Exception {0} {1}", e.Message, e.StackTrace);
  138. }
  139. return FailureResult("Unexpected server error");
  140. }
  141. private byte[] SuccessResult()
  142. {
  143. XmlDocument doc = new XmlDocument();
  144. XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration,
  145. "", "");
  146. doc.AppendChild(xmlnode);
  147. XmlElement rootElement = doc.CreateElement("", "ServerResponse",
  148. "");
  149. doc.AppendChild(rootElement);
  150. XmlElement result = doc.CreateElement("", "Result", "");
  151. result.AppendChild(doc.CreateTextNode("Success"));
  152. rootElement.AppendChild(result);
  153. return DocToBytes(doc);
  154. }
  155. private byte[] FailureResult(string msg)
  156. {
  157. XmlDocument doc = new XmlDocument();
  158. XmlNode xmlnode = doc.CreateNode(XmlNodeType.XmlDeclaration,
  159. "", "");
  160. doc.AppendChild(xmlnode);
  161. XmlElement rootElement = doc.CreateElement("", "ServerResponse",
  162. "");
  163. doc.AppendChild(rootElement);
  164. XmlElement result = doc.CreateElement("", "Result", "");
  165. result.AppendChild(doc.CreateTextNode("Failure"));
  166. rootElement.AppendChild(result);
  167. XmlElement message = doc.CreateElement("", "Message", "");
  168. message.AppendChild(doc.CreateTextNode(msg));
  169. rootElement.AppendChild(message);
  170. return DocToBytes(doc);
  171. }
  172. private byte[] DocToBytes(XmlDocument doc)
  173. {
  174. MemoryStream ms = new MemoryStream();
  175. XmlTextWriter xw = new XmlTextWriter(ms, null);
  176. xw.Formatting = Formatting.Indented;
  177. doc.WriteTo(xw);
  178. xw.Flush();
  179. return ms.ToArray();
  180. }
  181. private System.Net.IPAddress GetCallerIP(IOSHttpRequest request)
  182. {
  183. if (!m_Proxy)
  184. return request.RemoteIPEndPoint.Address;
  185. // We're behind a proxy
  186. string xff = "X-Forwarded-For";
  187. string xffValue = request.Headers[xff.ToLower()];
  188. if (xffValue == null || (xffValue != null && xffValue == string.Empty))
  189. xffValue = request.Headers[xff];
  190. if (xffValue == null || (xffValue != null && xffValue == string.Empty))
  191. {
  192. m_log.WarnFormat("[MAP IMAGE HANDLER]: No XFF header");
  193. return request.RemoteIPEndPoint.Address;
  194. }
  195. System.Net.IPEndPoint ep = Util.GetClientIPFromXFF(xffValue);
  196. if (ep != null)
  197. return ep.Address;
  198. // Oops
  199. return request.RemoteIPEndPoint.Address;
  200. }
  201. }
  202. }