< Summary

Class:Azure.Core.ArmOperationHelpers`1
Assembly:Azure.ResourceManager.DigitalTwins
File(s):C:\Git\azure-sdk-for-net\sdk\core\Azure.Core\src\Shared\AutoRest\ArmOperationHelpers.cs
Covered lines:105
Uncovered lines:50
Coverable lines:155
Total lines:359
Line coverage:67.7% (105 of 155)
Covered branches:45
Total branches:98
Branch coverage:45.9% (45 of 98)

Metrics

MethodCyclomatic complexity Line coverage Branch coverage
get_DefaultPollingInterval()-0%100%
.cctor()-100%100%
.ctor(...)-100%100%
GetRawResponse()-100%100%
WaitForCompletionAsync(...)-0%100%
WaitForCompletionAsync()-100%100%
UpdateStatusAsync()-74.19%42.86%
UpdateStatusAsync()-100%100%
UpdateStatus(...)-0%100%
get_Id()-0%100%
get_Value()-66.67%50%
get_HasCompleted()-100%100%
get_HasValue()-100%100%
CreateRequest(...)-100%100%
GetResponseAsync()-63.64%50%
GetResponse(...)-0%0%
IsTerminalState(...)-79.17%60.71%
InitializeScenarioInfo()-69.23%66.67%
UpdatePollUri()-50%33.33%
GetFinalUri()-25%25%

File(s)

C:\Git\azure-sdk-for-net\sdk\core\Azure.Core\src\Shared\AutoRest\ArmOperationHelpers.cs

#LineLine coverage
 1// Copyright (c) Microsoft Corporation. All rights reserved.
 2// Licensed under the MIT License.
 3
 4#nullable enable
 5
 6using System;
 7using System.Linq;
 8using System.Text.Json;
 9using System.Threading;
 10using System.Threading.Tasks;
 11using Azure.Core.Pipeline;
 12
 13namespace Azure.Core
 14{
 15    /// <summary>
 16    /// This implements the ARM scenarios for LROs. It is highly recommended to read the ARM spec prior to modifying thi
 17    /// https://github.com/Azure/azure-resource-manager-rpc/blob/master/v1.0/Addendum.md#asynchronous-operations
 18    /// Other reference documents include:
 19    /// https://github.com/Azure/autorest/blob/master/docs/extensions/readme.md#x-ms-long-running-operation
 20    /// https://github.com/Azure/adx-documentation-pr/blob/master/sdks/LRO/LRO_AzureSDK.md
 21    /// </summary>
 22    /// <typeparam name="T">The final result of the LRO.</typeparam>
 23    internal class ArmOperationHelpers<T>
 24    {
 025        public static TimeSpan DefaultPollingInterval { get; } = TimeSpan.FromSeconds(1);
 26
 427        private static readonly string[] s_failureStates = {"failed", "canceled"};
 428        private static readonly string[] s_terminalStates = {"succeeded", "failed", "canceled"};
 29
 30        private readonly HttpPipeline _pipeline;
 31        private readonly ClientDiagnostics _clientDiagnostics;
 32        private readonly string _scopeName;
 33        private readonly RequestMethod _requestMethod;
 34        private readonly string _originalUri;
 35        private readonly OperationFinalStateVia _finalStateVia;
 36        private HeaderFrom _headerFrom;
 37        private string _pollUri = default!;
 38        private bool _originalHasLocation;
 39        private string? _lastKnownLocation;
 40
 41        private readonly IOperationSource<T> _source;
 42        private Response _rawResponse;
 43        private T _value = default!;
 44        private bool _hasValue;
 45        private bool _hasCompleted;
 46        private bool _shouldPoll;
 47
 848        public ArmOperationHelpers(
 849            IOperationSource<T> source,
 850            ClientDiagnostics clientDiagnostics,
 851            HttpPipeline pipeline,
 852            Request originalRequest,
 853            Response originalResponse,
 854            OperationFinalStateVia finalStateVia,
 855            string scopeName)
 56        {
 857            _source = source;
 858            _rawResponse = originalResponse;
 859            _requestMethod = originalRequest.Method;
 860            _originalUri = originalRequest.Uri.ToString();
 861            _finalStateVia = finalStateVia;
 862            InitializeScenarioInfo();
 63
 864            _pipeline = pipeline;
 865            _clientDiagnostics = clientDiagnostics;
 866            _scopeName = scopeName;
 67            // When the original response has no headers, we do not start polling immediately.
 868            _shouldPoll = _headerFrom != HeaderFrom.None;
 869        }
 70
 13671        public Response GetRawResponse() => _rawResponse;
 72
 73        public ValueTask<Response<T>> WaitForCompletionAsync(CancellationToken cancellationToken = default)
 74        {
 075            return WaitForCompletionAsync(DefaultPollingInterval, cancellationToken);
 76        }
 77
 78        public async ValueTask<Response<T>> WaitForCompletionAsync(TimeSpan pollingInterval, CancellationToken cancellat
 79        {
 4480            while (true)
 81            {
 5282                await UpdateStatusAsync(cancellationToken).ConfigureAwait(false);
 5283                if (HasCompleted)
 84                {
 885                    return Response.FromValue(Value, GetRawResponse());
 86                }
 87
 4488                await Task.Delay(pollingInterval, cancellationToken).ConfigureAwait(false);
 89            }
 890        }
 91
 92        private async ValueTask<Response> UpdateStatusAsync(bool async, CancellationToken cancellationToken)
 93        {
 5294            if (_hasCompleted)
 95            {
 096                return GetRawResponse();
 97            }
 98
 5299            if (_shouldPoll)
 100            {
 48101                UpdatePollUri();
 48102                _rawResponse = async
 48103                    ? await GetResponseAsync(_pollUri, cancellationToken).ConfigureAwait(false)
 48104                    : GetResponse(_pollUri, cancellationToken);
 105            }
 106
 52107            _shouldPoll = true;
 52108            _hasCompleted = IsTerminalState(out string state);
 52109            if (_hasCompleted)
 110            {
 8111                Response finalResponse = GetRawResponse();
 8112                if (s_failureStates.Contains(state))
 113                {
 0114                    throw _clientDiagnostics.CreateRequestFailedException(finalResponse);
 115                }
 116
 8117                string? finalUri = GetFinalUri();
 8118                if (finalUri != null)
 119                {
 0120                    finalResponse = async
 0121                        ? await GetResponseAsync(finalUri, cancellationToken).ConfigureAwait(false)
 0122                        : GetResponse(finalUri, cancellationToken);
 123                }
 124
 8125                switch (finalResponse.Status)
 126                {
 127                    case 200:
 0128                    case 201 when _requestMethod == RequestMethod.Put:
 0129                    case 204 when !(_requestMethod == RequestMethod.Put || _requestMethod == RequestMethod.Patch):
 130                    {
 8131                        _value = async
 8132                            ? await _source.CreateResultAsync(finalResponse, cancellationToken).ConfigureAwait(false)
 8133                            : _source.CreateResult(finalResponse, cancellationToken);
 8134                        _rawResponse = finalResponse;
 8135                        _hasValue = true;
 8136                        break;
 137                    }
 138                    default:
 0139                        throw _clientDiagnostics.CreateRequestFailedException(finalResponse);
 140                }
 8141            }
 142
 52143            return GetRawResponse();
 52144        }
 145
 52146        public async ValueTask<Response> UpdateStatusAsync(CancellationToken cancellationToken = default) => await Updat
 147
 0148        public Response UpdateStatus(CancellationToken cancellationToken = default) => UpdateStatusAsync(async: false, c
 149
 150#pragma warning disable CA1822
 151        //TODO: This is currently unused.
 0152        public string Id => throw new NotImplementedException();
 153#pragma warning restore CA1822
 154
 155        public T Value
 156        {
 157            get
 158            {
 8159                if (!HasValue)
 160                {
 0161                    throw new InvalidOperationException("The operation has not completed yet.");
 162                }
 163
 8164                return _value;
 165            }
 166        }
 167
 52168        public bool HasCompleted => _hasCompleted;
 8169        public bool HasValue => _hasValue;
 170
 171        private HttpMessage CreateRequest(string link)
 172        {
 48173            HttpMessage message = _pipeline.CreateMessage();
 48174            Request request = message.Request;
 48175            request.Method = RequestMethod.Get;
 48176            request.Uri.Reset(new Uri(link));
 48177            return message;
 178        }
 179
 180        private async ValueTask<Response> GetResponseAsync(string link, CancellationToken cancellationToken = default)
 181        {
 48182            if (link == null)
 183            {
 0184                throw new ArgumentNullException(nameof(link));
 185            }
 186
 48187            using DiagnosticScope scope = _clientDiagnostics.CreateScope(_scopeName);
 48188            scope.Start();
 189            try
 190            {
 48191                using HttpMessage message = CreateRequest(link);
 48192                await _pipeline.SendAsync(message, cancellationToken).ConfigureAwait(false);
 48193                return message.Response;
 194            }
 0195            catch (Exception e)
 196            {
 0197                scope.Failed(e);
 0198                throw;
 199            }
 48200        }
 201
 202        private Response GetResponse(string link, CancellationToken cancellationToken = default)
 203        {
 0204            if (link == null)
 205            {
 0206                throw new ArgumentNullException(nameof(link));
 207            }
 208
 0209            using DiagnosticScope scope = _clientDiagnostics.CreateScope(_scopeName);
 0210            scope.Start();
 211            try
 212            {
 0213                using HttpMessage message = CreateRequest(link);
 0214                _pipeline.Send(message, cancellationToken);
 0215                return message.Response;
 216            }
 0217            catch (Exception e)
 218            {
 0219                scope.Failed(e);
 0220                throw;
 221            }
 0222        }
 223
 224        private bool IsTerminalState(out string state)
 225        {
 52226            Response response = GetRawResponse();
 52227            state = string.Empty;
 52228            if (_headerFrom == HeaderFrom.Location)
 229            {
 48230                return response.Status != 202;
 231            }
 232
 4233            if (response.Status >= 200 && response.Status <= 204)
 234            {
 4235                if (response.ContentStream?.Length > 0)
 236                {
 237                    try
 238                    {
 4239                        using JsonDocument document = JsonDocument.Parse(response.ContentStream);
 36240                        foreach (JsonProperty property in document.RootElement.EnumerateObject())
 241                        {
 16242                            if ((_headerFrom == HeaderFrom.OperationLocation ||
 16243                                 _headerFrom == HeaderFrom.AzureAsyncOperation) &&
 16244                                property.NameEquals("status"))
 245                            {
 0246                                state = property.Value.GetString().ToLowerInvariant();
 0247                                return s_terminalStates.Contains(state);
 248                            }
 249
 16250                            if (_headerFrom == HeaderFrom.None && property.NameEquals("properties"))
 251                            {
 12252                                foreach (JsonProperty innerProperty in property.Value.EnumerateObject())
 253                                {
 4254                                    if (innerProperty.NameEquals("provisioningState"))
 255                                    {
 4256                                        state = innerProperty.Value.GetString().ToLowerInvariant();
 4257                                        return s_terminalStates.Contains(state);
 258                                    }
 259                                }
 260                            }
 261                        }
 262                    }
 263                    finally
 264                    {
 265                        // It is required to reset the position of the content after reading as this response may be use
 4266                        response.ContentStream.Position = 0;
 4267                    }
 268                }
 269
 270                // If provisioningState was not found, it defaults to Succeeded.
 0271                if (_headerFrom == HeaderFrom.None)
 272                {
 0273                    return true;
 274                }
 275            }
 276
 0277            throw _clientDiagnostics.CreateRequestFailedException(response);
 4278        }
 279
 280        private enum HeaderFrom
 281        {
 282            None,
 283            OperationLocation,
 284            AzureAsyncOperation,
 285            Location
 286        }
 287
 288        private void InitializeScenarioInfo()
 289        {
 8290            _originalHasLocation = _rawResponse.Headers.Contains("Location");
 291
 8292            if (_rawResponse.Headers.Contains("Operation-Location"))
 293            {
 0294                _headerFrom = HeaderFrom.OperationLocation;
 0295                return;
 296            }
 297
 8298            if (_rawResponse.Headers.Contains("Azure-AsyncOperation"))
 299            {
 0300                _headerFrom = HeaderFrom.AzureAsyncOperation;
 0301                return;
 302            }
 303
 8304            if (_originalHasLocation)
 305            {
 4306                _headerFrom = HeaderFrom.Location;
 4307                return;
 308            }
 309
 4310            _pollUri = _originalUri;
 4311            _headerFrom = HeaderFrom.None;
 4312        }
 313
 314        private void UpdatePollUri()
 315        {
 48316            var hasLocation = _rawResponse.Headers.TryGetValue("Location", out string? location);
 48317            if (hasLocation)
 318            {
 48319                _lastKnownLocation = location;
 320            }
 321
 48322            switch (_headerFrom)
 323            {
 0324                case HeaderFrom.OperationLocation when _rawResponse.Headers.TryGetValue("Operation-Location", out string
 0325                    _pollUri = operationLocation;
 0326                    return;
 0327                case HeaderFrom.AzureAsyncOperation when _rawResponse.Headers.TryGetValue("Azure-AsyncOperation", out st
 0328                    _pollUri = azureAsyncOperation;
 0329                    return;
 48330                case HeaderFrom.Location when hasLocation:
 48331                    _pollUri = location!;
 48332                    return;
 333            }
 0334        }
 335
 336        private string? GetFinalUri()
 337        {
 8338            if (_headerFrom == HeaderFrom.OperationLocation || _headerFrom == HeaderFrom.AzureAsyncOperation)
 339            {
 0340                if (_requestMethod == RequestMethod.Delete)
 341                {
 0342                    return null;
 343                }
 344
 0345                if (_requestMethod == RequestMethod.Put || (_originalHasLocation && _finalStateVia == OperationFinalStat
 346                {
 0347                    return _originalUri;
 348                }
 349
 0350                if (_originalHasLocation && _finalStateVia == OperationFinalStateVia.Location)
 351                {
 0352                    return _lastKnownLocation;
 353                }
 354            }
 355
 8356            return null;
 357        }
 358    }
 359}
Generated by: ReportGenerator 4.6.4.0
8/12/2020 - 3:46:45 PM
GitHub | www.palmmedia.de

Methods/Properties

get_DefaultPollingInterval()
.cctor()
.ctor(...)
GetRawResponse()
WaitForCompletionAsync(...)
WaitForCompletionAsync()
UpdateStatusAsync()
UpdateStatusAsync()
UpdateStatus(...)
get_Id()
get_Value()
get_HasCompleted()
get_HasValue()
CreateRequest(...)
GetResponseAsync()
GetResponse(...)
IsTerminalState(...)
InitializeScenarioInfo()
UpdatePollUri()
GetFinalUri()