* V16: Cache Version Mechanism (#19747) * Add RepositoryCacheVersion table * Add repository * Add Cache version lock * Add GetAll method to repository * Add RepositoryCacheVersionService * Remember to add lock in data creator * Work my way out of constructor hell This is why we use DI folks. 🤦 * Add checks to specific cache policies * Fix migration * Add to schema creator * Fix database access * Initialize the cache version on in memory miss * Make cache version service internal * Add tests * Apply suggestions from code review Co-authored-by: Andy Butland <abutland73@gmail.com> * Add missing obsoletions * Prefer full name --------- Co-authored-by: Andy Butland <abutland73@gmail.com> * fixed merge * V16/feature/move last synced id to db (#19884) * Foundation work for moving last synced id * register manager and repo in dependency injection * Fixing to make tests work * Replacing the use of the old LastSyncedFileManager.cs with the new LastSyncedManager.cs * Testing to delete out of sync id and old entries * changing some stuff to please the reviewer. * Inverted saving methods id check and fixed documentation mishaps * Loadbalancing: Add Cache Sync service to allow us to roll forward isolated caches when backoffice is load balanced. (#20398) * Split cache refreshers into internal and external caches * Add obsolete constructor for CacheInstructionsPruningJob * Add xml docs * Move lastID management into CacheInstructionService * Cache last synced ids in memory * Lock when processing instructions * Sync caches when out of sync * Fix constructors for ICacheSyncService * Cache version on request * Register caches as synced when instructions are processed * Rename CacheVersionAccessor to IRepositoryCacheVersionAccessor * Set caches as synced before actually syncing the caches * Set caches as synced before syncing, within scope, this should also lock the cache version from being written to whilst updating caches * Only check version for backoffice requests * Clear request cache when caches are syned * Default to using NOOP cache version service * Don't generate local identity in database server messenger anymore * Fix ambiguous constructor * Add helper method to switch to load balanced isolated caches * Fix LastSyncedManagerTests * Fix RepositoryCacheVersionServiceTests * Fix DefaultCachePolicyTests * Use correct constructor in FullDataSetRepositoryCachePolicy * Minor cleanup * Add XML docs * Add more xml docs * Apply suggestions from code review Co-authored-by: Nikolaj Geisle <70372949+Zeegaan@users.noreply.github.com> --------- Co-authored-by: Zeegaan <skrivdetud@gmail.com> Co-authored-by: Nikolaj Geisle <70372949+Zeegaan@users.noreply.github.com> * Fix migration plan * fix tests * Fix integration tests * Fix changes from github review * Move premigrations to v17 * Make lock constantws sequential * Fix comment * Make IRepositoryCacheVersionService and ICacheSyncService protected on EntityRepositoryBase --------- Co-authored-by: Andy Butland <abutland73@gmail.com> Co-authored-by: Nicklas Kramer <nik@umbraco.dk> Co-authored-by: NillasKA <kramernicklas@gmail.com> Co-authored-by: Zeegaan <skrivdetud@gmail.com> Co-authored-by: Nikolaj Geisle <70372949+Zeegaan@users.noreply.github.com>
421 lines
13 KiB
C#
421 lines
13 KiB
C#
// Copyright (c) Umbraco.
|
|
// See LICENSE for more details.
|
|
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Linq;
|
|
using Microsoft.Extensions.Logging;
|
|
using Moq;
|
|
using NUnit.Framework;
|
|
using Umbraco.Cms.Core.Cache;
|
|
using Umbraco.Cms.Core.Configuration.Models;
|
|
using Umbraco.Cms.Core.Models;
|
|
using Umbraco.Cms.Core.Persistence.Repositories;
|
|
using Umbraco.Cms.Infrastructure.Persistence.Repositories.Implement;
|
|
using Umbraco.Cms.Infrastructure.Scoping;
|
|
using Umbraco.Cms.Tests.Common.Builders;
|
|
using Umbraco.Cms.Tests.Common.Testing;
|
|
using Umbraco.Cms.Tests.Integration.Testing;
|
|
|
|
namespace Umbraco.Cms.Tests.Integration.Umbraco.Infrastructure.Persistence.Repositories;
|
|
|
|
[TestFixture]
|
|
[UmbracoTest(Database = UmbracoTestOptions.Database.NewSchemaPerTest)]
|
|
internal sealed class DomainRepositoryTest : UmbracoIntegrationTest
|
|
{
|
|
private ILanguageRepository LanguageRepository => GetRequiredService<ILanguageRepository>();
|
|
|
|
private IDocumentRepository DocumentRepository => GetRequiredService<IDocumentRepository>();
|
|
|
|
private IContentTypeRepository ContentTypeRepository => GetRequiredService<IContentTypeRepository>();
|
|
|
|
private DomainRepository CreateRepository(IScopeProvider provider)
|
|
{
|
|
var accessor = (IScopeAccessor)provider;
|
|
var domainRepository =
|
|
new DomainRepository(accessor, AppCaches.NoCache, LoggerFactory.CreateLogger<DomainRepository>(), Mock.Of<IRepositoryCacheVersionService>(), Mock.Of<ICacheSyncService>());
|
|
return domainRepository;
|
|
}
|
|
|
|
private int CreateTestData(string isoName, out ContentType ct)
|
|
{
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var lang = new Language(isoName, isoName);
|
|
LanguageRepository.Save(lang);
|
|
|
|
ct = ContentTypeBuilder.CreateBasicContentType("test", "Test");
|
|
ContentTypeRepository.Save(ct);
|
|
var content = new Content("test", -1, ct) { CreatorId = 0, WriterId = 0 };
|
|
DocumentRepository.Save(content);
|
|
scope.Complete();
|
|
return content.Id;
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Can_Create_And_Get_By_Id()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
var domain = (IDomain)new UmbracoDomain("test.com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
|
|
// re-get
|
|
domain = repo.Get(domain.Id);
|
|
|
|
Assert.NotNull(domain);
|
|
Assert.IsTrue(domain.HasIdentity);
|
|
Assert.Greater(domain.Id, 0);
|
|
Assert.AreEqual("test.com", domain.DomainName);
|
|
Assert.AreEqual(content.Id, domain.RootContentId);
|
|
Assert.AreEqual(lang.Id, domain.LanguageId);
|
|
Assert.AreEqual(lang.IsoCode, domain.LanguageIsoCode);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Can_Create_And_Get_By_Id_Empty_lang()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
var domain = (IDomain)new UmbracoDomain("test.com") { RootContentId = content.Id };
|
|
repo.Save(domain);
|
|
|
|
// re-get
|
|
domain = repo.Get(domain.Id);
|
|
|
|
Assert.NotNull(domain);
|
|
Assert.IsTrue(domain.HasIdentity);
|
|
Assert.Greater(domain.Id, 0);
|
|
Assert.AreEqual("test.com", domain.DomainName);
|
|
Assert.AreEqual(content.Id, domain.RootContentId);
|
|
Assert.IsFalse(domain.LanguageId.HasValue);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Cant_Create_Duplicate_Domain_Name()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
var domain1 = (IDomain)new UmbracoDomain("test.com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain1);
|
|
|
|
var domain2 = (IDomain)new UmbracoDomain("test.com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
|
|
Assert.Throws<DuplicateNameException>(() => repo.Save(domain2));
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Can_Delete()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
var domain = (IDomain)new UmbracoDomain("test.com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
|
|
repo.Delete(domain);
|
|
|
|
// re-get
|
|
domain = repo.Get(domain.Id);
|
|
|
|
Assert.IsNull(domain);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Can_Update()
|
|
{
|
|
var contentId1 = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var content1 = DocumentRepository.Get(contentId1);
|
|
|
|
// more test data
|
|
var lang1 = LanguageRepository.GetByIsoCode("en-AU");
|
|
var globalSettings = new GlobalSettings();
|
|
var lang2 = new Language("es", "Spanish");
|
|
LanguageRepository.Save(lang2);
|
|
var content2 = new Content("test", -1, ct) { CreatorId = 0, WriterId = 0 };
|
|
DocumentRepository.Save(content2);
|
|
|
|
var domain = (IDomain)new UmbracoDomain("test.com") { RootContentId = content1.Id, LanguageId = lang1.Id };
|
|
repo.Save(domain);
|
|
|
|
// re-get
|
|
domain = repo.Get(domain.Id);
|
|
|
|
domain.DomainName = "blah.com";
|
|
domain.RootContentId = content2.Id;
|
|
domain.LanguageId = lang2.Id;
|
|
repo.Save(domain);
|
|
|
|
// re-get
|
|
domain = repo.Get(domain.Id);
|
|
|
|
Assert.AreEqual("blah.com", domain.DomainName);
|
|
Assert.AreEqual(content2.Id, domain.RootContentId);
|
|
Assert.AreEqual(lang2.Id, domain.LanguageId);
|
|
Assert.AreEqual(lang2.IsoCode, domain.LanguageIsoCode);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Exists()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain =
|
|
(IDomain)new UmbracoDomain("test" + i + ".com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var found = repo.Exists("test1.com");
|
|
|
|
Assert.IsTrue(found);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_By_Name()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain =
|
|
(IDomain)new UmbracoDomain("test" + i + ".com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var found = repo.GetByName("test1.com");
|
|
|
|
Assert.IsNotNull(found);
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_All()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain =
|
|
(IDomain)new UmbracoDomain("test " + i + ".com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var all = repo.GetMany();
|
|
|
|
Assert.AreEqual(10, all.Count());
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_All_Ids()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
var ids = new List<int>();
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain =
|
|
(IDomain)new UmbracoDomain("test " + i + ".com") { RootContentId = content.Id, LanguageId = lang.Id };
|
|
repo.Save(domain);
|
|
ids.Add(domain.Id);
|
|
}
|
|
|
|
var all = repo.GetMany(ids.Take(8).ToArray());
|
|
|
|
Assert.AreEqual(8, all.Count());
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_All_Without_Wildcards()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
var content = DocumentRepository.Get(contentId);
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain = (IDomain)new UmbracoDomain(i % 2 == 0 ? "test " + i + ".com" : "*" + i)
|
|
{
|
|
RootContentId = content.Id,
|
|
LanguageId = lang.Id
|
|
};
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var all = repo.GetAll(false);
|
|
|
|
Assert.AreEqual(5, all.Count());
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_All_For_Content()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var contentItems = new List<IContent>();
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
contentItems.Add(DocumentRepository.Get(contentId));
|
|
|
|
// more test data (3 content items total)
|
|
for (var i = 0; i < 2; i++)
|
|
{
|
|
var c = new Content("test" + i, -1, ct) { CreatorId = 0, WriterId = 0 };
|
|
DocumentRepository.Save(c);
|
|
contentItems.Add(c);
|
|
}
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain = (IDomain)new UmbracoDomain(i % 2 == 0 ? "test " + i + ".com" : "*" + i)
|
|
{
|
|
RootContentId = (i % 2 == 0 ? contentItems[0] : contentItems[1]).Id,
|
|
LanguageId = lang.Id
|
|
};
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var all1 = repo.GetAssignedDomains(contentItems[0].Id, true);
|
|
Assert.AreEqual(5, all1.Count());
|
|
|
|
var all2 = repo.GetAssignedDomains(contentItems[1].Id, true);
|
|
Assert.AreEqual(5, all2.Count());
|
|
|
|
var all3 = repo.GetAssignedDomains(contentItems[2].Id, true);
|
|
Assert.AreEqual(0, all3.Count());
|
|
}
|
|
}
|
|
|
|
[Test]
|
|
public void Get_All_For_Content_Without_Wildcards()
|
|
{
|
|
var contentId = CreateTestData("en-AU", out var ct);
|
|
|
|
var provider = ScopeProvider;
|
|
using (var scope = provider.CreateScope())
|
|
{
|
|
var repo = CreateRepository(provider);
|
|
|
|
var contentItems = new List<IContent>();
|
|
|
|
var lang = LanguageRepository.GetByIsoCode("en-AU");
|
|
contentItems.Add(DocumentRepository.Get(contentId));
|
|
|
|
// more test data (3 content items total)
|
|
for (var i = 0; i < 2; i++)
|
|
{
|
|
var c = new Content("test" + i, -1, ct) { CreatorId = 0, WriterId = 0 };
|
|
DocumentRepository.Save(c);
|
|
contentItems.Add(c);
|
|
}
|
|
|
|
for (var i = 0; i < 10; i++)
|
|
{
|
|
var domain = (IDomain)new UmbracoDomain(i % 2 == 0 ? "test " + i + ".com" : "*" + i)
|
|
{
|
|
RootContentId = (i % 2 == 0 ? contentItems[0] : contentItems[1]).Id,
|
|
LanguageId = lang.Id
|
|
};
|
|
repo.Save(domain);
|
|
}
|
|
|
|
var all1 = repo.GetAssignedDomains(contentItems[0].Id, false);
|
|
Assert.AreEqual(5, all1.Count());
|
|
|
|
var all2 = repo.GetAssignedDomains(contentItems[1].Id, false);
|
|
Assert.AreEqual(0, all2.Count());
|
|
}
|
|
}
|
|
}
|