fix(Dashboard): Fixed "paging" in timeline, both length and offset ha…

…ndling of next "pages"
neuroglia-io · May 2, 2024 · 7e59211 · 7e59211
1 parent 7e9c65a
commit 7e59211
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/dashboard/CloudStreams.Dashboard/Components/Timeline/Store.cs b/src/dashboard/CloudStreams.Dashboard/Components/Timeline/Store.cs
@@ -176,6 +176,7 @@ public async Task GatherCloudEventsAsync()
                 else
                 {
                     bool fetchMore = true;
+                    ulong length = StreamReadOptions.MaxLength;
                     long offset = options.Offset ?? (options.Direction == StreamReadDirection.Forwards ? 0 : -1);
                     do
                     {
@@ -184,12 +185,13 @@ public async Task GatherCloudEventsAsync()
                             Direction = options.Direction,
                             Partition = options.Partition,
                             Offset = offset,
-                            Length = StreamReadOptions.MaxLength
+                            Length = length
                         };
                         var cloudEvents = await (await cloudStreamsApi.CloudEvents.Stream.ReadStreamAsync(readOptions, this.CancellationTokenSource.Token).ConfigureAwait(false)).ToListAsync().ConfigureAwait(false);
                         data.AddRange(cloudEvents!);
-                        offset = (long)cloudEvents.Last()!.GetSequence()!;
-                        fetchMore = cloudEvents.Count > 1 && (ulong)data.Count < options!.Length;
+                        offset = (long)cloudEvents.Last()!.GetSequence()! + (options.Direction == StreamReadDirection.Forwards ? 1 : -1);
+                        length = Math.Min(options!.Length - (ulong)data.Count, StreamReadOptions.MaxLength);
+                        fetchMore = cloudEvents.Count > 1 && length != 0;
                     }
                     while(fetchMore);
                 }