From 51d75cfe6edee7fd478e732e319231656db24977 Mon Sep 17 00:00:00 2001
From: Claude <noreply@anthropic.com>
Date: Sun, 10 May 2026 12:36:37 +0000
Subject: [PATCH] fix: search accumulated log buffer for server readiness line

The stdout reader matched 'EngineFS server started at' against
string_data (the bytes from the most recent read only). If server.js
flushed in such a way that the readiness line straddled two reads,
neither chunk's .lines() yielded a full match, the endpoint channel
never received, recv() timed out, and the WebUI loaded against the
fallback URL.

Search the accumulated *lines buffer instead so a line split across
reads matches once the second chunk lands. Track endpoint_sent so we
do not resend on every subsequent chunk after a match.

Also preserve trailing newlines when trimming the retained buffer to
SRV_LOG_SIZE lines so a later chunk cannot be concatenated onto the
last unterminated line and corrupt a parser. Same trim treatment for
the stderr reader for consistency.

Closes #53
---
 src/stremio_app/stremio_server/server.rs | 31 ++++++++++++++++--------
 1 file changed, 21 insertions(+), 10 deletions(-)

diff --git a/src/stremio_app/stremio_server/server.rs b/src/stremio_app/stremio_server/server.rs
index d942b1b..922a416 100644
--- a/src/stremio_app/stremio_server/server.rs
+++ b/src/stremio_app/stremio_server/server.rs
@@ -104,7 +104,7 @@ impl StremioServer {
                     let out_lines = lines.clone();
                     let tx = tx.clone();
                     let out_thread = thread::spawn(move || {
-                        let http_endpoint = String::new();
+                        let mut endpoint_sent = false;
                         loop {
                             let mut buffer = [0; SRV_BUFFER_SIZE];
                             let on = match stdout.read(&mut buffer[..]) {
@@ -120,19 +120,21 @@ impl StremioServer {
                             {
                                 let lines = &mut *out_lines.lock().unwrap();
                                 *lines += string_data.deref();
-                                if http_endpoint.is_empty() {
-                                    if let Some(http_endpoint) = string_data
+                                if !endpoint_sent {
+                                    if let Some(line) = lines
                                         .lines()
                                         .find(|line| line.starts_with("EngineFS server started at"))
                                     {
-                                        let http_endpoint =
-                                            http_endpoint.split_whitespace().last().unwrap();
-                                        println!("HTTP endpoint: {http_endpoint}");
-                                        let endpoint = http_endpoint.to_string();
-                                        tx.send(endpoint.clone()).ok();
+                                        if let Some(endpoint) = line.split_whitespace().last() {
+                                            println!("HTTP endpoint: {endpoint}");
+                                            tx.send(endpoint.to_string()).ok();
+                                            endpoint_sent = true;
+                                        }
                                     }
                                 }
-                                *lines = lines
+                                // Preserve trailing newline so the next chunk can't glue onto an unterminated line.
+                                let had_trailing_newline = lines.ends_with('\n');
+                                let mut trimmed = lines
                                     .lines()
                                     .rev()
                                     .take(SRV_LOG_SIZE)
@@ -141,6 +143,10 @@ impl StremioServer {
                                     .rev()
                                     .collect::<Vec<&str>>()
                                     .join("\n");
+                                if had_trailing_newline {
+                                    trimmed.push('\n');
+                                }
+                                *lines = trimmed;
                             };
                         }
                     });
@@ -164,7 +170,8 @@ impl StremioServer {
                             {
                                 let lines = &mut *err_lines.lock().unwrap();
                                 *lines += string_data.deref();
-                                *lines = lines
+                                let had_trailing_newline = lines.ends_with('\n');
+                                let mut trimmed = lines
                                     .lines()
                                     .rev()
                                     .take(SRV_LOG_SIZE)
@@ -173,6 +180,10 @@ impl StremioServer {
                                     .rev()
                                     .collect::<Vec<&str>>()
                                     .join("\n");
+                                if had_trailing_newline {
+                                    trimmed.push('\n');
+                                }
+                                *lines = trimmed;
                             };
                         }
                     });