Synnefo » Pithos MS Client

using System.Linq;

using System.Net;

using System.Threading.Tasks;

using Castle.ActiveRecord;

using Pithos.Interfaces;

using Pithos.Network;

        private Agent<CloudAction> _agent;

        //A separate agent is used to execute delete actions immediatelly;

        readonly ConcurrentDictionary<string,DateTime> _deletedFiles=new ConcurrentDictionary<string, DateTime>();

        [System.ComponentModel.Composition.Import]

                loop();

            });

                Action loop = null;

                loop = () =>

                            {

                                inbox.LoopAsync(process, loop);

                            };

                loop();

        }

        private async Task Process(CloudAction action)

                    if (IsDeletedFile(action))

                    {

                        //Clear the status of already deleted files to avoid reprocessing

                    }

                    else

                    {

                        var key = GetFileKey(action.CloudFile);

                        _deletedFiles[key]=DateTime.Now;

                        // and then delete the file from the server

                        DeleteCloudFile(accountInfo, cloudFile);

                        Log.InfoFormat("[ACTION] End Delete {0}:{1}->{2}", action.Action, action.LocalFile,

                                       action.CloudFile.Name);

                    }

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

                        if (String.IsNullOrWhiteSpace(info.Hash))

                            //Go on and create the directory

                    }

                    else

                    {