Synnefo » Pithos MS Client

        private const string TOKEN_HEADER = "X-Auth-Token";

        private HttpClient _baseHttpClientNoTimeout;

                _baseClient.Headers[TOKEN_HEADER] = value;

            _baseHttpClient.DefaultRequestHeaders.Add(TOKEN_HEADER, Token);

            _baseHttpClientNoTimeout = new HttpClient(httpClientHandler)

            {

                BaseAddress = StorageUrl,

                Timeout = TimeSpan.FromMilliseconds(-1)

            };

            _baseHttpClientNoTimeout.DefaultRequestHeaders.Add(TOKEN_HEADER, Token);

                    token = response.Headers.GetValues(TOKEN_HEADER).First();

                _baseHttpClient.DefaultRequestHeaders.Add(TOKEN_HEADER, token);

                _baseHttpClientNoTimeout = new HttpClient(httpClientHandler)

                {

                    BaseAddress = StorageUrl,

                    Timeout = TimeSpan.FromMilliseconds(-1)

                };

                _baseHttpClientNoTimeout.DefaultRequestHeaders.Add(TOKEN_HEADER, token);

        public async Task<IList<string>> PutHashMap(string account, Uri container, Uri objectName, TreeHash hash)

        {

            if (container == null)

                throw new ArgumentNullException("container", "The container property can't be empty");

            if (container.IsAbsoluteUri)

                throw new ArgumentException("The container must be relative","container");

            if (objectName == null)

                throw new ArgumentNullException("objectName", "The objectName property can't be empty");

            if (objectName.IsAbsoluteUri)

                throw new ArgumentException("The objectName must be relative","objectName");

            if (hash == null)

                throw new ArgumentNullException("hash");

            if (String.IsNullOrWhiteSpace(Token))

                throw new InvalidOperationException("Invalid Token");

            if (StorageUrl == null)

                throw new InvalidOperationException("Invalid Storage Url");

            Contract.EndContractBlock();

            //The container and objectName are relative names. They are joined with the client's

            //BaseAddress to create the object's absolute address

            var targetUri = GetTargetUri(account).Combine(container).Combine(objectName);

            var uri = new Uri(String.Format("{0}?format=json&hashmap",targetUri),UriKind.Absolute);

            //Send the tree hash as Json to the server            

            var jsonHash = hash.ToJson();

            if (Log.IsDebugEnabled)

                Log.DebugFormat("Hashes:\r\n{0}", jsonHash);

            var message = new HttpRequestMessage(HttpMethod.Put, uri)

            {

                Content = new StringContent(jsonHash)

            };

            message.Headers.Add("ETag",hash.TopHash.ToHashString());

            //Don't use a timeout because putting the hashmap may be a long process

            using(var response=await _baseHttpClientNoTimeout.SendAsyncWithRetries(message,3))

            {

                var empty = (IList<string>)new List<string>();

                switch (response.StatusCode)

                {

                    case HttpStatusCode.Created:

                        //The server will respond either with 201-created if all blocks were already on the server

                        return empty;

                    case HttpStatusCode.Conflict:

                        //or with a 409-conflict and return the list of missing parts

                        using (var stream = await response.Content.ReadAsStreamAsync())

                        using(var reader=stream.GetLoggedReader(Log))

                        {                            

                            var serializer = new JsonSerializer();                            

                            serializer.Error += (sender, args) => Log.ErrorFormat("Deserialization error at [{0}] [{1}]", args.ErrorContext.Error, args.ErrorContext.Member);

                            var hashes = (List<string>)serializer.Deserialize(reader, typeof(List<string>));

                            return hashes;

                        }                        

                    default:

                        //All other cases are unexpected

                        //Ensure that failure codes raise exceptions

                        response.EnsureSuccessStatusCode();

                        //And log any other codes as warngings, but continute processing

                        Log.WarnFormat("Unexcpected status code when putting map: {0} - {1}",response.StatusCode,response.ReasonPhrase);

                        return empty;

                }

            }

        }

/*

*/