Code:
/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / TransactionBridge / Microsoft / Transactions / Wsat / Messaging / SupportingTokenSecurityTokenResolver.cs / 1 / SupportingTokenSecurityTokenResolver.cs
//------------------------------------------------------------------------------ // Copyright (c) Microsoft Corporation. All rights reserved. //----------------------------------------------------------------------------- // Defines an implementation of SecurityTokenResolver that provides per-message resolution // of SCTs for incoming supporting tokens using System; using System.Collections.ObjectModel; using System.Diagnostics; using System.IdentityModel.Selectors; using System.IdentityModel.Tokens; using System.ServiceModel; using System.ServiceModel.Channels; using System.ServiceModel.Security.Tokens; using System.ServiceModel.Transactions; using System.Xml; namespace Microsoft.Transactions.Wsat.Messaging { class SupportingTokenSecurityTokenResolver : SecurityTokenResolver, ISecurityContextSecurityTokenCache { // Note - this works because we understand our fixed binding set and we know we // won't switch threads between the following two steps in receiving a message: // - Our SupportingTokenXXXChannel element being called // - The SecurityChannel calling ISecurityContextSecurityTokenCache.GetContext [ThreadStatic] static SecurityContextSecurityToken currentSct; public bool FaultInSupportingToken(Message message) { DebugTrace.TraceEnter(this, "FaultInSupportingToken"); bool found = false; WsatRegistrationHeader header = ReadRegistrationHeader(message); if (header == null || header.TransactionId == Guid.Empty || string.IsNullOrEmpty(header.TokenId)) { if (DebugTrace.Warning) DebugTrace.Trace(TraceLevel.Warning, "Invalid or absent RegisterInfo in register message"); } else { currentSct = DeriveToken(header.TransactionId, header.TokenId); found = true; if (DebugTrace.Verbose) DebugTrace.Trace(TraceLevel.Verbose, "Created SCT with id {0} for transaction {1}", header.TokenId, header.TransactionId); } DebugTrace.TraceLeave(this, "FaultInSupportingToken"); return found; } WsatRegistrationHeader ReadRegistrationHeader(Message message) { WsatRegistrationHeader header = null; try { header = WsatRegistrationHeader.ReadFrom(message); } catch (InvalidEnlistmentHeaderException e) { DiagnosticUtility.ExceptionUtility.TraceHandledException(e, TraceEventType.Error); if (DebugTrace.Error) DebugTrace.Trace(TraceLevel.Error, "Invalid RegisterInfo header found in register message: {0}", e.Message); } return header; } SecurityContextSecurityToken DeriveToken(Guid transactionId, string tokenId) { byte[] derivedKey = CoordinationServiceSecurity.DeriveIssuedTokenKey(transactionId, tokenId); DateTime now = DateTime.UtcNow; return new SecurityContextSecurityToken(new UniqueId(tokenId), derivedKey, now, now + TimeSpan.FromMinutes(5)); } // // SecurityTokenResolver overrides // protected override bool TryResolveTokenCore(SecurityKeyIdentifier keyIdentifier, out SecurityToken token) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } protected override bool TryResolveTokenCore(SecurityKeyIdentifierClause keyIdentifierClause, out SecurityToken token) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } protected override bool TryResolveSecurityKeyCore(SecurityKeyIdentifierClause keyIdentifierClause, out SecurityKey key) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } // // ISecurityContextSecurityTokenCache implementation public void AddContext(SecurityContextSecurityToken token) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public void ClearContexts() { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public CollectionGetAllContexts(UniqueId contextId) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public SecurityContextSecurityToken GetContext(UniqueId contextId, UniqueId generation) { DebugTrace.TraceEnter(this, "GetContext"); SecurityContextSecurityToken sct = null; if (currentSct != null && currentSct.ContextId == contextId && currentSct.KeyGeneration == generation) { if (DebugTrace.Verbose) DebugTrace.Trace(TraceLevel.Verbose, "Found SCT with matching id {0}", contextId); sct = currentSct; currentSct = null; } DebugTrace.TraceLeave(this, "GetContext"); return sct; } public void RemoveAllContexts(UniqueId contextId) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public void RemoveContext(UniqueId contextId, UniqueId generation) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public bool TryAddContext(SecurityContextSecurityToken token) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } public void UpdateContextCachingTime(SecurityContextSecurityToken context, DateTime expirationTime) { throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotImplementedException()); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // Copyright (c) Microsoft Corporation. All rights reserved.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- SHA512.cs
- CatalogPartCollection.cs
- JournalEntryListConverter.cs
- CmsInterop.cs
- Condition.cs
- CustomTrackingRecord.cs
- Int64Storage.cs
- DiscoveryClient.cs
- PrivilegeNotHeldException.cs
- Semaphore.cs
- BitStream.cs
- AmbientProperties.cs
- TextEmbeddedObject.cs
- EditorZone.cs
- Triplet.cs
- ExtensibleSyndicationObject.cs
- SqlBulkCopyColumnMappingCollection.cs
- Soap.cs
- IISUnsafeMethods.cs
- MethodToken.cs
- ProtocolsConfigurationHandler.cs
- Composition.cs
- SharingService.cs
- ColumnProvider.cs
- OciHandle.cs
- HTTPNotFoundHandler.cs
- PropertyItem.cs
- HttpCapabilitiesBase.cs
- ProtocolsConfigurationEntry.cs
- PreloadedPackages.cs
- ColumnResizeUndoUnit.cs
- Hash.cs
- DefaultValueAttribute.cs
- HtmlInputHidden.cs
- CodeBlockBuilder.cs
- UniqueID.cs
- EffectiveValueEntry.cs
- FormView.cs
- PlatformNotSupportedException.cs
- DataGridAddNewRow.cs
- ReachFixedDocumentSerializerAsync.cs
- VerticalAlignConverter.cs
- PlatformNotSupportedException.cs
- PropertyDescriptorComparer.cs
- BitmapCacheBrush.cs
- ConstraintManager.cs
- DictionaryKeyPropertyAttribute.cs
- WSDualHttpSecurityElement.cs
- XmlDataSourceView.cs
- ObjectItemCachedAssemblyLoader.cs
- XPathNodeInfoAtom.cs
- DataGridItemAttachedStorage.cs
- prompt.cs
- Vector3dCollection.cs
- ResXResourceSet.cs
- ExpressionSelection.cs
- RegexCharClass.cs
- BevelBitmapEffect.cs
- SecurityTokenResolver.cs
- SemanticResultKey.cs
- ReaderWriterLockSlim.cs
- thaishape.cs
- MimeTypePropertyAttribute.cs
- SqlTriggerContext.cs
- ServiceParser.cs
- TableLayoutStyle.cs
- TableLayoutPanel.cs
- SelectorAutomationPeer.cs
- ObjectQueryProvider.cs
- MobilePage.cs
- GeneralTransform3DGroup.cs
- RelationshipConstraintValidator.cs
- Rect.cs
- QilReference.cs
- XmlSchemaDatatype.cs
- WindowsAuthenticationEventArgs.cs
- DataGridViewBindingCompleteEventArgs.cs
- DynamicFilter.cs
- MenuItemCollectionEditor.cs
- ISAPIWorkerRequest.cs
- ControlPaint.cs
- ActiveXHost.cs
- EncryptedPackageFilter.cs
- WorkflowMarkupSerializationProvider.cs
- QuaternionRotation3D.cs
- Matrix3DConverter.cs
- ObjectReferenceStack.cs
- AllMembershipCondition.cs
- GlyphInfoList.cs
- DecimalStorage.cs
- DataListItem.cs
- DeviceSpecificDesigner.cs
- ReadonlyMessageFilter.cs
- Pts.cs
- SystemInfo.cs
- FormClosedEvent.cs
- DispatchChannelSink.cs
- UpDownBaseDesigner.cs
- BStrWrapper.cs
- MediaScriptCommandRoutedEventArgs.cs