Provide expiration timeout for the serialized descriptors

Author: javiercn

src/Components/Server/src/Circuits/CircuitPersistenceManager.cs

@@ -8,10 +8,12 @@
 using Microsoft.AspNetCore.Components.Web;
 using Microsoft.AspNetCore.DataProtection;
 using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Options;
 
 namespace Microsoft.AspNetCore.Components.Server.Circuits;
 
 internal partial class CircuitPersistenceManager(
+    IOptions<CircuitOptions> circuitOptions,
     ServerComponentSerializer serverComponentSerializer,
     ICircuitPersistenceProvider circuitPersistenceProvider,
     IDataProtectionProvider dataProtectionProvider)
@@ -40,8 +42,12 @@ private Task PersistRootComponents(RemoteRenderer renderer, PersistentComponentS
         var invocation = new ServerComponentInvocationSequence();
         foreach (var (id, componentKey, (componentType, parameters)) in components)
         {
+            var distributedRetention = circuitOptions.Value.PersistedCircuitDistributedRetentionPeriod;
+            var localRetention = circuitOptions.Value.PersistedCircuitInMemoryRetentionPeriod;
+            var maxRetention = distributedRetention > localRetention ? distributedRetention : localRetention;
+
             var marker = ComponentMarker.Create(ComponentMarker.ServerMarkerType, false, componentKey);
-            serverComponentSerializer.SerializeInvocation(ref marker, invocation, componentType, parameters);
+            serverComponentSerializer.SerializeInvocation(ref marker, invocation, componentType, parameters, maxRetention);
             persistedComponents.Add(id, marker);
         }
 

src/Shared/Components/ServerComponentSerializer.cs

@@ -16,17 +16,24 @@ public ServerComponentSerializer(IDataProtectionProvider dataProtectionProvider)
             .CreateProtector(ServerComponentSerializationSettings.DataProtectionProviderPurpose)
             .ToTimeLimitedDataProtector();
 
-    public void SerializeInvocation(ref ComponentMarker marker, ServerComponentInvocationSequence invocationId, Type type, ParameterView parameters)
+    public void SerializeInvocation(
+        ref ComponentMarker marker,
+        ServerComponentInvocationSequence invocationId,
+        Type type,
+        ParameterView parameters,
+        TimeSpan? dataExpiration = default)
     {
-        var (sequence, serverComponent) = CreateSerializedServerComponent(invocationId, type, parameters, marker.Key);
+        var expiration = dataExpiration ?? ServerComponentSerializationSettings.DataExpiration;
+        var (sequence, serverComponent) = CreateSerializedServerComponent(invocationId, type, parameters, marker.Key, expiration);
         marker.WriteServerData(sequence, serverComponent);
     }
 
     private (int sequence, string payload) CreateSerializedServerComponent(
         ServerComponentInvocationSequence invocationId,
         Type rootComponent,
         ParameterView parameters,
-        ComponentMarkerKey? key)
+        ComponentMarkerKey? key,
+        TimeSpan dataExpiration)
     {
         var sequence = invocationId.Next();
 
@@ -42,7 +49,7 @@ public void SerializeInvocation(ref ComponentMarker marker, ServerComponentInvoc
             invocationId.Value);
 
         var serializedServerComponentBytes = JsonSerializer.SerializeToUtf8Bytes(serverComponent, ServerComponentSerializationSettings.JsonSerializationOptions);
-        var protectedBytes = _dataProtector.Protect(serializedServerComponentBytes, ServerComponentSerializationSettings.DataExpiration);
+        var protectedBytes = _dataProtector.Protect(serializedServerComponentBytes, dataExpiration);
         return (serverComponent.Sequence, Convert.ToBase64String(protectedBytes));
     }
 }