added new functionality for demos

Author: azurecoder

Elastacloud.FluentExamples/App.config

@@ -4,15 +4,16 @@
     <add key="dbname" value="stacked"/>
     <add key="username" value="azurecoder"/>
     <add key="password" value="Password101!"/>
-    <add key="sql_db_username" value="azurecoder_db"/>
-    <add key="default_storage" value="stackedstorage"/>
-    <add key="mobile_service_name" value="stackedmobile"/>
-    <add key="deployment_name" value="stacked deployment"/>
+    <add key="sqldbusername" value="azurecoder_db"/>
+    <add key="defaultstorage" value="stackedstorage"/>
+    <add key="mobileservicename" value="stackedmobile"/>
+    <add key="deploymentname" value="stacked deployment"/>
     <add key="publishsettings" value="C:\Users\Richard\Desktop\Engagements\AllAccounts.publishsettings"/>
     <add key="rdpfile" value="C:\Users\Richard\Desktop\Engagements\stackedliverpool.rdp"/>
     <add key="vmroleservice" value="stackedliverpool"/>
     <add key="cloudservice" value="stackedliverpoolpaas"/>
     <add key="rolename" value="ExampleWebRole"/>
+    <add key="deploymentpath" value="C:\Users\Richard\Documents\Fluent Examples\Elastacloud.FluentExamples\TestCloudInstall\bin\Release\app.publish"/>
   </appSettings>
   <startup>
     <supportedRuntime version="v4.0" sku=".NETFramework,Version=v4.5" />

Elastacloud.FluentExamples/BuildGetBlobRequest.cs

@@ -27,7 +27,7 @@ public void PreActionSteps()
         {
             // use AMS to transfer file
             var storageClient = new StorageClient(_subscriptionId, _managementCertificate);
-            var keys = storageClient.GetStorageAccountKeys("stackedstorage");
+            var keys = storageClient.GetStorageAccountKeys(Settings.DefaultStorage);
             StorageKey = keys[0];
         }
 
@@ -43,8 +43,8 @@ public void DoWork()
             var builder = new StringBuilder("GET");
             builder.Append(lineEndings);
             builder.AppendFormat("x-ms-date:{0}\n", date);
-            builder.AppendFormat("x-ms-version:2011-08-18\n");
-            builder.Append("/stackedstorage/docs/test.txt\n");
+            builder.Append("x-ms-version:2011-08-18\n");
+            builder.AppendFormat("/{0}/docs/test.txt\n",Settings.DefaultStorage);
             builder.Append("timeout:90");
 
             string signature;
@@ -56,7 +56,8 @@ public void DoWork()
 
             var authValue = "SharedKey stackedstorage:" + signature;
 
-            var request = (HttpWebRequest)WebRequest.Create("http://stackedstorage.blob.core.windows.net/docs/test.txt?timeout=90");
+            var request = (HttpWebRequest)WebRequest.Create(
+                String.Format("http://{0}.blob.core.windows.net/docs/test.txt?timeout=90", Settings.DefaultStorage));
             request.Method = "GET";
             request.ContentLength = 0;
             request.Headers.Add("x-ms-date", date);

Elastacloud.FluentExamples/BuildMobileService.cs

@@ -22,7 +22,7 @@ public BuildMobileService(string subscriptionId, X509Certificate2 managementCert
         public void SpinUp()
         {
             var client = new MobileServiceClient(SubscriptionId, ManagementCertificate);
-            client.CreateMobileServiceWithNewDb("mobilestacked", "azurecoder", "Password101!");
+            client.CreateMobileServiceWithNewDb(Settings.MobileServiceName, Settings.Username, Settings.Password);
             Console.WriteLine("Yeah, we created a mobile service using the Service Management API - even though it hasn't been published yet!");
 
             // Display some details about the mobile service
@@ -45,7 +45,7 @@ public void TearDown()
 
         public void DoSomething()
         {
-            var client = new MobileServiceClient(SubscriptionId, ManagementCertificate, "mobilestacked");
+            var client = new MobileServiceClient(SubscriptionId, ManagementCertificate, Settings.MobileServiceName);
             if (!client.Tables.Exists(a => a.TableName == "Speakers"))
                 client.AddTable("Speakers");
             client.AddTableScript(CrudOperation.Insert, "Speakers", "function insert(item, user, request){ /*Another fluent success!*/request.execute();}", Roles.User);

Elastacloud.FluentExamples/BuildVirtualMachine.cs

@@ -21,22 +21,21 @@ public class BuildVirtualMachine : IBuilder
         private readonly string _subscriptionId;
         private readonly string _rdpFile;
 
-        public BuildVirtualMachine(string subscriptionId, string publishSettingsFile, string rdpFile)
+        public BuildVirtualMachine(string subscriptionId, X509Certificate2 certificate)
         {
-            var settings = PublishSettingsExtractor.GetFromFile(publishSettingsFile);
-            _certificate = settings.AddPublishSettingsToPersonalMachineStore();
+            _certificate = certificate;
             _subscriptionId = subscriptionId;
-            _rdpFile = rdpFile;
+            _rdpFile = Settings.RemoteDesktopFilePath;
             _properties = new WindowsVirtualMachineProperties()
                              {
-                                 AdministratorPassword = "Password101!",
-                                 RoleName = "stackedliverpool",
-                                 DeploymentName = "stackedliverpool",
+                                 AdministratorPassword = Settings.Password,
+                                 RoleName = Settings.VmRoleAndServiceName,
+                                 DeploymentName = Settings.VmRoleAndServiceName,
                                  Certificate = _certificate,
                                  Location = LocationConstants.NorthEurope,
                                  UseExistingCloudService = false,
                                  SubscriptionId = subscriptionId,
-                                 CloudServiceName = "stackedliverpool",
+                                 CloudServiceName = Settings.VmRoleAndServiceName,
                                  PublicEndpoints = new List<InputEndpoint>(new[]
                                                                                {
                                                                                    new InputEndpoint()
@@ -49,7 +48,7 @@ public BuildVirtualMachine(string subscriptionId, string publishSettingsFile, st
                                                                                }),
                                  VirtualMachineType = VirtualMachineTemplates.WindowsServer2012,
                                  VmSize = VmSize.Medium,
-                                 StorageAccountName = "stackedstorage",
+                                 StorageAccountName = Settings.DefaultStorage,
                                  DataDisks = new List<DataVirtualHardDisk>(new[] {
                                      new DataVirtualHardDisk(){LogicalDiskSizeInGB = 100}
                                  })
@@ -59,7 +58,7 @@ public BuildVirtualMachine(string subscriptionId, string publishSettingsFile, st
         void IBuilder.SpinUp()
         {
             var storageClient = new StorageClient(_subscriptionId, _certificate);
-            storageClient.CreateNewStorageAccount("stackedstorage");
+            storageClient.CreateNewStorageAccount(Settings.DefaultStorage);
             var client = new WindowsVirtualMachineClient(_subscriptionId, _certificate);
             var newClient = client.CreateNewVirtualMachineFromTemplateGallery(_properties);
             Console.WriteLine("Virtual machine now created - with diskname {0}", 

Elastacloud.FluentExamples/Elastacloud.FluentExamples.csproj

@@ -76,6 +76,9 @@
     <Compile Include="BuildGetBlobRequest.cs" />
     <Compile Include="BuildMobileService.cs" />
     <Compile Include="BuildVirtualMachine.cs" />
+    <Compile Include="WorkflowLoadConfig.cs" />
+    <Compile Include="Settings.cs" />
+    <Compile Include="WorkflowPublishSettings.cs" />
     <Compile Include="WorkflowFluentDeploymentWithSSL.cs" />
     <Compile Include="WorkflowRoleSystemWatcher.cs" />
     <Compile Include="WorkflowFluentDeployment.cs" />

Elastacloud.FluentExamples/Program.cs

@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
+using System.IO;
 using System.Linq;
 using System.Text;
 using System.Threading;
@@ -10,47 +11,52 @@ namespace Elastacloud.FluentExamples
 {
     class Program
     {
+        static readonly List<IBuilder> Builders = new List<IBuilder>();
+        static readonly List<IWorkflow> Workflows = new List<IWorkflow>();
         // args 0 - the subscription id
         // args 1 - the path to the publishsettings file
         // args 2 - the path to the rdp output file 
         static void Main(string[] args)
         {
-            var builders = new List<IBuilder>();
-            var workflows = new List<IWorkflow>();
-            // create a virtual machine
-            IBuilder virtualMachine = new BuildVirtualMachine(args[0], args[1], args[2]);
-            builders.Add(virtualMachine);
+            if (args.Length < 1)
+                throw new ApplicationException("need a single argument to proceed");
+
+            // manipulate and transform config files
+            IWorkflow getConfig = new WorkflowLoadConfig(Path.Combine(Settings.DeploymentPath, "TestCloudInstall.cscfg"));
+            getConfig.PreActionSteps();
+
+            // do the publishsettings 
+            IWorkflow getSettings = new WorkflowPublishSettings(args[0], Settings.PublishSettingsFilePath);
+            getSettings.PreActionSteps();
 
             // Add the test get blob API - before running this create a storage account using AMS called stackedstorage
-            IWorkflow getBlob = new BuildGetBlobRequest(virtualMachine.SubscriptionId, virtualMachine.ManagementCertificate);
-            workflows.Add(getBlob);
+            IWorkflow getBlob = new BuildGetBlobRequest(Settings.SubscriptionId, Settings.ManagementCertificate);
+            Workflows.Add(getBlob);
+
+            // create a virtual machine
+            IBuilder virtualMachine = new BuildVirtualMachine(args[0], Settings.ManagementCertificate);
+            Builders.Add(virtualMachine);
 
             // test linq to azure with storage
-            IWorkflow linqToStorage = new WorkflowLinqToStorage(virtualMachine.SubscriptionId, virtualMachine.ManagementCertificate);
-            workflows.Add(linqToStorage);
+            IWorkflow linqToStorage = new WorkflowLinqToStorage(Settings.SubscriptionId, Settings.ManagementCertificate);
+            Workflows.Add(linqToStorage);
 
             // test create a mobile services deployment
-            IBuilder mobileService = new BuildMobileService(virtualMachine.SubscriptionId, virtualMachine.ManagementCertificate);
-            builders.Add(mobileService);
+            IBuilder mobileService = new BuildMobileService(Settings.SubscriptionId, Settings.ManagementCertificate);
+            Builders.Add(mobileService);
 
             // test paas deployment
             // test linq to azure with cloud services
             // test paas orchestration
-            IWorkflow fluentDeployment = new WorkflowFluentDeployment(virtualMachine.SubscriptionId, virtualMachine.ManagementCertificate);
-            workflows.Add(fluentDeployment);
+            IWorkflow fluentDeployment = new WorkflowFluentDeployment(Settings.SubscriptionId, Settings.ManagementCertificate);
+            Workflows.Add(fluentDeployment);
 
             // test role system watcher
             var watcher = new WorkflowRoleSystemWatcher(virtualMachine.SubscriptionId, virtualMachine.ManagementCertificate);
-            workflows.Add(watcher);
-            watcher.DoWork();
+            Workflows.Add(watcher);
 
             // test paas build
-
 
-
-
-            
-            // manipulate and transform config files
             Console.WriteLine("Press [ENTER] to exit");
             Console.Read();
         }

Elastacloud.FluentExamples/Settings.cs

@@ -0,0 +1,29 @@
+using System;
+using System.Collections.Generic;
+using System.Configuration;
+using System.Linq;
+using System.Security.Cryptography.X509Certificates;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Elastacloud.FluentExamples
+{
+    public static class Settings
+    {
+        public static string DatabaseName { get { return ConfigurationManager.AppSettings["dbname"]; } }
+        public static string Username { get { return ConfigurationManager.AppSettings["username"]; } }
+        public static string Password { get { return ConfigurationManager.AppSettings["password"]; } }
+        public static string SqlDatabaseUsername { get { return ConfigurationManager.AppSettings["sqldbusername"]; } }
+        public static string DefaultStorage { get { return ConfigurationManager.AppSettings["defaultStorage"]; } }
+        public static string MobileServiceName { get { return ConfigurationManager.AppSettings["mobileservicename"]; } }
+        public static string DeplopymentName { get { return ConfigurationManager.AppSettings["deploymentname"]; } }
+        public static string PublishSettingsFilePath { get { return ConfigurationManager.AppSettings["publishsettings"]; } }
+        public static string RemoteDesktopFilePath { get { return ConfigurationManager.AppSettings["rdpfile"]; } }
+        public static string VmRoleAndServiceName { get { return ConfigurationManager.AppSettings["vmservicerole"]; } }
+        public static string CloudServiceName { get { return ConfigurationManager.AppSettings["cloudservice"]; } }
+        public static string RoleName { get { return ConfigurationManager.AppSettings["rolename"]; } }
+        public static string DeploymentPath { get { return ConfigurationManager.AppSettings["deploymentpath"]; } }
+        public static string SubscriptionId { get; set; }
+        public static X509Certificate2 ManagementCertificate { get; set; }
+    }
+}

Elastacloud.FluentExamples/WorkflowFluentDeployment.cs

@@ -49,22 +49,22 @@ public void PreActionSteps()
                    .AddCertificate(_managementCertificate)
                    .AddNewFirewallRuleForWindowsAzureHostedService()
                    .AddNewFirewallRuleWithMyIp("my ip rule - for stacked")
-                   .WithSqlAzureCredentials("azurecoder", "Password101!")
-                   .AddNewDatabase("stacked")
-                   .AddNewDatabaseAdminUser("azurecoder_db", "Password101!")
+                   .WithSqlAzureCredentials(Settings.Username, Settings.Password)
+                   .AddNewDatabase(Settings.DatabaseName)
+                   .AddNewDatabaseAdminUser(Settings.SqlDatabaseUsername, Settings.Password)
                    .Go();
             _orchestrator.AddDeploymentStep(serviceTransactionSql);
             var serviceTransactionDeployment = manager.GetDeploymentManager()
                     .AddCertificate(_managementCertificate)
-                    .ForNewDeployment("stacked deployment")
-                    .SetCspkgEndpoint(@"C:\Users\Richard\Documents\Fluent Examples\Elastacloud.FluentExamples\TestCloudInstall\bin\Release\app.publish")
-                    .WithNewHostedService("stackedliverpoolpaas")
+                    .ForNewDeployment(Settings.DeplopymentName)
+                    .SetCspkgEndpoint(Settings.DeploymentPath)
+                    .WithNewHostedService(Settings.CloudServiceName)
                     .WithStorageAccount(_accountName)
                     .AddDescription("Fluent management @ Stacked")
                     .AddEnvironment(DeploymentSlot.Production)
                     .AddLocation(LocationConstants.NorthEurope)
                     .AddParams(DeploymentParams.StartImmediately|DeploymentParams.WarningsAsErrors)
-                    .ForRole("ExampleWebRole")
+                    .ForRole(Settings.RoleName)
                     .WithInstanceCount(4)
                     .WaitUntilAllRoleInstancesAreRunning()
                     .Go();

Elastacloud.FluentExamples/WorkflowFluentDeploymentWithSSL.cs

@@ -34,13 +34,13 @@ public void PreActionSteps()
             var manager = new SubscriptionManager(_subscriptionId);
             _context = manager.GetDeploymentManager()
                                  .AddCertificate(_managementCertificate)
-                                 .ForNewDeployment("stacked deployment")
+                                 .ForNewDeployment(Settings.DeplopymentName)
                                  .SetBuildDirectoryRoot("builddirectory")
-                                 .EnableRemoteDesktopAndSslForRole("ExampleWebRole")
-                                 .WithUsernameAndPassword("azurecoder", "Password101!")
-                                 .GenerateAndAddServiceCertificate("stackedliverpoolpaas")
-                                 .WithNewHostedService("stackedliverpoolpaas")
-                                 .WithStorageAccount("stackedstorage")
+                                 .EnableRemoteDesktopAndSslForRole(Settings.RoleName)
+                                 .WithUsernameAndPassword(Settings.Username, Settings.Password)
+                                 .GenerateAndAddServiceCertificate(Settings.CloudServiceName + ".cloudapp.net")
+                                 .WithNewHostedService(Settings.CloudServiceName)
+                                 .WithStorageAccount(Settings.DefaultStorage)
                                  .AddDescription("Created by fluent management")
                                  .AddEnvironment(DeploymentSlot.Production)
                                  .AddLocation(LocationConstants.NorthEurope)

Elastacloud.FluentExamples/WorkflowLoadConfig.cs

@@ -0,0 +1,49 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Security.Cryptography.X509Certificates;
+using System.Text;
+using System.Threading.Tasks;
+using Elastacloud.AzureManagement.Fluent.Clients;
+using Elastacloud.AzureManagement.Fluent.Helpers;
+using Elastacloud.AzureManagement.Fluent.Helpers.PublishSettings;
+using Elastacloud.AzureManagement.Fluent.Linq;
+using Elastacloud.AzureManagement.Fluent.Types;
+
+namespace Elastacloud.FluentExamples
+{
+    public class WorkflowLoadConfig : IWorkflow
+    {
+        private readonly string _configFile;
+        private List<string> roleList;
+        private int instanceCount;
+        private CscfgFile configFile;
+
+        public WorkflowLoadConfig(string configFile)
+        {
+            _configFile = configFile;
+        }
+
+        #region Implementation of IWorkflow
+
+        public void PreActionSteps()
+        {
+            Console.WriteLine("getting configuration settings for role");
+            configFile = (CscfgFile)CscfgFile.GetInstance(_configFile);
+            roleList = configFile.GetRoleNameList();
+        }
+
+        public void DoWork()
+        {
+            foreach (var role in roleList)
+                Console.WriteLine("Found role with name: {0}, has {1} instances", role, configFile.GetInstanceCountForRole(role));
+        }
+
+        public void PostActionSteps()
+        {
+            Console.WriteLine("Finished reading .cscfg file");
+        }
+
+        #endregion
+    }
+}