feat: implement streaming session logs with real-time updates (#1903)

* Initial plan

* feat: implement streaming session logs with real-time updates

Co-authored-by: rnwood <1327895+rnwood@users.noreply.github.com>

* fix: handle null session warnings in Vue component

Co-authored-by: rnwood <1327895+rnwood@users.noreply.github.com>

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: rnwood <1327895+rnwood@users.noreply.github.com>

Author: Copilot

Rnwood.Smtp4dev/ClientApp/src/components/sessionlist.vue

@@ -225,6 +225,9 @@
                 this.connection.on("sessionschanged", () => {
                     this.refresh(true);
                 });
+                this.connection.on("sessionupdated", (sessionId: string) => {
+                    this.refresh(true);
+                });
                 this.connection.addOnConnectedCallback(() => this.refresh(true));
             }
         }

Rnwood.Smtp4dev/ClientApp/src/components/sessionview.vue

@@ -11,7 +11,7 @@
                       type="warning"
                       show-icon
                       title="This session terminated abnormally">{{session.error}}</el-alert>
-                <el-alert v-for="warning in session.warnings"
+                <el-alert v-for="warning in session?.warnings || []"
                           v-bind:key="warning.details"
                           :title="'Warning: ' + warning.details"
                           type="warning"
@@ -41,12 +41,13 @@
     </div>
 </template>
 <script lang="ts">
-    import { Component, Vue, Prop, Watch, toNative } from "vue-facing-decorator";
+    import { Component, Vue, Prop, Watch, toNative, Inject } from "vue-facing-decorator";
 
     import SessionsController from "../ApiClient/SessionsController";
     import SessionSummary from "../ApiClient/SessionSummary";
     import Session from "../ApiClient/Session";
     import TextView from "@/components/textview.vue";
+    import HubConnectionManager from "../HubConnectionManager";
 
     @Component({
         components: {
@@ -57,18 +58,25 @@
 
         @Prop({})
         sessionSummary: SessionSummary | null = null;
+        
+        @Inject({ default: null })
+        connection!: HubConnectionManager | null;
+        
         session: Session | null = null;
         log: string | null = null;
 
         error: Error | null = null;
         loading = false;
+        
+        private pollInterval: number | null = null;
 
         @Watch("sessionSummary")
         async onMessageChanged(
             value: SessionSummary | null,
             oldValue: SessionSummary | null
         ) {
             await this.loadSession();
+            this.setupPolling();
         }
 
         async loadMessage() {
@@ -104,10 +112,72 @@
                 this.loading = false;
             }
         }
+        
+        async refreshLog() {
+            if (this.sessionSummary != null && !this.sessionSummary.endDate) {
+                try {
+                    const newSession = await new SessionsController().getSession(
+                        this.sessionSummary.id
+                    );
+                    const newLog = await new SessionsController().getSessionLog(
+                        this.sessionSummary.id
+                    );
+                    
+                    // Only update if content has changed
+                    if (this.log !== newLog) {
+                        this.log = newLog;
+                    }
+                    
+                    // Update session properties if they've changed
+                    if (JSON.stringify(this.session) !== JSON.stringify(newSession)) {
+                        this.session = newSession;
+                    }
+                    
+                    // If session has ended, stop polling
+                    if (newSession) {
+                        // Session ended, need to update the summary as well
+                        this.stopPolling();
+                    }
+                } catch (e: any) {
+                    // Silently ignore errors during polling
+                    console.warn('Failed to refresh session log:', e);
+                }
+            }
+        }
+        
+        setupPolling() {
+            this.stopPolling();
+            
+            // Only poll if session is active (no end date)
+            if (this.sessionSummary && !this.sessionSummary.endDate) {
+                this.pollInterval = window.setInterval(() => {
+                    this.refreshLog();
+                }, 1000); // Poll every second
+            }
+        }
+        
+        stopPolling() {
+            if (this.pollInterval !== null) {
+                clearInterval(this.pollInterval);
+                this.pollInterval = null;
+            }
+        }
+        
+        onSessionUpdated(sessionId: string) {
+            if (this.sessionSummary && this.sessionSummary.id === sessionId) {
+                this.refreshLog();
+            }
+        }
 
-        async created() { }
+        async created() {
+            if (this.connection) {
+                this.connection.on("sessionupdated", this.onSessionUpdated.bind(this));
+            }
+        }
 
-        async destroyed() { }
+        async unmounted() {
+            this.stopPolling();
+        }
     }
 
 

Rnwood.Smtp4dev/Controllers/SessionsController.cs

@@ -34,7 +34,7 @@ public SessionsController(Smtp4devDbContext dbContext, ISmtp4devServer server)
         [HttpGet]
         public PagedResult<SessionSummary> GetSummaries(int page = 1, int pageSize = 5)
         {
-            return dbContext.Sessions.AsNoTracking().Where(s => s.EndDate.HasValue).OrderByDescending(x => x.StartDate)
+            return dbContext.Sessions.AsNoTracking().OrderByDescending(x => x.StartDate)
                 .Select(m => new SessionSummary(m)).GetPaged(page, pageSize);
         }
 

Rnwood.Smtp4dev/Hubs/NotificationsHub.cs

@@ -50,6 +50,14 @@ public async Task OnSessionsChanged()
             }
         }
 
+        public async Task OnSessionUpdated(Guid sessionId)
+        {
+            if (Clients != null)
+            {
+                await Clients.All.SendAsync("sessionupdated", sessionId);
+            }
+        }
+
         public async Task OnMailboxesChanged()
         {
             if (Clients != null)

Rnwood.Smtp4dev/Server/Smtp4devServer.cs

@@ -416,6 +416,8 @@ await taskQueue.QueueTask(() =>
                 dbContext.SaveChanges();
 
                 activeSessionsToDbId[e.Session] = dbSession.Id;
+                
+                notificationsHub.OnSessionUpdated(dbSession.Id).Wait();
             }, false).ConfigureAwait(false);
         }
 
@@ -440,6 +442,7 @@ await taskQueue.QueueTask(() =>
 
                 activeSessionsToDbId.Remove(e.Session);
 
+                notificationsHub.OnSessionUpdated(dbSession.Id).Wait();
                 notificationsHub.OnSessionsChanged().Wait();
             }, false).ConfigureAwait(false);
         }