tja-develop branch PR (When a Sitecore instance is selected you can install/uninstall SPS)

src/SIM.Base/XmlDocumentEx.cs

@@ -212,6 +212,12 @@ public void SetElementValue(string xpath, string value)
       element.InnerText = value;
     }
 
+    public bool ElementAttributeContains(string xpath, string attributeName, string substring)
+    {
+      string value = this.GetElementAttributeValue(xpath, attributeName).ToLower();
+      return !string.IsNullOrEmpty(value) && value.Contains(substring.ToLower());
+    }
+
     #endregion
 
     #region Private methods

src/SIM.Instances/Instance.cs

@@ -29,6 +29,8 @@ public class Instance : Website, IXmlSerializable
 
     private Product _Product;
 
+    private ICollection<InstanceRole> _instanceRoles;
+
     #endregion
 
     #region Constructors
@@ -167,7 +169,6 @@ public virtual bool IsSitecoreEnvironmentMember
               }
             }
           }
-
           return false;
         }
         catch (Exception ex)
@@ -494,6 +495,78 @@ public InstanceType Type
       }
     }
 
+    /// <summary>
+    /// A collection of server roles this instance is defined as
+    /// </summary>
+    public ICollection<InstanceRole> Roles
+    {
+      get
+      {
+        if (_instanceRoles != null)
+        {
+          return _instanceRoles;
+        }
+
+        _instanceRoles = new List<InstanceRole>();
+
+        try
+        {
+          //Check if sitecore identity server
+          if (this.GetWebConfig().ElementAttributeContains("/configuration/system.webServer/aspNetCore", "arguments",
+            "sitecore.identityServer.host"))
+          {
+            _instanceRoles.Add(InstanceRole.IdentityServer);
+            return _instanceRoles;
+          }
+
+          //Check if xconnect
+          string instanceName = this.Name.ToLower();
+          if (instanceName.Contains(".xconnect"))
+          {
+            _instanceRoles.Add(InstanceRole.XConnect);
+            return _instanceRoles;
+          }
+
+          //Check if sitecore publishing service
+          if (this.GetWebConfig().ElementAttributeContains("/configuration/system.webServer/aspNetCore", "processPath",
+            "sitecore.framework.publishing.host"))
+          {
+            _instanceRoles.Add(InstanceRole.PublishingService);
+            return _instanceRoles;
+          }
+
+          //Find role by 'role:define' key in web.config
+          string roleDefine = this.GetWebConfig()
+            .GetElementAttributeValue("/configuration/appSettings/add[@key='role:define']", "value").ToLower();
+          if (string.IsNullOrEmpty(roleDefine))
+          {
+            _instanceRoles.Add((InstanceRole
+              .Unknown)); //If 'role:define' is not present, this is likely a pre-version 9 solution, and we don't know the role
+            return _instanceRoles;
+          }
+
+          //Add any and all roles that are found in the role:define key
+          foreach (InstanceRole role in Enum.GetValues(typeof(InstanceRole)).Cast<InstanceRole>())
+          {
+            if (roleDefine.Contains(role.ToString().ToLower()))
+            {
+              _instanceRoles.Add(role);
+            }
+          }
+        }
+        catch (Exception ex)
+        {
+          _instanceRoles.Add(InstanceRole.Unknown);
+          Log.Error(ex, "Instance role could not be resolved and was set to 'Unknown'");
+        }
+        return _instanceRoles;
+      }
+    }
+
+    public bool IsContentManagementInstance =>  this.Roles.Contains(InstanceRole.Standalone) || 
+                                                this.Roles.Contains(InstanceRole.ContentManagement) ||
+                                                this.Roles.Contains(InstanceRole.Unknown);
+
     public enum InstanceType
     {
       Sitecore8AndEarlier,
@@ -503,6 +576,21 @@ public enum InstanceType
       Unknown
     }
 
+    public enum InstanceRole
+    {
+      Standalone,
+      ContentManagement,
+      ContentDelivery,
+      Reporting,
+      Processing,
+      Indexing,
+      DedicatedDispatch,
+      XConnect,
+      IdentityServer,
+      PublishingService,
+      Unknown
+    }
+
     #endregion
 
     #region Public methods

src/SIM.Pipelines/Install/Containers/GenerateEnvironmentData.cs

@@ -59,7 +59,7 @@ protected override void Process([NotNull] ProcessorArgs arguments)
       string environmentName = args.EnvModel.ProjectName;
       Assert.ArgumentNotNullOrEmpty(environmentName, "projectName");
 
-      this.AddEnvironment(this.CreateEnvironment(environmentName, destinationFolder));
+      SitecoreEnvironmentHelper.AddSitecoreEnvironment(this.CreateEnvironment(environmentName, destinationFolder));
     }
 
     private SitecoreEnvironment CreateEnvironment(string environmentName, string destinationFolder)
@@ -110,19 +110,5 @@ private string GetMemberType(string serviceName)
 
       return null;
     }
-
-    private void AddEnvironment(SitecoreEnvironment environment)
-    {
-      foreach (SitecoreEnvironment se in SitecoreEnvironmentHelper.SitecoreEnvironments)
-      {
-        if (se.Name == environment.Name)
-        {
-          return;
-        }
-      }
-
-      SitecoreEnvironmentHelper.SitecoreEnvironments.Add(environment);
-      SitecoreEnvironmentHelper.SaveSitecoreEnvironmentData(SitecoreEnvironmentHelper.SitecoreEnvironments);
-    }
   }
 }

src/SIM.Pipelines/Install/GenerateSitecoreEnvironmentData.cs

@@ -27,7 +27,7 @@ protected override void Process([NotNull] ProcessorArgs args)
       InstallParam sqlDbPrefixParam = arguments.Tasker.GlobalParams.FirstOrDefault(p => p.Name == SqlDbPrefix);
       if (sqlDbPrefixParam != null && !string.IsNullOrEmpty(sqlDbPrefixParam.Value))
       {
-        this.AddSitecoreEnvironment(this.CreateSitecoreEnvironment(arguments.Tasker, sqlDbPrefixParam.Value,arguments.UnInstallDataPath));
+        SitecoreEnvironmentHelper.AddSitecoreEnvironment(this.CreateSitecoreEnvironment(arguments.Tasker, sqlDbPrefixParam.Value,arguments.UnInstallDataPath));
       }
     }
 
@@ -52,20 +52,5 @@ private SitecoreEnvironment CreateSitecoreEnvironment(Tasker tasker, string sqlD
 
       return sitecoreEnvironment;
     }
-
-    private void AddSitecoreEnvironment(SitecoreEnvironment sitecoreEnvironment)
-    {
-      // Do not add new Sitecore environment if its name already exists in the Environments.json file
-      foreach (SitecoreEnvironment se in SitecoreEnvironmentHelper.SitecoreEnvironments)
-      {
-        if (se.Name == sitecoreEnvironment.Name)
-        {
-          return;
-        }
-      }
-
-      SitecoreEnvironmentHelper.SitecoreEnvironments.Add(sitecoreEnvironment);
-      SitecoreEnvironmentHelper.SaveSitecoreEnvironmentData(SitecoreEnvironmentHelper.SitecoreEnvironments);
-    }
   }
 }

src/SIM.Pipelines/PipelinesConfig.cs

@@ -266,6 +266,34 @@ public static class PipelinesConfig
       <processor type=""SIM.Pipelines.Import.ImportHostNames, SIM.Pipelines"" title=""Update hosts file"" />
     </processor>
   </import>
+  <installpublishingservice title=""Installing Publishing Service"">
+    <processor type=""SIM.Pipelines.PublishingService.Install.AddToEnvironmentProcessor, SIM.Pipelines"" 
+                title=""Adding SPS instance to CM environment package"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.PrepareInstallationProcessor, SIM.Pipelines"" 
+                title=""Unzipping package"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.SetAdminConnectionStringsProcessor, SIM.Pipelines"" 
+                title=""Setting admin connection strings"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.UpgradeDatabaseSchemaProcessor, SIM.Pipelines""
+                title=""Upgrading database schema"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.ResetDatabaseSchemaProcessor, SIM.Pipelines""
+                title=""Resetting database schema"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.SetActualConnectionStringsProcessor, SIM.Pipelines""
+                title=""Setting actual connection strings"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.CreateIISiteProcessor, SIM.Pipelines""
+                title=""Creating IIS site"" />
+    <processor type=""SIM.Pipelines.PublishingService.Install.VerifyInstallationProcessor, SIM.Pipelines""
+                title=""Checking status endpoint for errors"" />
+  </installpublishingservice>
+  <uninstallpublishingservice title=""Removing Publishing Service"">
+    <processor type=""SIM.Pipelines.PublishingService.Uninstall.RemoveFromEnvironmentProcessor, SIM.Pipelines"" 
+                title=""Removing SPS instance from CM environment"" />
+    <processor type=""SIM.Pipelines.PublishingService.Uninstall.RemoveIISSiteProcessor, SIM.Pipelines"" 
+                title=""Removing iis site"" />
+    <processor type=""SIM.Pipelines.PublishingService.Uninstall.RemoveAppPoolProcessor, SIM.Pipelines"" 
+                title=""Removing application pool"" />
+    <processor type=""SIM.Pipelines.PublishingService.Uninstall.RemoveWebrootFolderProcessor, SIM.Pipelines"" 
+                title=""Removing webroot folder"" />
+  </uninstallpublishingservice>
 </pipelines>";
   }
-}
+}

src/SIM.Pipelines/PublishingService/Commands.cs

@@ -0,0 +1,43 @@
+using System.Management.Automation;
+
+namespace SIM.Pipelines.PublishingService
+{
+  public static class Commands
+  {
+    private const string SET_CONNECTION_STRING = "configuration setconnectionstring {0} \"{1}\"";
+    private const string SCHEMA_UPGRADE = "schema upgrade --force";
+    private const string SCHEMA_RESET = "schema reset --force";
+    private const string IIS_INSTALL = "iis install --sitename \"{0}\" --apppool \"{1}\" --port \"{2}\" --hosts --force";
+
+    public static string CommandRoot { get; set; }
+
+    public static void SetConnectionString(string connectionStringName, string connectionStringValue)
+    {
+      ExecuteCommand(SET_CONNECTION_STRING, connectionStringName, connectionStringValue);
+    }
+
+    public static void SchemaUpgrade()
+    {
+      ExecuteCommand(SCHEMA_UPGRADE);
+    }
+
+    public static void SchemaReset()
+    {
+      ExecuteCommand(SCHEMA_RESET);
+    }
+
+    public static void IISInstall(string siteName, string appPoolName, int port)
+    {
+      ExecuteCommand(IIS_INSTALL, siteName, appPoolName, port);
+    }
+
+    private static void ExecuteCommand(string commandArgs, params object[] args)
+    {
+      using (PowerShell PS = PowerShell.Create())
+      {
+        PS.AddScript($"Set-Location {CommandRoot}").Invoke();
+        PS.AddScript(string.Format(".\\Sitecore.Framework.Publishing.Host.exe " + commandArgs, args)).Invoke();
+      }
+    }
+  }
+}

src/SIM.Pipelines/PublishingService/Install/AddToEnvironmentProcessor.cs

@@ -0,0 +1,29 @@
+using System;
+using System.Collections.Generic;
+using SIM.SitecoreEnvironments;
+using Sitecore.Diagnostics.Logging;
+
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class AddToEnvironmentProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      try
+      {
+        SitecoreEnvironment se = SitecoreEnvironmentHelper.GetExistingOrNewSitecoreEnvironment(args.CMInstance.Name);
+        if (se.Members == null)
+        {
+          se.Members = new List<SitecoreEnvironmentMember>();
+        }
+
+        se.Members.Add(new SitecoreEnvironmentMember(args.SPSSiteName, SitecoreEnvironmentMember.Types.Site.ToString()));
+        SitecoreEnvironmentHelper.AddOrUpdateSitecoreEnvironment(se);
+      }
+      catch (Exception ex)
+      {
+        Log.Warn(ex, $"Exception thrown while adding new SPS instance to CM environment:\n{ex}");
+      }
+    }
+  }
+}

src/SIM.Pipelines/PublishingService/Install/CreateIISiteProcessor.cs

@@ -0,0 +1,10 @@
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class CreateIISiteProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Commands.IISInstall(args.SPSSiteName, args.SPSSiteName, args.SPSPort);
+    }
+  }
+}

src/SIM.Pipelines/PublishingService/Install/InstallSPSProcessorArgs.cs

@@ -0,0 +1,25 @@
+using System.Collections.Generic;
+using System.Data.SqlClient;
+using SIM.Instances;
+using SIM.Pipelines.Processors;
+
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class InstallSPSProcessorArgs : ProcessorArgs
+  {
+    #region Properties
+    public Instance CMInstance { get; set; }
+    public string InstanceFolder { get; set; }
+    public string SPSInstanceFolder { get; set; }
+    public string SqlAdminUsername { get; set; }
+    public string SqlAdminPassword { get; set; }
+    public string SPSPackagePath { get; set; }
+    public string SPSSiteName { get; set; }
+    public string SPSAppPoolName { get; set; }
+    public string SPSWebroot { get; set; }
+    public int SPSPort { get; set; }
+    public Dictionary<string, SqlConnectionStringBuilder> SPSConnectionStrings { get; set; }
+
+    #endregion
+  }
+}

src/SIM.Pipelines/PublishingService/Install/PrepareInstallationProcessor.cs

@@ -0,0 +1,13 @@
+using System.IO.Compression;
+
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class PrepareInstallationProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      ZipFile.ExtractToDirectory(args.SPSPackagePath, args.SPSWebroot);
+      Commands.CommandRoot = args.SPSWebroot;
+    }
+  }
+}

src/SIM.Pipelines/PublishingService/Install/ResetDatabaseSchemaProcessor.cs

@@ -0,0 +1,11 @@
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class ResetDatabaseSchemaProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    //Resetting the schema is done to clear any potentially existing Publishing tables 
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Commands.SchemaReset();
+    }
+  }
+}

src/SIM.Pipelines/PublishingService/Install/SetActualConnectionStringsProcessor.cs

@@ -0,0 +1,16 @@
+using System.Collections.Generic;
+using System.Data.SqlClient;
+
+namespace SIM.Pipelines.PublishingService.Install
+{
+  public class SetActualConnectionStringsProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      foreach (KeyValuePair<string, SqlConnectionStringBuilder> connString in args.SPSConnectionStrings)
+      {
+        Commands.SetConnectionString(connString.Key, connString.Value.ToString());
+      }
+    }
+  }
+}