//
// AspNetReplyChannel.cs
//
// Author:
//	Ankit Jain  <jankit@novell.com>
//
// Copyright (C) 2006 Novell, Inc.  http://www.novell.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.Collections.Generic;
using System.IO;
using System.Net;
using System.ServiceModel;
using System.Text;
using System.Threading;
using System.Web;

namespace System.ServiceModel.Channels
{
	internal class AspNetReplyChannel : HttpReplyChannel
	{
		HttpContext http_context;
		Uri uri;

		public AspNetReplyChannel (HttpChannelListener<IReplyChannel> listener,
			TimeSpan timeout)
			: base (listener, timeout)
		{
			uri = listener.Uri;
		}

		public override bool TryReceiveRequest (TimeSpan timeout, out RequestContext context)
		{
#if false
			context = null;
			if (waiting.Count == 0 && !WaitForRequest (timeout))
				return false;
			HttpListenerContext ctx = null;
			lock (waiting) {
				if (waiting.Count > 0) {
					ctx = waiting [0];
					waiting.RemoveAt (0);
				}
			}
			if (ctx == null) 
				// Though as long as this instance is used
				// synchronously, it should not happen.
				return false;
#endif

			Message msg;
			if (http_context.Request.HttpMethod == "GET") {
				if (http_context.Request.QueryString ["wsdl"] != null) {
					msg = Message.CreateMessage (Encoder.MessageVersion,
						"http://schemas.xmlsoap.org/ws/2004/09/transfer/Get");
					msg.Headers.To = http_context.Request.Url;
				} else {
					msg = Message.CreateMessage (Encoder.MessageVersion, null);
					msg.Headers.To = http_context.Request.Url;
				}
			} else {
				//FIXME: Do above stuff for HttpContext ?
				int maxSizeOfHeaders = 0x10000;

				msg = Encoder.ReadMessage (
					http_context.Request.InputStream, maxSizeOfHeaders);

				if (Encoder.MessageVersion.Envelope == EnvelopeVersion.Soap11) {
					string action = GetHeaderItem (http_context.Request.Headers ["SOAPAction"]);
					if (action != null)
						msg.Headers.Action = action;
				}
			}
			context = new AspNetRequestContext (this, msg, http_context);

			return true;
		}

		public HttpContext Context {
			get { return http_context; }
			set { http_context = value; }
		}

		public override bool WaitForRequest (TimeSpan timeout)
		{
			// FIXME: we might want to take other approaches.
			if (timeout.Ticks > int.MaxValue)
				timeout = TimeSpan.FromDays (20);

			SvcHttpHandler h = SvcHttpHandlerFactory.GetHandler (uri.OriginalString.Replace ("file://", ""));
			return h.WaitForRequest (this, timeout);

#if false
			AutoResetEvent wait = new AutoResetEvent (false);
			source.Http.BeginGetContext (HttpContextReceived, wait);
			// FIXME: we might want to take other approaches.
			if (timeout.Ticks > int.MaxValue)
				timeout = TimeSpan.FromDays (20);
			return wait.WaitOne (timeout, false);
#endif
		}

		void HttpContextReceived (IAsyncResult result)
		{
			throw new NotImplementedException ();
#if false	
			waiting.Add (source.Http.EndGetContext (result));
			AutoResetEvent wait = (AutoResetEvent) result.AsyncState;
			wait.Set ();
#endif
		}
	}
}