1
0

XBakesHandler.cs 5.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133
  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.IO;
  29. using System.Text;
  30. using System.Net;
  31. using Nini.Config;
  32. using OpenSim.Server.Base;
  33. using OpenSim.Services.Interfaces;
  34. using OpenSim.Framework.ServiceAuth;
  35. using OpenSim.Framework.Servers.HttpServer;
  36. using OpenSim.Server.Handlers.Base;
  37. namespace OpenSim.Server.Handlers.BakedTextures
  38. {
  39. public class XBakesConnector : ServiceConnector
  40. {
  41. private string m_ConfigName = "BakedTextureService";
  42. public XBakesConnector(IConfigSource config, IHttpServer server, string configName) :
  43. base(config, server, configName)
  44. {
  45. if (configName != string.Empty)
  46. m_ConfigName = configName;
  47. IConfig serverConfig = config.Configs[m_ConfigName];
  48. if (serverConfig == null)
  49. throw new Exception(String.Format("No section '{0}' in config file", m_ConfigName));
  50. string bakesServiceName = serverConfig.GetString("LocalServiceModule", string.Empty);
  51. if (string.IsNullOrWhiteSpace(bakesServiceName))
  52. throw new Exception("No BakedTextureService in config file");
  53. object[] args = new object[] { config };
  54. IBakedTextureService bakesService = ServerUtils.LoadPlugin<IBakedTextureService>(bakesServiceName, args);
  55. IServiceAuth auth = ServiceAuth.Create(config, m_ConfigName);
  56. server.AddSimpleStreamHandler(new BakesServerHandler(bakesService, auth), true);
  57. }
  58. }
  59. public class BakesServerHandler : SimpleStreamHandler
  60. {
  61. private IBakedTextureService m_BakesService;
  62. public BakesServerHandler(IBakedTextureService service, IServiceAuth auth) :
  63. base("/bakes", auth)
  64. {
  65. m_BakesService = service;
  66. }
  67. protected override void ProcessRequest(IOSHttpRequest httpRequest, IOSHttpResponse httpResponse)
  68. {
  69. if(m_BakesService == null)
  70. {
  71. httpResponse.StatusCode = (int)HttpStatusCode.InternalServerError;
  72. return;
  73. }
  74. switch (httpRequest.HttpMethod)
  75. {
  76. case "GET":
  77. doGet(httpRequest, httpResponse);
  78. break;
  79. case "POST":
  80. doPost(httpRequest, httpResponse);
  81. break;
  82. default:
  83. httpResponse.StatusCode = (int)HttpStatusCode.MethodNotAllowed;
  84. return;
  85. }
  86. httpResponse.StatusCode = (int)HttpStatusCode.OK;
  87. }
  88. private void doGet(IOSHttpRequest httpRequest, IOSHttpResponse httpResponse)
  89. {
  90. string[] p = SplitParams(httpRequest.UriPath);
  91. httpRequest.InputStream.Dispose();
  92. if (p.Length == 0)
  93. return;
  94. httpResponse.RawBuffer = m_BakesService.Get(p[0]);
  95. }
  96. private void doPost(IOSHttpRequest httpRequest, IOSHttpResponse httpResponse)
  97. {
  98. string[] p = SplitParams(httpRequest.UriPath);
  99. if (p.Length == 0)
  100. return;
  101. // httpRequest.InputStream is a memorystream with origin = 0
  102. // so no need to copy to another array
  103. MemoryStream ms = (MemoryStream)httpRequest.InputStream;
  104. int len = (int)ms.Length;
  105. byte[] data = ms.GetBuffer();
  106. httpRequest.InputStream.Dispose(); // the buffer stays in data
  107. m_BakesService.Store(p[0], data, len);
  108. }
  109. public string[] SplitParams(string path)
  110. {
  111. string param = GetParam(path);
  112. return param.Split(new char[] { '/', '?', '&' }, StringSplitOptions.RemoveEmptyEntries);
  113. }
  114. }
  115. }