Add CloudEvents support poppastring#671

clemensv · Dec 28, 2022 · 9ede8c3 · 9ede8c3
1 parent deb7265
commit 9ede8c3
Show file tree

Hide file tree

Showing 18 changed files with 574 additions and 179 deletions.
diff --git a/source/DasBlog.Services/ConfigFile/Interfaces/ISiteConfig.cs b/source/DasBlog.Services/ConfigFile/Interfaces/ISiteConfig.cs
@@ -130,7 +130,9 @@ public interface ISiteConfig
 
         bool EnableCrossposts { get; set; }
 
-        bool UseUserCulture { get; set; }
+		bool EnableCloudEvents { get; set; }
+
+		bool UseUserCulture { get; set; }
 
 		bool ShowItemSummaryInAggregatedViews { get; set; }
 
@@ -199,7 +201,13 @@ public interface ISiteConfig
         [XmlArray("CrosspostSites")]
         CrosspostSite[] CrosspostSiteArray { get; set; }
 
-        bool Pop3DeleteAllMessages { get; set; }
+		[XmlIgnore]
+		CloudEventsTargetCollection CloudEventsTargets { get; set; }
+
+		[XmlArray("CloudEventsTargets")]
+		CloudEventsTarget[] CloudEventsTargetArray { get; set; }
+
+		bool Pop3DeleteAllMessages { get; set; }
 
         bool Pop3LogIgnoredEmails { get; set; }
 

diff --git a/source/DasBlog.Services/ConfigFile/SiteConfig.cs b/source/DasBlog.Services/ConfigFile/SiteConfig.cs
@@ -126,8 +126,10 @@ public SiteConfig() { }
         public ContentFilterCollection ContentFilters { get; set; }
         public ContentFilter[] ContentFilterArray { get; set; }
         public CrosspostSiteCollection CrosspostSites { get; set; }
-        public CrosspostSite[] CrosspostSiteArray { get; set; }
-        public bool Pop3DeleteAllMessages { get; set; }
+		public CloudEventsTargetCollection CloudEventsTargets { get; set; }
+		public CrosspostSite[] CrosspostSiteArray { get; set; }
+		public CloudEventsTarget[] CloudEventsTargetArray { get; set; }
+		public bool Pop3DeleteAllMessages { get; set; }
         public bool Pop3LogIgnoredEmails { get; set; }
         public bool EnableReferralUrlBlackList { get; set; }
         public string ReferralUrlBlackList { get; set; }
@@ -224,6 +226,6 @@ public SiteConfig() { }
 		public string MastodonServerUrl { get; set; }
 
 		public string MastodonAccount { get; set; }
-
+		public bool EnableCloudEvents { get; set; }
 	}
 }
diff --git a/source/DasBlog.Services/IDasBlogSettings.cs b/source/DasBlog.Services/IDasBlogSettings.cs
@@ -49,5 +49,6 @@ public interface IDasBlogSettings
 		SendMailInfo GetMailInfo(MailMessage emailmessage);
 		DateTime GetDisplayTime(DateTime datetime);
 		DateTime GetCreateTime(DateTime datetime);
+		string GetRssEntryUrl(string entryId);
 	}
 }
diff --git a/source/DasBlog.Services/Rss/Rss.cs b/source/DasBlog.Services/Rss/Rss.cs
@@ -125,7 +125,10 @@ public class RssItem
 		[XmlAttribute("xml:lang")]
         public string Language;
 
-        [XmlElement("author")]
+		[XmlAttribute("id")]
+		public string Id;
+
+		[XmlElement("author")]
 		public string Author { get; set; }
 
 		[XmlElement("title")]

diff --git a/source/DasBlog.Tests/UnitTests/DasBlogSettingTest.cs b/source/DasBlog.Tests/UnitTests/DasBlogSettingTest.cs
@@ -272,5 +272,10 @@ public DateTime GetCreateTime(DateTime datetime)
 		{
 			throw new NotImplementedException();
 		}
+
+		public string GetRssEntryUrl(string entryId)
+		{
+			throw new NotImplementedException();
+		}
 	}
 }
diff --git a/source/DasBlog.Tests/UnitTests/SiteConfigTest.cs b/source/DasBlog.Tests/UnitTests/SiteConfigTest.cs
@@ -171,5 +171,8 @@ public class SiteConfigTest : ISiteConfig
 		public string MastodonServerUrl { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
 		public string MastodonAccount { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
         public bool AllowMarkdownInComments { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
-       }
+		public bool EnableCloudEvents { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
+		public CloudEventsTargetCollection CloudEventsTargets { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
+		public CloudEventsTarget[] CloudEventsTargetArray { get => throw new NotImplementedException(); set => throw new NotImplementedException(); }
+	}
 }
diff --git a/source/DasBlog.Web.Repositories/BlogManager.cs b/source/DasBlog.Web.Repositories/BlogManager.cs
@@ -20,6 +20,11 @@
 using System.Net.Mail;
 using System.Net;
 using System.IO;
+using CloudNative.CloudEvents;
+using System.Xml.Linq;
+using CloudNative.CloudEvents.Http;
+using CloudNative.CloudEvents.SystemTextJson;
+using System.Net.Http;
 
 namespace DasBlog.Managers
 {
@@ -187,22 +192,134 @@ public EntrySaveState CreateEntry(Entry entry)
 		{
 			var rtn = InternalSaveEntry(entry, null, null);
 			LogEvent(EventCodes.EntryAdded, entry);
+			RaisePostCreatedCloudEvent(entry);
 			return rtn;
 		}
 
+
+		private void RaisePostCreatedCloudEvent(Entry entry)
+		{
+			var ext = CloudEventAttribute.CreateExtension("tags", CloudEventAttributeType.String);
+			var cloudEvent = new CloudEvent(CloudEventsSpecVersion.V1_0, new[] { ext })
+			{
+				Type = "dasblog.post.created",
+				Source = new Uri(dasBlogSettings.GetBaseUrl()),
+				Subject = entry.Link,
+				Data = MapEntryToCloudEventData(entry),
+				Id = Guid.NewGuid().ToString(),
+				Time = DateTime.UtcNow,
+			};
+			cloudEvent.SetAttributeFromString("tags", entry.Categories);
+			RaiseCloudEvent(cloudEvent);
+
+		}
+
+		private void RaiseCloudEvent(CloudEvent cloudEvent)
+		{
+			if ( dasBlogSettings.SiteConfiguration.EnableCloudEvents &&
+				 dasBlogSettings.SiteConfiguration.CloudEventsTargets != null)
+			{
+				foreach (var target in dasBlogSettings.SiteConfiguration.CloudEventsTargets)
+				{
+					if (!string.IsNullOrEmpty(target.Uri))
+					{
+						try
+						{
+							var content = cloudEvent.ToHttpContent(ContentMode.Structured, new JsonEventFormatter());
+							var uriBuilder = new UriBuilder(target.Uri);
+							if (target.Headers != null)
+							{
+								foreach (var header in target.Headers)
+								{
+									if (!string.IsNullOrEmpty(header.Name))
+									{
+										content.Headers.Add(header.Name, header.Value);
+									}
+								}
+							}
+							if (target.QueryArgs!= null)
+							{
+								foreach (var queryArgs in target.QueryArgs)
+								{
+									uriBuilder.Query = (string.IsNullOrEmpty(uriBuilder.Query) ? string.Empty : uriBuilder.Query + "&") + queryArgs.Name + "=" + queryArgs.Value;
+								}
+							}
+							var httpClient = new HttpClient();
+							var result = httpClient.PostAsync(uriBuilder.Uri, content).GetAwaiter().GetResult();
+						}
+						catch(Exception ex)
+						{
+							logger.LogError(ex, "Failed to post CloudEvent");
+						}
+					}
+				}
+			}
+		}
+
+		private EntryCloudEventData MapEntryToCloudEventData(Entry entry)
+		{
+			var data = new EntryCloudEventData();
+			data.Id = entry.EntryId;
+			data.Title = entry.Title;
+			data.CreatedUtc = entry.CreatedUtc;
+			data.ModifiedUtc = entry.ModifiedUtc;
+			data.Tags = entry.Categories;
+			data.Description = entry.Description;
+			data.PermaLink = entry.Link;
+			data.DetailsLink = dasBlogSettings.GetRssEntryUrl(entry.EntryId);
+			data.IsPublic = entry.IsPublic;
+			data.Author = entry.Author;
+			data.Longitude = entry.Longitude;
+			data.Latitude = entry.Latitude;
+			return data;
+		}
+
 		public EntrySaveState UpdateEntry(Entry entry)
 		{
 			var rtn = InternalSaveEntry(entry, null, null);
 			LogEvent(EventCodes.EntryChanged, entry);
+			RaisePostUpdatedCloudEvent(entry);
 			return rtn;
 		}
 
+		private void RaisePostUpdatedCloudEvent(Entry entry)
+		{
+			var ext = CloudEventAttribute.CreateExtension("tags", CloudEventAttributeType.String);
+			var cloudEvent = new CloudEvent(CloudEventsSpecVersion.V1_0, new[] { ext })
+			{
+				Type = "dasblog.post.updated",
+				Source = new Uri(dasBlogSettings.GetBaseUrl()),
+				Subject = entry.Link,
+				Data = MapEntryToCloudEventData(entry),
+				Id = Guid.NewGuid().ToString(),
+				Time = DateTime.UtcNow,
+			};
+			cloudEvent.SetAttributeFromString("tags", entry.Categories);
+			RaiseCloudEvent(cloudEvent);
+		}
+
 		public void DeleteEntry(string postid)
 		{
 			var entry = GetEntryForEdit(postid);
 			dataService.DeleteEntry(postid, null);
-
 			LogEvent(EventCodes.EntryDeleted, entry);
+			RaisePostDeletedCloudEvent(entry);
+		}
+
+		private void RaisePostDeletedCloudEvent(Entry entry)
+		{
+			var ext = CloudEventAttribute.CreateExtension("tags", CloudEventAttributeType.String);
+			var cloudEvent = new CloudEvent(CloudEventsSpecVersion.V1_0, new[] { ext })
+			{
+				Type = "dasblog.post.deleted",
+				Source = new Uri(dasBlogSettings.GetBaseUrl()),
+				Subject = entry.Link,
+				Id = Guid.NewGuid().ToString(),
+				Time = DateTime.UtcNow,
+				Data = MapEntryToCloudEventData(entry)
+			};
+			cloudEvent.SetAttributeFromString("tags", entry.Categories);
+			RaiseCloudEvent(cloudEvent);
 		}
 
 		private static StringCollection GetSearchWords(string searchString)

diff --git a/source/DasBlog.Web.Repositories/DasBlog.Managers.csproj b/source/DasBlog.Web.Repositories/DasBlog.Managers.csproj
@@ -10,8 +10,10 @@
     <SymbolPackageFormat>snupkg</SymbolPackageFormat>
   </PropertyGroup>
   <ItemGroup>
+    <PackageReference Include="CloudNative.CloudEvents" Version="2.5.1" />
+    <PackageReference Include="CloudNative.CloudEvents.SystemTextJson" Version="2.5.1" />
     <PackageReference Include="NodaTime" Version="3.0.9" />
-    <PackageReference Include="Microsoft.SourceLink.GitHub" Version="1.1.1" PrivateAssets="All"/>
+    <PackageReference Include="Microsoft.SourceLink.GitHub" Version="1.1.1" PrivateAssets="All" />
   </ItemGroup>
   <ItemGroup>
     <FrameworkReference Include="Microsoft.AspNetCore.App" />

diff --git a/source/DasBlog.Web.Repositories/EntryCloudEventData.cs b/source/DasBlog.Web.Repositories/EntryCloudEventData.cs
@@ -0,0 +1,34 @@
+using System;
+using System.Text.Json.Serialization;
+
+namespace DasBlog.Managers
+{
+	internal class EntryCloudEventData
+	{
+		[JsonPropertyName("id")]
+		public string Id { get; internal set; }
+		[JsonPropertyName("title")]
+		public string Title { get; internal set; }
+		[JsonPropertyName("createdUtc")]
+		public DateTime CreatedUtc { get; internal set; }
+		[JsonPropertyName("modifiedUtc")]
+		public DateTime ModifiedUtc { get; internal set; }
+		[JsonPropertyName("tags")]
+		public string Tags { get; internal set; }
+		[JsonPropertyName("description")]
+		public string Description { get; internal set; }
+		[JsonPropertyName("permaLink")]
+		public string PermaLink { get; internal set; }
+		[JsonPropertyName("contentLink")]
+		public string DetailsLink { get; internal set; }
+		[JsonPropertyName("isPublic")]
+		public bool IsPublic { get; internal set; }
+		[JsonPropertyName("author")]
+		public string Author { get; internal set; }
+		[JsonPropertyName("longitude")]
+		public double? Longitude { get; internal set; }
+		[JsonPropertyName("latitude")]
+		public double? Latitude { get; internal set; }
+
+	}
+}
diff --git a/source/DasBlog.Web.Repositories/Interfaces/ISubscriptionManager.cs b/source/DasBlog.Web.Repositories/Interfaces/ISubscriptionManager.cs
@@ -10,5 +10,6 @@ public interface ISubscriptionManager
         RssRoot GetAtom();
         RssRoot GetAtomCategory(string categoryName);
         RsdRoot GetRsd();
-    }
+		RssItem GetRssItem(string entryId);
+	}
 }