Synnefo » Pithos MS Client

      <DependentUpon>ProxyAccountView.xaml</DependentUpon>

    </Compile>

    <Compile Include="Preferences\ProxyAccountViewModel.cs" />

    <Compile Include="Proxy.cs" />

    <Compile Include="Shell\AboutView.xaml.cs">

      <DependentUpon>AboutView.xaml</DependentUpon>

// General Information about an assembly is controlled through the following 

// set of attributes. Change these attribute values to modify the information

// associated with an assembly.

[assembly: AssemblyTitle("Pithos+ Client for Windows")]

[assembly: AssemblyDescription("Pithos+ Client for Windows")]

[assembly: AssemblyConfiguration("")]

[assembly: AssemblyTrademark("")]

[assembly: AssemblyCulture("")]

// Setting ComVisible to false makes the types in this assembly not visible 

// to COM components.  If you need to access a type in this assembly from 

// You can specify all the values or you can default the Build and Revision Numbers 

// by using the '*' as shown below:

// [assembly: AssemblyVersion("1.0.*")]

            }

            var treeHash = Signature.CalculateTreeHashAsync(filePath, accountInfo.BlockSize, accountInfo.BlockHash, 2, new Progress<double>());

            var cloudFile = new ObjectInfo {Account = account, Container = "pithos"};

                var container = cloudFile.Container;//?? FolderConstants.PithosContainer;

                var client = new CloudFilesClient(accountInfo);

                StatusKeeper.ClearFileStatus(fullPath);

                StatusNotification.Notify(new CloudNotification{Data=cloudFile});

            //Ignore takes into account Selective Sync

            if (Ignore(fullPath))

                return;

            _eventIdleBatch.Post(e);

        }

        readonly ConcurrentQueue<IEnumerable<string>> _batchQueue=new ConcurrentQueue<IEnumerable<string>>();

        /// <summary>

        /// Remote files are polled periodically. Any changes are processed

        /// </summary>

                            var accountBatch = batch.Where(path => path.IsAtOrBelow(account.AccountPath));

                            accountBatches[account.AccountKey] = accountBatch;

                        }

                    var tasks = new List<Task<DateTime?>>();

                    foreach(var accountInfo in _accounts.Values)

                    {

                        IEnumerable<string> accountBatch ;

                        accountBatches.TryGetValue(accountInfo.AccountKey,out accountBatch);

                        tasks.Add(t);

                    }

        {

            if (accountInfo == null)

                throw new ArgumentNullException("accountInfo");

                        var token = _currentOperationCancellation.Token;

                        //Process only the changes in the batch file, if one exists

                        var stateTuples = accountBatch==null?tuples:tuples.Where(t => accountBatch.Contains(t.FilePath));

                            //Set the Merkle Hash

                            //SetMerkleHash(accountInfo, tuple);

                        }

            Pause = false;

        }

        {

            Log.DebugFormat("Sync [{0}] C:[{1}] L:[{2}] S:[{3}]", tuple.FilePath, tuple.C, tuple.L, tuple.S);

                                StatusKeeper.StoreInfo(targetPath, tuple.ObjectInfo);

                            }

                            /*

                                if (isUnselectedRootFolder)

                                {

                                }

                            }

                        }

                                var targetPath = MoveForServerMove(accountInfo, tuple);

                                StatusKeeper.StoreInfo(targetPath, tuple.ObjectInfo);

                            }

                            else

                            {

            }

        }

        {

            //Also ensure that any newly created folders are added to the selectives, if the original folder was selected

            var containerPath = Path.Combine(accountInfo.AccountPath, tuple.ObjectInfo.Container);

            //If this is a root folder encountered for the first time

            if (tuple.L == null && Directory.Exists(tuple.FileInfo.FullName) 

            {

                var relativePath = tuple.ObjectInfo.RelativeUrlToFilePath(accountInfo.UserName);

                var initialPath = Path.Combine(accountInfo.AccountPath, relativePath);

                {

                    Selectives.AddUri(accountInfo, tuple.ObjectInfo.Uri);

                    Selectives.Save(accountInfo);

            }

        }

        {

            var dirInfo = tuple.FileInfo as DirectoryInfo;

                             select new StateTuple(file);

            //Process folders first, to ensure folders appear on the sever as soon as possible

        }

                return results;

         */

        {

            var tuplesByPath = files.ToDictionary(f => f.FullName, f => new StateTuple {FileInfo = f}); new Dictionary<string, StateTuple>();

    <Reference Include="System.Xml" />

  </ItemGroup>

  <ItemGroup>

    <Compile Include="Agents\Agent.cs" />

    <Compile Include="Agents\AgentLocator.cs" />

    <Compile Include="Agents\AsyncAutoResetEvent.cs" />

[assembly: AssemblyTitle("Pithos.Core")]

[assembly: AssemblyDescription("")]

[assembly: AssemblyConfiguration("")]

[assembly: AssemblyProduct("Pithos.Core")]

[assembly: AssemblyTrademark("")]

[assembly: AssemblyCulture("")]

// You can specify all the values or you can default the Build and Revision Numbers 

// by using the '*' as shown below:

// [assembly: AssemblyVersion("1.0.*")]

            var deleted= !_client.ObjectExists(_account, PithosContainer, "File1.txt");

            Assert.That(deleted, Is.True);

        }

        [Test]

            var targetExists = _client.ObjectExists(_account, PithosContainer, "File2.txt");

            Assert.That(targetExists, Is.True);

            var deleted= !_client.ObjectExists(_account, PithosContainer, "File2.txt");

            Assert.That(deleted, Is.True);

    <Reference Include="System.Xml" />

  </ItemGroup>

  <ItemGroup>

    <Compile Include="AccountSettings.cs" />

    <Compile Include="FileInfoExtensions.cs" />

    <Compile Include="FolderConstants.cs" />

[assembly: AssemblyTitle("Pithos.Interfaces")]

[assembly: AssemblyDescription("")]

[assembly: AssemblyConfiguration("")]

[assembly: AssemblyProduct("Pithos.Interfaces")]

[assembly: AssemblyTrademark("")]

[assembly: AssemblyCulture("")]

// You can specify all the values or you can default the Build and Revision Numbers 

// by using the '*' as shown below:

// [assembly: AssemblyVersion("1.0.*")]

            var localInfo = new FileInfo("test.txt");

            client.PutObject(null, "Pithos","RootFolder/Folder1/test.txt","test.txt");

            Assert.IsTrue(client.ObjectExists(null, "Pithos", "RootFolder/Folder1"));

            var folderInfo = client.GetObjectInfo(null, "Pithos", "RootFolder/Folder1");

                Assert.IsTrue(client.ObjectExists(null, "Shares",info.Name),"File Created");

            });

                Assert.IsTrue(client.ObjectExists(null, "Shares",info.Name),"File Created");

                Assert.IsFalse(client.ObjectExists(null, "Shares", info.Name),"Container Deleted");

                Assert.IsFalse(client.ObjectExists(null, "Moo", info.Name),"Container Deleted");

            });

            }

        }

        {            

            if (String.IsNullOrWhiteSpace(sourceContainer))

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

            Contract.EndContractBlock();

            var targetUrl = FolderConstants.TrashContainer + "/" + objectName;

            var sourceUrl = String.Format("/{0}/{1}", sourceContainer, objectName);

            using (var client = new RestClient(_baseClient))

                    var expectedCodes = new[] { HttpStatusCode.OK, HttpStatusCode.NoContent, HttpStatusCode.Created};

                    var result=(expectedCodes.Contains(client.StatusCode));

                    return result;

                }

                catch

        #region Object operations        

        Task GetObject(string account, string container, string objectName, string fileName,CancellationToken cancellationToken);

        Task PutObject(string account, string container, string objectName, string fileName, string hash = null, string contentType = "application/octet-stream");

        //void DeleteObject(string container, string objectName, string account = null);

        void MoveObject(string account, string sourceContainer, string oldObjectName, string targetContainer, string newObjectName);

        bool ObjectExists(string account, string container, string objectName);

            return default(Task);

        }

        {

            Contract.Requires(!String.IsNullOrWhiteSpace(Token));

    <Reference Include="System.Xml" />

  </ItemGroup>

  <ItemGroup>

    <Compile Include="AccountInfo.cs" />

    <Compile Include="BlockHashAlgorithms.cs" />

    <Compile Include="CloudFilesClient.cs" />

[assembly: AssemblyTitle("Pithos.Network")]

[assembly: AssemblyDescription("")]

[assembly: AssemblyConfiguration("")]

[assembly: AssemblyProduct("Pithos.Network")]

[assembly: AssemblyTrademark("")]

[assembly: AssemblyCulture("")]

// You can specify all the values or you can default the Build and Revision Numbers 

// by using the '*' as shown below:

// [assembly: AssemblyVersion("1.0.*")]

    <Reference Include="System.Xml" />

  </ItemGroup>

  <ItemGroup>

    <Compile Include="FileContext.cs" />

    <Compile Include="IoC.cs" />

    <Compile Include="LogCategories.cs" />

[assembly: AssemblyTitle("Pithos.ShellExtensions")]

[assembly: AssemblyDescription("")]

[assembly: AssemblyConfiguration("")]

[assembly: AssemblyProduct("Pithos.ShellExtensions")]

[assembly: AssemblyTrademark("")]

[assembly: AssemblyCulture("")]

// You can specify all the values or you can default the Build and Revision Numbers 

// by using the '*' as shown below:

// [assembly: AssemblyVersion("1.0.*")]