Use 'ScaleUnitPipeline' user for the interAOS app (#154)

* Use 'ScaleUnitPipeline' user for the interAOS app

Inserting the interAOS appId into SYSAADCLIENTTABLE will use the user 'ScaleUnitPipeline' if it exists, otherwise 'Admin'

* Remove unnecessary field

Author: Antonstockmarr

src/ScaleUnitManagement/DatabaseManager/AxDbManager.cs

@@ -0,0 +1,15 @@
+using ScaleUnitManagement.Utilities;
+
+namespace ScaleUnitManagement.DatabaseManager
+{
+    public class AxDbManager
+    {
+        public static bool UserExists(string userName)
+        {
+            string query = $"select count(name) from USERINFO where name = '{userName}'";
+
+            var sqlQueryExecutor = new SqlQueryExecutor();
+            return sqlQueryExecutor.ExecuteBooleanQuery(query);
+        }
+    }
+}

src/ScaleUnitManagement/ScaleUnitFeatureManager/Hub/AddToolToHubSysAADClientTable.cs

@@ -19,20 +19,25 @@ public float Priority()
 
         public Task Run()
         {
-            const string UserName = "ScaleUnitManagement";
             string hubDb = Config.HubScaleUnit().AxDbName;
             var allowListing = new AADAppAllowListing();
 
             try
             {
-                string interAOSAppId = Config.InterAOSAppId();
+                string interAOSUserName =
+                    AxDbManager.UserExists("ScaleUnitPipeline")
+                    ? "ScaleUnitPipeline"
+                    : "Admin";
+
                 const string InterAOSAppName = "ScaleUnits";
-                allowListing.UpdateAADAppClientTable(hubDb, UserName, InterAOSAppName, interAOSAppId);
+                string interAOSAppId = Config.InterAOSAppId();
+                allowListing.UpdateAADAppClientTable(hubDb, interAOSUserName, InterAOSAppName, interAOSAppId);
 
+                const string ScaleUnitUserName = "ScaleUnitManagement";
                 const string ScaleUnitAppName = "Scale Unit Management Tool";
                 ScaleUnitInstance scaleUnit = Config.FindScaleUnitWithId(ScaleUnitContext.GetScaleUnitId());
                 string scaleUnitAppId = scaleUnit.AuthConfiguration.AppId;
-                allowListing.UpdateAADAppClientTable(hubDb, UserName, ScaleUnitAppName, scaleUnitAppId);
+                allowListing.UpdateAADAppClientTable(hubDb, ScaleUnitUserName, ScaleUnitAppName, scaleUnitAppId);
             }
             catch (Exception ex)
             {

src/ScaleUnitManagement/Utilities/SqlQueryExecutor.cs

@@ -1,26 +1,59 @@
+using System;
 using System.Data.SqlClient;
 
 namespace ScaleUnitManagement.Utilities
 {
     public class SqlQueryExecutor
     {
-        private readonly ScaleUnitInstance scaleUnit;
+        private readonly string dbName;
 
         public SqlQueryExecutor()
         {
-            scaleUnit = Config.FindScaleUnitWithId(ScaleUnitContext.GetScaleUnitId());
+            ScaleUnitInstance scaleUnit = Config.FindScaleUnitWithId(ScaleUnitContext.GetScaleUnitId());
+            dbName = scaleUnit.AxDbName;
+        }
+
+        public SqlQueryExecutor(string dbName)
+        {
+            this.dbName = dbName;
+        }
+
+        private string ConnectionString()
+        {
+            return $"Data Source=localhost;Initial Catalog={dbName};Integrated Security=True;Enlist=True;Application Name=ScaleUnitDevTool";
         }
 
         public void Execute(string query)
         {
-            string connectionString = $"Data Source=localhost;Initial Catalog={scaleUnit.AxDbName};Integrated Security=True;Enlist=True;Application Name=ScaleUnitDevTool";
-            using (var conn = new SqlConnection(connectionString))
+            using (var conn = new SqlConnection(ConnectionString()))
             using (var cmd = new SqlCommand(query, conn))
             {
                 conn.Open();
                 cmd.CommandTimeout = 65535;
                 cmd.ExecuteNonQuery();
             }
         }
+
+        public bool ExecuteBooleanQuery(string query)
+        {
+            using (var conn = new SqlConnection(ConnectionString()))
+            using (var cmd = new SqlCommand(query, conn))
+            {
+                conn.Open();
+                cmd.CommandTimeout = 65535;
+                SqlDataReader reader = cmd.ExecuteReader();
+                try
+                {
+                    reader.Read();
+                    int value = reader.GetInt32(0);
+                    return value != 0;
+                }
+                catch
+                {
+                    Console.WriteLine("sql query did not return a boolean result");
+                    throw;
+                }
+            }
+        }
     }
 }