release: v0.4.0

- Bidirectional async chat REPL (subscribe + concurrent input)
- Deduplicate work-log steps by (title, status)
- Filter stale events by timestamp
- Require pine-assistant>=0.3.0

Co-authored-by: Cursor <cursoragent@cursor.com>

Author: bojieli

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "pineai-cli"
-version = "0.3.0"
+version = "0.4.0"
 description = "Unified CLI for Pine AI — voice calls & assistant tasks from your terminal"
 readme = "README.md"
 license = "MIT"
@@ -27,7 +27,7 @@ classifiers = [
 ]
 dependencies = [
     "pine-voice>=0.1.5",
-    "pine-assistant>=0.2.0",
+    "pine-assistant>=0.3.0",
     "click>=8.1.0",
     "rich>=13.0.0",
 ]

src/pine_cli/__init__.py

@@ -1,3 +1,3 @@
 """Pine CLI — unified command-line interface for Pine AI."""
 
-__version__ = "0.3.0"
+__version__ = "0.4.0"

src/pine_cli/chat.py

@@ -275,10 +275,11 @@ def _print_history_message(msg):
 
 
 class _StreamPrinter:
-    """Handles streaming text_part events inline; delegates everything else."""
+    """Handles streaming text_part events inline; deduplicates work-log steps."""
 
     def __init__(self):
         self._in_text = False
+        self._seen_steps: set[tuple[str, str]] = set()
 
     def feed(self, event):
         if event.type == S2CEvent.SESSION_TEXT_PART:
@@ -290,10 +291,35 @@ def feed(self, event):
                     self._in_text = True
                 console.file.write(content)
                 console.file.flush()
+        elif event.type in (S2CEvent.SESSION_WORK_LOG, S2CEvent.SESSION_WORK_LOG_PART):
+            self.flush()
+            self._print_work_steps(event)
         else:
             self.flush()
             _print_event(event)
 
+    def _print_work_steps(self, event):
+        data = event.data if isinstance(event.data, dict) else {}
+        if event.type == S2CEvent.SESSION_WORK_LOG:
+            steps = data.get("steps", [])
+        else:
+            t = data.get("step_title", "")
+            steps = [{"step_title": t, "status": data.get("status", "")}] if t else []
+
+        for step in steps:
+            title = step.get("step_title", "").strip()
+            status = step.get("status", "").strip()
+            if not title:
+                continue
+            key = (title, status)
+            if key in self._seen_steps:
+                continue
+            self._seen_steps.add(key)
+            if status:
+                console.print(f"[dim]  ● {title} \\[{status}][/dim]")
+            else:
+                console.print(f"[dim]  ● {title}[/dim]")
+
     def flush(self):
         if self._in_text:
             console.file.write("\n")
@@ -320,16 +346,3 @@ def _print_event(event):
             console.print(f"[dim]  ● state → {state}[/dim]")
     elif event.type == S2CEvent.SESSION_THINKING:
         console.print("[dim]  ● thinking…[/dim]")
-    elif event.type == S2CEvent.SESSION_WORK_LOG:
-        data = event.data if isinstance(event.data, dict) else {}
-        steps = data.get("steps", [])
-        for step in steps:
-            title = step.get("step_title", "")
-            status = step.get("status", "")
-            console.print(f"[dim]  ● {title} \\[{status}][/dim]" if status else f"[dim]  ● {title}[/dim]")
-    elif event.type == S2CEvent.SESSION_WORK_LOG_PART:
-        data = event.data if isinstance(event.data, dict) else {}
-        title = data.get("step_title", "")
-        status = data.get("status", "")
-        if title or status:
-            console.print(f"[dim]  ● {title} \\[{status}][/dim]" if status else f"[dim]  ● {title}[/dim]")