/* * Copyright (c) 2008 Intel Corporation * 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 Intel Corporation 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 THE COPYRIGHT HOLDERS AND CONTRIBUTORS * ``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 THE INTEL OR ITS * CONTRIBUTORS 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.IO; using System.Reflection; using System.Collections.Generic; using System.Collections.Specialized; using System.Net; using System.Text; using System.Web; using OpenMetaverse; using OpenSim.Framework; using OpenSim.Framework.Servers; using log4net; namespace OpenSim.Grid.AssetInventoryServer.Plugins { public class BrowseFrontendPlugin : IAssetInventoryServerPlugin { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); AssetInventoryServer m_server; public BrowseFrontendPlugin() { } #region IPlugin implementation public void Initialise(AssetInventoryServer server) { m_server = server; // Request for / or /?... //server.HttpServer.AddHandler("get", null, @"(^/$)|(^/\?.*)", BrowseRequestHandler); m_server.HttpServer.AddStreamHandler(new BrowseRequestHandler(server)); m_log.Info("[ASSET] Browser Frontend loaded."); } /// /// Initialises asset interface /// public void Initialise() { m_log.InfoFormat("[ASSET]: {0} cannot be default-initialized!", Name); throw new PluginNotInitialisedException(Name); } public void Dispose() { } public string Version { // TODO: this should be something meaningful and not hardcoded? get { return "0.1"; } } public string Name { get { return "AssetInventoryServer Browse asset frontend"; } } #endregion IPlugin implementation public class BrowseRequestHandler : IStreamedRequestHandler { AssetInventoryServer m_server; string m_contentType; string m_httpMethod; string m_path; public BrowseRequestHandler(AssetInventoryServer server) { m_server = server; m_contentType = null; m_httpMethod = "GET"; m_path = @"(^/$)|(^/\?.*)"; } #region IStreamedRequestHandler implementation public string ContentType { get { return m_contentType; } } public string HttpMethod { get { return m_httpMethod; } } public string Path { get { return m_path; } } public byte[] Handle(string path, Stream request, OSHttpRequest httpRequest, OSHttpResponse httpResponse) { const int ASSETS_PER_PAGE = 25; const string HEADER = "Asset Server"; const string TABLE_HEADER = ""; const string TABLE_FOOTER = "
NameDescriptionTypeIDTemporarySHA-1
"; const string FOOTER = ""; UUID authToken = Utils.GetAuthToken(httpRequest); StringBuilder html = new StringBuilder(); int start = 0; uint page = 0; if (!String.IsNullOrEmpty(httpRequest.Url.Query)) { NameValueCollection query = HttpUtility.ParseQueryString(httpRequest.Url.Query); if (!String.IsNullOrEmpty(query["page"]) && UInt32.TryParse(query["page"], out page)) start = (int)page * ASSETS_PER_PAGE; } html.AppendLine(HEADER); html.AppendLine("

"); if (page > 0) html.AppendFormat("< Previous Page | ", httpRequest.RawUrl, page - 1); html.AppendFormat("Next Page >", httpRequest.RawUrl, page + 1); html.AppendLine("

"); html.AppendLine(TABLE_HEADER); m_server.StorageProvider.ForEach( delegate(Metadata data) { if (m_server.AuthorizationProvider.IsMetadataAuthorized(authToken, data.ID)) { html.AppendLine(String.Format( "{0}{1}{2}{3}{4}{5}", data.Name, data.Description, data.ContentType, data.ID, data.Temporary, BitConverter.ToString(data.SHA1).Replace("-", String.Empty))); } else { html.AppendLine(String.Format( "[Protected Asset]  {0}{1} ", data.ID, data.Temporary)); } }, start, ASSETS_PER_PAGE ); html.AppendLine(TABLE_FOOTER); html.AppendLine(FOOTER); byte[] responseData = System.Text.Encoding.UTF8.GetBytes(html.ToString()); httpResponse.StatusCode = (int) HttpStatusCode.OK; httpResponse.Body.Write(responseData, 0, responseData.Length); httpResponse.Body.Flush(); return responseData; } #endregion IStreamedRequestHandler implementation } } }