Make sure we always create a valid index if the database has old/inva…

…lid json data Fixes #1319
github · Feb 1, 2018 · ac16e66 · ac16e66
1 parent f10ea7d
commit ac16e66
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/GitHub.App/Caches/CacheIndex.cs b/src/GitHub.App/Caches/CacheIndex.cs
@@ -62,6 +62,7 @@ public CacheIndex Add(string indexKey, CacheItem item)
             Guard.ArgumentNotNull(item, nameof(item));
 
             return cache.GetOrCreateObject(indexKey, () => Create(indexKey))
+                .Select(x => x.IndexKey == null ? Create(indexKey) : x)
                 .Do(index =>
                 {
                     var k = string.Format(CultureInfo.InvariantCulture, "{0}|{1}", index.IndexKey, item.Key);

diff --git a/src/GitHub.App/Extensions/AkavacheExtensions.cs b/src/GitHub.App/Extensions/AkavacheExtensions.cs
@@ -200,7 +200,11 @@ public static class AkavacheExtensions
             bool shouldInvalidateOnError = false)
                 where T : CacheItem
         {
-            var idx = Observable.Defer(() => This.GetOrCreateObject(key, () => CacheIndex.Create(key))).Replay().RefCount();
+            var idx = Observable.Defer(() => This
+                                            .GetOrCreateObject(key, () => CacheIndex.Create(key)))
+                                            .Select(x => x.IndexKey == null ? CacheIndex.Create(key) : x)
+                                            .Replay()
+                                            .RefCount();
 
 
             var fetch = idx
@@ -264,6 +268,7 @@ public static class AkavacheExtensions
             {
                 var absoluteExpiration = blobCache.Scheduler.Now + maxCacheDuration;
                 return blobCache.GetOrCreateObject(key, () => CacheIndex.Create(key))
+                    .Select(x => x.IndexKey == null ? CacheIndex.Create(key) : x)
                     .SelectMany(index => fetchFunc()
                             .Catch<T, Exception>(Observable.Throw<T>)
                             .SelectMany(x => x.Save<T>(blobCache, key, absoluteExpiration))