AKS updates to latest REST ContainerService specification

src/SDKs/ContainerService/AzSdk.RP.props

@@ -0,0 +1,7 @@
+<Project ToolsVersion="15.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003">
+  <!--This file and it's contents are updated at build time moving or editing might result in build failure. Take due deligence while editing this file-->
+  <PropertyGroup>
+    <AzureApiTag>ContainerService_2018-08-31;</AzureApiTag>
+    <PackageTags>$(PackageTags);$(CommonTags);$(AzureApiTag);</PackageTags>
+  </PropertyGroup>
+</Project>

src/SDKs/ContainerService/ContainerService.Tests/Microsoft.Azure.Management.ContainerService.Tests.csproj

@@ -0,0 +1,25 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <Import Project="$([MSBuild]::GetPathOfFileAbove('AzSdk.test.reference.props'))" />
+  <PropertyGroup>
+    <PackageId>Microsoft.Azure.Management.ContainerService.Tests</PackageId>
+    <Version>1.0.0</Version>
+    <Description>ContainerService.Tests Class Library</Description>
+    <Authors>Microsoft Corporation</Authors>
+    <AssemblyName>Microsoft.Azure.Management.ContainerService.Tests</AssemblyName>
+    <TreatWarningsAsErrors>true</TreatWarningsAsErrors>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Management.ContainerService\Microsoft.Azure.Management.ContainerService.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <None Update="SessionRecords\**\*.json">
+      <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
+    </None>
+  </ItemGroup>
+
+  <ItemGroup>
+    <Service Include="{82a7f48d-3b50-4b1e-b82e-3ada8210c358}" />
+  </ItemGroup>
+</Project>

src/SDKs/ContainerService/ContainerService.Tests/Tests/Helpers/ContainerServiceTestUtilities.cs

@@ -0,0 +1,109 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System;
+using System.Linq;
+using ContainerService.Tests;
+using Microsoft.Azure.Management.ContainerService.Models;
+using Microsoft.Azure.Management.Resources;
+using Microsoft.Rest.ClientRuntime.Azure.TestFramework;
+using Microsoft.Azure.Management.Resources.Models;
+using System.Threading.Tasks;
+using System.Collections.Generic;
+
+namespace Microsoft.Azure.Management.ContainerService.Tests
+{
+    public static class ContainerServiceTestUtilities
+    {
+        internal const string DnsPrefix = "aksdotnetsdk";
+        internal const string ResourceGroupPrefix = "aks-dotnet-sdk-RG-";
+        internal const string AgentPoolProfileName = "aksdotnetagent";
+        internal const string VMSize = "Standard_A1";
+
+        public static ResourceManagementClient GetResourceManagementClient(MockContext context, RecordedDelegatingHandler handler)
+        {
+            handler.IsPassThrough = true;
+            ResourceManagementClient resourceManagementClient = context.GetServiceClient<ResourceManagementClient>(handlers: handler);
+            return resourceManagementClient;
+        }
+
+        internal static ContainerServiceClient GetContainerServiceManagementClient(MockContext context, RecordedDelegatingHandler handler)
+        {
+            handler.IsPassThrough = true;
+            ContainerServiceClient containerServiceClient = context.GetServiceClient<ContainerServiceClient>(handlers: handler);
+            return containerServiceClient;
+        }
+
+        public static string GetLocationFromProvider(this ResourceManagementClient resourceManagementClient)
+        {
+            return "westus2";
+        }
+
+        public static void TryRegisterResourceGroup(this ResourceManagementClient resourceManagementClient, string location, string resourceGroupName)
+        {
+            resourceManagementClient.ResourceGroups.CreateOrUpdate(resourceGroupName, new ResourceGroup(location));
+        }
+
+        public static string TryGetResourceGroup(this ResourceManagementClient resourceManagementClient, string location)
+        {
+            const string DefaultResourceGroupName = "AKSTests";
+
+            var resourceGroup = resourceManagementClient.ResourceGroups
+                    .List().Where(group => string.IsNullOrWhiteSpace(location) || group.Location.Equals(location.Replace(" ", string.Empty), StringComparison.OrdinalIgnoreCase))
+                    .FirstOrDefault(group => group.Name.Contains(DefaultResourceGroupName));
+
+            return resourceGroup != null
+                ? resourceGroup.Name
+                : string.Empty;
+        }
+
+        /// <summary>
+        /// CreateManagedCluster creates an AKS managed cluster
+        /// </summary>
+        /// <param name="resourceManagementClient"></param>
+        /// <param name="containerServiceClient"></param>
+        /// <param name="location"></param>
+        /// <param name="clusterName"></param>
+        /// <param name="resourceGroupName"></param>
+        /// <returns></returns>
+        internal async static Task<ManagedCluster> CreateManagedCluster(
+            MockContext context,
+            ResourceManagementClient resourceManagementClient,
+            ContainerServiceClient containerServiceClient,
+            string location,
+            string clusterName,
+            string resourceGroupName)
+        {
+
+            TestEnvironment testEnvironment = TestEnvironmentFactory.GetTestEnvironment();
+            string authClientId = testEnvironment.ConnectionString.KeyValuePairs[ConnectionStringKeys.ServicePrincipalKey];
+            string authSecret = testEnvironment.ConnectionString.KeyValuePairs[ConnectionStringKeys.ServicePrincipalSecretKey];
+
+            var agentPoolProfiles = new List<ManagedClusterAgentPoolProfile>
+            {
+                new ManagedClusterAgentPoolProfile
+                {
+                    Name = AgentPoolProfileName,
+                    VmSize = VMSize,
+                    Count = 1
+                }
+            };
+
+            ManagedCluster desiredManagedCluster = new ManagedCluster
+            {
+                DnsPrefix = DnsPrefix,
+                Location = location,
+                AgentPoolProfiles = agentPoolProfiles,
+                ServicePrincipalProfile = new ManagedClusterServicePrincipalProfile
+                {
+                    ClientId = authClientId,
+                    Secret = authSecret
+                }
+            };
+
+            var cluster = await containerServiceClient.ManagedClusters.CreateOrUpdateAsync(resourceGroupName, clusterName, desiredManagedCluster);
+
+            return cluster;
+        }
+    }
+}

src/SDKs/ContainerService/ContainerService.Tests/Tests/Helpers/RecordedDelegatingHandler.cs

@@ -0,0 +1,90 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License. See License.txt in the project root for license information.
+
+using System;
+using System.Net;
+using System.Net.Http;
+using System.Net.Http.Headers;
+using System.Threading.Tasks;
+
+namespace ContainerService.Tests
+{
+    public class RecordedDelegatingHandler : DelegatingHandler
+    {
+        private HttpResponseMessage _response;
+
+        public RecordedDelegatingHandler()
+        {
+            StatusCodeToReturn = HttpStatusCode.Created;
+            SubsequentStatusCodeToReturn = StatusCodeToReturn;
+        }
+
+        public RecordedDelegatingHandler(HttpResponseMessage response)
+        {
+            StatusCodeToReturn = HttpStatusCode.Created;
+            SubsequentStatusCodeToReturn = StatusCodeToReturn;
+            _response = response;
+        }
+
+        public HttpStatusCode StatusCodeToReturn { get; set; }
+
+        public HttpStatusCode SubsequentStatusCodeToReturn { get; set; }
+
+        public string Request { get; private set; }
+
+        public HttpRequestHeaders RequestHeaders { get; private set; }
+
+        public HttpContentHeaders ContentHeaders { get; private set; }
+
+        public HttpMethod Method { get; private set; }
+
+        public Uri Uri { get; private set; }
+
+        public bool IsPassThrough { get; set; }
+
+        private int counter;
+
+        protected override async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, System.Threading.CancellationToken cancellationToken)
+        {
+            counter++;
+            // Save request
+            if (request.Content == null)
+            {
+                Request = string.Empty;
+            }
+            else
+            {
+                Request = await request.Content.ReadAsStringAsync();
+            }
+            RequestHeaders = request.Headers;
+            if (request.Content != null)
+            {
+                ContentHeaders = request.Content.Headers;
+            }
+            Method = request.Method;
+            Uri = request.RequestUri;
+
+            // Prepare response
+            if (IsPassThrough)
+            {
+                return await base.SendAsync(request, cancellationToken);
+            }
+            else
+            {
+                if (_response != null && counter == 1)
+                {
+                    return _response;
+                }
+                else
+                {
+                    var statusCode = StatusCodeToReturn;
+                    if (counter > 1)
+                        statusCode = SubsequentStatusCodeToReturn;
+                    HttpResponseMessage response = new HttpResponseMessage(statusCode);
+                    response.Content = new StringContent("");
+                    return response;
+                }
+            }
+        }
+    }
+}