//
// (C) 2005 Mainsoft Corporation (http://www.mainsoft.com)
//

//
// Permission is hereby granted, free of charge, to any person obtaining
// a copy of this software and associated documentation files (the
// "Software"), to deal in the Software without restriction, including
// without limitation the rights to use, copy, modify, merge, publish,
// distribute, sublicense, and/or sell copies of the Software, and to
// permit persons to whom the Software is furnished to do so, subject to
// the following conditions:
//
// The above copyright notice and this permission notice shall be
// included in all copies or substantial portions of the Software.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
// EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
// NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
// LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
using System;
using System.IO;
using System.Text;
using System.Runtime.InteropServices;
using System.Web.Util;
using vmw.common;
using System.Web.J2EE;
using System.Collections;
using System.Web;
using javax.servlet;
using javax.servlet.http;
using System.Collections.Specialized;
using System.Globalization;

namespace System.Web.Hosting {
	[MonoTODO("Implement security demands on the path usage functions (and review)")]
	[ComVisible (false)]
	internal sealed class ServletWorkerRequest : HttpWorkerRequest {
		readonly HttpServlet _HttpServlet;
		readonly HttpServletRequest _HttpServletRequest;
		readonly HttpServletResponse _HttpServletResponse;

		readonly string _requestUri;
		readonly string _pathInfo;

		static readonly StringDictionary _srvVarsToHeaderMap;

		private string [][] unknownHeaders;
		string _rawUrl;

		private HttpWorkerRequest.EndOfSendNotification _endOfSendCallback;
		private object _endOfSendArgs;

		enum KnownServerVariable {
			AUTH_TYPE,
			CONTENT_LENGTH,
			CONTENT_TYPE,
			QUERY_STRING,
			REMOTE_ADDR,
			REMOTE_HOST,
			REMOTE_USER,
			REQUEST_METHOD,
			REQUEST_URI,
			SCRIPT_NAME,
			SERVER_NAME,
			SERVER_PORT,
			SERVER_PROTOCOL,
			SERVER_SOFTWARE,
			PATH_INFO
		};

		static readonly Hashtable KnownServerVariableMap;

		static ServletWorkerRequest() {
			_srvVarsToHeaderMap = new StringDictionary();
			_srvVarsToHeaderMap.Add("HTTP_ACCEPT", "Accept");
			_srvVarsToHeaderMap.Add("HTTP_REFERER", "Referer");
			_srvVarsToHeaderMap.Add("HTTP_ACCEPT_LANGUAGE", "Accept-Language");
			_srvVarsToHeaderMap.Add("HTTP_ACCEPT_ENCODING", "Accept-Encoding");
			_srvVarsToHeaderMap.Add("HTTP_CONNECTION", "Connection");
			_srvVarsToHeaderMap.Add("HTTP_HOST", "Host");
			_srvVarsToHeaderMap.Add("HTTP_USER_AGENT", "User-Agent");
			_srvVarsToHeaderMap.Add("HTTP_SOAPACTION", "SOAPAction");

			string[] knownServerVariableNames = Enum.GetNames(typeof(KnownServerVariable));
			KnownServerVariableMap = CollectionsUtil.CreateCaseInsensitiveHashtable(knownServerVariableNames.Length);
			for (int i = 0; i < knownServerVariableNames.Length; i++)
				KnownServerVariableMap[knownServerVariableNames[i]] = (KnownServerVariable)i;
		}

		public ServletWorkerRequest (HttpServlet servlet, HttpServletRequest req, HttpServletResponse resp) {
			_HttpServlet = servlet;
			_HttpServletRequest = req;
			_HttpServletResponse = resp;

			string contextPath = req.getContextPath();
			string requestURI = req.getRequestURI();
			if (String.CompareOrdinal(requestURI, contextPath) == 0 ||
				(((requestURI.Length - contextPath.Length) == 1) &&
					requestURI[contextPath.Length] == '/' &&
					String.CompareOrdinal(requestURI, 0, contextPath, 0, contextPath.Length) == 0 ))
				requestURI = contextPath + req.getServletPath();	

			_requestUri = HttpUtility.UrlDecode(requestURI);
			const int dotInvokeLength = 7; //".invoke".Length
			if (_requestUri.Length > dotInvokeLength &&
				String.CompareOrdinal(".invoke", 0, _requestUri, 
				_requestUri.Length - dotInvokeLength, dotInvokeLength) == 0) {

				_requestUri = _requestUri.Substring(0, _requestUri.Length - dotInvokeLength);
				
				int paramNameStart = _requestUri.LastIndexOf('/');
				_pathInfo = _requestUri.Substring(paramNameStart, _requestUri.Length - paramNameStart);
			}
		}

		public HttpServlet Servlet {
			get {
				return _HttpServlet;
			}
		}
		
		public HttpServletRequest ServletRequest {
			get{
				return _HttpServletRequest;
			}
		}

		public HttpServletResponse ServletResponse {
			get{
				return _HttpServletResponse;
			}
		}
		
		[MonoTODO("Implement security")]
		public override string MachineInstallDirectory {
			get {
				return ICalls.GetMachineInstallDirectory ();
			}
		}

		public override string MachineConfigPath {
			get { return ICalls.GetMachineConfigPath (); }
		}

		public override void EndOfRequest () {
			if (_endOfSendCallback != null)
				_endOfSendCallback(this, _endOfSendArgs);
		}

		public override void FlushResponse (bool finalFlush) {
			ServletOutputStream servletOutputStream = _HttpServletResponse.getOutputStream();
			servletOutputStream.flush();
			if (finalFlush)
				servletOutputStream.close();
		}

		public override string GetAppPath () {
			return _HttpServletRequest.getContextPath();
		}
   		public override string GetAppPathTranslated () {
			return J2EEUtils.GetApplicationRealPath(_HttpServlet.getServletConfig());;
		}

		public override string GetFilePath () {
			string uri = GetUriPath();
			string pathInfo = GetPathInfo();
			if (pathInfo != null && pathInfo.Length > 0)
				uri = uri.Substring(0, uri.Length - pathInfo.Length);

			return uri;
		}

		public override string GetFilePathTranslated () {
			string page = GetFilePath ();

			if (Path.DirectorySeparatorChar != '/')
				page = page.Replace ('/', Path.DirectorySeparatorChar);

			if (page [0] == Path.DirectorySeparatorChar)
				page = page.Substring (1);
			
			return Path.Combine (GetAppPathTranslated (), page);
		}

		public override string GetHttpVerbName () {
			return _HttpServletRequest.getMethod();
		}

		public override string GetHttpVersion () {
			return _HttpServletRequest.getProtocol();
		}

		public override string GetLocalAddress () {
			return _HttpServletRequest.getLocalAddr();
		}

		public override int GetLocalPort () {
			return _HttpServletRequest.getLocalPort();
		}

		public override string GetPathInfo () {
			return _pathInfo != null ? _pathInfo : _HttpServletRequest.getPathInfo();
		}

		public override string GetQueryString () {
			return _HttpServletRequest.getQueryString();
		}

		public override string GetRawUrl () {
			if (_rawUrl == null) {
				StringBuilder builder = new StringBuilder();
				builder.Append(GetUriPath());
				string pathInfo = GetPathInfo();
				string query = GetQueryString();
				if (query != null && query.Length > 0) {
					builder.Append('?');
					builder.Append(query);
				}

				_rawUrl = builder.ToString();
			}

			return _rawUrl;
		}

		public override string GetRemoteAddress() {
			return _HttpServletRequest.getRemoteAddr();
		}

		public override string GetRemoteName() {
			return _HttpServletRequest.getRemoteHost();
		}


		public override int GetRemotePort() {
			try {
				return _HttpServletRequest.getRemotePort();
			}
			catch(Exception e) { //should catch also java.lang.Throwable
				//if servlet API is 2.3 and below - there is no
				//method getRemotePort in ServletRequest interface...
				//should be described as limitation.
				return 0;
			}
		}

		public override string GetServerVariable(string name) {
			// FIXME: We need to make a proper mapping between the standard server
			// variables and java equivalent. probably we have to have a configuration file 
			// which associates between the two. Pay a special attention on GetUnknownRequestHeader/s
			// while implementing. Ensure that system web "common" code correctly calls each method.

			string headerName = _srvVarsToHeaderMap[name];

			if (headerName != null)
				return _HttpServletRequest.getHeader( headerName );

			object knownVariable = KnownServerVariableMap[name];
			if (knownVariable != null)
				return GetKnownServerVariable((KnownServerVariable)knownVariable);

			return _HttpServletRequest.getHeader( name );
		}

		string GetKnownServerVariable(KnownServerVariable index) {
			switch (index) {
				case KnownServerVariable.AUTH_TYPE : return _HttpServletRequest.getAuthType();
				case KnownServerVariable.CONTENT_LENGTH : return Convert.ToString(_HttpServletRequest.getContentLength());
				case KnownServerVariable.CONTENT_TYPE : return _HttpServletRequest.getContentType();
				case KnownServerVariable.QUERY_STRING : return GetQueryString();
				case KnownServerVariable.REMOTE_ADDR : return GetRemoteAddress();
				case KnownServerVariable.REMOTE_HOST : return GetRemoteName();
				case KnownServerVariable.REMOTE_USER : return _HttpServletRequest.getRemoteUser();
				case KnownServerVariable.REQUEST_METHOD : return GetHttpVerbName ();
				case KnownServerVariable.REQUEST_URI : return GetUriPath();
				case KnownServerVariable.SCRIPT_NAME : return GetFilePath ();
				case KnownServerVariable.SERVER_NAME : return GetServerName();
				case KnownServerVariable.SERVER_PORT : return Convert.ToString(_HttpServletRequest.getServerPort());
				case KnownServerVariable.SERVER_PROTOCOL : return GetHttpVersion ();
				case KnownServerVariable.SERVER_SOFTWARE : return Servlet.getServletContext().getServerInfo();
				case KnownServerVariable.PATH_INFO : return GetPathInfo();
				default: throw new IndexOutOfRangeException("index");
			}
		}

		public override string GetUriPath() {
			return _requestUri;
		}

		public override IntPtr GetUserToken() {
			return IntPtr.Zero;
		}

		public override string MapPath (string path) {
			string appVirtualPath = GetAppPath();
			if (path.StartsWith(appVirtualPath)) {
				path = path.Remove(0,appVirtualPath.Length);
				if (path.StartsWith("/"))
					path = path.Remove(0,1);
			}
			//string realPath = Servlet.getServletContext().getRealPath(path);
			//			if (Path.IsPathRooted(path))
			//				return path;
			//			if (!path.StartsWith(IAppDomainConfig.WAR_ROOT_SYMBOL)&& 
			//				!path.StartsWith("/") && !path.StartsWith("\\")&& !Path.IsPathRooted(path))            
			//				return IAppDomainConfig.WAR_ROOT_SYMBOL + "/" + path;
			//			else if (!path.StartsWith(IAppDomainConfig.WAR_ROOT_SYMBOL)&& !Path.IsPathRooted(path))
			//				return IAppDomainConfig.WAR_ROOT_SYMBOL + path;
			//			else 
			//				return path;

			if (path.StartsWith(IAppDomainConfig.WAR_ROOT_SYMBOL)) {
				return path;
			}

			string retVal =  IAppDomainConfig.WAR_ROOT_SYMBOL;

			if (!path.StartsWith("/") && !path.StartsWith("\\"))
				retVal += "/";

			retVal += path;

			return retVal;
		}

		public override void SendResponseFromFile (IntPtr handle, long offset, long length) {
			throw new NotSupportedException();
		}

		public override void SendResponseFromFile (string filename, long offset, long length) {
			using (FileStream fs = File.OpenRead (filename)) {
				byte [] buffer = new byte [4 * 1024];

				if (offset != 0)
					fs.Position = offset;

				long remain = length;
				int n;
				while (remain > 0 && (n = fs.Read (buffer, 0, (int) Math.Min (remain, buffer.Length))) != 0){
					remain -= n;
					SendResponseFromMemory(buffer, n);
				}
			}
		}

		public override void SendResponseFromMemory (byte [] data, int length) {
			sbyte [] sdata = vmw.common.TypeUtils.ToSByteArray(data);
			_HttpServletResponse.getOutputStream().write(sdata, 0 , length);
		}

		public override void SendStatus(int statusCode, string statusDescription) {
			// setStatus(int, string) is deprecated
			_HttpServletResponse.setStatus(statusCode/*, statusDescription*/);
		}

		public override void SendUnknownResponseHeader(string name, string value) {
			if (HeadersSent ())
				return;

			_HttpServletResponse.addHeader(name, value);
		}

		public override bool HeadersSent () {
			return _HttpServletResponse.isCommitted();
		}

		public override void SendCalculatedContentLength (int contentLength) {
			_HttpServletResponse.setContentLength(contentLength);
		}

		public override void SendKnownResponseHeader (int index, string value) {
			SendUnknownResponseHeader (GetKnownResponseHeaderName (index), value);
		}

		public override string GetKnownRequestHeader (int index) {	
			return GetUnknownRequestHeader(GetKnownRequestHeaderName (index));
		}

		public override string GetUnknownRequestHeader (string name) {
			return _HttpServletRequest.getHeader(name);
		}

		public override string [][] GetUnknownRequestHeaders () {
			if (unknownHeaders == null) {
				ArrayList pairs = new ArrayList ();
				for (java.util.Enumeration he = _HttpServletRequest.getHeaderNames(); he.hasMoreElements() ;) {
					string key = (string) he.nextElement();
					int index = HttpWorkerRequest.GetKnownRequestHeaderIndex (key);
					if (index != -1)
						continue;
					pairs.Add (new string [] {key, _HttpServletRequest.getHeader(key)});
				}
				
				if (pairs.Count != 0) {
					unknownHeaders = new string [pairs.Count][];
					for (int i = 0; i < pairs.Count; i++)
						unknownHeaders [i] = (string []) pairs [i];
				}
			}
			if (unknownHeaders == null) unknownHeaders = new string [0][];

			return unknownHeaders;
		}

		public override int ReadEntityBody (byte [] buffer, int size) {
			if (buffer == null || size == 0)
				return 0;
			sbyte [] sbuffer = vmw.common.TypeUtils.ToSByteArray(buffer);
			int r = _HttpServletRequest.getInputStream().read(sbuffer, 0, size);	
			return (r==-1)?0:r;
		}

		public override void SetEndOfSendNotification(System.Web.HttpWorkerRequest.EndOfSendNotification callback, object extraData) {
			_endOfSendCallback = callback;
			_endOfSendArgs = extraData;
		}

		public override string GetProtocol() {
			return _HttpServletRequest.getScheme();
		}

		public override string GetServerName() {
			return _HttpServletRequest.getServerName();
		}

		public override bool IsSecure() {
			return _HttpServletRequest.isSecure();
		}
	}
}