Synnefo » Pithos MS Client

using System;

using System.Collections.Generic;

using System.ComponentModel.Composition;

using System.Diagnostics.Contracts;

using System.IO;

using System.Linq;

using Hammock.Caching;

using Hammock.Retries;

using Hammock.Serialization;

using Hammock.Web;

using Newtonsoft.Json;

using Pithos.Interfaces;

        private string _pithosAuthUrl = "http://pithos.dev.grnet.gr";

        private RestClient _client;

        private readonly int _retries = 5;

        public string ApiKey { get; set; }

        public string UserName { get; set; }

        public Uri StorageUrl { get; set; }

        public string Token { get; set; }

        public string AuthUrl

        {

            string authUrl = UsePithos ? String.Format("{0}/{1}/{2}", AuthUrl, VersionPath,UserName) 

                                    : String.Format("{0}/{1}", AuthUrl, VersionPath);

            authClient.AddHeader("X-Auth-User", UserName);

            authClient.AddHeader("X-Auth-Key", ApiKey);            

            var retryPolicy = new RetryPolicy { RetryCount = _retries };

            retryPolicy.RetryConditions.Add(new TimeoutRetryCondition());

            _client.AddHeader("X-Auth-Token", Token);

            if (UsePithos)

            //appends a / unless a Path is specified.

            //Create a request with a complete path

            request.AddParameter("format","json");

            //Create a client clone

            foreach (var header in _client.GetAllHeaders())

            {

                client.AddHeader(header.Name,header.Value);

            var response = client.Request(request);

            if (response.StatusCode == HttpStatusCode.NoContent)

                return new List<ContainerInfo>();

            var infos=JsonConvert.DeserializeObject<IList<ContainerInfo>>(response.Content);

            return infos;

            if (String.IsNullOrWhiteSpace(container))

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

            request.AddParameter("format", "json");

            var response = _client.Request(request);

            return infos;

        }

        public IList<ObjectInfo> ListObjects(string container,string folder)

        {

            if (String.IsNullOrWhiteSpace(container))

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

            request.AddParameter("format", "json");

            request.AddParameter("path", folder);

            var response = _client.Request(request);

            if (response.TimedOut)

                return new List<ObjectInfo>();

            if (response.StatusCode == HttpStatusCode.NoContent)

                return new List<ObjectInfo>();

            return infos;

        }

            if (String.IsNullOrWhiteSpace(container))

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

            var response = _client.Request(request);

            switch(response.StatusCode)

            if (String.IsNullOrWhiteSpace(objectName))

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

            var response = _client.Request(request);

            switch (response.StatusCode)

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

            var response = _client.Request(request);

            if (response.TimedOut)

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

            var folderUrl=String.Format("{0}/{1}",container,folder);

            request.AddHeader("Content-Type", @"application/directory");

            request.AddHeader("Content-Length", "0");

            if (String.IsNullOrWhiteSpace(container))

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

            var response = _client.Request(request);

            switch(response.StatusCode)

            if (String.IsNullOrWhiteSpace(container))

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

            var response = _client.Request(request);

            if (String.IsNullOrWhiteSpace(container))

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

            var response = _client.Request(request);

            if (response.StatusCode == HttpStatusCode.NotFound || response.StatusCode == HttpStatusCode.NoContent)

        }

        public Stream GetObject(string container, string objectName)

        {

            if (String.IsNullOrWhiteSpace(container))

                throw new WebException(String.Format("GetObject failed with unexpected status code {0}", response.StatusCode));

        }

        public void PutObject(string container, string objectName, string fileName)

        {

            if (String.IsNullOrWhiteSpace(container))

            string url = container + "/" + objectName;

            var request = new RestRequest {Path=url,Method=WebMethod.Put};           

            string hash = CalculateHash(fileName);

            request.AddPostContent(File.ReadAllBytes(fileName));

            request.AddHeader("Content-Type","application/octet-stream");

            request.AddHeader("ETag",hash);

            if (response.StatusCode == HttpStatusCode.Created)

                return;

            if (response.StatusCode == HttpStatusCode.LengthRequired)

            if (String.IsNullOrWhiteSpace(objectName))

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

            var response = _client.Request(request);

            if (response.StatusCode == HttpStatusCode.NotFound || response.StatusCode == HttpStatusCode.NoContent)