﻿/*
 * ******************************************************************************
 *   Copyright 2014 Spectra Logic Corporation. All Rights Reserved.
 *   Licensed under the Apache License, Version 2.0 (the "License"). You may not use
 *   this file except in compliance with the License. A copy of the License is located at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 *   or in the "license" file accompanying this file.
 *   This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 *   CONDITIONS OF ANY KIND, either express or implied. See the License for the
 *   specific language governing permissions and limitations under the License.
 * ****************************************************************************
 */

using Ds3.Calls;
using Ds3.Runtime;
using System;
using System.Linq;
using System.Net;

namespace Ds3.ResponseParsers
{
    internal class GetAvailableJobChunksResponseParser : IResponseParser<GetAvailableJobChunksRequest, GetAvailableJobChunksResponse>
    {
        public GetAvailableJobChunksResponse Parse(GetAvailableJobChunksRequest request, IWebResponse response)
        {
            using (response)
            {
                ResponseParseUtilities.HandleStatusCode(response, HttpStatusCode.OK, HttpStatusCode.NotFound);
                using (var responseStream = response.GetResponseStream())
                {
                    switch (response.StatusCode)
                    {
                        case HttpStatusCode.OK:
                            var jobResponse = JobResponseParser<GetAvailableJobChunksRequest>.ParseResponseContent(responseStream);
                            if (jobResponse.ObjectLists.Any())
                            {
                                return GetAvailableJobChunksResponse.Success(RetryAfterHeader(response), jobResponse);
                            }
                            return GetAvailableJobChunksResponse.RetryAfter(RetryAfterHeader(response));

                        case HttpStatusCode.NotFound:
                            return GetAvailableJobChunksResponse.JobGone;

                        default:
                            throw new NotSupportedException(Resources.InvalidEnumValueException);
                    }
                }
            }
        }

        private static TimeSpan RetryAfterHeader(IWebResponse response)
        {
            return TimeSpan.FromSeconds(int.Parse(response.Headers["retry-after"]));
        }
    }
}
