From 6bfce48b0c22677642553d7c5ff7f0cf6d0eca01 Mon Sep 17 00:00:00 2001
From: Nikhil Rao <nikhil@pynecone.io>
Date: Fri, 25 Aug 2023 16:16:51 -0700
Subject: [PATCH] Use stream_logs for frontend process (#1682)

---
 reflex/utils/exec.py      | 25 +++++++------------------
 reflex/utils/processes.py | 10 ++--------
 2 files changed, 9 insertions(+), 26 deletions(-)

diff --git a/reflex/utils/exec.py b/reflex/utils/exec.py
index abebc1d05..44f986004 100644
--- a/reflex/utils/exec.py
+++ b/reflex/utils/exec.py
@@ -25,9 +25,7 @@ def start_watching_assets_folder(root):
     asset_watch.start()
 
 
-def run_process_and_launch_url(
-    run_command: list[str],
-):
+def run_process_and_launch_url(run_command: list[str]):
     """Run the process and launch the URL.
 
     Args:
@@ -37,19 +35,13 @@ def run_process_and_launch_url(
         run_command, cwd=constants.WEB_DIR, shell=constants.IS_WINDOWS
     )
 
-    if process.stdout:
-        for line in process.stdout:
-            if "ready started server on" in line:
-                url = line.split("url: ")[-1].strip()
-                console.print(f"App running at: [bold green]{url}")
-            else:
-                console.debug(line)
+    for line in processes.stream_logs("Starting frontend", process):
+        if "ready started server on" in line:
+            url = line.split("url: ")[-1].strip()
+            console.print(f"App running at: [bold green]{url}")
 
 
-def run_frontend(
-    root: Path,
-    port: str,
-):
+def run_frontend(root: Path, port: str):
     """Run the frontend.
 
     Args:
@@ -67,10 +59,7 @@ def run_frontend(
     run_process_and_launch_url([prerequisites.get_package_manager(), "run", "dev"])  # type: ignore
 
 
-def run_frontend_prod(
-    root: Path,
-    port: str,
-):
+def run_frontend_prod(root: Path, port: str):
     """Run the frontend.
 
     Args:
diff --git a/reflex/utils/processes.py b/reflex/utils/processes.py
index 3b6ecccef..e8f9c6b94 100644
--- a/reflex/utils/processes.py
+++ b/reflex/utils/processes.py
@@ -193,10 +193,7 @@ def run_concurrently(*fns: Union[Callable, Tuple]) -> None:
         pass
 
 
-def stream_logs(
-    message: str,
-    process: subprocess.Popen,
-):
+def stream_logs(message: str, process: subprocess.Popen):
     """Stream the logs for a process.
 
     Args:
@@ -228,10 +225,7 @@ def stream_logs(
         raise typer.Exit(1)
 
 
-def show_logs(
-    message: str,
-    process: subprocess.Popen,
-):
+def show_logs(message: str, process: subprocess.Popen):
     """Show the logs for a process.
 
     Args: