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
- RuleSet.cs
- DataColumnMapping.cs
- PageContentAsyncResult.cs
- MenuItemBindingCollection.cs
- ConfigXmlReader.cs
- NetNamedPipeBinding.cs
- KeyConverter.cs
- ValidatingReaderNodeData.cs
- RootNamespaceAttribute.cs
- SynchronousSendBindingElement.cs
- FunctionParameter.cs
- WindowsRichEdit.cs
- HostProtectionException.cs
- AnnotationHighlightLayer.cs
- WindowsSysHeader.cs
- AmbiguousMatchException.cs
- SamlSubject.cs
- EmptyControlCollection.cs
- PropertyInfoSet.cs
- ElasticEase.cs
- PagedDataSource.cs
- AbstractExpressions.cs
- TextEditor.cs
- FontWeights.cs
- EnlistmentState.cs
- LoginUtil.cs
- XmlSchemaAnnotation.cs
- PersistenceProviderDirectory.cs
- PropertyGridCommands.cs
- Context.cs
- Tile.cs
- DataSourceHelper.cs
- HideDisabledControlAdapter.cs
- LinqDataSourceDeleteEventArgs.cs
- NotifyIcon.cs
- DesignerSerializationOptionsAttribute.cs
- MimeMultiPart.cs
- ReadOnlyTernaryTree.cs
- UserNameSecurityTokenAuthenticator.cs
- StreamReader.cs
- OrderingQueryOperator.cs
- CryptographicAttribute.cs
- PropertyMapper.cs
- HelloOperationAsyncResult.cs
- InvalidWMPVersionException.cs
- ObjectDataSourceEventArgs.cs
- CopyAttributesAction.cs
- TrustManagerPromptUI.cs
- BookmarkResumptionRecord.cs
- Hex.cs
- ReflectionUtil.cs
- MdiWindowListStrip.cs
- PersonalizationAdministration.cs
- ObjectMaterializedEventArgs.cs
- XmlSchemaAppInfo.cs
- SQLBoolean.cs
- ControlValuePropertyAttribute.cs
- PagedDataSource.cs
- XmlValidatingReader.cs
- FormDocumentDesigner.cs
- WorkflowViewService.cs
- XmlCharCheckingWriter.cs
- Parameter.cs
- ContextProperty.cs
- FormViewDeleteEventArgs.cs
- FixedSOMContainer.cs
- SqlNodeAnnotation.cs
- FormViewCommandEventArgs.cs
- MonthChangedEventArgs.cs
- WeakReadOnlyCollection.cs
- CompositeFontParser.cs
- DefaultObjectMappingItemCollection.cs
- AssemblyResourceLoader.cs
- Utils.cs
- WriteableBitmap.cs
- CommandValueSerializer.cs
- DbExpressionVisitor_TResultType.cs
- streamingZipPartStream.cs
- BitmapEncoder.cs
- SizeChangedEventArgs.cs
- SafeEventLogReadHandle.cs
- CookielessHelper.cs
- UriTemplatePathPartiallyEquivalentSet.cs
- AdCreatedEventArgs.cs
- HtmlControl.cs
- BlurBitmapEffect.cs
- ButtonColumn.cs
- EnumUnknown.cs
- HtmlControlAdapter.cs
- FontFamilyValueSerializer.cs
- IisTraceWebEventProvider.cs
- FileEnumerator.cs
- ExpressionReplacer.cs
- DbDataRecord.cs
- ZipPackage.cs
- altserialization.cs
- BuildProvider.cs
- Stack.cs
- StructuredProperty.cs
- Menu.cs