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
- FlowLayout.cs
- EventSetter.cs
- OdbcError.cs
- ParameterToken.cs
- DesignBindingPicker.cs
- GenericAuthenticationEventArgs.cs
- TextFindEngine.cs
- CompilationSection.cs
- XhtmlBasicTextBoxAdapter.cs
- OpenTypeLayoutCache.cs
- HMACSHA256.cs
- RemotingServices.cs
- FixedSOMTable.cs
- SQLStringStorage.cs
- CodePageUtils.cs
- ListViewHitTestInfo.cs
- ReceiveCompletedEventArgs.cs
- UnaryExpressionHelper.cs
- UnmanagedMemoryStream.cs
- MenuEventArgs.cs
- TranslateTransform3D.cs
- validationstate.cs
- CreatingCookieEventArgs.cs
- FrameworkContextData.cs
- ExpressionConverter.cs
- SingleAnimationUsingKeyFrames.cs
- XamlReaderHelper.cs
- DocumentViewerConstants.cs
- login.cs
- SmiEventStream.cs
- _PooledStream.cs
- QilGeneratorEnv.cs
- TableLayoutStyle.cs
- TemplateParser.cs
- ExpressionPrinter.cs
- SizeAnimationClockResource.cs
- Update.cs
- AdditionalEntityFunctions.cs
- ConditionBrowserDialog.cs
- MessageBuilder.cs
- Vector.cs
- SapiRecognizer.cs
- arabicshape.cs
- VectorConverter.cs
- KeyFrames.cs
- PerformanceCounterManager.cs
- NamedPipeTransportBindingElement.cs
- ClientSponsor.cs
- MdiWindowListStrip.cs
- ImageDrawing.cs
- CompilationLock.cs
- DesignerRegionCollection.cs
- PrintPreviewGraphics.cs
- ConversionContext.cs
- Delegate.cs
- TextDecorations.cs
- WebPartVerbCollection.cs
- DesignerForm.cs
- Double.cs
- TypeLoadException.cs
- VisualStyleElement.cs
- MetabaseReader.cs
- BatchParser.cs
- DbDataAdapter.cs
- TextElementEnumerator.cs
- LambdaCompiler.Binary.cs
- OnOperation.cs
- ReachSerializationUtils.cs
- HtmlForm.cs
- EntityDataSourceViewSchema.cs
- Rotation3DKeyFrameCollection.cs
- TemplateColumn.cs
- XmlSchemaGroup.cs
- ExpiredSecurityTokenException.cs
- UrlAuthorizationModule.cs
- FSWPathEditor.cs
- ComboBoxDesigner.cs
- PasswordTextNavigator.cs
- Selection.cs
- DeviceSpecificDesigner.cs
- WebPartAddingEventArgs.cs
- WindowsGraphicsCacheManager.cs
- coordinator.cs
- DeflateEmulationStream.cs
- EventItfInfo.cs
- XmlSerializerFactory.cs
- InvokeMethodDesigner.xaml.cs
- EdmSchemaAttribute.cs
- RuntimeWrappedException.cs
- ToolStrip.cs
- SchemaReference.cs
- XmlSchemaComplexContentRestriction.cs
- X509SubjectKeyIdentifierClause.cs
- QilLoop.cs
- MouseGesture.cs
- SupportsEventValidationAttribute.cs
- DigestComparer.cs
- CodeArrayIndexerExpression.cs
- DeviceContexts.cs
- JournalNavigationScope.cs