Merge pull request #286 from umbraco/bugfix/algolia-load-balanced

Trigger memory cache reload on load balanced published

Author: acoumb

src/Umbraco.Cms.Integrations.Search.Algolia/AlgoliaComposer.cs

@@ -23,8 +23,9 @@ public void Compose(IUmbracoBuilder builder)
             builder.AddNotificationHandler<UmbracoApplicationStartingNotification, RunAlgoliaIndicesMigration>();
 
             builder.AddNotificationAsyncHandler<ContentCacheRefresherNotification, AlgoliaContentCacheRefresherHandler>();
-            
-           builder.Services.AddOptions<AlgoliaSettings>()
+            builder.AddNotificationAsyncHandler<ContentPublishedNotification, AlgoliaContentPublishedHandler>();
+
+            builder.Services.AddOptions<AlgoliaSettings>()
                 .Bind(builder.Config.GetSection(Constants.SettingsPath));
 
             builder.Services.AddSingleton<IAlgoliaIndexService, AlgoliaIndexService>();

src/Umbraco.Cms.Integrations.Search.Algolia/App_Plugins/UmbracoCms.Integrations/Search/Algolia/package.manifest

@@ -1,6 +1,6 @@
 {
 	"name": "Umbraco.Cms.Integrations.Search.Algolia",
-	"version": "1.3.1",
+	"version": "2.3.3",
 	"allowPackageTelemetry": true,
 	"javascript": [
 		"~/App_Plugins/UmbracoCms.Integrations/Search/Algolia/js/algolia.service.js",

src/Umbraco.Cms.Integrations.Search.Algolia/Handlers/AlgoliaContentPublishedHandler.cs

@@ -0,0 +1,31 @@
+using Umbraco.Cms.Core.Cache;
+using Umbraco.Cms.Core.Events;
+using Umbraco.Cms.Core.Notifications;
+using Umbraco.Cms.Core.Sync;
+using Umbraco.Extensions;
+
+namespace Umbraco.Cms.Integrations.Search.Algolia.Handlers
+{
+    public class AlgoliaContentPublishedHandler : INotificationAsyncHandler<ContentPublishedNotification>
+    {
+        private readonly IServerRoleAccessor _serverRoleAccessor;
+        private readonly DistributedCache _distributedCache;
+
+        public AlgoliaContentPublishedHandler(
+            IServerRoleAccessor serverRoleAccessor,
+            DistributedCache distributedCache)
+        {
+            _serverRoleAccessor = serverRoleAccessor;
+            _distributedCache = distributedCache;
+        }
+
+        public Task HandleAsync(ContentPublishedNotification notification, CancellationToken cancellationToken)
+        {
+            if (_serverRoleAccessor.CurrentServerRole == ServerRole.SchedulingPublisher)
+            {
+                _distributedCache.RefreshAllContentCache();
+            }
+            return Task.CompletedTask;
+        }
+    }
+}

src/Umbraco.Cms.Integrations.Search.Algolia/Umbraco.Cms.Integrations.Search.Algolia.csproj

@@ -13,7 +13,7 @@
 		<PackageIconUrl></PackageIconUrl>
 		<PackageProjectUrl>https://github.com/umbraco/Umbraco.Cms.Integrations/tree/main/src/Umbraco.Cms.Integrations.Search.Algolia</PackageProjectUrl>
 		<RepositoryUrl>https://github.com/umbraco/Umbraco.Cms.Integrations</RepositoryUrl>
-		<Version>2.3.2</Version>
+		<Version>2.3.3</Version>
 		<Authors>Umbraco HQ</Authors>
 		<Company>Umbraco</Company>
 		<PackageTags>Umbraco;Umbraco-Marketplace</PackageTags>