in progress log viewer (part 2) (#26)

* simple solution to updating the client

* fix layout of expanded row

* Refactor ChatInterface and MetadataSection components for improved layout and functionality

- Adjusted default chat height in ChatInterface from 512px to 400px for better UI consistency.
- Enhanced MetadataSection to include expandable functionality, allowing users to toggle visibility of metadata details.
- Updated Row component to set defaultExpanded prop for MetadataSection, ensuring sections are expanded by default.

* Enhance StatusIndicator to show spinner for running status

- Updated Row component to pass showSpinner prop to StatusIndicator when the status is "running".
- Modified StatusIndicator to conditionally render a spinner based on the showSpinner prop, improving user feedback during loading states.

* Implement row expansion management in GlobalState and Dashboard

- Added functionality to manage expanded rows in GlobalState, including methods to toggle individual row expansion and set all rows expanded or collapsed.
- Updated Dashboard component to include buttons for expanding and collapsing all rows, and display the count of currently expanded rows.
- Refactored Row component to utilize GlobalState for determining and toggling row expansion state.

* Add auto-scroll functionality to ChatInterface for new messages

- Implemented auto-scrolling to the bottom of the chat window when new messages are received, enhancing user experience during conversations.
- Introduced a new scrollContainerRef to manage scrolling behavior effectively.

* Refactor GlobalState and Dashboard components for improved data handling and UI

- Changed dataset and expandedRows in GlobalState from arrays and sets to objects for better performance and reactivity.
- Updated setDataset method to create a new dataset object, preserving expansion state more efficiently.
- Refactored Dashboard to utilize totalCount for dataset management and replaced the Row component with EvaluationTable for cleaner structure.
- Introduced EvaluationRow and EvaluationTable components to enhance modularity and maintainability of the evaluation display.

* Enhance auto-scroll functionality in ChatInterface to prevent initial scroll on mount

- Added a reference to track the initial mount state, preventing auto-scrolling on the first render.
- Updated the scrolling logic to only trigger after the initial mount when new messages are received, improving user experience during chat interactions.

* Refactor auto-scroll logic in ChatInterface to enhance user experience

- Replaced initial mount reference with a previous messages length reference to prevent scrolling on the first render and only scroll when new messages are added.
- Improved scrolling behavior to avoid unnecessary scrolls when messages are removed, ensuring a smoother chat interaction.

* update build

* Remove redundant arguments from logs command in CLI and simplify serve_logs call

* Update logs command to use default localhost settings and simplify output

- Removed the ability to specify watch paths, defaulting to 'current directory'.
- Changed server host and port to fixed values (localhost:8000) for consistency.

* Implement message expansion feature in MessageBubble component

- Added state management to toggle message expansion for long messages.
- Introduced a helper function to format message content based on its type.
- Updated rendering logic to display a "Show more" / "Show less" button for long messages, enhancing user interaction.

* update build

Author: Dylan Huang

eval_protocol/cli.py

@@ -25,9 +25,9 @@
 )
 from .cli_commands.deploy import deploy_command
 from .cli_commands.deploy_mcp import deploy_mcp_command
+from .cli_commands.logs import logs_command
 from .cli_commands.preview import preview_command
 from .cli_commands.run_eval_cmd import hydra_cli_entry_point
-from .cli_commands.logs import logs_command
 
 
 def parse_args(args=None):
@@ -289,36 +289,6 @@ def parse_args(args=None):
 
     # Logs command
     logs_parser = subparsers.add_parser("logs", help="Serve logs with file watching and real-time updates")
-    logs_parser.add_argument(
-        "--build-dir",
-        default="dist",
-        help="Path to the Vite build output directory (default: dist)",
-    )
-    logs_parser.add_argument(
-        "--host",
-        default="localhost",
-        help="Host to bind the server to (default: localhost)",
-    )
-    logs_parser.add_argument(
-        "--port",
-        type=int,
-        default=4789,
-        help="Port to bind the server to (default: 4789)",
-    )
-    logs_parser.add_argument(
-        "--index-file",
-        default="index.html",
-        help="Name of the main index file (default: index.html)",
-    )
-    logs_parser.add_argument(
-        "--watch-paths",
-        help="Comma-separated list of paths to watch for file changes (default: current directory)",
-    )
-    logs_parser.add_argument(
-        "--reload",
-        action="store_true",
-        help="Enable auto-reload (default: False)",
-    )
 
     # Run command (for Hydra-based evaluations)
     # This subparser intentionally defines no arguments itself.

eval_protocol/cli_commands/logs.py

@@ -11,26 +11,15 @@
 def logs_command(args):
     """Serve logs with file watching and real-time updates"""
 
-    # Parse watch paths
-    watch_paths = None
-    if args.watch_paths:
-        watch_paths = args.watch_paths.split(",")
-        watch_paths = [path.strip() for path in watch_paths if path.strip()]
-
     print(f"🚀 Starting Eval Protocol Logs Server")
-    print(f"🌐 URL: http://{args.host}:{args.port}")
-    print(f"🔌 WebSocket: ws://{args.host}:{args.port}/ws")
-    print(f"👀 Watching paths: {watch_paths or ['current directory']}")
+    print(f"🌐 URL: http://localhost:8000")
+    print(f"🔌 WebSocket: ws://localhost:8000/ws")
+    print(f"👀 Watching paths: {['current directory']}")
     print("Press Ctrl+C to stop the server")
     print("-" * 50)
 
     try:
-        serve_logs(
-            host=args.host,
-            port=args.port,
-            watch_paths=watch_paths,
-            reload=args.reload,
-        )
+        serve_logs()
         return 0
     except KeyboardInterrupt:
         print("\n🛑 Server stopped by user")

eval_protocol/utils/logs_server.py

@@ -97,6 +97,18 @@ def broadcast_file_update(self, update_type: str, file_path: str):
             return
         logger.info(f"Broadcasting file update: {update_type} {file_path}")
 
+        logs = default_logger.read()
+        # send initialize_logs message to all connected clients
+        for connection in self.active_connections:
+            asyncio.run_coroutine_threadsafe(
+                connection.send_text(
+                    json.dumps(
+                        {"type": "initialize_logs", "logs": [log.model_dump_json(exclude_none=True) for log in logs]}
+                    )
+                ),
+                self._loop,
+            )
+
         message = {"type": update_type, "path": file_path, "timestamp": time.time()}
         # Include file contents for created and modified events
         if update_type in ["file_created", "file_changed"] and os.path.exists(file_path):
@@ -137,7 +149,7 @@ def __init__(
             os.path.join(os.path.dirname(os.path.dirname(os.path.dirname(__file__))), "vite-app", "dist")
         ),
         host: str = "localhost",
-        port: Optional[int] = None,
+        port: Optional[int] = 8000,
         index_file: str = "index.html",
         watch_paths: Optional[List[str]] = None,
     ):