From a8f8753a66156335e4b7c4612cc292cbcc607304 Mon Sep 17 00:00:00 2001
From: TobiasGunther <tobiasg@egde.no>
Date: Fri, 28 Apr 2023 13:09:09 +0200
Subject: [PATCH] GH-235: Added filtering of consumers.

---
 src/vite-api/Classes/StreamManager.cs | 17 +++++++++++++++--
 1 file changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/vite-api/Classes/StreamManager.cs b/src/vite-api/Classes/StreamManager.cs
index 9112d0b..29eb2ea 100644
--- a/src/vite-api/Classes/StreamManager.cs
+++ b/src/vite-api/Classes/StreamManager.cs
@@ -54,7 +54,7 @@ public List<BasicStreamInfoDto> GetAllStreams()
                {
                    Name = x.Config.Name,
                    SubjectCount = x.State.SubjectCount,
-                   ConsumerCount = x.State.ConsumerCount,
+                   ConsumerCount = FilterConsumers(jsm.GetConsumers(x.Config.Name).ToList()).Count,
                    MessageCount = x.State.Messages
                }).ToList();
         }
@@ -76,7 +76,7 @@ public ExtendedStreamInfoDto GetSpecificStream(string streamName)
                 {
                     Name = streamInfo.Config.Name,
                     Subjects = streamInfo.Config.Subjects,
-                    Consumers = jsm.GetConsumerNames(streamName).ToList(),
+                    Consumers = FilterConsumers(jsm.GetConsumers(streamName).ToList()).Select(x => x.Name).ToList(),
                     Description = streamInfo.Config.Description,
                     Messages = streamInfo.State.Messages,
                     Deleted = streamInfo.State.DeletedCount,
@@ -92,5 +92,18 @@ public ExtendedStreamInfoDto GetSpecificStream(string streamName)
                 throw new ArgumentException("Given stream name or sequence number does not exist on the server");
             }
         }
+
+        /// <summary>
+        /// Filters consumers based on the date they where created. Only consumers older than 10 minutes are being kept.
+        /// </summary>
+        /// <param name="consumers">List of consumers.</param>
+        /// <returns>Filtered list.</returns>
+        private static List<ConsumerInfo> FilterConsumers(IEnumerable<ConsumerInfo> consumers)
+        {
+            return consumers.Where(x =>
+                DateTime.Now.Date > x.Created ||
+                (DateTime.Now.ToUniversalTime() - x.Created.ToUniversalTime()).TotalHours >= 1 ||
+                (DateTime.Now.ToUniversalTime() - x.Created.ToUniversalTime()).TotalMinutes > 10).ToList();
+        }
     }
 }