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

src/SIM.Instances/Instance.cs

@@ -494,6 +494,67 @@ public InstanceType Type
       }
     }
 
+    /// <summary>
+    /// A collection of server roles this instance is defined as
+    /// </summary>
+    public ICollection<InstanceRole> Roles
+    {
+      get
+      {
+        ICollection<InstanceRole> InstanceRoles = new List<InstanceRole>();
+
+        //Find role by name
+        string instanceName = this.Name;
+        if (instanceName.Contains(".identityserver"))
+        {
+          InstanceRoles.Add(InstanceRole.IdentityServer);
+          return InstanceRoles;
+        }
+        if (instanceName.Contains(".xconnect"))
+        {
+          InstanceRoles.Add(InstanceRole.XConnect);
+          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;
+        }
+        if (roleDefine.Contains("standalone"))
+        {
+          InstanceRoles.Add(InstanceRole.Standalone);
+        }
+        if (roleDefine.Contains("contentmanagement"))
+        {
+          InstanceRoles.Add(InstanceRole.ContentManagement);
+        }
+        if (roleDefine.Contains("contentdelivery"))
+        {
+          InstanceRoles.Add(InstanceRole.ContentDelivery);
+        }
+        if (roleDefine.Contains("reporting"))
+        {
+          InstanceRoles.Add(InstanceRole.Reporting);
+        }
+        if (roleDefine.Contains("processing"))
+        {
+          InstanceRoles.Add(InstanceRole.Processing);
+        }
+        if (roleDefine.Contains("indexing"))
+        {
+          InstanceRoles.Add(InstanceRole.Indexing);
+        }
+
+        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 +564,19 @@ public enum InstanceType
       Unknown
     }
 
+    public enum InstanceRole
+    {
+      Standalone,
+      ContentManagement,
+      ContentDelivery,
+      Reporting,
+      Processing,
+      Indexing,
+      XConnect,
+      IdentityServer,
+      Unknown
+    }
+
     #endregion
 
     #region Public methods

src/SIM.Pipelines/InstallPublishingService/Commands.cs

@@ -0,0 +1,46 @@
+using MongoDB.Driver.Linq;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Management.Automation;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  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 void SetConnectionString(string connectionStringName, string connectrionStringValue)
+    {
+      ExecuteCommand(SET_CONNECTION_STRING, connectionStringName, connectrionStringValue);
+    }
+
+    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(string.Format(".\\Sitecore.Framework.Publishing.Host.exe " + commandArgs, args)).Invoke();
+      }
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/CreateIISiteProcessor.cs

@@ -0,0 +1,17 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class CreateIISiteProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Commands.IISInstall(args.SPSSiteName, args.SPSSiteName, args.SPSPort);
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/InstallSPSProcessorArgs.cs

@@ -0,0 +1,31 @@
+using SIM.Pipelines.Processors;
+using System;
+using System.Collections.Generic;
+using System.Data.SqlClient;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class InstallSPSProcessorArgs : ProcessorArgs
+  {
+    #region Properties
+    //Populated from InstallPublishingServiceWizardArgs
+    public string InstanceName { 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; }
+    public bool OverwriteExisting { get; set; }
+
+    #endregion
+  }
+}

src/SIM.Pipelines/InstallPublishingService/RemoveExistingSPSProcessor.cs

@@ -0,0 +1,40 @@
+using JetBrains.Annotations;
+using Microsoft.Web.Administration;
+using SIM.Adapters.WebServer;
+using SIM.Pipelines.UninstallPublishingService;
+using Sitecore.Diagnostics.Logging;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class RemoveExistingSPSProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      if (!args.OverwriteExisting)
+      {
+        return;
+      }
+
+      UninstallSPSProcessorArgs uninstallArgs = new UninstallSPSProcessorArgs()
+      {
+        SPSSiteName = args.SPSSiteName,
+        SPSAppPoolName = args.SPSAppPoolName,
+        SPSWebroot = args.SPSWebroot,
+        SkipSPSSite = false,
+        SkipSPSAppPool = false,
+        SkipSPSWebroot = false
+      };
+
+      new RemoveIISSiteProcessor().DoProcess(uninstallArgs);
+      new RemoveAppPoolProcessor().DoProcess(uninstallArgs);
+      new RemoveWebrootFolderProcessor().DoProcess(uninstallArgs);
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/ResetDatabaseSchemaProcessor.cs

@@ -0,0 +1,19 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class ResetDatabaseSchemaProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    //Resetting the schema is done to clear any potentially existing Publishing tables 
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Directory.SetCurrentDirectory(args.SPSWebroot);
+      Commands.SchemaReset();
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/SPSProcessor.cs

@@ -0,0 +1,48 @@
+using JetBrains.Annotations;
+using SIM.Pipelines.Processors;
+using Sitecore.Diagnostics.Logging;
+using System;
+using System.Collections.Generic;
+using System.Deployment.Internal;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public abstract class SPSProcessor<T> : Processor where T : ProcessorArgs
+  {
+    protected static bool AbortPipeline = false;
+
+    protected override void Process([NotNull] ProcessorArgs args)
+    {
+      T processorArgs = args as T;
+
+      if (AbortPipeline)
+      {
+        Log.Warn($"The {this.GetType().Name} processor was skipped.");
+        this.Skip();
+        return;
+      }
+
+      try
+      {
+        this.ProcessCore(processorArgs);
+      }
+      catch (Exception ex)
+      {
+        AbortPipeline = true;
+        Log.Error($"Publishing Service Pipeline was aborted.  The remaining steps were skipped.");
+        throw ex;
+      }
+    }
+
+    protected abstract void ProcessCore([NotNull] T args);
+
+    //Kind of a hack so I can resure some of the uninstall sps processors in the RemoveExistingSPSProcessor class
+    internal void DoProcess([NotNull] T args)
+    {
+      this.Process(args);
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/SetActualConnectionStringsProcessor.cs

@@ -0,0 +1,22 @@
+using System;
+using System.Collections.Generic;
+using System.Data.SqlClient;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class SetActualConnectionStringsProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Directory.SetCurrentDirectory(args.SPSWebroot);
+      foreach (KeyValuePair<string, SqlConnectionStringBuilder> connString in args.SPSConnectionStrings)
+      {
+        Commands.SetConnectionString(connString.Key, connString.Value.ToString());
+      }
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/SetAdminConnectionStringsProcessor.cs

@@ -0,0 +1,29 @@
+using System;
+using System.Collections.Generic;
+using System.Data.SqlClient;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class SetAdminConnectionStringsProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    //Using the admin credentials for connection strings is necessary to upgrade and reset the database schema
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Directory.SetCurrentDirectory(args.SPSWebroot);
+      foreach (KeyValuePair<string, SqlConnectionStringBuilder> connString in args.SPSConnectionStrings)
+      {
+        string AdminConnString = new SqlConnectionStringBuilder(connString.Value.ToString())
+        {
+          UserID = args.SqlAdminUsername,
+          Password = args.SqlAdminPassword
+        }.ToString();
+
+        Commands.SetConnectionString(connString.Key, AdminConnString);
+      }
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/UnzipSPSPackageProcessor.cs

@@ -0,0 +1,22 @@
+using JetBrains.Annotations;
+using SIM.Pipelines.Processors;
+using Sitecore.Diagnostics.Logging;
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.IO.Compression;
+using System.Linq;
+using System.Runtime.CompilerServices;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class UnzipSPSPackageProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      ZipFile.ExtractToDirectory(args.SPSPackagePath, args.SPSWebroot);
+    }
+  }
+}

src/SIM.Pipelines/InstallPublishingService/UpgradeDatabaseSchemaProcessor.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Collections.Generic;
+using System.IO;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace SIM.Pipelines.InstallPublishingService
+{
+  public class UpgradeDatabaseSchemaProcessor : SPSProcessor<InstallSPSProcessorArgs>
+  {
+    protected override void ProcessCore(InstallSPSProcessorArgs args)
+    {
+      Directory.SetCurrentDirectory(args.SPSWebroot);
+      Commands.SchemaUpgrade();
+    }
+  }
+}