Method flush

src/services/session_storage.py:164–179

Flush buffered messages to disk.

(self)

            self.flush()

    def flush(self) -> None:
        """Flush buffered messages to disk."""
        if not self._write_buffer:
            return
        self._session_dir.mkdir(parents=True, exist_ok=True)
        with open(self._transcript_path, "a", encoding="utf-8") as f:
            for entry in self._write_buffer:
                f.write(json.dumps(entry, ensure_ascii=False) + "\n")
        count = len(self._write_buffer)
        self._write_buffer.clear()

        # Update metadata message count
        if self._metadata:
            self._metadata.message_count += count
            self._metadata.last_updated = time.time()
            self._save_metadata()

    # --- Content replacement ---