sqltoolsservice/test/Microsoft.SqlTools.Migration.IntegrationTests/Utility/LiveConnectionHelper.cs

//
// Copyright (c) Microsoft. All rights reserved.
// Licensed under the MIT license. See LICENSE file in the project root for full license information.
//

#nullable disable

using System;
using Microsoft.Data.SqlClient;
using System.IO;
using System.Reflection;
using System.Threading.Tasks;
using Microsoft.SqlServer.Management.Common;
using Microsoft.SqlTools.ServiceLayer.Connection;
using Microsoft.SqlTools.ServiceLayer.Connection.Contracts;
using Microsoft.SqlTools.ServiceLayer.Test.Common;
using Microsoft.SqlTools.ServiceLayer.Workspace.Contracts;
using NUnit.Framework;
using System.Threading;

namespace Microsoft.SqlTools.Migration.IntegrationTests.Utility
{
    public class LiveConnectionException : Exception
    {
        public LiveConnectionException(string message)
            : base(message) { }
    }

    public class LiveConnectionHelper
    {
        public static string GetTestSqlFile(string fileName = null)
        {
            string filePath = null;
            if (string.IsNullOrEmpty(fileName))
            {
                filePath = Path.Combine(Path.GetDirectoryName(Assembly.GetEntryAssembly().Location), "sqltest.sql");
            }
            else
            {
                filePath = Path.Combine(Path.GetDirectoryName(Assembly.GetEntryAssembly().Location), fileName + ".sql");
            }

            if (File.Exists(filePath))
            {
                File.Delete(filePath);
            }
            File.WriteAllText(filePath, "SELECT * FROM sys.objects\n");
            return filePath;
        }

        public static TestConnectionResult InitLiveConnectionInfo(string databaseName = null, string ownerUri = null)
            => InitLiveConnectionInfoAsync(databaseName, ownerUri, ServiceLayer.Connection.ConnectionType.Default).ConfigureAwait(false).GetAwaiter().GetResult();

        public static async Task<TestConnectionResult> InitLiveConnectionInfoAsync(string databaseName = "master", string ownerUri = null,
            string connectionType = ServiceLayer.Connection.ConnectionType.Default, TestServerType serverType = TestServerType.OnPrem)
        {
            ScriptFile scriptFile = null;
            if (string.IsNullOrEmpty(ownerUri))
            {
                ownerUri = GetTestSqlFile();
                scriptFile = TestServiceProvider.Instance.WorkspaceService.Workspace.GetFile(ownerUri);
                ownerUri = scriptFile.ClientUri;
            }
            if (string.IsNullOrEmpty(databaseName))
            {
                databaseName = "master";
            }
            ConnectParams connectParams = TestServiceProvider.Instance.ConnectionProfileService.GetConnectionParameters(serverType, databaseName);

            // try to connect up to 3 times, sleeping in between retries
            const int RetryCount = 3;
            const int RetryDelayMs = 15000;
            for (int attempt = 0; attempt < RetryCount; ++attempt)
            {
                var connectionService = GetLiveTestConnectionService();
                var connectionResult =
                    await connectionService.Connect(new ConnectParams
                    {
                        OwnerUri = ownerUri,
                        Connection = connectParams.Connection,
                        Type = connectionType
                    });
                if (!string.IsNullOrEmpty(connectionResult.ErrorMessage))
                {
                    Console.WriteLine(connectionResult.ErrorMessage);
                }

                ConnectionInfo connInfo;
                connectionService.TryFindConnection(ownerUri, out connInfo);

                // if the connection wasn't successful then cleanup and try again (up to max retry count)
                if (connInfo == null)
                {
                    connectionService.Disconnect(new DisconnectParams()
                    {
                        OwnerUri = ownerUri
                    });
                    // don't sleep on the final iterations since we won't try again
                    if (attempt < RetryCount - 1)
                    {
                        Thread.Sleep(RetryDelayMs);
                    }
                }
                else
                {
                    return new TestConnectionResult() { ConnectionInfo = connInfo, ScriptFile = scriptFile };
                }
            }

            throw new LiveConnectionException(string.Format("Could not establish a connection to {0}:{1}",
                connectParams.Connection.ServerName, connectParams.Connection.DatabaseName));
        }

        public static ConnectionInfo InitLiveConnectionInfoForDefinition(string databaseName = null)
        {
            using (SelfCleaningTempFile queryTempFile = new SelfCleaningTempFile())
            {
                ConnectParams connectParams = TestServiceProvider.Instance.ConnectionProfileService.GetConnectionParameters(TestServerType.OnPrem, databaseName);
                string ownerUri = queryTempFile.FilePath;

                InitLiveConnectionInfo(databaseName, ownerUri);

                var connectionService = GetLiveTestConnectionService();
                ConnectionInfo connInfo;
                connectionService.TryFindConnection(ownerUri, out connInfo);

                Assert.NotNull(connInfo);
                return connInfo;
            }
        }

        public static ServerConnection InitLiveServerConnectionForDefinition(ConnectionInfo connInfo)
        {
            SqlConnection sqlConn = new SqlConnection(ConnectionService.BuildConnectionString(connInfo.ConnectionDetails));
            return new ServerConnection(sqlConn);
        }

        /// <summary>
        /// Creates a test sql connection factory instance
        /// </summary>
        public static ISqlConnectionFactory GetLiveTestSqlConnectionFactory()
        {
            // connect to a real server instance
            return ConnectionService.Instance.ConnectionFactory;
        }

        public static ConnectionService GetLiveTestConnectionService()
        {
            // connect to a real server instance
            return ConnectionService.Instance;
        }

        public class TestConnectionResult
        {
            public ConnectionInfo ConnectionInfo { get; set; }

            public ScriptFile ScriptFile { get; set; }

            public TextDocumentPosition TextDocumentPosition { get; set; }
        }
    }
}