Synnefo » Pithos MS Client

        public static void StoreFileStatus(string absolutePath, FileStatus newStatus)

        {

            if (string.IsNullOrWhiteSpace(absolutePath))

                throw new ArgumentNullException("absolutePath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set FileStatus= :status where FilePath = :path  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("path", absolutePath.ToLower())

                        .SetEnum("status", newStatus)

                        .ExecuteUpdate();

                if (updatedEntities == 0)

                {

                    var newState = new FileState { FilePath = absolutePath, Id = Guid.NewGuid(), FileStatus = newStatus };

                    newState.CreateAndFlush();

                }

                return null;

            }, null);

        }

        public static void StoreOverlayStatus(string absolutePath, FileOverlayStatus newStatus)

        {

            if (string.IsNullOrWhiteSpace(absolutePath))

                throw new ArgumentNullException("absolutePath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set OverlayStatus= :status where FilePath = :path  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("path", absolutePath.ToLower())

                        .SetEnum("status", newStatus)

                        .ExecuteUpdate();

                if (updatedEntities == 0)

                {

                    var newState = new FileState { FilePath = absolutePath, Id = Guid.NewGuid(), OverlayStatus = newStatus };

                    newState.CreateAndFlush();

                }

                return null;

            }, null);

        }

        public static void UpdateStatus(string absolutePath, FileStatus fileStatus, FileOverlayStatus overlayStatus)

        {

            if (string.IsNullOrWhiteSpace(absolutePath))

                throw new ArgumentNullException("absolutePath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set OverlayStatus= :overlayStatus, FileStatus= :fileStatus where FilePath = :path  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("path", absolutePath.ToLower())

                        .SetEnum("fileStatus", fileStatus)

                        .SetEnum("overlayStatus", overlayStatus)

                        .ExecuteUpdate();

                return null;

            }, null);

        }

        public static void UpdateStatus(string absolutePath, FileStatus fileStatus)

        {

            if (string.IsNullOrWhiteSpace(absolutePath))

                throw new ArgumentNullException("absolutePath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set FileStatus= :fileStatus where FilePath = :path  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("path", absolutePath.ToLower())

                        .SetEnum("fileStatus", fileStatus)                        

                        .ExecuteUpdate();

                return updatedEntities;

            }, null);

        }

        public static void RenameState(string oldPath, string newPath)

        {

            if (string.IsNullOrWhiteSpace(oldPath))

                throw new ArgumentNullException("oldPath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set FilePath= :newPath where FilePath = :oldPath  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("oldPath", oldPath.ToLower())

                        .SetString("newPath", newPath.ToLower())                                          

                        .ExecuteUpdate();

                return updatedEntities;

            }, null);

        }

        public static void UpdateStatus(Guid id, FileStatus fileStatus)

        {

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set FileStatus= :fileStatus where Id = :id  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetGuid("id", id)

                        .SetEnum("fileStatus", fileStatus)                        

                        .ExecuteUpdate();

                return null;

            }, null);

        }

        public static void UpdateChecksum(string absolutePath, string checksum)

        {

            if (string.IsNullOrWhiteSpace(absolutePath))

                throw new ArgumentNullException("absolutePath");

            Contract.EndContractBlock();

            Execute((session, instance) =>

            {

                const string hqlUpdate = "update FileState set Checksum= :checksum where FilePath = :path  ";

                var updatedEntities = session.CreateQuery(hqlUpdate)

                        .SetString("path", absolutePath.ToLower())

                        .SetString("checksum", checksum)                        

                        .ExecuteUpdate();

                return null;

            }, null);

        }