Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / cdf / src / WCF / Tools / comsvcutil / SvcFileManager.cs / 1305376 / SvcFileManager.cs
//------------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//-----------------------------------------------------------------------------
namespace Microsoft.Tools.ServiceModel.ComSvcConfig
{
using System;
using System.ServiceModel.Channels;
using System.Diagnostics;
using System.Configuration;
using System.Globalization;
using System.Collections;
using System.Collections.Specialized;
using System.Collections.Generic;
using System.IO;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Runtime.InteropServices;
using System.Security;
using System.ServiceModel;
using System.ServiceModel.Activation;
using System.ServiceModel.Configuration;
using System.ServiceModel.ComIntegration;
using Microsoft.Tools.ServiceModel;
using Microsoft.Tools.ServiceModel.SvcUtil;
class SvcFileManager
{
string webDirectoryPath;
Dictionary svcFiles;
public SvcFileManager(string webDirectoryPath)
{
this.webDirectoryPath = webDirectoryPath;
this.svcFiles = new Dictionary();
string[] fileNames = Directory.GetFiles(webDirectoryPath, "*.svc");
foreach (string fileName in fileNames)
{
SvcFile svcFile = SvcFile.OpenExisting(fileName);
if (svcFile != null)
{
this.svcFiles.Add(svcFile.Clsid, svcFile);
}
}
}
public void Abort()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Abort();
}
}
public void Add(Guid appid, Guid clsid)
{
SvcFile svcFile = null;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
// we found an existing SVC file, all is good
// We should never be adding and deleting SVC files at the same time..
Debug.Assert(svcFile.State != SvcFileState.Deleted, "svcFile.State != SvcFileState.Deleted");
}
else
{
svcFile = SvcFile.CreateNew(this.webDirectoryPath, appid, clsid);
this.svcFiles.Add(clsid, svcFile);
}
}
public bool Remove(Guid appid, Guid clsid)
{
SvcFile svcFile = null;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
// we found an existing SVC file
// We should never be adding and deleting SVC files at the same time..
Debug.Assert(svcFile.State != SvcFileState.Added, "svcFile.State != SvcFileState.Added");
if (svcFile.State == SvcFileState.Deleted)
{
// already marked for deletion
return true;
}
else
{
Debug.Assert(svcFile.State == SvcFileState.Existing, "svcFile.State == SvcFileState.Existing");
svcFile.Delete();
return true;
}
}
else
{
// didn't find any SVC file to remove
return false;
}
}
public void Prepare()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Prepare();
}
}
public void Commit()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Commit();
}
}
public bool ResolveClsid(Guid clsid, out Guid appid)
{
SvcFile svcFile;
appid = Guid.Empty;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
if (svcFile.State == SvcFileState.Deleted)
{
return false; // we cant resolve because we think its deleted
}
else
{
appid = svcFile.Appid;
return true;
}
}
else
{
return false; // Clsid not found
}
}
enum SvcFileState
{
Existing,
Added,
Deleted
}
class SvcFile
{
Guid appid;
Guid clsid;
SvcFileState state;
AtomicFile svcFile;
const string factoryAttributeName = "Factory";
const string serviceAttributeName = "Service";
SvcFile(Guid appid, Guid clsid, SvcFileState state, AtomicFile svcFile)
{
this.appid = appid;
this.clsid = clsid;
this.state = state;
this.svcFile = svcFile;
}
public static SvcFile CreateNew(string webDirectoryPath, Guid appid, Guid clsid)
{
ComAdminAppInfo adminAppInfo = ComAdminWrapper.GetAppInfo(appid.ToString("B"));
if (null == adminAppInfo)
{
throw Tool.CreateException(SR.GetString(SR.CannotFindAppInfo, appid.ToString("B")), null);
}
ComAdminClassInfo adminClassInfo = adminAppInfo.FindClass(clsid.ToString("B"));
if (null == adminClassInfo)
{
throw Tool.CreateException(SR.GetString(SR.CannotFindClassInfo, clsid.ToString("B")), null);
}
string fileName = webDirectoryPath + "\\" + adminClassInfo.Name;
if (File.Exists(fileName + ".svc"))
{
int count = 1;
while (File.Exists(fileName + "." + count.ToString(CultureInfo.InvariantCulture) + ".svc"))
{
count++;
}
fileName = fileName + "." + count.ToString(CultureInfo.InvariantCulture);
}
fileName = fileName + ".svc";
string comPlusString = clsid.ToString("B") + "," + appid.ToString("B");
using (StreamWriter sw = File.CreateText(fileName))
{
sw.WriteLine("<%@ServiceHost {0}=\"{1}\" {2}=\"{3}\" %>",
factoryAttributeName,
typeof(WasHostedComPlusFactory).FullName,
serviceAttributeName,
comPlusString);
}
return new SvcFile(appid, clsid, SvcFileState.Added, new AtomicFile(fileName));
}
// this function wraps the call to the internal method in ServiceModel assembly.
static IDictionary ParseServiceDirective(string serviceText)
{
IDictionary dictionary = null;
try
{
Type serviceParser = typeof(ServiceHostFactory).Assembly.GetType("System.ServiceModel.Activation.ServiceParser");
dictionary = (IDictionary) serviceParser.InvokeMember("ParseServiceDirective", BindingFlags.InvokeMethod | BindingFlags.Static | BindingFlags.NonPublic,
null, null, new object[1] { serviceText }, CultureInfo.InvariantCulture);
}
catch (TargetInvocationException e)
{
throw e.InnerException;
}
return dictionary;
}
public static SvcFile OpenExisting(string fileName)
{
if (!File.Exists(fileName))
{
return null;
}
string svcFileContents = null;
Guid appid;
Guid clsid;
using (StreamReader sr = File.OpenText(fileName))
{
svcFileContents = sr.ReadToEnd();
}
IDictionary dictionary = null;
try
{
dictionary = ParseServiceDirective(svcFileContents);
}
catch (Exception e)
{
if (e is NullReferenceException || e is SEHException)
{
throw e;
}
ToolConsole.WriteWarning (SR.GetString (SR.SvcFileParsingFailedWithError, fileName, e.Message));
return null;
}
if (dictionary == null)
{
return null;
}
if (!dictionary.ContainsKey(factoryAttributeName) ||
!dictionary.ContainsKey(serviceAttributeName))
{
return null;
}
string typeName = dictionary[factoryAttributeName];
Type factoryType = typeof(WasHostedComPlusFactory);
Type compiledType = factoryType.Assembly.GetType(dictionary[factoryAttributeName], false);
if (compiledType != factoryType)
{
return null;
}
string comPlusText = dictionary[serviceAttributeName];
string[] parameters = comPlusText.Split(',');
if (parameters.Length != 2)
{
ToolConsole.WriteWarning (SR.GetString (SR.BadlyFormattedSvcFile, fileName));
return null;
}
try
{
clsid = new Guid(parameters[0]);
appid = new Guid(parameters[1]);
}
catch (FormatException)
{
ToolConsole.WriteWarning (SR.GetString (SR.BadlyFormattedAppIDOrClsidInSvcFile, fileName));
return null;
}
return new SvcFile(appid, clsid, SvcFileState.Existing, new AtomicFile(fileName));
}
public Guid Appid
{
get { return this.appid; }
}
public Guid Clsid
{
get { return this.clsid; }
}
public SvcFileState State
{
get { return this.state; }
}
public void Abort()
{
this.svcFile.Abort();
}
public void Commit()
{
this.svcFile.Commit();
}
public void Delete()
{
Debug.Assert(this.state == SvcFileState.Existing, "this.state == SvcFileState.Existing");
this.svcFile.Delete();
this.state = SvcFileState.Deleted;
}
public void Prepare()
{
this.svcFile.Prepare();
}
}
}
}
// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
//------------------------------------------------------------------------------
// Copyright (c) Microsoft Corporation. All rights reserved.
//-----------------------------------------------------------------------------
namespace Microsoft.Tools.ServiceModel.ComSvcConfig
{
using System;
using System.ServiceModel.Channels;
using System.Diagnostics;
using System.Configuration;
using System.Globalization;
using System.Collections;
using System.Collections.Specialized;
using System.Collections.Generic;
using System.IO;
using System.Reflection;
using System.Text;
using System.Threading;
using System.Runtime.InteropServices;
using System.Security;
using System.ServiceModel;
using System.ServiceModel.Activation;
using System.ServiceModel.Configuration;
using System.ServiceModel.ComIntegration;
using Microsoft.Tools.ServiceModel;
using Microsoft.Tools.ServiceModel.SvcUtil;
class SvcFileManager
{
string webDirectoryPath;
Dictionary svcFiles;
public SvcFileManager(string webDirectoryPath)
{
this.webDirectoryPath = webDirectoryPath;
this.svcFiles = new Dictionary();
string[] fileNames = Directory.GetFiles(webDirectoryPath, "*.svc");
foreach (string fileName in fileNames)
{
SvcFile svcFile = SvcFile.OpenExisting(fileName);
if (svcFile != null)
{
this.svcFiles.Add(svcFile.Clsid, svcFile);
}
}
}
public void Abort()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Abort();
}
}
public void Add(Guid appid, Guid clsid)
{
SvcFile svcFile = null;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
// we found an existing SVC file, all is good
// We should never be adding and deleting SVC files at the same time..
Debug.Assert(svcFile.State != SvcFileState.Deleted, "svcFile.State != SvcFileState.Deleted");
}
else
{
svcFile = SvcFile.CreateNew(this.webDirectoryPath, appid, clsid);
this.svcFiles.Add(clsid, svcFile);
}
}
public bool Remove(Guid appid, Guid clsid)
{
SvcFile svcFile = null;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
// we found an existing SVC file
// We should never be adding and deleting SVC files at the same time..
Debug.Assert(svcFile.State != SvcFileState.Added, "svcFile.State != SvcFileState.Added");
if (svcFile.State == SvcFileState.Deleted)
{
// already marked for deletion
return true;
}
else
{
Debug.Assert(svcFile.State == SvcFileState.Existing, "svcFile.State == SvcFileState.Existing");
svcFile.Delete();
return true;
}
}
else
{
// didn't find any SVC file to remove
return false;
}
}
public void Prepare()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Prepare();
}
}
public void Commit()
{
foreach (SvcFile file in svcFiles.Values)
{
file.Commit();
}
}
public bool ResolveClsid(Guid clsid, out Guid appid)
{
SvcFile svcFile;
appid = Guid.Empty;
if (this.svcFiles.TryGetValue(clsid, out svcFile))
{
if (svcFile.State == SvcFileState.Deleted)
{
return false; // we cant resolve because we think its deleted
}
else
{
appid = svcFile.Appid;
return true;
}
}
else
{
return false; // Clsid not found
}
}
enum SvcFileState
{
Existing,
Added,
Deleted
}
class SvcFile
{
Guid appid;
Guid clsid;
SvcFileState state;
AtomicFile svcFile;
const string factoryAttributeName = "Factory";
const string serviceAttributeName = "Service";
SvcFile(Guid appid, Guid clsid, SvcFileState state, AtomicFile svcFile)
{
this.appid = appid;
this.clsid = clsid;
this.state = state;
this.svcFile = svcFile;
}
public static SvcFile CreateNew(string webDirectoryPath, Guid appid, Guid clsid)
{
ComAdminAppInfo adminAppInfo = ComAdminWrapper.GetAppInfo(appid.ToString("B"));
if (null == adminAppInfo)
{
throw Tool.CreateException(SR.GetString(SR.CannotFindAppInfo, appid.ToString("B")), null);
}
ComAdminClassInfo adminClassInfo = adminAppInfo.FindClass(clsid.ToString("B"));
if (null == adminClassInfo)
{
throw Tool.CreateException(SR.GetString(SR.CannotFindClassInfo, clsid.ToString("B")), null);
}
string fileName = webDirectoryPath + "\\" + adminClassInfo.Name;
if (File.Exists(fileName + ".svc"))
{
int count = 1;
while (File.Exists(fileName + "." + count.ToString(CultureInfo.InvariantCulture) + ".svc"))
{
count++;
}
fileName = fileName + "." + count.ToString(CultureInfo.InvariantCulture);
}
fileName = fileName + ".svc";
string comPlusString = clsid.ToString("B") + "," + appid.ToString("B");
using (StreamWriter sw = File.CreateText(fileName))
{
sw.WriteLine("<%@ServiceHost {0}=\"{1}\" {2}=\"{3}\" %>",
factoryAttributeName,
typeof(WasHostedComPlusFactory).FullName,
serviceAttributeName,
comPlusString);
}
return new SvcFile(appid, clsid, SvcFileState.Added, new AtomicFile(fileName));
}
// this function wraps the call to the internal method in ServiceModel assembly.
static IDictionary ParseServiceDirective(string serviceText)
{
IDictionary dictionary = null;
try
{
Type serviceParser = typeof(ServiceHostFactory).Assembly.GetType("System.ServiceModel.Activation.ServiceParser");
dictionary = (IDictionary) serviceParser.InvokeMember("ParseServiceDirective", BindingFlags.InvokeMethod | BindingFlags.Static | BindingFlags.NonPublic,
null, null, new object[1] { serviceText }, CultureInfo.InvariantCulture);
}
catch (TargetInvocationException e)
{
throw e.InnerException;
}
return dictionary;
}
public static SvcFile OpenExisting(string fileName)
{
if (!File.Exists(fileName))
{
return null;
}
string svcFileContents = null;
Guid appid;
Guid clsid;
using (StreamReader sr = File.OpenText(fileName))
{
svcFileContents = sr.ReadToEnd();
}
IDictionary dictionary = null;
try
{
dictionary = ParseServiceDirective(svcFileContents);
}
catch (Exception e)
{
if (e is NullReferenceException || e is SEHException)
{
throw e;
}
ToolConsole.WriteWarning (SR.GetString (SR.SvcFileParsingFailedWithError, fileName, e.Message));
return null;
}
if (dictionary == null)
{
return null;
}
if (!dictionary.ContainsKey(factoryAttributeName) ||
!dictionary.ContainsKey(serviceAttributeName))
{
return null;
}
string typeName = dictionary[factoryAttributeName];
Type factoryType = typeof(WasHostedComPlusFactory);
Type compiledType = factoryType.Assembly.GetType(dictionary[factoryAttributeName], false);
if (compiledType != factoryType)
{
return null;
}
string comPlusText = dictionary[serviceAttributeName];
string[] parameters = comPlusText.Split(',');
if (parameters.Length != 2)
{
ToolConsole.WriteWarning (SR.GetString (SR.BadlyFormattedSvcFile, fileName));
return null;
}
try
{
clsid = new Guid(parameters[0]);
appid = new Guid(parameters[1]);
}
catch (FormatException)
{
ToolConsole.WriteWarning (SR.GetString (SR.BadlyFormattedAppIDOrClsidInSvcFile, fileName));
return null;
}
return new SvcFile(appid, clsid, SvcFileState.Existing, new AtomicFile(fileName));
}
public Guid Appid
{
get { return this.appid; }
}
public Guid Clsid
{
get { return this.clsid; }
}
public SvcFileState State
{
get { return this.state; }
}
public void Abort()
{
this.svcFile.Abort();
}
public void Commit()
{
this.svcFile.Commit();
}
public void Delete()
{
Debug.Assert(this.state == SvcFileState.Existing, "this.state == SvcFileState.Existing");
this.svcFile.Delete();
this.state = SvcFileState.Deleted;
}
public void Prepare()
{
this.svcFile.Prepare();
}
}
}
}
// 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
- StoragePropertyMapping.cs
- Tile.cs
- ServiceParser.cs
- ReadOnlyDataSourceView.cs
- CatalogPartChrome.cs
- WebPartConnectionsCloseVerb.cs
- VBCodeProvider.cs
- AtomMaterializer.cs
- FixedSOMTableRow.cs
- DbMetaDataFactory.cs
- CodeDomSerializer.cs
- RowType.cs
- HtmlTernaryTree.cs
- CodeDomConfigurationHandler.cs
- XmlUTF8TextWriter.cs
- XamlFilter.cs
- StrokeCollection2.cs
- ZipQueryOperator.cs
- TraceUtility.cs
- SqlBulkCopy.cs
- Container.cs
- InternalEnumValidatorAttribute.cs
- PartialClassGenerationTask.cs
- Config.cs
- ButtonAutomationPeer.cs
- FixedSOMPageConstructor.cs
- FixedTextBuilder.cs
- HandleRef.cs
- CommentEmitter.cs
- ToolBarButton.cs
- QilDataSource.cs
- ContractListAdapter.cs
- PartBasedPackageProperties.cs
- DataFormats.cs
- QueryIntervalOp.cs
- ISAPIWorkerRequest.cs
- NotImplementedException.cs
- ServiceChannelManager.cs
- EventsTab.cs
- StringComparer.cs
- ToolBarButtonClickEvent.cs
- WMIInterop.cs
- EventItfInfo.cs
- HttpAsyncResult.cs
- XmlSchemaSet.cs
- XmlDownloadManager.cs
- AsyncPostBackErrorEventArgs.cs
- SamlAuthorizationDecisionStatement.cs
- UpWmlMobileTextWriter.cs
- DocumentApplication.cs
- AbsoluteQuery.cs
- PageContentAsyncResult.cs
- SqlNode.cs
- VectorCollectionValueSerializer.cs
- OracleCommandBuilder.cs
- WithStatement.cs
- ExtendedPropertiesHandler.cs
- PropertyGeneratedEventArgs.cs
- SimpleMailWebEventProvider.cs
- ClientSession.cs
- CollectionChangeEventArgs.cs
- InfoCardRSAOAEPKeyExchangeDeformatter.cs
- UserPreferenceChangingEventArgs.cs
- PreviewPrintController.cs
- SqlProvider.cs
- TdsParserHelperClasses.cs
- DesignTimeTemplateParser.cs
- TextRunProperties.cs
- Token.cs
- Transform3DCollection.cs
- PropertyDescriptorGridEntry.cs
- TheQuery.cs
- RightNameExpirationInfoPair.cs
- CustomWebEventKey.cs
- StringFunctions.cs
- TerminatorSinks.cs
- RegistryPermission.cs
- WarningException.cs
- TwoPhaseCommitProxy.cs
- IconBitmapDecoder.cs
- XmlSchemaInfo.cs
- PopOutPanel.cs
- ApplicationId.cs
- WindowsGraphicsWrapper.cs
- ToggleProviderWrapper.cs
- XmlIlVisitor.cs
- Quaternion.cs
- HttpCacheVary.cs
- XmlDomTextWriter.cs
- StrongNameKeyPair.cs
- TreeViewBindingsEditorForm.cs
- OleDbEnumerator.cs
- GeometryCombineModeValidation.cs
- TargetFrameworkUtil.cs
- DetailsViewInsertEventArgs.cs
- Sentence.cs
- PackageFilter.cs
- PolyLineSegment.cs
- SecUtil.cs
- PeerTransportListenAddressValidatorAttribute.cs