Native: Enable Stick-to-bottom for logs table

* Add stick to end for logs table with stream sources and file source
  once it get into tailing state after finishing the initial file
  reading.
* Reference egui_table to special patch until the next crate release
  with the accepted changes.

Author: AmmarAbouZor

application/apps/indexer/Cargo.toml

@@ -83,7 +83,7 @@ egui = "0.33"
 eframe = { version = "0.33", default-features = false }
 rfd = "0.17"
 egui_extras = { version = "0.33", default-features = false }
-egui_table = "0.6"
+egui_table = "0.7"
 egui_plot = "0.34"
 # We don't have direct dependency to winit but we need to specify it here to activate 
 # its default features which won't be activated otherwise without activating egui default 
@@ -99,6 +99,10 @@ criterion = { version = "0.5", features = ["html_reports"] }
 insta = { version = "1.41", features = ["yaml"] }
 proptest = "1.6"
 
+[patch.crates-io]
+# This is needed until the next release "0.8" is available.
+egui_table = { git = "https://github.com/rerun-io/egui_table.git", rev = "cb95a2481f0e62f8f128d62ba2045ae0e6fb6253" }
+
 [workspace.lints.clippy]
 undocumented_unsafe_blocks = "deny"
 

application/apps/indexer/gui/application/src/session/message.rs

@@ -43,4 +43,10 @@ pub enum SessionMessage {
 
     /// Source has been added to session.
     SourceAdded { observe_op: Box<ObserveOperation> },
+
+    /// Triggered when a file is opened within the session.
+    /// Although `chipmunk` continues to monitor the file for changes,
+    /// this event is triggered upon the completion of file reading.
+    /// This event is not triggered for streams within a session.
+    FileReadCompleted,
 }

application/apps/indexer/gui/application/src/session/service/mod.rs

@@ -424,6 +424,11 @@ impl SessionService {
                     })
                     .await;
             }
+            CallbackEvent::FileRead => {
+                self.senders
+                    .send_session_msg(SessionMessage::FileReadCompleted)
+                    .await;
+            }
             event => {
                 println!("************** DEBUG: Received unhandled callback: {event:?}");
                 log::warn!("Unhandled callback: {event}");

application/apps/indexer/gui/application/src/session/ui/logs_table/mod.rs

@@ -4,7 +4,7 @@ use egui::{Color32, Sense, TextBuffer, Ui};
 use egui_table::{CellInfo, Column, HeaderCellInfo, PrefetchInfo, TableDelegate};
 use processor::grabber::LineRange;
 use std::sync::mpsc::Receiver as StdReceiver;
-use stypes::GrabbedElement;
+use stypes::{GrabbedElement, ObserveOrigin};
 use tokio::sync::mpsc::Sender;
 
 use crate::{
@@ -53,11 +53,27 @@ impl LogsTable {
         actions: &mut UiActions,
         ui: &mut Ui,
     ) {
+        let stick_to_bottom =
+            shared
+                .observe
+                .operations()
+                .first()
+                .is_some_and(|op| match &op.origin {
+                    ObserveOrigin::File(..) => {
+                        // Enable stick to bottom for files only when they reach tailing phase
+                        // after reading the already existed data in that file.
+                        op.phase().is_running() && shared.observe.is_file_read_completed()
+                    }
+                    ObserveOrigin::Concat(..) => false,
+                    ObserveOrigin::Stream(..) => true,
+                });
+
         let mut table = egui_table::Table::new()
             .id_salt("logs_table")
             .num_rows(shared.logs.logs_count)
             .columns(self.columns.as_ref())
-            .num_sticky_cols(1);
+            .num_sticky_cols(1)
+            .stick_to_bottom(stick_to_bottom);
 
         if !self.schema.has_headers() {
             table = table.headers(Vec::new());

application/apps/indexer/gui/application/src/session/ui/mod.rs

@@ -225,6 +225,7 @@ impl Session {
                     }
                     // Potential components which keep track for operations can go here.
                 }
+                SessionMessage::FileReadCompleted => self.shared.observe.set_file_read_completed(),
             }
         }
     }

application/apps/indexer/gui/application/src/session/ui/shared/observe.rs

@@ -14,13 +14,17 @@ use crate::{
 pub struct ObserveState {
     sources_count: usize,
     operations: Vec<ObserveOperation>,
+    /// Indicates if the initial file reading process has completed.
+    /// This is only relevant for file sources.
+    file_read_completed: bool,
 }
 
 impl ObserveState {
     pub fn new(observe_op: ObserveOperation) -> Self {
         let mut state = Self {
             sources_count: 0,
             operations: Vec::with_capacity(1),
+            file_read_completed: false,
         };
         state.add_operation(observe_op);
 
@@ -35,6 +39,7 @@ impl ObserveState {
         let Self {
             sources_count,
             operations,
+            file_read_completed: _,
         } = self;
 
         operations.push(observe_op);
@@ -73,4 +78,14 @@ impl ObserveState {
     pub fn is_initial_loading(&self) -> bool {
         self.operations.iter().all(ObserveOperation::initializing)
     }
+
+    /// Mark the initial file reading as completed.
+    pub fn set_file_read_completed(&mut self) {
+        self.file_read_completed = true
+    }
+
+    /// Check if the initial file reading has completed.
+    pub fn is_file_read_completed(&self) -> bool {
+        self.file_read_completed
+    }
 }