Synnefo » Pithos MS Client

using System.Security.Cryptography;

using Castle.ActiveRecord.Framework;

                        queue.NotifyComplete(action);

            var pairs = currentFiles.Union(deletedFiles).ToList();

            using (var shortHasher = HashAlgorithm.Create("sha1"))

                foreach (var pair in pairs)

                    var fileState = pair.State;

                    var file = pair.File;

                    if (fileState == null)

                        //This is a new file                        

                        var createState = FileState.CreateFor(file);

                        _persistenceAgent.Post(createState.Create);                        

                    }

                    else if (file == null)

                    {

                        //This file was deleted while we were down. We should mark it as deleted

                        //We have to go through UpdateStatus here because the state object we are using

                        //was created by a different ORM session.

                        _persistenceAgent.Post(() => UpdateStatusDirect(fileState.Id, FileStatus.Deleted));

                    }

                    else

                    {

                        //This file has a matching state. Need to check for possible changes

                        //To check for changes, we use the cheap (in CPU terms) SHA1 algorithm

                        //on the entire file.

                        var hashString = file.ComputeShortHash(shortHasher);                        

                        //TODO: Need a way to attach the hashes to the filestate so we don't

                        //recalculate them each time a call to calculate has is made

                        //We can either store them to the filestate or add them to a 

                        //dictionary

                        //If the hashes don't match the file was changed

                        if (fileState.ShortHash != hashString)

                        {

                            _persistenceAgent.Post(() => UpdateStatusDirect(fileState.Id, FileStatus.Modified));

                        }

                    }

            }

                using (var command = new SQLiteCommand("select Id, FilePath, OverlayStatus,FileStatus ,Checksum ,ShortHash,Version    ,VersionTimeStamp,IsShared   ,SharedBy   ,ShareWrite  from FileState where FilePath=:path COLLATE NOCASE", connection))

                                                ShortHash= reader.IsDBNull(5)?"":reader.GetString(5),

                                                Version = reader.IsDBNull(6)?default(long):reader.GetInt64(6),

                                                VersionTimeStamp = reader.IsDBNull(7)?default(DateTime):reader.GetDateTime(7),

                                                IsShared = !reader.IsDBNull(8) && reader.GetBoolean(8),

                                                SharedBy = reader.IsDBNull(9)?"":reader.GetString(9),

                                                ShareWrite = !reader.IsDBNull(10) && reader.GetBoolean(10)

       /* public void SetFileOverlayStatus(string path, FileOverlayStatus overlayStatus)

        }*/

        public Task SetFileOverlayStatus(string path, FileOverlayStatus overlayStatus, string shortHash = null)

        {

            if (String.IsNullOrWhiteSpace(path))

                throw new ArgumentNullException("path");

            if (!Path.IsPathRooted(path))

                throw new ArgumentException("The path must be rooted","path");

            Contract.EndContractBlock();

            return _persistenceAgent.PostAndAwait(() => FileState.StoreOverlayStatus(path,overlayStatus,shortHash));

                            "INSERT INTO FileState (Id,FilePath,Checksum,Version,VersionTimeStamp,ShortHash,FileStatus,OverlayStatus) VALUES (:id,:path,:checksum,:version,:versionTimeStamp,:shortHash,:fileStatus,:overlayStatus)";

                    command.Parameters.AddWithValue("shortHash", "");

        public void EnsureFileState(string path)

        {

            var existingState = GetStateByFilePath(path);

            if (existingState != null)

                return;

            var fileInfo = FileInfoExtensions.FromPath(path);

            using (new SessionScope())

            {

                var newState = FileState.CreateFor(fileInfo);

                newState.FileStatus=FileStatus.Missing;

                _persistenceAgent.PostAndAwait(newState.CreateAndFlush).Wait();

            }

        }

        public void UpdateFileChecksum(string path, string shortHash, string checksum)

            _persistenceAgent.Post(() => FileState.UpdateChecksum(path, shortHash,checksum));