Migrated / Rewritten ScopedNuCacheTests (#11636)
* Migrated / Rewritten ScopedNuCacheTests * Cleanup Co-authored-by: Elitsa Marinovska <elm@umbraco.dk>
This commit is contained in:
Bjarke Berg
@@ -0,0 +1,119 @@
|
||||
using System;
|
||||
using Microsoft.AspNetCore.Http;
|
||||
using Moq;
|
||||
using NUnit.Framework;
|
||||
using Umbraco.Cms.Core.DependencyInjection;
|
||||
using Umbraco.Cms.Core.Events;
|
||||
using Umbraco.Cms.Core.Models;
|
||||
using Umbraco.Cms.Core.Models.PublishedContent;
|
||||
using Umbraco.Cms.Core.Notifications;
|
||||
using Umbraco.Cms.Core.Services;
|
||||
using Umbraco.Cms.Core.Sync;
|
||||
using Umbraco.Cms.Core.Web;
|
||||
using Umbraco.Cms.Infrastructure.DependencyInjection;
|
||||
using Umbraco.Cms.Tests.Common;
|
||||
using Umbraco.Cms.Tests.Common.Testing;
|
||||
using Umbraco.Cms.Tests.Integration.Testing;
|
||||
using Umbraco.Cms.Tests.Integration.Umbraco.Infrastructure.Scoping;
|
||||
using Umbraco.Extensions;
|
||||
|
||||
namespace Umbraco.Tests.Scoping
|
||||
{
|
||||
[TestFixture]
|
||||
[UmbracoTest(Database = UmbracoTestOptions.Database.NewSchemaPerTest)]
|
||||
public class ScopedNuCacheTests : UmbracoIntegrationTest
|
||||
{
|
||||
private IContentService ContentService => GetRequiredService<IContentService>();
|
||||
private Mock<IHttpContextAccessor> MockHttpContextAccessor { get; set; } = CreateMockHttpContextAccessor();
|
||||
private IUmbracoContextFactory UmbracoContextFactory => GetRequiredService<IUmbracoContextFactory>();
|
||||
private IContentTypeService ContentTypeService => GetRequiredService<IContentTypeService>();
|
||||
private IVariationContextAccessor VariationContextAccessor => GetRequiredService<IVariationContextAccessor>();
|
||||
|
||||
protected override void CustomTestSetup(IUmbracoBuilder builder)
|
||||
{
|
||||
NotificationHandler.PublishedContent = notification => { };
|
||||
builder.Services.AddUnique<IServerMessenger, ScopedRepositoryTests.LocalServerMessenger>();
|
||||
builder.AddCoreNotifications();
|
||||
builder.AddNotificationHandler<ContentPublishedNotification, NotificationHandler>();
|
||||
builder.Services.AddUnique<IUmbracoContextAccessor, TestUmbracoContextAccessor>();
|
||||
builder.Services.AddUnique<IHttpContextAccessor>(MockHttpContextAccessor.Object);
|
||||
builder.AddNuCache();
|
||||
}
|
||||
|
||||
public class NotificationHandler : INotificationHandler<ContentPublishedNotification>
|
||||
{
|
||||
public void Handle(ContentPublishedNotification notification) => PublishedContent?.Invoke(notification);
|
||||
|
||||
public static Action<ContentPublishedNotification> PublishedContent { get; set; }
|
||||
}
|
||||
|
||||
private static Mock<IHttpContextAccessor> CreateMockHttpContextAccessor()
|
||||
{
|
||||
var mockHttpContextAccessor = new Mock<IHttpContextAccessor>();
|
||||
var httpContext = new DefaultHttpContext();
|
||||
httpContext.Request.Scheme = "http";
|
||||
httpContext.Request.Host = new HostString("localhost");
|
||||
|
||||
mockHttpContextAccessor.SetupGet(x => x.HttpContext).Returns(httpContext);
|
||||
return mockHttpContextAccessor;
|
||||
}
|
||||
|
||||
[TestCase(true)]
|
||||
[TestCase(false)]
|
||||
public void TestScope(bool complete)
|
||||
{
|
||||
var umbracoContext = UmbracoContextFactory.EnsureUmbracoContext().UmbracoContext;
|
||||
|
||||
// create document type, document
|
||||
var contentType = new ContentType(ShortStringHelper, -1) { Alias = "CustomDocument", Name = "Custom Document" };
|
||||
ContentTypeService.Save(contentType);
|
||||
var item = new Content("name", -1, contentType);
|
||||
|
||||
using (var scope = ScopeProvider.CreateScope())
|
||||
{
|
||||
ContentService.SaveAndPublish(item);
|
||||
scope.Complete();
|
||||
}
|
||||
|
||||
// event handler
|
||||
var evented = 0;
|
||||
NotificationHandler.PublishedContent = notification =>
|
||||
{
|
||||
evented++;
|
||||
|
||||
var e = umbracoContext.Content.GetById(item.Id);
|
||||
|
||||
// during events, due to LiveSnapshot, we see the changes
|
||||
Assert.IsNotNull(e);
|
||||
Assert.AreEqual("changed", e.Name(VariationContextAccessor));
|
||||
};
|
||||
|
||||
// been created
|
||||
var x = umbracoContext.Content.GetById(item.Id);
|
||||
Assert.IsNotNull(x);
|
||||
Assert.AreEqual("name", x.Name(VariationContextAccessor));
|
||||
|
||||
using (var scope = ScopeProvider.CreateScope())
|
||||
{
|
||||
item.Name = "changed";
|
||||
ContentService.SaveAndPublish(item);
|
||||
|
||||
if (complete)
|
||||
{
|
||||
scope.Complete();
|
||||
}
|
||||
}
|
||||
|
||||
// only 1 event occuring because we are publishing twice for the same event for
|
||||
// the same object and the scope deduplicates the events (uses the latest)
|
||||
Assert.AreEqual(complete ? 1 : 0, evented);
|
||||
|
||||
// after the scope,
|
||||
// if completed, we see the changes
|
||||
// else changes have been rolled back
|
||||
x = umbracoContext.Content.GetById(item.Id);
|
||||
Assert.IsNotNull(x);
|
||||
Assert.AreEqual(complete ? "changed" : "name", x.Name(VariationContextAccessor));
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -1,192 +0,0 @@
|
||||
using System;
|
||||
using System.Web.Routing;
|
||||
using Microsoft.Extensions.DependencyInjection;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using Microsoft.Extensions.Logging.Abstractions;
|
||||
using Moq;
|
||||
using NUnit.Framework;
|
||||
using Umbraco.Cms.Core;
|
||||
using Umbraco.Cms.Core.Cache;
|
||||
using Umbraco.Cms.Core.Configuration.Models;
|
||||
using Umbraco.Cms.Core.DependencyInjection;
|
||||
using Umbraco.Cms.Core.Events;
|
||||
using Umbraco.Cms.Core.Hosting;
|
||||
using Umbraco.Cms.Core.Models;
|
||||
using Umbraco.Cms.Core.Models.PublishedContent;
|
||||
using Umbraco.Cms.Core.Notifications;
|
||||
using Umbraco.Cms.Core.Persistence.Repositories;
|
||||
using Umbraco.Cms.Core.PublishedCache;
|
||||
using Umbraco.Cms.Core.Security;
|
||||
using Umbraco.Cms.Core.Services;
|
||||
using Umbraco.Cms.Core.Strings;
|
||||
using Umbraco.Cms.Core.Sync;
|
||||
using Umbraco.Cms.Core.Web;
|
||||
using Umbraco.Cms.Infrastructure.PublishedCache;
|
||||
using Umbraco.Cms.Infrastructure.PublishedCache.Persistence;
|
||||
using Umbraco.Cms.Tests.Common;
|
||||
using Umbraco.Cms.Tests.Common.Testing;
|
||||
using Umbraco.Extensions;
|
||||
using Umbraco.Tests.TestHelpers;
|
||||
using Umbraco.Web;
|
||||
using Umbraco.Web.Composing;
|
||||
|
||||
namespace Umbraco.Tests.Scoping
|
||||
{
|
||||
[TestFixture]
|
||||
[UmbracoTest(Database = UmbracoTestOptions.Database.NewSchemaPerTest, PublishedRepositoryEvents = true)]
|
||||
public class ScopedNuCacheTests : TestWithDatabaseBase
|
||||
{
|
||||
private DistributedCacheBinder _distributedCacheBinder;
|
||||
|
||||
protected override void Compose()
|
||||
{
|
||||
base.Compose();
|
||||
|
||||
// the cache refresher component needs to trigger to refresh caches
|
||||
// but then, it requires a lot of plumbing ;(
|
||||
// FIXME: and we cannot inject a DistributedCache yet
|
||||
// so doing all this mess
|
||||
Builder.Services.AddUnique<IServerMessenger, ScopedXmlTests.LocalServerMessenger>();
|
||||
Builder.Services.AddUnique(f => Mock.Of<IServerRoleAccessor>());
|
||||
Builder.WithCollectionBuilder<CacheRefresherCollectionBuilder>()
|
||||
.Add(() => Builder.TypeLoader.GetCacheRefreshers());
|
||||
Builder.AddNotificationHandler<ContentPublishedNotification, NotificationHandler>();
|
||||
}
|
||||
|
||||
public class NotificationHandler : INotificationHandler<ContentPublishedNotification>
|
||||
{
|
||||
public void Handle(ContentPublishedNotification notification) => PublishedContent?.Invoke(notification);
|
||||
|
||||
public static Action<ContentPublishedNotification> PublishedContent { get; set; }
|
||||
}
|
||||
|
||||
public override void TearDown()
|
||||
{
|
||||
base.TearDown();
|
||||
|
||||
NotificationHandler.PublishedContent = null;
|
||||
}
|
||||
|
||||
protected override IPublishedSnapshotService CreatePublishedSnapshotService(GlobalSettings globalSettings = null)
|
||||
{
|
||||
var options = new PublishedSnapshotServiceOptions { IgnoreLocalDb = true };
|
||||
var publishedSnapshotAccessor = new UmbracoContextPublishedSnapshotAccessor(Current.UmbracoContextAccessor);
|
||||
var runtimeStateMock = new Mock<IRuntimeState>();
|
||||
runtimeStateMock.Setup(x => x.Level).Returns(() => RuntimeLevel.Run);
|
||||
|
||||
var contentTypeFactory = Factory.GetRequiredService<IPublishedContentTypeFactory>();
|
||||
var documentRepository = Mock.Of<IDocumentRepository>();
|
||||
var mediaRepository = Mock.Of<IMediaRepository>();
|
||||
var memberRepository = Mock.Of<IMemberRepository>();
|
||||
var hostingEnvironment = TestHelper.GetHostingEnvironment();
|
||||
|
||||
var typeFinder = TestHelper.GetTypeFinder();
|
||||
|
||||
var nuCacheSettings = new NuCacheSettings();
|
||||
var lifetime = new Mock<IUmbracoApplicationLifetime>();
|
||||
var repository = new NuCacheContentRepository(ScopeProvider, AppCaches.Disabled, Mock.Of<ILogger<NuCacheContentRepository>>(), memberRepository, documentRepository, mediaRepository, Mock.Of<IShortStringHelper>(), new UrlSegmentProviderCollection(new[] { new DefaultUrlSegmentProvider(ShortStringHelper) }));
|
||||
var snapshotService = new PublishedSnapshotService(
|
||||
options,
|
||||
null,
|
||||
ServiceContext,
|
||||
contentTypeFactory,
|
||||
publishedSnapshotAccessor,
|
||||
Mock.Of<IVariationContextAccessor>(),
|
||||
base.ProfilingLogger,
|
||||
NullLoggerFactory.Instance,
|
||||
ScopeProvider,
|
||||
new NuCacheContentService(repository, ScopeProvider, NullLoggerFactory.Instance, Mock.Of<IEventMessagesFactory>()),
|
||||
DefaultCultureAccessor,
|
||||
Microsoft.Extensions.Options.Options.Create(globalSettings ?? new GlobalSettings()),
|
||||
Factory.GetRequiredService<IEntityXmlSerializer>(),
|
||||
new NoopPublishedModelFactory(),
|
||||
hostingEnvironment,
|
||||
Microsoft.Extensions.Options.Options.Create(nuCacheSettings));
|
||||
|
||||
return snapshotService;
|
||||
}
|
||||
|
||||
protected IUmbracoContext GetUmbracoContextNu(string url, RouteData routeData = null, bool setSingleton = false)
|
||||
{
|
||||
// ensure we have a PublishedSnapshotService
|
||||
var service = PublishedSnapshotService as PublishedSnapshotService;
|
||||
|
||||
var httpContext = GetHttpContextFactory(url, routeData).HttpContext;
|
||||
var httpContextAccessor = TestHelper.GetHttpContextAccessor(httpContext);
|
||||
var globalSettings = TestObjects.GetGlobalSettings();
|
||||
var umbracoContext = new UmbracoContext(
|
||||
httpContextAccessor,
|
||||
service,
|
||||
Mock.Of<IBackOfficeSecurity>(),
|
||||
globalSettings,
|
||||
HostingEnvironment,
|
||||
new TestVariationContextAccessor(),
|
||||
UriUtility,
|
||||
new AspNetCookieManager(httpContextAccessor));
|
||||
|
||||
if (setSingleton)
|
||||
Umbraco.Web.Composing.Current.UmbracoContextAccessor.UmbracoContext = umbracoContext;
|
||||
|
||||
return umbracoContext;
|
||||
}
|
||||
|
||||
[TestCase(true)]
|
||||
[TestCase(false)]
|
||||
public void TestScope(bool complete)
|
||||
{
|
||||
var umbracoContext = GetUmbracoContextNu("http://example.com/", setSingleton: true);
|
||||
|
||||
// wire cache refresher
|
||||
_distributedCacheBinder = new DistributedCacheBinder(new DistributedCache(Current.ServerMessenger, Current.CacheRefreshers));
|
||||
|
||||
// create document type, document
|
||||
var contentType = new ContentType(ShortStringHelper, -1) { Alias = "CustomDocument", Name = "Custom Document" };
|
||||
ServiceContext.ContentTypeService.Save(contentType);
|
||||
var item = new Content("name", -1, contentType);
|
||||
|
||||
// event handler
|
||||
var evented = 0;
|
||||
NotificationHandler.PublishedContent = notification =>
|
||||
{
|
||||
evented++;
|
||||
|
||||
var e = umbracoContext.Content.GetById(item.Id);
|
||||
|
||||
// during events, due to LiveSnapshot, we see the changes
|
||||
Assert.IsNotNull(e);
|
||||
Assert.AreEqual("changed", e.Name(VariationContextAccessor));
|
||||
};
|
||||
|
||||
using (var scope = ScopeProvider.CreateScope())
|
||||
{
|
||||
ServiceContext.ContentService.SaveAndPublish(item);
|
||||
scope.Complete();
|
||||
}
|
||||
|
||||
// been created
|
||||
var x = umbracoContext.Content.GetById(item.Id);
|
||||
Assert.IsNotNull(x);
|
||||
Assert.AreEqual("name", x.Name(VariationContextAccessor));
|
||||
|
||||
using (var scope = ScopeProvider.CreateScope())
|
||||
{
|
||||
item.Name = "changed";
|
||||
ServiceContext.ContentService.SaveAndPublish(item);
|
||||
|
||||
if (complete)
|
||||
scope.Complete();
|
||||
}
|
||||
|
||||
// only 1 event occuring because we are publishing twice for the same event for
|
||||
// the same object and the scope deduplicates the events (uses the latest)
|
||||
Assert.AreEqual(complete ? 1 : 0, evented);
|
||||
|
||||
// after the scope,
|
||||
// if completed, we see the changes
|
||||
// else changes have been rolled back
|
||||
x = umbracoContext.Content.GetById(item.Id);
|
||||
Assert.IsNotNull(x);
|
||||
Assert.AreEqual(complete ? "changed" : "name", x.Name(VariationContextAccessor));
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user