Implement IFlushable interface in ModifiableProject, ModifiablePublisher, and ModifiableUser classes

Author: Arlodotexe

src/Nomad/ModifiableProject.cs

@@ -15,7 +15,7 @@ namespace WindowsAppCommunity.Sdk.Nomad;
 /// <summary>
 /// Represents a project that can be modified.
 /// </summary>
-public class ModifiableProject : NomadKuboEventStreamHandler<ValueUpdateEvent>, IDelegable<Project>, IModifiableProject
+public class ModifiableProject : NomadKuboEventStreamHandler<ValueUpdateEvent>, IDelegable<Project>, IModifiableProject, IFlushable
 {
     /// <summary>
     /// Creates a new instance of <see cref="ModifiableProject"/> from the specified handler configuration.
@@ -504,4 +504,11 @@ public override async Task ResetEventStreamPositionAsync(CancellationToken cance
         await InnerUserRoleCollection.ResetEventStreamPositionAsync(cancellationToken);
         await ((ModifiableProjectCollection)Dependencies).ResetEventStreamPositionAsync(cancellationToken);
     }
+
+    /// <inheritdoc/>
+    public async Task FlushAsync(CancellationToken cancellationToken)
+    {
+        await this.PublishLocalAsync<ModifiableProject, ValueUpdateEvent>(cancellationToken);
+        await this.PublishRoamingAsync<ModifiableProject, ValueUpdateEvent, Project>(cancellationToken);
+    }
 }

src/Nomad/ModifiablePublisher.cs

@@ -15,7 +15,7 @@
 /// <summary>
 /// A modifiable event stream handler for modifying roaming publisher data.
 /// </summary>
-public class ModifiablePublisher : NomadKuboEventStreamHandler<ValueUpdateEvent>, IDelegable<Publisher>, IModifiablePublisher
+public class ModifiablePublisher : NomadKuboEventStreamHandler<ValueUpdateEvent>, IDelegable<Publisher>, IModifiablePublisher, IFlushable
 {
     /// <summary>
     /// Creates a new instance of <see cref="ModifiablePublisher"/> from the specified handler configuration.
@@ -238,7 +238,7 @@ public static ModifiablePublisher FromHandlerConfig(NomadKuboEventStreamHandlerC
     public bool? ForgetMe => InnerEntity.ForgetMe;
 
     /// <inheritdoc/>
-    public bool IsUnlisted => InnerEntity.IsUnlisted; 
+    public bool IsUnlisted => InnerEntity.IsUnlisted;
 
     /// <inheritdoc/>
     public Link[] Links => InnerEntity.Links;
@@ -415,7 +415,8 @@ public override async Task ApplyEntryUpdateAsync(EventStreamEntry<DagCid> stream
                 break;
             default:
                 throw new NotImplementedException();
-        };
+        }
+        ;
     }
 
     /// <inheritdoc/>
@@ -430,4 +431,11 @@ public override async Task ResetEventStreamPositionAsync(CancellationToken cance
         await ((ModifiablePublisherCollection)ParentPublishers).ResetEventStreamPositionAsync(cancellationToken);
         await ((ModifiablePublisherCollection)ChildPublishers).ResetEventStreamPositionAsync(cancellationToken);
     }
+
+    /// <inheritdoc/>
+    public async Task FlushAsync(CancellationToken cancellationToken)
+    {
+        await this.PublishLocalAsync<ModifiablePublisher, ValueUpdateEvent>(cancellationToken);
+        await this.PublishRoamingAsync<ModifiablePublisher, ValueUpdateEvent, Publisher>(cancellationToken);
+    }
 }

src/Nomad/ModifiableUser.cs

@@ -14,7 +14,7 @@ namespace WindowsAppCommunity.Sdk.Nomad;
 /// <summary>
 /// Represents a user that can be modified.
 /// </summary>
-public class ModifiableUser : NomadKuboEventStreamHandler<ValueUpdateEvent>, IModifiableUser, IDelegable<User>
+public class ModifiableUser : NomadKuboEventStreamHandler<ValueUpdateEvent>, IModifiableUser, IDelegable<User>, IFlushable
 {
     /// <summary>
     /// Creates a new instance of the <see cref="ModifiableUser"/> class from the given handler configuration.
@@ -351,4 +351,11 @@ public override async Task ResetEventStreamPositionAsync(CancellationToken cance
         await InnerPublisherRoles.ResetEventStreamPositionAsync(cancellationToken);
         await InnerProjectRoles.ResetEventStreamPositionAsync(cancellationToken);
     }
+
+    /// <inheritdoc/>
+    public async Task FlushAsync(CancellationToken cancellationToken)
+    {
+        await this.PublishLocalAsync<ModifiableUser, ValueUpdateEvent>(cancellationToken);
+        await this.PublishRoamingAsync<ModifiableUser, ValueUpdateEvent, User>(cancellationToken);
+    }
 }