Synnefo » Pithos MS Client

using System;

using System.ComponentModel.Composition;

using System.Diagnostics;

using System.Diagnostics.Contracts;

using System.IO;

using System.Net;

using System.Reflection;

using System.Threading.Tasks;

using Pithos.Interfaces;

using Pithos.Network;

        public IStatusNotification StatusNotification { get; set; }

        {

            if (action == null)

                throw new ArgumentNullException("action");

            {

                try

                {

                    var fileInfo = action.LocalFile;

                    if (fileInfo.Extension.Equals("ignore", StringComparison.InvariantCultureIgnoreCase))

                        return;

                    //Try to load the action's local state, if it is empty

                    if (action.FileState == null)

                        action.FileState = StatusKeeper.GetStateByFilePath(fileInfo.FullName);

                            }

                            if (fileInfo is DirectoryInfo)

                            {

                                //If the directory doesn't exist the Hash property will be empty

                                //Upload even small files using the Hashmap. The server may already contain

                                //the relevant block                                

                            }

                            //If everything succeeds, change the file and overlay status to normal

                            StatusKeeper.SetFileState(fullFileName, FileStatus.Unchanged, FileOverlayStatus.Normal, "");

        }

        {

            if (accountInfo == null)

                throw new ArgumentNullException("accountInfo");

                throw new ArgumentException("Invalid container", "cloudFile");

            Contract.EndContractBlock();

            using (StatusNotification.GetNotifier("Uploading {0}", "Finished Uploading {0}", fileInfo.Name))

            {

                var fullFileName = fileInfo.GetProperCapitalization();

                var account = cloudFile.Account ?? accountInfo.UserName;

                var container = cloudFile.Container;

                var client = new CloudFilesClient(accountInfo);

                //Send the hashmap to the server            

                var missingHashes = await client.PutHashMap(account, container, url, treeHash);

                while (missingHashes.Count > 0)

                {

                    var buffer = new byte[accountInfo.BlockSize];

                    foreach (var missingHash in missingHashes)

                    {

                        //Find the proper block

                        var blockIndex = treeHash.HashDictionary[missingHash];

                        long offset = blockIndex*accountInfo.BlockSize;

                        ReportUploadProgress(fileInfo.Name, block++, missingHashes.Count, fileInfo.Length);

                    }

                    //Repeat until there are no more missing hashes                

                    missingHashes = await client.PutHashMap(account, container, url, treeHash);

                }

            }

            return false;

        }

    }

}