Add authentication parameters

Author: twsouthwick

doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml

@@ -12,5 +12,8 @@
           <param name="input">Received buffer, if any.</param>
           <returns>A memory owned type with the response of the client.</returns>
         </GenerateSspiClientContext>
+        <AuthenticationParameters>
+          <summary>Gets the authentication parameters for the SSPI context.</summary>
+        </AuthenticationParameters>
     </members>
 </docs>

src/Microsoft.Data.SqlClient/netcore/ref/Microsoft.Data.SqlClient.cs

@@ -957,6 +957,9 @@ public abstract class SSPIContextProvider
         /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/ServerNames/*' />
         public System.Collections.Generic.IReadOnlyList<string> ServerNames { get { throw null; } }
 
+        /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/AuthenticationParameters/*' />
+        public SqlAuthenticationParameters AuthenticationParameters { get { throw null; } }
+
         /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/GenerateSspiClientContext/*' />
         protected abstract System.Buffers.IMemoryOwner<byte> GenerateSspiClientContext(System.ReadOnlyMemory<byte> input);
     }

src/Microsoft.Data.SqlClient/netcore/src/Microsoft/Data/SqlClient/TdsParser.cs

@@ -468,7 +468,7 @@ internal void Connect(
                 hostNameInCertificate,
                 serverCertificateFilename);
 
-            _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, _sniSpn);
+            _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, _sniSpn, _connHandler);
 
             if (TdsEnums.SNI_SUCCESS != _physicalStateObj.Status)
             {
@@ -574,7 +574,7 @@ internal void Connect(
                     ThrowExceptionAndWarning(_physicalStateObj);
                 }
 
-                _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, _sniSpn);
+                _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, _sniSpn, _connHandler);
 
                 uint retCode = _physicalStateObj.SniGetConnectionId(ref _connHandler._clientConnectionId);
 

src/Microsoft.Data.SqlClient/netfx/ref/Microsoft.Data.SqlClient.cs

@@ -897,6 +897,9 @@ public abstract class SSPIContextProvider
         /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/ServerNames/*' />
         public System.Collections.Generic.IReadOnlyList<string> ServerNames { get { throw null; } }
 
+        /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/AuthenticationParameters/*' />
+        public SqlAuthenticationParameters AuthenticationParameters { get { throw null; } }
+
         /// <include file='../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/GenerateSspiClientContext/*' />
         protected abstract System.Buffers.IMemoryOwner<byte> GenerateSspiClientContext(System.ReadOnlyMemory<byte> input);
     }

src/Microsoft.Data.SqlClient/netfx/src/Microsoft/Data/SqlClient/TdsParser.cs

@@ -649,7 +649,7 @@ internal void Connect(ServerInfo serverInfo,
                 FQDNforDNSCache,
                 hostNameInCertificate);
 
-            _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, new[] { _sniSpn });
+            _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, new[] { _sniSpn }, _connHandler);
 
             if (TdsEnums.SNI_SUCCESS != _physicalStateObj.Status)
             {
@@ -756,8 +756,6 @@ internal void Connect(ServerInfo serverInfo,
                     serverInfo.ResolvedServerName,
                     hostNameInCertificate);
 
-                _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, new[] { _sniSpn });
-
                 if (TdsEnums.SNI_SUCCESS != _physicalStateObj.Status)
                 {
                     _physicalStateObj.AddError(ProcessSNIError(_physicalStateObj));
@@ -766,7 +764,7 @@ internal void Connect(ServerInfo serverInfo,
                     ThrowExceptionAndWarning(_physicalStateObj);
                 }
 
-                _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, new[] { _sniSpn });
+                _authenticationProvider?.Initialize(serverInfo, _physicalStateObj, this, new[] { _sniSpn }, _connHandler);
 
                 UInt32 retCode = SNINativeMethodWrapper.SniGetConnectionId(_physicalStateObj.Handle, ref _connHandler._clientConnectionId);
                 Debug.Assert(retCode == TdsEnums.SNI_SUCCESS, "Unexpected failure state upon calling SniGetConnectionId");

src/Microsoft.Data.SqlClient/src/Microsoft/Data/SqlClient/SSPI/SSPIContextProvider.cs

@@ -16,22 +16,43 @@ public abstract class SSPIContextProvider
         private protected TdsParserStateObject _physicalStateObj = null!;
         private string[] _serverNames = Array.Empty<string>();
 
-        internal void Initialize(ServerInfo serverInfo, TdsParserStateObject physicalStateObj, TdsParser parser, string[] serverNames)
+        internal void Initialize(ServerInfo serverInfo, TdsParserStateObject physicalStateObj, TdsParser parser, string[] serverNames, SqlInternalConnectionTds connection)
         {
             _parser = parser;
             _physicalStateObj = physicalStateObj;
             _serverInfo = serverInfo;
             _serverNames = serverNames;
+            AuthenticationParameters = InitializeAuthenticationParameters(connection);
 
             Debug.Assert(_serverNames.Length > 0);
 
             Initialize();
         }
 
+        private SqlAuthenticationParameters InitializeAuthenticationParameters(SqlInternalConnectionTds connection)
+        {
+            var auth = new SqlAuthenticationParameters.Builder(connection.ConnectionOptions.Authentication, "resource", "auth", connection.ConnectionOptions.ObtainWorkstationId(), connection.ConnectionOptions.InitialCatalog);
+
+            if (connection.ConnectionOptions.UserID is { } userId)
+            {
+                auth.WithUserId(userId);
+            }
+
+            if (connection.ConnectionOptions.Password is { } password)
+            {
+                auth.WithPassword(password);
+            }
+
+            return auth;
+        }
+
         private protected virtual void Initialize()
         {
         }
 
+        /// <include file='../../../../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/AuthenticationParameters/*' />
+        public SqlAuthenticationParameters AuthenticationParameters { get; private set; } = null!;
+
         /// <include file='../../../../../../../doc/snippets/Microsoft.Data.SqlClient/SSPIContextProvider.xml' path='docs/members[@name="SSPIContextProvider"]/ServerNames/*' />
         public IReadOnlyList<string> ServerNames => _serverNames;