// // SvcHttpHandler.cs // // Author: // Ankit Jain // // 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.Web; using System.Threading; using System.ServiceModel; using System.ServiceModel.Activation; using System.ServiceModel.Configuration; using System.ServiceModel.Description; namespace System.ServiceModel.Channels { internal class SvcHttpHandler : IHttpHandler { Type type; Type factory_type; internal string path; Uri request_url; ServiceHostBase host; AspNetReplyChannel reply_channel; AutoResetEvent wait = new AutoResetEvent (false); AutoResetEvent listening = new AutoResetEvent (false); public SvcHttpHandler (Type type, Type factoryType, string path) { this.type = type; this.factory_type = factoryType; this.path = path; } public bool IsReusable { get { return true; } } public bool WaitForRequest (AspNetReplyChannel reply_channel, TimeSpan timeout) { this.reply_channel = reply_channel; listening.Set (); return wait.WaitOne (timeout, false); } public void ProcessRequest (HttpContext context) { request_url = context.Request.Url; EnsureServiceHost (); reply_channel.Context = context; wait.Set (); listening.WaitOne (); reply_channel.Context = null; } public void Close () { host.Close (); host = null; } void ApplyConfiguration (ServiceHost host) { foreach (ServiceElement service in ConfigUtil.ServicesSection.Services) { foreach (ServiceEndpointElement endpoint in service.Endpoints) { // FIXME: consider BindingName as well ServiceEndpoint se = host.AddServiceEndpoint ( endpoint.Contract, ConfigUtil.CreateBinding (endpoint.Binding, endpoint.BindingConfiguration), new Uri (path)); } // behaviors ServiceBehaviorElement behavior = ConfigUtil.BehaviorsSection.ServiceBehaviors.Find (service.BehaviorConfiguration); if (behavior != null) { foreach (BehaviorExtensionElement bxel in behavior) { IServiceBehavior b = null; ServiceMetadataPublishingElement meta = bxel as ServiceMetadataPublishingElement; if (meta != null) { ServiceMetadataBehavior smb = meta.CreateBehavior () as ServiceMetadataBehavior; smb.HttpGetUrl = request_url; // FIXME: HTTPS as well b = smb; } if (b != null) host.Description.Behaviors.Add (b); } } } } void EnsureServiceHost () { if (reply_channel != null) return; //ServiceHost for this not created yet if (factory_type != null) host = ((ServiceHostFactory) Activator.CreateInstance (factory_type)).CreateServiceHost (type, new Uri [0]); else host = new ServiceHost (type); #if true //FIXME: Binding: Get from web.config. host.AddServiceEndpoint (ContractDescription.GetContract (type).Name, new BasicHttpBinding (), new Uri (path)); #else ApplyConfiguration (host); #endif host.Open (); listening.WaitOne (); } } }