Code:
/ 4.0 / 4.0 / untmp / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Services / Web / System / Web / Services / Protocols / DiscoveryServerProtocol.cs / 1305376 / DiscoveryServerProtocol.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Web.Services.Protocols { using System; using System.Collections; using System.IO; using System.Reflection; using System.Xml.Serialization; using System.Xml.Schema; using System.Web.Services.Description; using System.Web.Services.Discovery; using System.Web.UI; using System.Text; using System.Diagnostics; using System.Net; using System.Web.Services.Configuration; using System.Globalization; internal class DiscoveryServerType : ServerType { ServiceDescription description; LogicalMethodInfo methodInfo; Hashtable schemaTable = new Hashtable(); Hashtable wsdlTable = new Hashtable(); DiscoveryDocument discoDoc; internal DiscoveryServerType(Type type, string uri) : base(typeof(DiscoveryServerProtocol)) { // // parse the uri from a string into a Uri object // Uri uriObject = new Uri(uri, true); // // and get rid of the query string if there's one // uri = uriObject.GetLeftPart(UriPartial.Path); methodInfo = new LogicalMethodInfo(typeof(DiscoveryServerProtocol).GetMethod("Discover", BindingFlags.Instance | BindingFlags.Static | BindingFlags.Public | BindingFlags.NonPublic)); ServiceDescriptionReflector reflector = new ServiceDescriptionReflector(); reflector.Reflect(type, uri); XmlSchemas schemas = reflector.Schemas; this.description = reflector.ServiceDescription; // We need to force initialization of ServiceDescription's XmlSerializer since we // won't necessarily have the permissions to do it when we actually need it XmlSerializer serializer = ServiceDescription.Serializer; // add imports to the external schemas AddSchemaImports(schemas, uri, reflector.ServiceDescriptions); // add imports to the other service descriptions for (int i = 1; i < reflector.ServiceDescriptions.Count; i++) { ServiceDescription description = reflector.ServiceDescriptions[i]; Import import = new Import(); import.Namespace = description.TargetNamespace; // string id = "wsdl" + i.ToString(CultureInfo.InvariantCulture); import.Location = uri + "?wsdl=" + id; reflector.ServiceDescription.Imports.Add(import); wsdlTable.Add(id, description); } discoDoc = new DiscoveryDocument(); discoDoc.References.Add(new ContractReference(uri + "?wsdl", uri)); foreach (Service service in reflector.ServiceDescription.Services) { foreach (Port port in service.Ports) { SoapAddressBinding soapAddress = (SoapAddressBinding)port.Extensions.Find(typeof(SoapAddressBinding)); if (soapAddress != null) { System.Web.Services.Discovery.SoapBinding binding = new System.Web.Services.Discovery.SoapBinding(); binding.Binding = port.Binding; binding.Address = soapAddress.Location; discoDoc.References.Add(binding); } } } } internal void AddExternal(XmlSchema schema, string ns, string location) { if (schema == null) return; if (schema.TargetNamespace == ns) { XmlSchemaInclude include = new XmlSchemaInclude(); include.SchemaLocation = location; schema.Includes.Add(include); } else { XmlSchemaImport import = new XmlSchemaImport(); import.SchemaLocation = location; import.Namespace = ns; schema.Includes.Add(import); } } void AddSchemaImports(XmlSchemas schemas, string uri, ServiceDescriptionCollection descriptions) { int id = 0; foreach(XmlSchema schema in schemas) { if (schema == null) continue; // if (schema.Id == null || schema.Id.Length == 0) schema.Id = "schema" + (++id).ToString(CultureInfo.InvariantCulture); string location = uri + "?schema=" + schema.Id; foreach(ServiceDescription description in descriptions) { if (description.Types.Schemas.Count == 0) { XmlSchema top = new XmlSchema(); top.TargetNamespace = description.TargetNamespace; schema.ElementFormDefault = XmlSchemaForm.Qualified; AddExternal(top, schema.TargetNamespace, location); description.Types.Schemas.Add(top); } else { AddExternal(description.Types.Schemas[0], schema.TargetNamespace, location); } } //schema.SchemaLocation = location; schemaTable.Add(schema.Id, schema); } } internal XmlSchema GetSchema(string id) { return (XmlSchema)schemaTable[id]; } internal ServiceDescription GetServiceDescription(string id) { return (ServiceDescription)wsdlTable[id]; } internal ServiceDescription Description { get { return description; } } internal LogicalMethodInfo MethodInfo { get { return methodInfo; } } internal DiscoveryDocument Disco { get { return discoDoc; } } } internal class DiscoveryServerProtocolFactory : ServerProtocolFactory { protected override ServerProtocol CreateIfRequestCompatible(HttpRequest request){ if (request.PathInfo.Length > 0) return null; if (request.HttpMethod != "GET") // MethodNotAllowed = 405, return new UnsupportedRequestProtocol(405); string queryString = request.QueryString[null]; if (queryString == null) queryString = ""; if (request.QueryString["schema"] == null && request.QueryString["wsdl"] == null && string.Compare(queryString, "wsdl", StringComparison.OrdinalIgnoreCase) != 0 && string.Compare(queryString, "disco", StringComparison.OrdinalIgnoreCase) != 0) return null; return new DiscoveryServerProtocol(); } } internal sealed class DiscoveryServerProtocol : ServerProtocol { DiscoveryServerType serverType; internal override bool Initialize() { // // see if we already cached a DiscoveryServerType // serverType = (DiscoveryServerType)GetFromCache(typeof(DiscoveryServerProtocol), Type); if (serverType == null) { lock (InternalSyncObject) { serverType = (DiscoveryServerType)GetFromCache(typeof(DiscoveryServerProtocol), Type); if (serverType == null) { // // if not create a new DiscoveryServerType and cache it // string escapedUri = Uri.EscapeUriString(Request.Url.ToString()).Replace("#", "%23"); serverType = new DiscoveryServerType(Type, escapedUri); AddToCache(typeof(DiscoveryServerProtocol), Type, serverType); } } } return true; } internal override ServerType ServerType { get { return serverType; } } internal override bool IsOneWay { get { return false; } } internal override LogicalMethodInfo MethodInfo { get { return serverType.MethodInfo; } } internal override object[] ReadParameters() { return new object[0]; } internal override void WriteReturns(object[] returnValues, Stream outputStream) { string id = Request.QueryString["schema"]; Encoding encoding = new UTF8Encoding(false); if (id != null) { XmlSchema schema = serverType.GetSchema(id); if (schema == null) throw new InvalidOperationException(Res.GetString(Res.WebSchemaNotFound)); Response.ContentType = ContentType.Compose("text/xml", encoding); schema.Write(new StreamWriter(outputStream, encoding)); return; } id = Request.QueryString["wsdl"]; if (id != null) { ServiceDescription description = serverType.GetServiceDescription(id); if (description == null) throw new InvalidOperationException(Res.GetString(Res.ServiceDescriptionWasNotFound0)); Response.ContentType = ContentType.Compose("text/xml", encoding); description.Write(new StreamWriter(outputStream, encoding)); return; } string queryString = Request.QueryString[null]; if (queryString != null && string.Compare(queryString, "wsdl", StringComparison.OrdinalIgnoreCase) == 0) { Response.ContentType = ContentType.Compose("text/xml", encoding); serverType.Description.Write(new StreamWriter(outputStream, encoding)); return; } if (queryString != null && string.Compare(queryString, "disco", StringComparison.OrdinalIgnoreCase) == 0) { Response.ContentType = ContentType.Compose("text/xml", encoding); serverType.Disco.Write(new StreamWriter(outputStream, encoding)); return; } throw new InvalidOperationException(Res.GetString(Res.internalError0)); } internal override bool WriteException(Exception e, Stream outputStream) { Response.Clear(); Response.ClearHeaders(); Response.ContentType = ContentType.Compose("text/plain", Encoding.UTF8); Response.StatusCode = (int) HttpStatusCode.InternalServerError; Response.StatusDescription = HttpWorkerRequest.GetStatusDescription(Response.StatusCode); StreamWriter writer = new StreamWriter(outputStream, new UTF8Encoding(false)); writer.WriteLine(GenerateFaultString(e, true)); writer.Flush(); return true; } internal void Discover() { // This is the "server method" that is called for this protocol } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- ChannelSettingsElement.cs
- StateDesigner.LayoutSelectionGlyph.cs
- AccessibleObject.cs
- ContentElementAutomationPeer.cs
- DecoderFallbackWithFailureFlag.cs
- AsyncOperationManager.cs
- NavigationExpr.cs
- X509ChainElement.cs
- Command.cs
- RSACryptoServiceProvider.cs
- ResXBuildProvider.cs
- ADConnectionHelper.cs
- DataTrigger.cs
- XpsSerializerWriter.cs
- RIPEMD160Managed.cs
- ThumbButtonInfo.cs
- TypedTableBase.cs
- CodeCastExpression.cs
- SQLBytes.cs
- itemelement.cs
- ErrorRuntimeConfig.cs
- WebPartZone.cs
- xdrvalidator.cs
- HtmlTitle.cs
- UnregisterInfo.cs
- ClientUrlResolverWrapper.cs
- CatalogPartChrome.cs
- BinaryExpressionHelper.cs
- ObjectPropertyMapping.cs
- OperatorExpressions.cs
- Gdiplus.cs
- LocalizationComments.cs
- Border.cs
- CellRelation.cs
- Int32RectConverter.cs
- ChangesetResponse.cs
- NonVisualControlAttribute.cs
- _DigestClient.cs
- Mouse.cs
- ListViewItemSelectionChangedEvent.cs
- SqlDataReader.cs
- PermissionSetTriple.cs
- BitmapCodecInfo.cs
- _SingleItemRequestCache.cs
- DoubleAnimationUsingKeyFrames.cs
- FormViewPageEventArgs.cs
- TabControl.cs
- FactoryMaker.cs
- Types.cs
- SectionXmlInfo.cs
- unsafeIndexingFilterStream.cs
- ServiceModelReg.cs
- HostedNamedPipeTransportManager.cs
- ChtmlTextWriter.cs
- OutputCacheSection.cs
- Utility.cs
- CodeDOMUtility.cs
- RowParagraph.cs
- SpeechRecognitionEngine.cs
- BodyGlyph.cs
- Bidi.cs
- XpsFilter.cs
- JavascriptXmlWriterWrapper.cs
- ProxyWebPartConnectionCollection.cs
- TreeNodeEventArgs.cs
- SemaphoreSlim.cs
- RelationshipConverter.cs
- SupportsPreviewControlAttribute.cs
- AdPostCacheSubstitution.cs
- InvalidOperationException.cs
- ArgumentNullException.cs
- FlowDocumentScrollViewer.cs
- Configuration.cs
- WindowsFormsHelpers.cs
- PointLight.cs
- RequestQueue.cs
- MessageBox.cs
- XmlComment.cs
- ChtmlMobileTextWriter.cs
- NetTcpSectionData.cs
- StaticFileHandler.cs
- StorageEntitySetMapping.cs
- GraphicsContainer.cs
- Currency.cs
- OracleNumber.cs
- UIElement3D.cs
- DynamicControlParameter.cs
- SplitterPanel.cs
- BamlRecordWriter.cs
- NetworkCredential.cs
- UnionExpr.cs
- MappingItemCollection.cs
- AlternateViewCollection.cs
- GridPattern.cs
- BitmapEffectvisualstate.cs
- ColumnHeaderCollectionEditor.cs
- LogArchiveSnapshot.cs
- HttpDigestClientElement.cs
- StrokeCollectionDefaultValueFactory.cs
- EntityDataSourceUtil.cs