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
- InputLanguage.cs
- TypedReference.cs
- ProtectedProviderSettings.cs
- WebPartConnectionsDisconnectVerb.cs
- HttpConfigurationSystem.cs
- ConfigurationProperty.cs
- InputChannel.cs
- CommandManager.cs
- EntityViewContainer.cs
- TextDecorationLocationValidation.cs
- sqlinternaltransaction.cs
- GridPatternIdentifiers.cs
- StylusOverProperty.cs
- PngBitmapEncoder.cs
- RegexWriter.cs
- UnsafeNativeMethodsPenimc.cs
- PrimarySelectionAdorner.cs
- RootNamespaceAttribute.cs
- SmtpNetworkElement.cs
- TextServicesCompartmentContext.cs
- XmlSchemaObjectTable.cs
- BinaryObjectWriter.cs
- ViewStateModeByIdAttribute.cs
- VirtualPathUtility.cs
- CubicEase.cs
- PointCollection.cs
- CryptoKeySecurity.cs
- GridViewRow.cs
- InlineObject.cs
- CookieParameter.cs
- TableRowGroup.cs
- HttpServerChannel.cs
- PriorityBindingExpression.cs
- CodeMemberEvent.cs
- Compilation.cs
- CodeBlockBuilder.cs
- SmiEventStream.cs
- PagesSection.cs
- KeyNotFoundException.cs
- InstanceContextManager.cs
- listitem.cs
- AssemblyLoader.cs
- LazyTextWriterCreator.cs
- TimelineClockCollection.cs
- PartialCachingAttribute.cs
- RuntimeHandles.cs
- CommonObjectSecurity.cs
- GregorianCalendarHelper.cs
- ReachFixedDocumentSerializer.cs
- EmptyStringExpandableObjectConverter.cs
- ValidationSummary.cs
- ResizeBehavior.cs
- ProbeMatchesMessageCD1.cs
- LogManagementAsyncResult.cs
- Win32NamedPipes.cs
- PerspectiveCamera.cs
- UnsafeNativeMethods.cs
- MemoryRecordBuffer.cs
- RectIndependentAnimationStorage.cs
- BoolExpr.cs
- SurrogateEncoder.cs
- GcHandle.cs
- ChtmlPhoneCallAdapter.cs
- TextCompositionEventArgs.cs
- ReadOnlyPropertyMetadata.cs
- HttpUnhandledOperationInvoker.cs
- KnownTypeAttribute.cs
- SqlTrackingQuery.cs
- UiaCoreProviderApi.cs
- CompModSwitches.cs
- RegistryPermission.cs
- WCFModelStrings.Designer.cs
- Parallel.cs
- PrintPreviewGraphics.cs
- SapiInterop.cs
- SystemInfo.cs
- SqlException.cs
- CompiledELinqQueryState.cs
- Glyph.cs
- ImageDrawing.cs
- TreeNodeCollectionEditorDialog.cs
- ParameterCollection.cs
- DataGridViewCellContextMenuStripNeededEventArgs.cs
- BorderGapMaskConverter.cs
- NavigationPropertySingletonExpression.cs
- ExpressionParser.cs
- StringFreezingAttribute.cs
- AssemblyResolver.cs
- UserPreferenceChangedEventArgs.cs
- DataGridItem.cs
- ObjectDataSourceEventArgs.cs
- Button.cs
- XmlDataProvider.cs
- XmlSerializationReader.cs
- NameValueConfigurationElement.cs
- ApplicationDirectoryMembershipCondition.cs
- UTF32Encoding.cs
- ISSmlParser.cs
- PropertyMapper.cs
- XmlReader.cs