From 5b2410da3faf4c3478948d3f3e2ced947ccf0296 Mon Sep 17 00:00:00 2001
From: Keivan Beigi <kay.one@gmail.com>
Date: Thu, 30 May 2013 16:32:50 -0700
Subject: [PATCH] non-working cached repository.

---
 NzbDrone.Common/Cache/CacheManger.cs          | 16 +++++++-
 NzbDrone.Common/Cache/Cached.cs               | 15 +++++++
 NzbDrone.Common/Cache/ICached.cs              | 14 +++++--
 NzbDrone.Core/Datastore/BasicRepository.cs    | 11 +++++
 .../Datastore/CachedBasicRepository.cs        | 40 +++++++++++++++++++
 NzbDrone.Core/NzbDrone.Core.csproj            |  1 +
 6 files changed, 92 insertions(+), 5 deletions(-)
 create mode 100644 NzbDrone.Core/Datastore/CachedBasicRepository.cs

diff --git a/NzbDrone.Common/Cache/CacheManger.cs b/NzbDrone.Common/Cache/CacheManger.cs
index b5ab02844..beba81651 100644
--- a/NzbDrone.Common/Cache/CacheManger.cs
+++ b/NzbDrone.Common/Cache/CacheManger.cs
@@ -1,4 +1,5 @@
 using System;
+using System.Collections.Generic;
 using NzbDrone.Common.EnsureThat;
 
 namespace NzbDrone.Common.Cache
@@ -7,15 +8,18 @@ public interface ICacheManger
     {
         ICached<T> GetCache<T>(Type host, string name);
         ICached<T> GetCache<T>(Type host);
+        //ICollection<ICached<T>> Caches<T> { get;}
+        void Clear();
+        ICollection<ICached> Caches { get; }
     }
 
     public class CacheManger : ICacheManger
     {
-        private readonly ICached<object> _cache;
+        private readonly ICached<ICached> _cache;
 
         public CacheManger()
         {
-            _cache = new Cached<object>();
+            _cache = new Cached<ICached>();
 
         }
 
@@ -25,6 +29,14 @@ public ICached<T> GetCache<T>(Type host)
             return GetCache<T>(host, host.FullName);
         }
 
+
+        public void Clear()
+        {
+            _cache.Clear();
+        }
+
+        public ICollection<ICached> Caches { get { return _cache.Values; } }
+
         public ICached<T> GetCache<T>(Type host, string name)
         {
             Ensure.That(() => host).IsNotNull();
diff --git a/NzbDrone.Common/Cache/Cached.cs b/NzbDrone.Common/Cache/Cached.cs
index 59ac622c7..de5680b8e 100644
--- a/NzbDrone.Common/Cache/Cached.cs
+++ b/NzbDrone.Common/Cache/Cached.cs
@@ -64,5 +64,20 @@ public void Remove(string key)
             T value;
             _store.TryRemove(key, out value);
         }
+
+        public ICollection<T> Values
+        {
+            get
+            {
+                return _store.Values;
+            }
+        }
+        public ICollection<string> Keys
+        {
+            get
+            {
+                return _store.Keys;
+            }
+        }
     }
 }
\ No newline at end of file
diff --git a/NzbDrone.Common/Cache/ICached.cs b/NzbDrone.Common/Cache/ICached.cs
index cd4fc9e28..599479f7c 100644
--- a/NzbDrone.Common/Cache/ICached.cs
+++ b/NzbDrone.Common/Cache/ICached.cs
@@ -1,15 +1,23 @@
 using System;
+using System.Collections.Generic;
 
 namespace NzbDrone.Common.Cache
 {
-    public interface ICached<T>
+    public interface ICached
     {
-        void Set(string key, T value);
-        T Get(string key, Func<T> function);
         bool ContainsKey(string key);
         void Clear();
         void Remove(string key);
+    }
+
+    public interface ICached<T> : ICached
+    {
+        void Set(string key, T value);
+        T Get(string key, Func<T> function);
         T Get(string key);
         T Find(string key);
+
+        ICollection<T> Values { get; }
+        ICollection<string> Keys { get; }
     }
 }
\ No newline at end of file
diff --git a/NzbDrone.Core/Datastore/BasicRepository.cs b/NzbDrone.Core/Datastore/BasicRepository.cs
index 18f6bf3b7..0a9bdb453 100644
--- a/NzbDrone.Core/Datastore/BasicRepository.cs
+++ b/NzbDrone.Core/Datastore/BasicRepository.cs
@@ -32,6 +32,7 @@ namespace NzbDrone.Core.Datastore
         TModel Single();
     }
 
+
     public class BasicRepository<TModel> : IBasicRepository<TModel> where TModel : ModelBase, new()
     {
         private readonly IDatabase _database;
@@ -202,6 +203,16 @@ private void PublishModelEvent(TModel model, RepositoryAction action)
             }
         }
 
+        protected virtual void OnModelChanged(IEnumerable<TModel> models)
+        {
+
+        }
+
+        protected virtual void OnModelDeleted(IEnumerable<TModel> models)
+        {
+
+        }
+
         protected virtual bool PublishModelEvents
         {
             get { return false; }
diff --git a/NzbDrone.Core/Datastore/CachedBasicRepository.cs b/NzbDrone.Core/Datastore/CachedBasicRepository.cs
new file mode 100644
index 000000000..1938af390
--- /dev/null
+++ b/NzbDrone.Core/Datastore/CachedBasicRepository.cs
@@ -0,0 +1,40 @@
+using System.Collections.Generic;
+using NzbDrone.Common.Cache;
+using NzbDrone.Common.Messaging;
+
+namespace NzbDrone.Core.Datastore
+{
+    public abstract class CachedBasicRepository<TModel> : BasicRepository<TModel> where TModel : ModelBase, new()
+    {
+        private readonly ICacheManger _cacheManger;
+
+        protected CachedBasicRepository(IDatabase database, IMessageAggregator messageAggregator)
+            : base(database, messageAggregator)
+        {
+            _cacheManger = new CacheManger();
+        }
+
+        protected ICached<T> GetCache<T>(string name)
+        {
+            return _cacheManger.GetCache<T>(GetType(), name);
+        }
+
+        protected override void OnModelChanged(IEnumerable<TModel> models)
+        {
+            PurgeCache();
+        }
+
+        protected override void OnModelDeleted(IEnumerable<TModel> models)
+        {
+            PurgeCache();
+        }
+
+        private void PurgeCache()
+        {
+            foreach (var model in _cacheManger.Caches)
+            {
+                model.Clear();
+            }
+        }
+    }
+}
\ No newline at end of file
diff --git a/NzbDrone.Core/NzbDrone.Core.csproj b/NzbDrone.Core/NzbDrone.Core.csproj
index 5f2559af5..bc485a87d 100644
--- a/NzbDrone.Core/NzbDrone.Core.csproj
+++ b/NzbDrone.Core/NzbDrone.Core.csproj
@@ -193,6 +193,7 @@
     <Compile Include="DataAugmentation\Scene\SceneMappingProxy.cs" />
     <Compile Include="DataAugmentation\Scene\SceneMappingRepository.cs" />
     <Compile Include="DataAugmentation\Scene\UpdateSceneMappingCommand.cs" />
+    <Compile Include="Datastore\CachedBasicRepository.cs" />
     <Compile Include="Datastore\Converters\BooleanIntConverter.cs" />
     <Compile Include="Datastore\Converters\QualityIntConverter.cs" />
     <Compile Include="Datastore\Converters\Int32Converter.cs" />