Merge pull request #8 from tgiachi/develop

release: templating, messaging pub/sub, and the workers system

Author: tgiachi

README.md

@@ -86,6 +86,7 @@ block until cancellation for long-running hosts.
 | `SquidStd.Storage` | Local file storage backend (`AddFileStorage`). | [![readme](https://img.shields.io/badge/readme-1390A3.svg)](src/SquidStd.Storage/README.md) · [![NuGet](https://img.shields.io/nuget/v/SquidStd.Storage.svg)](https://www.nuget.org/packages/SquidStd.Storage/) |
 | `SquidStd.Storage.S3` | S3/MinIO storage backend (`AddS3Storage`). | [![readme](https://img.shields.io/badge/readme-1390A3.svg)](src/SquidStd.Storage.S3/README.md) · [![NuGet](https://img.shields.io/nuget/v/SquidStd.Storage.S3.svg)](https://www.nuget.org/packages/SquidStd.Storage.S3/) |
 | `SquidStd.Scripting.Lua` | Lua scripting engine with attribute-based modules and event bridging. | [![readme](https://img.shields.io/badge/readme-1390A3.svg)](src/SquidStd.Scripting.Lua/README.md) · [![NuGet](https://img.shields.io/nuget/v/SquidStd.Scripting.Lua.svg)](https://www.nuget.org/packages/SquidStd.Scripting.Lua/) |
+| `SquidStd.Templating` | Scriban templating with a named-template registry and `templates/*.tmpl` auto-load (`AddTemplating`). | [![readme](https://img.shields.io/badge/readme-1390A3.svg)](src/SquidStd.Templating/README.md) · [![NuGet](https://img.shields.io/nuget/v/SquidStd.Templating.svg)](https://www.nuget.org/packages/SquidStd.Templating/) |
 
 ## Architecture
 

SquidStd.slnx

@@ -18,6 +18,10 @@
         <Project Path="src/SquidStd.Storage.Abstractions/SquidStd.Storage.Abstractions.csproj" />
         <Project Path="src/SquidStd.Storage.S3/SquidStd.Storage.S3.csproj" />
         <Project Path="src/SquidStd.Storage/SquidStd.Storage.csproj" />
+        <Project Path="src/SquidStd.Templating/SquidStd.Templating.csproj" />
+        <Project Path="src/SquidStd.Workers.Abstractions/SquidStd.Workers.Abstractions.csproj" />
+        <Project Path="src/SquidStd.Workers/SquidStd.Workers.csproj" />
+        <Project Path="src/SquidStd.Workers.Manager/SquidStd.Workers.Manager.csproj" />
     </Folder>
     <Folder Name="/tests/">
         <Project Path="tests/SquidStd.Tests/SquidStd.Tests.csproj" />

docs/articles/templating.md

@@ -0,0 +1 @@
+[!include[](../../src/SquidStd.Templating/README.md)]

docs/articles/toc.yml

@@ -36,6 +36,14 @@
   href: storage-s3.md
 - name: SquidStd.Scripting.Lua
   href: scripting-lua.md
+- name: SquidStd.Templating
+  href: templating.md
+- name: SquidStd.Workers.Abstractions
+  href: workers-abstractions.md
+- name: SquidStd.Workers
+  href: workers.md
+- name: SquidStd.Workers.Manager
+  href: workers-manager.md
 - name: Serialization
   href: serialization.md
 - name: Scheduler

docs/articles/workers-abstractions.md

@@ -0,0 +1 @@
+[!include[](../../src/SquidStd.Workers.Abstractions/README.md)]

docs/articles/workers-manager.md

@@ -0,0 +1 @@
+[!include[](../../src/SquidStd.Workers.Manager/README.md)]

docs/articles/workers.md

@@ -0,0 +1 @@
+[!include[](../../src/SquidStd.Workers/README.md)]

src/SquidStd.Messaging.Abstractions/Data/Events/TopicMessageEvent.cs

@@ -0,0 +1,9 @@
+using SquidStd.Core.Interfaces.Events;
+
+namespace SquidStd.Messaging.Abstractions.Data.Events;
+
+/// <summary>
+/// Event published on the in-process event bus when a topic message is bridged. <see cref="Data" /> is the
+/// deserialized message.
+/// </summary>
+public sealed record TopicMessageEvent(string Topic, object Data) : IEvent;

src/SquidStd.Messaging.Abstractions/Interfaces/IMessageTopic.cs

@@ -0,0 +1,13 @@
+namespace SquidStd.Messaging.Abstractions.Interfaces;
+
+/// <summary>
+/// Typed facade for publishing to and subscribing to topics (fan-out).
+/// </summary>
+public interface IMessageTopic
+{
+    /// <summary>Publishes a typed message to a topic.</summary>
+    Task PublishAsync<TMessage>(string topic, TMessage message, CancellationToken cancellationToken = default);
+
+    /// <summary>Subscribes a typed handler to a topic. Dispose to unsubscribe.</summary>
+    IDisposable Subscribe<TMessage>(string topic, Func<TMessage, CancellationToken, Task> handler);
+}

src/SquidStd.Messaging.Abstractions/Interfaces/ITopicEventBridge.cs

@@ -0,0 +1,11 @@
+namespace SquidStd.Messaging.Abstractions.Interfaces;
+
+/// <summary>
+/// Bridges a topic into the in-process event bus: each message of type <c>T</c> on the topic is republished
+/// as a <c>TopicMessageEvent</c>.
+/// </summary>
+public interface ITopicEventBridge
+{
+    /// <summary>Starts bridging the given topic; dispose the result to stop.</summary>
+    IDisposable Bridge<T>(string topic);
+}