Code:
/ 4.0 / 4.0 / 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. //------------------------------------------------------------------------------ //// 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
- TemplatePartAttribute.cs
- SmiXetterAccessMap.cs
- TargetConverter.cs
- RunInstallerAttribute.cs
- AppDomainUnloadedException.cs
- LoadWorkflowByKeyAsyncResult.cs
- OleStrCAMarshaler.cs
- Parsers.cs
- StylusDownEventArgs.cs
- FloatUtil.cs
- DifferencingCollection.cs
- PersistChildrenAttribute.cs
- LateBoundBitmapDecoder.cs
- EventHandlersStore.cs
- SectionInput.cs
- WebPartTransformerCollection.cs
- MenuAdapter.cs
- FileSystemInfo.cs
- UnsignedPublishLicense.cs
- BamlRecords.cs
- StringToken.cs
- CalendarBlackoutDatesCollection.cs
- PreProcessor.cs
- HMACRIPEMD160.cs
- CompleteWizardStep.cs
- IisTraceWebEventProvider.cs
- ObjectStateEntryBaseUpdatableDataRecord.cs
- FlatButtonAppearance.cs
- TreeNodeStyleCollection.cs
- FontWeightConverter.cs
- MarginsConverter.cs
- MdiWindowListItemConverter.cs
- AttachmentService.cs
- versioninfo.cs
- securestring.cs
- _IPv6Address.cs
- HttpGetClientProtocol.cs
- FixedDocument.cs
- XmlImplementation.cs
- TypeElementCollection.cs
- RequestQueryParser.cs
- ErrorFormatterPage.cs
- FlowDocumentReaderAutomationPeer.cs
- ContextMenuAutomationPeer.cs
- brushes.cs
- InProcStateClientManager.cs
- NodeInfo.cs
- SmtpFailedRecipientException.cs
- ElementHost.cs
- PackWebRequestFactory.cs
- DataListItemCollection.cs
- HttpResponseBase.cs
- MessageFormatterConverter.cs
- SslSecurityTokenParameters.cs
- GlyphElement.cs
- NetTcpSection.cs
- Keywords.cs
- TextRangeAdaptor.cs
- SqlProfileProvider.cs
- PopupRoot.cs
- CodeSnippetStatement.cs
- LayoutInformation.cs
- XmlTextAttribute.cs
- WebInvokeAttribute.cs
- DesignerFrame.cs
- ViewEventArgs.cs
- ViewgenContext.cs
- ShowExpandedMultiValueConverter.cs
- DetailsViewUpdatedEventArgs.cs
- DataGridPageChangedEventArgs.cs
- View.cs
- COAUTHIDENTITY.cs
- CompiledQuery.cs
- XmlAnyElementAttributes.cs
- QilFactory.cs
- SqlDataRecord.cs
- PersonalizationStateInfo.cs
- XamlDesignerSerializationManager.cs
- RtfFormatStack.cs
- ScriptReference.cs
- MatrixIndependentAnimationStorage.cs
- RadioButton.cs
- SchemaImporterExtensionElement.cs
- ModifierKeysValueSerializer.cs
- XmlSchemaExternal.cs
- BuildProviderAppliesToAttribute.cs
- WebConfigurationFileMap.cs
- CodeExporter.cs
- ToolStripStatusLabel.cs
- AppDomainUnloadedException.cs
- controlskin.cs
- cache.cs
- DateTimeOffset.cs
- Source.cs
- FreezableDefaultValueFactory.cs
- CompiledScopeCriteria.cs
- DbModificationCommandTree.cs
- NativeMethods.cs
- JapaneseLunisolarCalendar.cs
- OperatingSystem.cs