Logging changes, first changes to multi account support

[pithos-ms-client] / trunk / Pithos.Core.Test / MockStatusKeeper.cs

diff --git a/trunk/Pithos.Core.Test/MockStatusKeeper.cs b/trunk/Pithos.Core.Test/MockStatusKeeper.cs
index 577b7fc..0d91029 100644 (file)
--- a/trunk/Pithos.Core.Test/MockStatusKeeper.cs
+++ b/trunk/Pithos.Core.Test/MockStatusKeeper.cs
@@ -1,9 +1,13 @@
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
 using System.Diagnostics.Contracts;
+using System.IO;
 using System.Linq;
 using System.Text;
+using System.Threading;
 using Pithos.Interfaces;
+using Pithos.Network;
 
 namespace Pithos.Core.Test
 {
@@ -13,15 +17,15 @@ namespace Pithos.Core.Test
 
         private readonly string[] _states = { "Normal", "Modified", "Conflict", "Synch" };
 
-        Dictionary<string, FileOverlayStatus> _overlayCache = new Dictionary<string, FileOverlayStatus>();
-        Dictionary<string, FileStatus> _statusCache = new Dictionary<string, FileStatus>();
-        Dictionary<string, string> _checksums = new Dictionary<string, string>();
+        ConcurrentDictionary<string, FileOverlayStatus> _overlayCache = new ConcurrentDictionary<string, FileOverlayStatus>();
+        ConcurrentDictionary<string, FileStatus> _statusCache = new ConcurrentDictionary<string, FileStatus>();
+        ConcurrentDictionary<string, string> _checksums = new ConcurrentDictionary<string, string>();
 
         public FileOverlayStatus GetFileOverlayStatus(string path)
         {
             Contract.Requires(!String.IsNullOrWhiteSpace(path));
             if (!_overlayCache.ContainsKey(path))
-                return FileOverlayStatus.NA;
+                return FileOverlayStatus.Unversioned;
 
             var pithosPath = Settings.PithosPath;
             if (path.StartsWith(pithosPath, true, null))
@@ -29,12 +33,114 @@ namespace Pithos.Core.Test
                 var status = _overlayCache[path];
                 return status;
             }
-            return FileOverlayStatus.NA;
+            return FileOverlayStatus.Unversioned;
+        }
+
+        public void ProcessExistingFiles(IEnumerable<FileInfo> paths)
+        {
+
+            var newFiles = (from file in paths
+                            where !_overlayCache.ContainsKey(file.FullName)
+                            select new
+                            {
+                                FilePath = file.FullName.ToLower(),
+                                OverlayStatus = FileOverlayStatus.Unversioned,
+                                FileStatus = FileStatus.Created,
+                                Checksum = Signature.CalculateMD5(file)
+                            });
+            var files = new ConcurrentBag<string>();
+            foreach (var state in newFiles)
+            {            
+                _overlayCache[state.FilePath] = state.OverlayStatus;
+                _statusCache[state.FilePath] = state.FileStatus;
+                _checksums[state.FilePath] = state.Checksum;
+                files.Add(state.FilePath);
+            }            
+            
+        }
+
+        public void Stop()
+        {
+            throw new NotImplementedException();
+        }
+
+        public void SetFileState(string path, FileStatus fileStatus, FileOverlayStatus overlayStatus)
+        {
+            if (String.IsNullOrWhiteSpace(path))
+                throw new ArgumentNullException("path", "path can't be empty");
+            SetFileStatus(path, fileStatus);
+            SetFileOverlayStatus(path, overlayStatus);
+        }
+
+        public void StoreInfo(string path, ObjectInfo objectInfo)
+        {
+            if (String.IsNullOrWhiteSpace(path))
+                throw new ArgumentNullException("path", "path can't be empty");
+            if (objectInfo == null)
+                throw new ArgumentNullException("objectInfo", "objectInfo can't be empty");
+
+            _statusCache[path] = FileStatus.Unchanged;
+            _overlayCache[path] = FileOverlayStatus.Normal;
+            _checksums[path] = objectInfo.Hash;
+
+
+        }
+
+        public T GetStatus<T>(string path, Func<FileState, T> getter, T defaultValue)
+        {
+            throw new NotImplementedException();
+        }
+
+        public void SetStatus(string path, Action<FileState> setter)
+        {
+            throw new NotImplementedException();
+        }
+
+        ConcurrentDictionary<string, NetworkOperation> _networkState = new ConcurrentDictionary<string, NetworkOperation>();
+
+
+        public void SetNetworkState(string path, NetworkOperation operation)
+        {
+            _networkState[path.ToLower()] = operation;
+            //Removing may fail so we store the "None" value anyway
+            if (operation == NetworkOperation.None)
+            {
+                NetworkOperation oldOperation;
+                _networkState.TryRemove(path, out oldOperation);
+            }
+        }
+
+        public NetworkOperation GetNetworkState(string path)
+        {
+            NetworkOperation operation;
+            if (_networkState.TryGetValue(path, out operation))
+                return operation;
+            return NetworkOperation.None;
+        }
+
+        public void StartProcessing(CancellationToken token)
+        {
+            
+        }
+
+        public string BlockHash { get; set; }
+
+        public int BlockSize { get; set; }
+        public void ChangeRoots(string oldPath, string newPath)
+        {
+            throw new NotImplementedException();
+        }
+
+
+        private PithosStatus _pithosStatus = PithosStatus.InSynch;
+        public void SetPithosStatus(PithosStatus status)
+        {
+            _pithosStatus = status;
         }
 
         public PithosStatus GetPithosStatus()
         {
-            return PithosStatus.InSynch;
+            return _pithosStatus;
         }
 
         public void SetFileOverlayStatus(string path, FileOverlayStatus overlayStatus)
@@ -44,14 +150,16 @@ namespace Pithos.Core.Test
 
         public void RemoveFileOverlayStatus(string path)
         {
-            _overlayCache.Remove(path);
+            FileOverlayStatus value;
+            _overlayCache.TryRemove(path, out value);
         }
 
         public void RenameFileOverlayStatus(string oldPath, string newPath)
         {
             var status = _overlayCache[oldPath];
             _overlayCache[newPath] = status;
-            _overlayCache.Remove(oldPath);
+            FileOverlayStatus value;
+            _overlayCache.TryRemove(oldPath, out value);
         }
 
         public void UpdateFileChecksum(string path, string checksum)
@@ -73,7 +181,8 @@ namespace Pithos.Core.Test
 
         public void ClearFileStatus(string path)
         {
-            _statusCache.Remove(path);
+            FileStatus value;
+            _statusCache.TryRemove(path,out value);
         }
     }
 }