feat: introduce io publisher for communicating events via stdio

Author: onur-askui

.env.tmp

@@ -0,0 +1,79 @@
+HOMEBREW_PREFIX=/opt/homebrew
+TERM=xterm-256color
+PYDEVD_DISABLE_FILE_VALIDATION=1
+TARS_API_KEY=
+CURSOR_CLI=ELECTRON_RUN_AS_NODE=1 "/Applications/Cursor.app/Contents/MacOS/Cursor" "/Applications/Cursor.app/Contents/Resources/app/out/cli.js"
+TMPDIR=/var/folders/0g/0d6s2wwd7xdd8qjrwn1dxk880000gn/T/
+ANTHROPIC_API_KEY=
+LC_TERMINAL=iTerm2
+NVM_CD_FLAGS=-q
+LS_COLORS=di=1;36:ln=35:so=32:pi=33:ex=31:bd=34;46:cd=34;43:su=30;41:sg=30;46:tw=30;42:ow=30;43
+VSCODE_GIT_ASKPASS_EXTRA_ARGS=
+LSCOLORS=Gxfxcxdxbxegedabagacad
+ENABLE_IDE_INTEGRATION=true
+ITERM_PROFILE=Default
+SHLVL=2
+STARSHIP_SHELL=zsh
+VSCODE_GIT_ASKPASS_MAIN=/Applications/Cursor.app/Contents/Resources/app/extensions/git/dist/askpass-main.js
+SECURITYSESSIONID=186af
+LaunchInstanceID=39A1C5AE-6C97-44A7-A1BF-0E129B1C8710
+TARS_URL=
+ASKUI_WORKSPACE_ID=
+TERM_SESSION_ID=w0t6p1:C9B1756F-C835-4699-9774-41ADAAD736D2
+NVM_INC=/Users/onur/.nvm/versions/node/v22.15.0/include/node
+__CF_USER_TEXT_ENCODING=0x1F5:0:2
+OLDPWD=/Users/onur/Workspace/vision-agent
+CURSOR_CLI_MODE=local
+FZF_DEFAULT_COMMAND=fd ~ --type f . ~
+GIT_ASKPASS=/Applications/Cursor.app/Contents/Resources/app/extensions/git/dist/askpass.sh
+USER=onur
+TERM_PROGRAM=vscode
+PWD=/Users/onur/Workspace/vision-agent
+ASKUI_COMPONENT_REGISTRY_FILE=/Applications/.askui-suite/DependencyCache/Suite.Installation.Cache.json
+STARSHIP_SESSION_KEY=1222059937035211
+ASKUI_INFERENCE_ENDPOINT=https://inference.askui.dev
+TERM_PROGRAM_VERSION=2.1.34
+VSCODE_GIT_IPC_HANDLE=/var/folders/0g/0d6s2wwd7xdd8qjrwn1dxk880000gn/T/vscode-git-acb06570d6.sock
+FZF_DEFAULT_OPTS=--highlight-line   --info=inline-right   --ansi   --layout=reverse   --border=none   --color=bg+:#2d3f76   --color=bg:#1e2030   --color=border:#589ed7   --color=fg:#c8d3f5   --color=gutter:#1e2030   --color=header:#ff966c   --color=hl+:#65bcff   --color=hl:#65bcff   --color=info:#545c7e   --color=marker:#ff007c   --color=pointer:#ff007c   --color=prompt:#65bcff   --color=query:#c8d3f5:regular   --color=scrollbar:#589ed7   --color=separator:#ff966c   --color=spinner:#ff007c
+ASKUI_INSTALLATION_DIRECTORY=/Applications/.askui-suite
+FZF_CTRL_T_OPTS=--bind 'enter:execute(nvim {})'
+LC_TERMINAL_VERSION=3.5.14
+COLORFGBG=15;0
+ASKUI__VA__TELEMETRY__ENABLED=True
+ASKUI__CHAT_API__allow_origins=["http://localhost:4200", "https://app.caesr.dev", "https://app.caesr.ai"]
+ASKUI_TOKEN=
+BUNDLED_DEBUGPY_PATH=/Users/onur/.cursor/extensions/ms-python.debugpy-2025.14.1-darwin-arm64/bundled/libs/debugpy
+ZSH=/Users/onur/.oh-my-zsh
+TERM_FEATURES=T3LrMSc7UUw9Ts3BFGsSyHNoSxF
+SHELL=/bin/zsh
+PATH=/Library/Frameworks/Python.framework/Versions/3.10/bin:/Library/Frameworks/Python.framework/Versions/3.13/bin:/opt/homebrew/bin:/opt/homebrew/sbin:/usr/local/bin:/System/Cryptexes/App/usr/bin:/usr/bin:/bin:/usr/sbin:/sbin:/var/run/com.apple.security.cryptexd/codex.system/bootstrap/usr/local/bin:/var/run/com.apple.security.cryptexd/codex.system/bootstrap/usr/bin:/var/run/com.apple.security.cryptexd/codex.system/bootstrap/usr/appleinternal/bin:/Library/Apple/usr/bin:/Users/onur/.local/bin:/Users/onur/Library/pnpm:/Users/onur/.nvm/versions/node/v22.15.0/bin:/Applications/iTerm.app/Contents/Resources/utilities:/Applications/.askui-suite/Tools:/Users/onur/.cursor/extensions/ms-python.debugpy-2025.14.1-darwin-arm64/bundled/scripts/noConfigScripts
+LANG=en_GB.UTF-8
+MallocNanoZone=0
+VSCODE_DEBUGPY_ADAPTER_ENDPOINTS=/Users/onur/.cursor/extensions/ms-python.debugpy-2025.14.1-darwin-arm64/.noConfigDebugAdapterEndpoints/endpoint-720b1a8060458e4a.txt
+HOMEBREW_REPOSITORY=/opt/homebrew
+INFOPATH=/opt/homebrew/share/info:/opt/homebrew/share/info:
+XPC_FLAGS=0x0
+HOME=/Users/onur
+_=/opt/homebrew/bin/op
+__CFBundleIdentifier=com.todesktop.230313mzl4w4u92
+PNPM_HOME=/Users/onur/Library/pnpm
+ORIGINAL_XDG_CURRENT_DESKTOP=undefined
+VSCODE_GIT_ASKPASS_NODE=/Applications/Cursor.app/Contents/Frameworks/Cursor Helper (Plugin).app/Contents/MacOS/Cursor Helper (Plugin)
+PAGER=less
+LESS=-R
+COLORTERM=truecolor
+CLAUDE_CODE_SSE_PORT=24679
+VSCODE_NONCE=e81e6f9d-bf64-44dd-bd8e-e50cac1a260a
+NVM_BIN=/Users/onur/.nvm/versions/node/v22.15.0/bin
+HOMEBREW_CELLAR=/opt/homebrew/Cellar
+COMMAND_MODE=unix2003
+LOGNAME=onur
+SSH_AUTH_SOCK=/private/tmp/com.apple.launchd.PkTOjWQpfr/Listeners
+OPEN_ROUTER_API_KEY=
+CURSOR_TRACE_ID=d154d744e0a94add96fead13888a6b7f
+XPC_SERVICE_NAME=application.com.todesktop.230313mzl4w4u92.22148485.22148491.41E3398D-0345-42F5-951F-93E5AC13F203
+NVM_DIR=/Users/onur/.nvm
+SQLITE_EXEMPT_PATH_FROM_VNODE_GUARDS=/Users/onur/Library/WebKit/Databases
+ITERM_SESSION_ID=w0t6p1:C9B1756F-C835-4699-9774-41ADAAD736D2
+TERMINFO_DIRS=/Applications/iTerm.app/Contents/Resources/terminfo:/usr/share/terminfo
+OSLogRateLimit=64

src/askui/chat/api/runs/events/io_publisher.py

@@ -0,0 +1,28 @@
+"""IO publisher for publishing events to stdout."""
+
+import json
+import sys
+from typing import Any
+
+from askui.chat.api.runs.events.events import Event
+
+
+class IOPublisher:
+    """Publisher that serializes events to JSON and writes to stdout."""
+
+    def publish(self, event: Event) -> None:
+        """
+        Publish an event by serializing it to JSON and writing to stdout.
+
+        Args:
+            event: The event to publish
+        """
+        try:
+            event_dict: dict[str, Any] = event.model_dump(mode="json")
+            event_json = json.dumps(event_dict)
+
+            sys.stdout.write(event_json + "\n")
+            sys.stdout.flush()
+        except (TypeError, ValueError, AttributeError, OSError) as e:
+            sys.stderr.write(f"Error publishing event: {e}\n")
+            sys.stderr.flush()

src/askui/chat/api/runs/service.py

@@ -12,6 +12,7 @@
 from askui.chat.api.messages.chat_history_manager import ChatHistoryManager
 from askui.chat.api.models import RunId, ThreadId, WorkspaceId
 from askui.chat.api.runs.events.events import DoneEvent, ErrorEvent, Event, RunEvent
+from askui.chat.api.runs.events.io_publisher import IOPublisher
 from askui.chat.api.runs.events.service import EventService
 from askui.chat.api.runs.models import (
     Run,
@@ -43,6 +44,7 @@ def __init__(
         self._chat_history_manager = chat_history_manager
         self._settings = settings
         self._event_service = EventService(settings.data_dir, self)
+        self._io_publisher = IOPublisher()
 
     def _find_by_id(
         self, workspace_id: WorkspaceId | None, thread_id: ThreadId, run_id: RunId
@@ -136,6 +138,7 @@ async def run_runner() -> None:
                                 if isinstance(event, DoneEvent) or isinstance(
                                     event, ErrorEvent
                                 ):
+                                    self._io_publisher.publish(event)
                                     break
                             except anyio.EndOfStream:
                                 break