Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / NetFx35 / System.ServiceModel.Web / System / ServiceModel / Dispatcher / SingleBodyParameterMessageFormatter.cs / 1305376 / SingleBodyParameterMessageFormatter.cs
//------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------- namespace System.ServiceModel.Dispatcher { using System; using System.ServiceModel; using System.ServiceModel.Channels; using System.ServiceModel.Description; using System.Collections.Generic; using System.Xml; using System.Runtime.Serialization; using DiagnosticUtility = System.ServiceModel.DiagnosticUtility; using System.ServiceModel.Web; abstract class SingleBodyParameterMessageFormatter : IDispatchMessageFormatter, IClientMessageFormatter { string contractName; string contractNs; bool isRequestFormatter; string operationName; string serializerType; protected SingleBodyParameterMessageFormatter(OperationDescription operation, bool isRequestFormatter, string serializerType) { if (operation == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("operation"); } this.contractName = operation.DeclaringContract.Name; this.contractNs = operation.DeclaringContract.Namespace; this.operationName = operation.Name; this.isRequestFormatter = isRequestFormatter; this.serializerType = serializerType; } protected string ContractName { get { return this.contractName; } } protected string ContractNs { get { return this.contractNs; } } protected string OperationName { get { return this.operationName; } } public static IClientMessageFormatter CreateXmlAndJsonClientFormatter(OperationDescription operation, Type type, bool isRequestFormatter, UnwrappedTypesXmlSerializerManager xmlSerializerManager) { IClientMessageFormatter xmlFormatter = CreateClientFormatter(operation, type, isRequestFormatter, false, xmlSerializerManager); if (!WebHttpBehavior.SupportsJsonFormat(operation)) { return xmlFormatter; } IClientMessageFormatter jsonFormatter = CreateClientFormatter(operation, type, isRequestFormatter, true, xmlSerializerManager); Dictionarymap = new Dictionary (); map.Add(WebContentFormat.Xml, xmlFormatter); map.Add(WebContentFormat.Json, jsonFormatter); return new DemultiplexingClientMessageFormatter(map, xmlFormatter); } public static IDispatchMessageFormatter CreateXmlAndJsonDispatchFormatter(OperationDescription operation, Type type, bool isRequestFormatter, UnwrappedTypesXmlSerializerManager xmlSerializerManager, string callbackParameterName) { IDispatchMessageFormatter xmlFormatter = CreateDispatchFormatter(operation, type, isRequestFormatter, false, xmlSerializerManager, null); if (!WebHttpBehavior.SupportsJsonFormat(operation)) { return xmlFormatter; } IDispatchMessageFormatter jsonFormatter = CreateDispatchFormatter(operation, type, isRequestFormatter, true, xmlSerializerManager, callbackParameterName); Dictionary map = new Dictionary (); map.Add(WebContentFormat.Xml, xmlFormatter); map.Add(WebContentFormat.Json, jsonFormatter); return new DemultiplexingDispatchMessageFormatter(map, xmlFormatter); } public object DeserializeReply(Message message, object[] parameters) { if (isRequestFormatter) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR2.GetString(SR2.FormatterCannotBeUsedForReplyMessages))); } return ReadObject(message); } public void DeserializeRequest(Message message, object[] parameters) { if (!isRequestFormatter) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR2.GetString(SR2.FormatterCannotBeUsedForRequestMessages))); } parameters[0] = ReadObject(message); } public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) { if (isRequestFormatter) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR2.GetString(SR2.FormatterCannotBeUsedForReplyMessages))); } Message message = Message.CreateMessage(messageVersion, (string) null, CreateBodyWriter(result)); if (result == null) { SuppressReplyEntityBody(message); } AttachMessageProperties(message, false); return message; } public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) { if (!isRequestFormatter) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR2.GetString(SR2.FormatterCannotBeUsedForRequestMessages))); } Message message = Message.CreateMessage(messageVersion, (string) null, CreateBodyWriter(parameters[0])); if (parameters[0] == null) { SuppressRequestEntityBody(message); } AttachMessageProperties(message, true); return message; } internal static IClientMessageFormatter CreateClientFormatter(OperationDescription operation, Type type, bool isRequestFormatter, bool useJson, UnwrappedTypesXmlSerializerManager xmlSerializerManager) { if (type == null) { return new NullMessageFormatter(false, null); } else if (useJson) { return CreateJsonFormatter(operation, type, isRequestFormatter); } else { return CreateXmlFormatter(operation, type, isRequestFormatter, xmlSerializerManager); } } internal static IDispatchMessageFormatter CreateDispatchFormatter(OperationDescription operation, Type type, bool isRequestFormatter, bool useJson, UnwrappedTypesXmlSerializerManager xmlSerializerManager, string callbackParameterName) { if (type == null) { return new NullMessageFormatter(useJson, callbackParameterName); } else if (useJson) { return CreateJsonFormatter(operation, type, isRequestFormatter); } else { return CreateXmlFormatter(operation, type, isRequestFormatter, xmlSerializerManager); } } internal static void SuppressReplyEntityBody(Message message) { if (WebOperationContext.Current != null) { WebOperationContext.Current.OutgoingResponse.SuppressEntityBody = true; } else { object untypedProp; message.Properties.TryGetValue(HttpResponseMessageProperty.Name, out untypedProp); HttpResponseMessageProperty prop = untypedProp as HttpResponseMessageProperty; if (prop == null) { prop = new HttpResponseMessageProperty(); message.Properties[HttpResponseMessageProperty.Name] = prop; } prop.SuppressEntityBody = true; } } internal static void SuppressRequestEntityBody(Message message) { if (WebOperationContext.Current != null) { WebOperationContext.Current.OutgoingRequest.SuppressEntityBody = true; } else { object untypedProp; message.Properties.TryGetValue(HttpRequestMessageProperty.Name, out untypedProp); HttpRequestMessageProperty prop = untypedProp as HttpRequestMessageProperty; if (prop == null) { prop = new HttpRequestMessageProperty(); message.Properties[HttpRequestMessageProperty.Name] = prop; } prop.SuppressEntityBody = true; } } protected virtual void AttachMessageProperties(Message message, bool isRequest) { } protected abstract XmlObjectSerializer[] GetInputSerializers(); protected abstract XmlObjectSerializer GetOutputSerializer(Type type); protected virtual void ValidateMessageFormatProperty(Message message) { } protected void ValidateOutputType(Type type, Type parameterType, IList knownTypes) { // ensure that the type is the parameter type or is in the list of known types bool isValidType = false; if (type == parameterType) { isValidType = true; } else if (knownTypes != null) { for (int i = 0; i < knownTypes.Count; ++i) { if (type == knownTypes[i]) { isValidType = true; break; } } } if (!isValidType) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR2.GetString(SR2.TypeIsNotParameterTypeAndIsNotPresentInKnownTypes, type, this.OperationName, this.ContractName, parameterType))); } } public static SingleBodyParameterMessageFormatter CreateXmlFormatter(OperationDescription operation, Type type, bool isRequestFormatter, UnwrappedTypesXmlSerializerManager xmlSerializerManager) { DataContractSerializerOperationBehavior dcsob = operation.Behaviors.Find (); if (dcsob != null) { return new SingleBodyParameterDataContractMessageFormatter(operation, type, isRequestFormatter, false, dcsob); } XmlSerializerOperationBehavior xsob = operation.Behaviors.Find (); if (xsob != null) { return new SingleBodyParameterXmlSerializerMessageFormatter(operation, type, isRequestFormatter, xsob, xmlSerializerManager); } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotSupportedException(SR2.GetString(SR2.OnlyDataContractAndXmlSerializerTypesInUnWrappedMode, operation.Name))); } public static SingleBodyParameterMessageFormatter CreateJsonFormatter(OperationDescription operation, Type type, bool isRequestFormatter) { DataContractSerializerOperationBehavior dcsob = operation.Behaviors.Find (); if (dcsob == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR2.GetString(SR2.JsonFormatRequiresDataContract, operation.Name, operation.DeclaringContract.Name, operation.DeclaringContract.Namespace))); } return new SingleBodyParameterDataContractMessageFormatter(operation, type, isRequestFormatter, true, dcsob); } BodyWriter CreateBodyWriter(object body) { XmlObjectSerializer serializer; if (body != null) { serializer = GetOutputSerializer(body.GetType()); if (serializer == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotSupportedException(SR2.GetString(SR2.CannotSerializeType, body.GetType(), this.operationName, this.contractName, this.contractNs, this.serializerType))); } } else { serializer = null; } return new SingleParameterBodyWriter(body, serializer); } object ReadObject(Message message) { if (HttpStreamFormatter.IsEmptyMessage(message)) { return null; } XmlObjectSerializer[] inputSerializers = GetInputSerializers(); XmlDictionaryReader reader = message.GetReaderAtBodyContents(); if (inputSerializers != null) { for (int i = 0; i < inputSerializers.Length; ++i) { if (inputSerializers[i].IsStartObject(reader)) { return inputSerializers[i].ReadObject(reader, false); } } } throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR2.GetString(SR2.CannotDeserializeBody, reader.LocalName, reader.NamespaceURI, operationName, contractName, contractNs, this.serializerType))); } class NullMessageFormatter : IDispatchMessageFormatter, IClientMessageFormatter { bool useJson; string callbackParameterName; public NullMessageFormatter(bool useJson, string callbackParameterName) { this.useJson = useJson; this.callbackParameterName = callbackParameterName; } public object DeserializeReply(Message message, object[] parameters) { return null; } public void DeserializeRequest(Message message, object[] parameters) { } public Message SerializeReply(MessageVersion messageVersion, object[] parameters, object result) { Message reply = Message.CreateMessage(messageVersion, (string)null); SuppressReplyEntityBody(reply); if (useJson && WebHttpBehavior.TrySetupJavascriptCallback(callbackParameterName) != null) { reply.Properties.Add(WebBodyFormatMessageProperty.Name, WebBodyFormatMessageProperty.JsonProperty); } return reply; } public Message SerializeRequest(MessageVersion messageVersion, object[] parameters) { Message request = Message.CreateMessage(messageVersion, (string)null); SuppressRequestEntityBody(request); return request; } } class SingleParameterBodyWriter : BodyWriter { object body; XmlObjectSerializer serializer; public SingleParameterBodyWriter(object body, XmlObjectSerializer serializer) : base(false) { if (body != null && serializer == null) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("serializer"); } this.body = body; this.serializer = serializer; } protected override void OnWriteBodyContents(XmlDictionaryWriter writer) { if (body != null) { this.serializer.WriteObject(writer, body); } } } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
![Network programming in C#, Network Programming in VB.NET, Network Programming in .NET](/images/book.jpg)
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- SchemaTableColumn.cs
- RijndaelManaged.cs
- OracleTransaction.cs
- tibetanshape.cs
- HandleCollector.cs
- recordstatescratchpad.cs
- ResourcesGenerator.cs
- TypedElement.cs
- HwndTarget.cs
- PublisherIdentityPermission.cs
- ChildrenQuery.cs
- BufferedReadStream.cs
- CompiledRegexRunner.cs
- ContourSegment.cs
- UnknownBitmapEncoder.cs
- RsaSecurityTokenAuthenticator.cs
- RuleRef.cs
- sqlstateclientmanager.cs
- storepermissionattribute.cs
- SchemaImporterExtensionElementCollection.cs
- AssemblyNameProxy.cs
- StreamGeometry.cs
- ValidationResult.cs
- SettingsPropertyWrongTypeException.cs
- XPathNavigator.cs
- CryptoApi.cs
- Decimal.cs
- DataObjectSettingDataEventArgs.cs
- XmlAggregates.cs
- CanonicalFontFamilyReference.cs
- DataViewListener.cs
- GeometryModel3D.cs
- PrimitiveCodeDomSerializer.cs
- CheckBoxList.cs
- FormatSettings.cs
- sqlpipe.cs
- CounterSet.cs
- ProfessionalColors.cs
- Property.cs
- GenericRootAutomationPeer.cs
- InsufficientMemoryException.cs
- CTreeGenerator.cs
- Convert.cs
- PropertyStore.cs
- ToolStripDropDownClosedEventArgs.cs
- ArraySegment.cs
- XmlIlVisitor.cs
- OSEnvironmentHelper.cs
- GACIdentityPermission.cs
- PageRouteHandler.cs
- RotateTransform.cs
- JoinTreeSlot.cs
- CodeFieldReferenceExpression.cs
- ApplicationDirectoryMembershipCondition.cs
- ParallelLoopState.cs
- ListViewGroupConverter.cs
- ItemMap.cs
- CompressionTracing.cs
- PeerEndPoint.cs
- PaginationProgressEventArgs.cs
- IisHelper.cs
- AssociationTypeEmitter.cs
- HebrewNumber.cs
- XamlVector3DCollectionSerializer.cs
- UrlPath.cs
- SqlXmlStorage.cs
- DocumentPageTextView.cs
- ChangeProcessor.cs
- XmlSchemaDatatype.cs
- DBDataPermission.cs
- RangeContentEnumerator.cs
- CommandBindingCollection.cs
- CapabilitiesSection.cs
- DescendentsWalker.cs
- TagMapInfo.cs
- TdsParser.cs
- BindingOperations.cs
- Soap12ServerProtocol.cs
- BatchWriter.cs
- FocusManager.cs
- MobileControl.cs
- ApplicationFileCodeDomTreeGenerator.cs
- IncrementalCompileAnalyzer.cs
- CommandBinding.cs
- PagesChangedEventArgs.cs
- DefaultTextStore.cs
- DeviceSpecific.cs
- Authorization.cs
- DataSetMappper.cs
- XsltArgumentList.cs
- MsmqIntegrationChannelListener.cs
- OracleInfoMessageEventArgs.cs
- WebPartMenuStyle.cs
- MailMessage.cs
- SetStoryboardSpeedRatio.cs
- ActivityMarkupSerializationProvider.cs
- LocalizedNameDescriptionPair.cs
- ListViewItemMouseHoverEvent.cs
- QueryConverter.cs
- PowerEase.cs