//
// WebHttpBehavior.cs
//
// Author:
// Atsushi Enomoto <atsushi@ximian.com>
//
// Copyright (C) 2008 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.ServiceModel;
using System.ServiceModel.Channels;
using System.ServiceModel.Dispatcher;
using System.ServiceModel.Web;
namespace System.ServiceModel.Description{
internal static class WebHttpBehaviorExtensions
{
public static WebAttributeInfo GetWebAttributeInfo (this OperationDescription od)
{
#if NET_2_1
var mi = od.BeginMethod ?? od.SyncMethod;
var atts = mi.GetCustomAttributes (typeof (WebGetAttribute), true);
if (atts.Length == 1)
return ((WebGetAttribute) atts [0]).Info;
atts = mi.GetCustomAttributes (typeof (WebInvokeAttribute), true);
if (atts.Length == 1)
return ((WebInvokeAttribute) atts [0]).Info;
return null;
#else
foreach (IOperationBehavior ob in od.Behaviors) {
WebAttributeInfo info = null;
var wg = ob as WebGetAttribute;
if (wg != null)
return wg.Info;
var wi = ob as WebInvokeAttribute;
if (wi != null)
return wi.Info;
}
return new WebGetAttribute ().Info; // blank one
#endif
}
}
public class WebHttpBehavior
#if !NET_2_1
: IEndpointBehavior
#endif
{
public WebHttpBehavior ()
{
DefaultBodyStyle = WebMessageBodyStyle.Bare;
DefaultOutgoingRequestFormat = WebMessageFormat.Xml;
DefaultOutgoingResponseFormat = WebMessageFormat.Xml;
}
public virtual WebMessageBodyStyle DefaultBodyStyle { get; set; }
public virtual WebMessageFormat DefaultOutgoingRequestFormat { get; set; }
public virtual WebMessageFormat DefaultOutgoingResponseFormat { get; set; }
public virtual void AddBindingParameters (ServiceEndpoint endpoint, BindingParameterCollection bindingParameters)
{
// nothing
}
[MonoTODO]
protected virtual void AddClientErrorInspector (ServiceEndpoint endpoint, ClientRuntime clientRuntime)
{
// clientRuntime.MessageInspectors.Add (something);
}
#if !NET_2_1
[MonoTODO]
protected virtual void AddServerErrorHandlers (ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
{
// endpointDispatcher.ChannelDispatcher.ErrorHandlers.Add (something);
}
#endif
public virtual void ApplyClientBehavior (ServiceEndpoint endpoint, ClientRuntime clientRuntime)
{
AddClientErrorInspector (endpoint, clientRuntime);
#if MOONLIGHT
throw new NotSupportedException ("Due to the lack of ClientRuntime.Operations, Silverlight cannot support this binding.");
#else
foreach (ClientOperation oper in clientRuntime.Operations) {
var req = GetRequestClientFormatter (endpoint.Contract.Operations.Find (oper.Name), endpoint);
var res = GetReplyClientFormatter (endpoint.Contract.Operations.Find (oper.Name), endpoint);
oper.Formatter = new ClientPairFormatter (req, res);
}
#endif
}
#if !NET_2_1
public virtual void ApplyDispatchBehavior (ServiceEndpoint endpoint, EndpointDispatcher endpointDispatcher)
{
endpointDispatcher.DispatchRuntime.OperationSelector = GetOperationSelector (endpoint);
// FIXME: get HostNameComparisonMode from WebHttpBinding by some means.
endpointDispatcher.FilterPriority = 1; // It is to take higher priority than that of ServiceMetadataExtension (whose URL likely conflicts with this one).
endpointDispatcher.AddressFilter = new PrefixEndpointAddressMessageFilter (endpoint.Address);
endpointDispatcher.ContractFilter = new MatchAllMessageFilter ();
AddServerErrorHandlers (endpoint, endpointDispatcher);
foreach (DispatchOperation oper in endpointDispatcher.DispatchRuntime.Operations) {
var req = GetRequestDispatchFormatter (endpoint.Contract.Operations.Find (oper.Name), endpoint);
var res = GetReplyDispatchFormatter (endpoint.Contract.Operations.Find (oper.Name), endpoint);
oper.Formatter = new DispatchPairFormatter (req, res);
}
}
#endif
internal class ClientPairFormatter : IClientMessageFormatter
{
public ClientPairFormatter (IClientMessageFormatter request, IClientMessageFormatter reply)
{
this.request = request;
this.reply = reply;
}
IClientMessageFormatter request, reply;
public Message SerializeRequest (MessageVersion messageVersion, object [] parameters)
{
return request.SerializeRequest (messageVersion, parameters);
}
public object DeserializeReply (Message message, object [] parameters)
{
return reply.DeserializeReply (message, parameters);
}
}
#if !NET_2_1
internal class DispatchPairFormatter : IDispatchMessageFormatter
{
public DispatchPairFormatter (IDispatchMessageFormatter request, IDispatchMessageFormatter reply)
{
this.request = request;
this.reply = reply;
}
IDispatchMessageFormatter request;
IDispatchMessageFormatter reply;
public void DeserializeRequest (Message message, object [] parameters)
{
request.DeserializeRequest (message, parameters);
}
public Message SerializeReply (MessageVersion messageVersion, object [] parameters, object result)
{
return reply.SerializeReply (messageVersion, parameters, result);
}
}
protected virtual WebHttpDispatchOperationSelector GetOperationSelector (ServiceEndpoint endpoint)
{
return new WebHttpDispatchOperationSelector (endpoint);
}
#endif
protected virtual QueryStringConverter GetQueryStringConverter (OperationDescription operationDescription)
{
return new QueryStringConverter ();
}
protected virtual IClientMessageFormatter GetReplyClientFormatter (OperationDescription operationDescription, ServiceEndpoint endpoint)
{
return new WebMessageFormatter.ReplyClientFormatter (operationDescription, endpoint, GetQueryStringConverter (operationDescription), this);
}
#if !NET_2_1
protected virtual IDispatchMessageFormatter GetReplyDispatchFormatter (OperationDescription operationDescription, ServiceEndpoint endpoint)
{
return new WebMessageFormatter.ReplyDispatchFormatter (operationDescription, endpoint, GetQueryStringConverter (operationDescription), this);
}
#endif
protected virtual IClientMessageFormatter GetRequestClientFormatter (OperationDescription operationDescription, ServiceEndpoint endpoint)
{
return new WebMessageFormatter.RequestClientFormatter (operationDescription, endpoint, GetQueryStringConverter (operationDescription), this);
}
#if !NET_2_1
protected virtual IDispatchMessageFormatter GetRequestDispatchFormatter (OperationDescription operationDescription, ServiceEndpoint endpoint)
{
return new WebMessageFormatter.RequestDispatchFormatter (operationDescription, endpoint, GetQueryStringConverter (operationDescription), this);
}
#endif
[MonoTODO ("check UriTemplate validity")]
public virtual void Validate (ServiceEndpoint endpoint)
{
if (endpoint == null)
throw new ArgumentNullException ("endpoint");
foreach (var oper in endpoint.Contract.Operations) {
var wai = oper.GetWebAttributeInfo ();
if (wai.Method == "GET")
continue;
var style = wai != null && wai.IsBodyStyleSetExplicitly ? wai.BodyStyle : DefaultBodyStyle;
foreach (var msg in oper.Messages)
switch (style) {
case WebMessageBodyStyle.Wrapped:
continue;
case WebMessageBodyStyle.WrappedRequest:
if (msg.Direction == MessageDirection.Output)
continue;
goto case WebMessageBodyStyle.Bare;
case WebMessageBodyStyle.WrappedResponse:
if (msg.Direction == MessageDirection.Input)
continue;
goto case WebMessageBodyStyle.Bare;
case WebMessageBodyStyle.Bare:
default:
if (msg.Body.Parts.Count > 1)
throw new InvalidOperationException (String.Format ("{0} message on operation '{1}' has multiple parameters which is not allowed when the operation indicates no wrapper element. BodyStyle must be 'wrapped' on the operation WebInvoke/WebGet attribute.", msg.Direction, oper.Name));
break;
}
}
ValidateBinding (endpoint);
}
protected virtual void ValidateBinding (ServiceEndpoint endpoint)
{
switch (endpoint.Binding.Scheme) {
case "http":
case "https":
break;
default:
throw new InvalidOperationException ("Only http and https are allowed for WebHttpBehavior");
}
if (!endpoint.Binding.MessageVersion.Equals (MessageVersion.None))
throw new InvalidOperationException ("Only MessageVersion.None is allowed for WebHttpBehavior");
if (!endpoint.Binding.CreateBindingElements ().Find<TransportBindingElement> ().ManualAddressing)
throw new InvalidOperationException ("ManualAddressing in the transport binding element in the binding must be true for WebHttpBehavior");
}
}
}
|