release: v2.32.0 — Codex session catchup, Loaditout badge, Stop hook fix, version sync

- Bump version to 2.32.0 across all 12 SKILL.md files, plugin.json,
  marketplace.json, and CITATION.cff (fixes scattered versions 2.22.0-2.26.1)
- Add CHANGELOG entry for v2.32.0 (PR #124 Codex catchup by @ebrevdo,
  PR #126 Loaditout badge + Stop hook fix for #123 and #125)
- Add @ebrevdo to CONTRIBUTORS.md (Major Contributions section)
- Update README Releases table with v2.30.0-v2.32.0 entries
- Update README version badge to 2.32.0

.claude-plugin/marketplace.json

@@ -9,7 +9,7 @@
       "name": "planning-with-files",
       "source": "./",
       "description": "Manus-style persistent markdown files for planning, progress tracking, and knowledge storage. Now with hooks integration.",
-      "version": "2.23.0"
+      "version": "2.32.0"
     }
   ]
 }

.claude-plugin/plugin.json

@@ -1,6 +1,6 @@
 {
   "name": "planning-with-files",
-  "version": "2.23.0",
+  "version": "2.32.0",
   "description": "Manus-style persistent markdown files for planning, progress tracking, and knowledge storage. Works with Claude Code, Kiro, Clawd CLI, Gemini CLI, Cursor, Continue, and 11+ AI coding assistants.",
   "author": {
     "name": "OthmanAdi",

.codebuddy/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CODEBUDDY_PLUGIN_ROOT:-$HOME/.codebuddy/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CODEBUDDY_PLUGIN_ROOT:-$HOME/.codebuddy/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.23.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.codebuddy/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

.codex/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CODEX_SKILL_ROOT:-$HOME/.codex/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CODEX_SKILL_ROOT:-$HOME/.codex/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.23.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.codex/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

.continue/skills/planning-with-files/SKILL.md

@@ -2,7 +2,7 @@
 name: planning-with-files
 description: Implements Manus-style file-based planning to organize and track progress on complex tasks. Creates task_plan.md, findings.md, and progress.md. Use when asked to plan out, break down, or organize a multi-step project, research task, or any work requiring >5 tool calls. Supports automatic session recovery after /clear.
 metadata:
-  version: "2.22.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.continue/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

.cursor/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CURSOR_SKILL_ROOT:-.cursor/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CURSOR_SKILL_ROOT:-.cursor/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.23.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.factory/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${FACTORY_PROJECT_DIR:-.factory/skills/planning-with-files}/scripts\"; sh \"$SD/check-complete.sh\" 2>/dev/null || true"
+          command: "export SD=\"${FACTORY_PROJECT_DIR:-.factory/skills/planning-with-files}/scripts\"; sh \"$SD/check-complete.sh\" 2>/dev/null || true"
 metadata:
-  version: "2.26.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.factory/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

.gemini/skills/planning-with-files/SKILL.md

@@ -2,7 +2,7 @@
 name: planning-with-files
 description: Implements Manus-style file-based planning to organize and track progress on complex tasks. Creates task_plan.md, findings.md, and progress.md. Use when asked to plan out, break down, or organize a multi-step project, research task, or any work requiring >5 tool calls. Supports automatic session recovery after /clear.
 metadata:
-  version: "2.26.0"
+  version: "2.32.0"
   hooks: "Configured in .gemini/settings.json (SessionStart, BeforeTool, AfterTool, BeforeModel)"
 ---
 

.gemini/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

.kiro/skills/planning-with-files/SKILL.md

@@ -5,7 +5,7 @@ license: MIT
 compatibility: Requires a POSIX shell or PowerShell, Python 3 for session-catchup, and read/write access to the workspace. See Kiro Agent Skills — https://kiro.dev/docs/skills/
 allowed-tools: shell read write
 metadata:
-  version: "3.0.0-kiro"
+  version: "2.32.0-kiro"
   integration: kiro
 ---
 

.mastracode/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"$HOME/.mastracode/skills/planning-with-files/scripts\"; [ -f \"$SD/check-complete.sh\" ] || SD=\".mastracode/skills/planning-with-files/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"$HOME/.mastracode/skills/planning-with-files/scripts\"; [ -f \"$SD/check-complete.sh\" ] || export SD=\".mastracode/skills/planning-with-files/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.23.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.opencode/skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${OPENCODE_SKILL_ROOT:-$HOME/.config/opencode/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${OPENCODE_SKILL_ROOT:-$HOME/.config/opencode/skills/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.23.0"
+  version: "2.32.0"
 ---
 
 # Planning with Files

.pi/skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

CHANGELOG.md

@@ -2,6 +2,31 @@
 
 All notable changes to this project will be documented in this file.
 
+## [2.32.0] - 2026-04-08
+
+### Added
+
+- **Codex session catchup** (PR #124 by @ebrevdo)
+  - `session-catchup.py` now reads Codex rollout JSONL from `~/.codex/sessions`, prefers `CODEX_THREAD_ID` when skipping the current thread, filters subagent and tiny sessions, and detects planning-file updates from structured Codex `patch_apply_end` events
+  - Major rewrite: +1,945/-486 lines across session-catchup, tests, and docs
+
+- **Loaditout security badge** (PR #126, closes #123)
+  - Added A-grade security badge to README (top 20.5% of 20,000+ MCP servers scanned)
+
+### Fixed
+
+- **Stop hook fails on Windows Git Bash (MSYS2)** (PR #126, closes #125)
+  - Root cause: MSYS2 treats bare `SD="/c/Users/..."` as a command to execute rather than a variable assignment
+  - Fix: changed `SD="..."` to `export SD="..."` across all 9 SKILL.md variants (Claude Code, Codex, CodeBuddy, Cursor, Factory, Gemini, Mastra Code, OpenCode, + zh/zht)
+
+### Changed
+
+- Version bumped to 2.32.0 across all 12 SKILL.md files, plugin.json, marketplace.json, and CITATION.cff
+
+### Thanks
+
+- @ebrevdo (Eugene Brevdo) for the Codex session catchup rewrite (PR #124)
+
 ## [2.29.0] - 2026-03-24
 
 ### Added

CITATION.cff

@@ -0,0 +1,23 @@
+cff-version: 1.2.0
+message: "If you use this software, please cite it using the metadata below."
+type: software
+title: "planning-with-files"
+abstract: "Claude Code skill implementing Manus-style persistent markdown planning — the workflow pattern behind the $2B acquisition. Enables AI agents to plan, track progress, and resume work across sessions using structured markdown files."
+authors:
+  - family-names: Adi
+    given-names: Ahmad Othman Ammar
+    alias: OthmanAdi
+version: "2.32.0"
+date-released: "2026-04-08"
+license: MIT
+url: "https://github.com/OthmanAdi/planning-with-files"
+repository-code: "https://github.com/OthmanAdi/planning-with-files"
+keywords:
+  - claude-code
+  - agent-skill
+  - planning
+  - task-management
+  - manus-style
+  - autonomous-agents
+  - markdown
+  - ai-agents

CONTRIBUTORS.md

@@ -89,6 +89,12 @@ These amazing people have contributed code, documentation, or significant improv
   - Analytics-specific `progress.md` with Query Log replacing Test Results
   - **Impact:** Extends the planning pattern to data analytics workflows (addresses #103)
 
+- **[@ebrevdo](https://github.com/ebrevdo)** (Eugene Brevdo) - [PR #124](https://github.com/OthmanAdi/planning-with-files/pull/124)
+  - Rewrote `session-catchup.py` to support Codex rollout JSONL session format
+  - Added `CODEX_THREAD_ID` preference, subagent/tiny session filtering, and structured `patch_apply_end` event detection
+  - Updated tests and docs for the new Codex catchup behavior
+  - **Impact:** Brings session recovery parity to Codex users
+
 ### Other Contributors
 
 - **[@popey](https://github.com/popey)** - [PR #83](https://github.com/OthmanAdi/planning-with-files/pull/83)
@@ -192,6 +198,6 @@ If you've contributed and don't see your name here, please open an issue! We wan
 
 ---
 
-**Total Contributors:** 27+ and growing!
+**Total Contributors:** 28+ and growing!
 
-*Last updated: March 24, 2026*
+*Last updated: April 8, 2026*

README.md

@@ -1,12 +1,18 @@
+<div align="center">
+<img src="media/banner.png" alt="planning-with-files" width="100%">
+</div>
+
 # Planning with Files
 
 > **Work like Manus** — the AI agent company Meta acquired for **$2 billion**.
 
 [![Closed Issues](https://img.shields.io/github/issues-closed/OthmanAdi/planning-with-files?color=success)](https://github.com/OthmanAdi/planning-with-files/issues?q=is%3Aissue+is%3Aclosed)
+[![Skills Playground](https://skillsplayground.com/badges/installs/othmanadi-planning-with-files-planning-with-files.svg)](https://skillsplayground.com/skills/othmanadi-planning-with-files-planning-with-files/)
 [![Closed PRs](https://img.shields.io/github/issues-pr-closed/OthmanAdi/planning-with-files?color=success)](https://github.com/OthmanAdi/planning-with-files/pulls?q=is%3Apr+is%3Aclosed)
 [![Benchmark](https://img.shields.io/badge/Benchmark-96.7%25_pass_rate-brightgreen)](docs/evals.md)
 [![A/B Verified](https://img.shields.io/badge/A%2FB_Blind-3%2F3_wins-brightgreen)](docs/evals.md)
 [![Security Verified](https://img.shields.io/badge/Security-Audited_%26_Fixed_v2.21.0-blue)](docs/evals.md)
+[![Loaditout Security Grade](https://loaditout.ai/badge/OthmanAdi/planning-with-files)](https://loaditout.ai/skills/OthmanAdi/planning-with-files)
 
 <details>
 <summary><strong>💬 A Note from the Author</strong></summary>
@@ -42,10 +48,14 @@ See the full list of everyone who made this project better in [CONTRIBUTORS.md](
 <details>
 <summary><strong>📦 Releases & Session Recovery</strong></summary>
 
-### Current Version: v2.29.0
+### Current Version: v2.32.0
 
 | Version | Highlights |
 |---------|------------|
+| **v2.32.0** | Codex session catchup rewrite (thanks @ebrevdo!), Loaditout A-grade security badge, Stop hook Git Bash fix |
+| **v2.31.0** | Codex hooks.json integration with full lifecycle hooks (thanks @Leon-Algo!) |
+| **v2.30.1** | Fix: Codex script executable bits restored (thanks @Leon-Algo!) |
+| **v2.30.0** | `CLAUDE_SKILL_DIR` variable, IDE configs moved to per-IDE branches, plugin.json bumped from 2.23.0 |
 | **v2.29.0** | Analytics workflow template: `--template analytics` flag for data exploration sessions (thanks @mvanhorn!) |
 | **v2.28.0** | Traditional Chinese (zh-TW) skill variant (thanks @waynelee2048!) |
 | **v2.26.2** | Fix: `---` in hook commands broke YAML frontmatter parsing, hooks now register correctly |
@@ -77,7 +87,7 @@ See the full list of everyone who made this project better in [CONTRIBUTORS.md](
 When your context fills up and you run `/clear`, this skill **automatically recovers** your previous session.
 
 **How it works:**
-1. Checks for previous session data in `~/.claude/projects/`
+1. Checks for previous session data in the active IDE's session store (`~/.claude/projects/` for Claude Code, `~/.codex/sessions/` for Codex)
 2. Finds when planning files were last updated
 3. Extracts conversation that happened after (potentially lost context)
 4. Shows a catchup report so you can sync
@@ -154,7 +164,7 @@ A Claude Code plugin that transforms your workflow to use persistent markdown fi
 [![GitHub Copilot](https://img.shields.io/badge/GitHub%20Copilot-Hooks-000000)](https://docs.github.com/en/copilot/reference/hooks-configuration)
 [![Mastra Code](https://img.shields.io/badge/Mastra%20Code-Skills-00BCD4)](https://code.mastra.ai)
 [![BoxLite](https://img.shields.io/badge/BoxLite-Sandbox-6C3483)](https://boxlite.ai)
-[![Version](https://img.shields.io/badge/version-2.29.0-brightgreen)](https://github.com/OthmanAdi/planning-with-files/releases)
+[![Version](https://img.shields.io/badge/version-2.32.0-brightgreen)](https://github.com/OthmanAdi/planning-with-files/releases)
 [![SkillCheck Validated](https://img.shields.io/badge/SkillCheck-Validated-4c1)](https://getskillcheck.com)
 
 ## Quick Install

skills/planning-with-files-zh/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.24.0"
+  version: "2.32.0"
 ---
 
 # 文件规划系统

skills/planning-with-files-zht/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files-zht}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files-zht}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.28.0"
+  version: "2.32.0"
 ---
 
 # 檔案規劃系統

skills/planning-with-files/SKILL.md

@@ -21,9 +21,9 @@ hooks:
   Stop:
     - hooks:
         - type: command
-          command: "SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
+          command: "export SD=\"${CLAUDE_PLUGIN_ROOT:-$HOME/.claude/plugins/planning-with-files}/scripts\"; powershell.exe -NoProfile -ExecutionPolicy Bypass -File \"$SD/check-complete.ps1\" 2>/dev/null || sh \"$SD/check-complete.sh\""
 metadata:
-  version: "2.26.1"
+  version: "2.32.0"
 ---
 
 # Planning with Files

skills/planning-with-files/scripts/session-catchup.py

@@ -12,9 +12,35 @@ import json
 import sys
 import os
 from pathlib import Path
-from typing import List, Dict, Optional, Tuple
+from typing import Any, Dict, Iterable, List, Optional, Tuple
+
+try:
+    import orjson
+except ImportError:
+    orjson = None
 
 PLANNING_FILES = ['task_plan.md', 'progress.md', 'findings.md']
+MIN_SESSION_BYTES = 5000
+
+
+def json_loads(line: str) -> Optional[Dict[str, Any]]:
+    """Prefer optional orjson while keeping the hook dependency-free."""
+    try:
+        if orjson is not None:
+            data = orjson.loads(line)
+        else:
+            data = json.loads(line)
+    except (ValueError, TypeError, UnicodeDecodeError):
+        return None
+    return data if isinstance(data, dict) else None
+
+
+def normalize_for_compare(path_value: str) -> str:
+    expanded = os.path.expanduser(path_value)
+    try:
+        return str(Path(expanded).resolve())
+    except (OSError, ValueError):
+        return os.path.abspath(expanded)
 
 
 def normalize_path(project_path: str) -> str:
@@ -43,8 +69,8 @@ def normalize_path(project_path: str) -> str:
     return p
 
 
-def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
-    """Resolve session storage path for the current runtime variant."""
+def get_claude_project_dir(project_path: str) -> Path:
+    """Resolve Claude Code's project-specific session storage path."""
     normalized = normalize_path(project_path)
 
     # Claude Code's sanitization: replace path separators and : with -
@@ -54,44 +80,141 @@ def get_project_dir(project_path: str) -> Tuple[Optional[Path], Optional[str]]:
     if sanitized.startswith('-'):
         sanitized = sanitized[1:]
 
-    claude_path = Path.home() / '.claude' / 'projects' / sanitized
-
-    # Codex stores sessions in ~/.codex/sessions with a different format.
-    # Avoid silently scanning Claude paths when running from Codex skill folder.
-    script_path = Path(__file__).as_posix().lower()
-    is_codex_variant = '/.codex/' in script_path
-    codex_sessions_dir = Path.home() / '.codex' / 'sessions'
-    if is_codex_variant and codex_sessions_dir.exists() and not claude_path.exists():
-        return None, (
-            "[planning-with-files] Session catchup skipped: Codex stores sessions "
-            "in ~/.codex/sessions and native Codex parsing is not implemented yet."
-        )
-
-    return claude_path, None
+    return Path.home() / '.claude' / 'projects' / sanitized
 
 
 def get_sessions_sorted(project_dir: Path) -> List[Path]:
     """Get all session files sorted by modification time (newest first)."""
     sessions = list(project_dir.glob('*.jsonl'))
     main_sessions = [s for s in sessions if not s.name.startswith('agent-')]
-    return sorted(main_sessions, key=lambda p: p.stat().st_mtime, reverse=True)
+    return sorted(main_sessions, key=safe_stat_mtime, reverse=True)
 
 
-def parse_session_messages(session_file: Path) -> List[Dict]:
+def safe_stat_mtime(path: Path) -> float:
+    try:
+        return path.stat().st_mtime
+    except OSError:
+        return 0.0
+
+
+def is_substantial_session(session: Path) -> bool:
+    try:
+        return session.stat().st_size > MIN_SESSION_BYTES
+    except OSError:
+        return False
+
+
+def read_codex_meta(session_file: Path) -> Optional[Dict[str, Any]]:
+    """Read the first session_meta; later meta records may be copied parent context."""
+    try:
+        with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
+            for line in f:
+                data = json_loads(line)
+                if not data or data.get('type') != 'session_meta':
+                    continue
+                payload = data.get('payload')
+                return payload if isinstance(payload, dict) else None
+    except OSError:
+        return None
+    return None
+
+
+def codex_meta_cwd(meta: Dict[str, Any]) -> Optional[str]:
+    cwd = meta.get('cwd')
+    return cwd if isinstance(cwd, str) else None
+
+
+def find_current_codex_session(sessions: List[Path]) -> Optional[Path]:
+    thread_id = os.getenv('CODEX_THREAD_ID', '').strip()
+    if not thread_id:
+        return None
+
+    for session in sessions:
+        if thread_id in session.name:
+            return session
+    return None
+
+
+def is_codex_project_session(session: Path, project_cmp: str) -> bool:
+    if not is_substantial_session(session):
+        return False
+
+    meta = read_codex_meta(session)
+    if not meta:
+        return False
+    source = meta.get('source')
+    if isinstance(source, dict) and 'subagent' in source:
+        return False
+    cwd = codex_meta_cwd(meta)
+    return bool(cwd and normalize_for_compare(cwd) == project_cmp)
+
+
+def get_codex_sessions(project_path: str) -> Iterable[Path]:
+    sessions_dir = Path(os.path.expanduser(os.getenv('CODEX_SESSIONS_DIR', '~/.codex/sessions')))
+    if not sessions_dir.exists():
+        return
+
+    project_cmp = normalize_for_compare(project_path)
+    sessions = sorted(sessions_dir.rglob('rollout-*.jsonl'), key=safe_stat_mtime, reverse=True)
+    current = find_current_codex_session(sessions)
+    if current and is_codex_project_session(current, project_cmp):
+        yield current
+
+    for session in sessions:
+        if session == current:
+            continue
+        if is_codex_project_session(session, project_cmp):
+            yield session
+
+
+def get_session_candidates(project_path: str) -> Tuple[str, Iterable[Path]]:
+    if '/.codex/' in Path(__file__).resolve().as_posix().lower():
+        return 'codex', get_codex_sessions(project_path)
+
+    claude_project_dir = get_claude_project_dir(project_path)
+    if claude_project_dir.exists():
+        return 'claude', get_sessions_sorted(claude_project_dir)
+    return 'claude', []
+
+
+def parse_session_messages(session_file: Path) -> List[Dict[str, Any]]:
     """Parse all messages from a session file, preserving order."""
     messages = []
     with open(session_file, 'r', encoding='utf-8', errors='replace') as f:
         for line_num, line in enumerate(f):
-            try:
-                data = json.loads(line)
+            data = json_loads(line)
+            if data is not None:
                 data['_line_num'] = line_num
                 messages.append(data)
-            except json.JSONDecodeError:
-                pass
     return messages
 
 
-def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]:
+def planning_file_from_path(path_value: Any) -> Optional[str]:
+    if not isinstance(path_value, str):
+        return None
+    for pf in PLANNING_FILES:
+        if path_value.endswith(pf):
+            return pf
+    return None
+
+
+def planning_file_from_paths(paths: Iterable[Any]) -> Optional[str]:
+    matches = {pf for path in paths if (pf := planning_file_from_path(path))}
+    for pf in PLANNING_FILES:
+        if pf in matches:
+            return pf
+    return None
+
+
+def codex_planning_update(payload: Dict[str, Any]) -> Optional[str]:
+    """Use Codex's structured apply_patch result instead of parsing tool text."""
+    if payload.get('type') != 'patch_apply_end' or payload.get('success') is not True:
+        return None
+    changes = payload.get('changes')
+    return planning_file_from_paths(changes.keys()) if isinstance(changes, dict) else None
+
+
+def find_last_planning_update(messages: List[Dict[str, Any]]) -> Tuple[int, Optional[str]]:
     """
     Find the last time a planning file was written/edited.
     Returns (line_number, filename) or (-1, None) if not found.
@@ -100,6 +223,9 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
     last_update_file = None
 
     for msg in messages:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int):
+            continue
         msg_type = msg.get('type')
 
         if msg_type == 'assistant':
@@ -109,57 +235,90 @@ def find_last_planning_update(messages: List[Dict]) -> Tuple[int, Optional[str]]
                     if item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
 
                         if tool_name in ('Write', 'Edit'):
-                            file_path = tool_input.get('file_path', '')
-                            for pf in PLANNING_FILES:
-                                if file_path.endswith(pf):
-                                    last_update_line = msg['_line_num']
-                                    last_update_file = pf
+                            planning_file = planning_file_from_path(tool_input.get('file_path', ''))
+                            if planning_file:
+                                last_update_line = line_num
+                                last_update_file = planning_file
+
+        elif msg_type == 'event_msg':
+            payload = msg.get('payload')
+            if isinstance(payload, dict):
+                planning_file = codex_planning_update(payload)
+                if planning_file:
+                    last_update_line = line_num
+                    last_update_file = planning_file
 
     return last_update_line, last_update_file
 
 
-def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
+def text_content(content: Any) -> str:
+    if isinstance(content, str):
+        return content
+    if not isinstance(content, list):
+        return ''
+    return '\n'.join(
+        item.get('text', '')
+        for item in content
+        if isinstance(item, dict) and isinstance(item.get('text'), str)
+    )
+
+
+def parse_codex_tool_args(payload: Dict[str, Any]) -> Tuple[Dict[str, Any], str]:
+    raw_args = payload.get('arguments', payload.get('input', ''))
+    if isinstance(raw_args, dict):
+        return raw_args, json.dumps(raw_args, ensure_ascii=True)
+    if not isinstance(raw_args, str):
+        return {}, ''
+    decoded = json_loads(raw_args)
+    return (decoded, raw_args) if isinstance(decoded, dict) else ({}, raw_args)
+
+
+def summarize_codex_tool(payload: Dict[str, Any]) -> str:
+    tool_name = payload.get('name', 'tool')
+    tool_args, raw_args = parse_codex_tool_args(payload)
+    if tool_name == 'exec_command':
+        command = tool_args.get('cmd', raw_args)
+        if isinstance(command, str):
+            return f"exec_command: {command[:80]}"
+    return str(tool_name)
+
+
+def extract_messages_after(messages: List[Dict[str, Any]], after_line: int) -> List[Dict[str, Any]]:
     """Extract conversation messages after a certain line number."""
     result = []
     for msg in messages:
-        if msg['_line_num'] <= after_line:
+        line_num = msg.get('_line_num')
+        if not isinstance(line_num, int) or line_num <= after_line:
             continue
 
         msg_type = msg.get('type')
         is_meta = msg.get('isMeta', False)
 
         if msg_type == 'user' and not is_meta:
-            content = msg.get('message', {}).get('content', '')
-            if isinstance(content, list):
-                for item in content:
-                    if isinstance(item, dict) and item.get('type') == 'text':
-                        content = item.get('text', '')
-                        break
-                else:
-                    content = ''
+            content = text_content(msg.get('message', {}).get('content', ''))
 
-            if content and isinstance(content, str):
+            if content:
                 if content.startswith(('<local-command', '<command-', '<task-notification')):
                     continue
                 if len(content) > 20:
-                    result.append({'role': 'user', 'content': content, 'line': msg['_line_num']})
+                    result.append({'role': 'user', 'content': content, 'line': line_num})
 
         elif msg_type == 'assistant':
             msg_content = msg.get('message', {}).get('content', '')
-            text_content = ''
+            text = text_content(msg_content)
             tool_uses = []
 
-            if isinstance(msg_content, str):
-                text_content = msg_content
-            elif isinstance(msg_content, list):
+            if isinstance(msg_content, list):
                 for item in msg_content:
-                    if item.get('type') == 'text':
-                        text_content = item.get('text', '')
-                    elif item.get('type') == 'tool_use':
+                    if isinstance(item, dict) and item.get('type') == 'tool_use':
                         tool_name = item.get('name', '')
                         tool_input = item.get('input', {})
+                        if not isinstance(tool_input, dict):
+                            tool_input = {}
                         if tool_name == 'Edit':
                             tool_uses.append(f"Edit: {tool_input.get('file_path', 'unknown')}")
                         elif tool_name == 'Write':
@@ -170,12 +329,43 @@ def extract_messages_after(messages: List[Dict], after_line: int) -> List[Dict]:
                         else:
                             tool_uses.append(f"{tool_name}")
 
-            if text_content or tool_uses:
+            if text or tool_uses:
                 result.append({
                     'role': 'assistant',
-                    'content': text_content[:600] if text_content else '',
+                    'content': text[:600] if text else '',
                     'tools': tool_uses,
-                    'line': msg['_line_num']
+                    'line': line_num
+                })
+
+        elif msg_type == 'response_item':
+            payload = msg.get('payload')
+            if not isinstance(payload, dict):
+                continue
+
+            payload_type = payload.get('type')
+            if payload_type == 'message':
+                role = payload.get('role')
+                if role not in ('user', 'assistant'):
+                    continue
+                content = text_content(payload.get('content'))
+                if role == 'user':
+                    if content.startswith(('<local-command', '<command-', '<task-notification')):
+                        continue
+                    if len(content) > 20:
+                        result.append({'role': 'user', 'content': content, 'line': line_num})
+                elif content:
+                    result.append({
+                        'role': 'assistant',
+                        'content': content[:600],
+                        'tools': [],
+                        'line': line_num
+                    })
+            elif payload_type in ('function_call', 'custom_tool_call'):
+                result.append({
+                    'role': 'assistant',
+                    'content': '',
+                    'tools': [summarize_codex_tool(payload)],
+                    'line': line_num
                 })
 
     return result
@@ -192,25 +382,15 @@ def main():
         # No planning files in this project; skip catchup to avoid noise.
         return
 
-    project_dir, skip_reason = get_project_dir(project_path)
-    if skip_reason:
-        print(skip_reason)
-        return
-
-    if not project_dir.exists():
-        # No previous sessions, nothing to catch up on
-        return
-
-    sessions = get_sessions_sorted(project_dir)
-    if len(sessions) < 1:
-        return
+    runtime_name, sessions = get_session_candidates(project_path)
 
     # Find a substantial previous session
     target_session = None
     for session in sessions:
-        if session.stat().st_size > 5000:
-            target_session = session
-            break
+        if runtime_name == 'claude' and not is_substantial_session(session):
+            continue
+        target_session = session
+        break
 
     if not target_session:
         return
@@ -231,17 +411,19 @@ def main():
     # Output catchup report
     print("\n[planning-with-files] SESSION CATCHUP DETECTED")
     print(f"Previous session: {target_session.stem}")
+    print(f"Runtime: {runtime_name}")
 
     print(f"Last planning update: {last_update_file} at message #{last_update_line}")
     print(f"Unsynced messages: {len(messages_after)}")
 
     print("\n--- UNSYNCED CONTEXT ---")
+    assistant_label = 'CODEX' if runtime_name == 'codex' else 'CLAUDE'
     for msg in messages_after[-15:]:  # Last 15 messages
         if msg['role'] == 'user':
             print(f"USER: {msg['content'][:300]}")
         else:
             if msg.get('content'):
-                print(f"CLAUDE: {msg['content'][:300]}")
+                print(f"{assistant_label}: {msg['content'][:300]}")
             if msg.get('tools'):
                 print(f"  Tools: {', '.join(msg['tools'][:4])}")
 

tests/test_session_catchup.py

@@ -1,7 +1,11 @@
 import importlib.util
+import io
+import json
+import os
 import shutil
 import tempfile
 import unittest
+from contextlib import redirect_stdout
 from pathlib import Path
 from unittest import mock
 
@@ -27,7 +31,11 @@ class SessionCatchupCodexTests(unittest.TestCase):
     def setUp(self):
         self.tempdir = tempfile.TemporaryDirectory()
         self.root = Path(self.tempdir.name)
-        self.project_path = "/tmp/project"
+        self.project_dir = self.root / "project"
+        self.project_dir.mkdir()
+        self.project_path = str(self.project_dir)
+        self.sessions_dir = self.root / ".codex/sessions"
+        self.sessions_dir.mkdir(parents=True)
         self.codex_script = (
             self.root / ".codex/skills/planning-with-files/scripts/session-catchup.py"
         )
@@ -38,26 +46,197 @@ class SessionCatchupCodexTests(unittest.TestCase):
     def tearDown(self):
         self.tempdir.cleanup()
 
-    def test_codex_variant_skips_when_only_codex_sessions_exist(self):
-        (self.root / ".codex/sessions").mkdir(parents=True, exist_ok=True)
+    def write_codex_session(
+        self,
+        name,
+        *,
+        cwd=None,
+        source="codex",
+        records=(),
+        substantial=True,
+        mtime=100,
+    ):
+        path = self.sessions_dir / name
+        path.parent.mkdir(parents=True, exist_ok=True)
+        session_records = [
+            {
+                "timestamp": "2026-04-07T00:00:00.000Z",
+                "type": "session_meta",
+                "payload": {"cwd": cwd or self.project_path, "source": source},
+            }
+        ]
+        if substantial:
+            session_records.append(
+                {
+                    "timestamp": "2026-04-07T00:00:01.000Z",
+                    "type": "response_item",
+                    "payload": {
+                        "type": "message",
+                        "role": "assistant",
+                        "content": [
+                            {"type": "output_text", "text": "x" * 6000},
+                        ],
+                    },
+                }
+            )
+        session_records.extend(records)
+        with path.open("w", encoding="utf-8") as f:
+            for record in session_records:
+                f.write(json.dumps(record) + "\n")
+        os.utime(path, (mtime, mtime))
+        return path
 
-        with mock.patch("pathlib.Path.home", return_value=self.root):
-            project_dir, skip_reason = self.module.get_project_dir(self.project_path)
+    def codex_candidates(self, *, thread_id=None):
+        updates = {"CODEX_SESSIONS_DIR": str(self.sessions_dir)}
+        if thread_id is not None:
+            updates["CODEX_THREAD_ID"] = thread_id
+        with mock.patch.dict(os.environ, updates, clear=False):
+            if thread_id is None:
+                os.environ.pop("CODEX_THREAD_ID", None)
+            with mock.patch("pathlib.Path.home", return_value=self.root):
+                runtime, sessions = self.module.get_session_candidates(self.project_path)
+                return runtime, list(sessions)
 
-        self.assertIsNone(project_dir)
-        self.assertIn("~/.codex/sessions", skip_reason)
-        self.assertIn("not implemented yet", skip_reason)
+    def test_codex_variant_finds_matching_project_sessions(self):
+        session = self.write_codex_session(
+            "rollout-2026-04-07T00-00-00-previous-thread.jsonl"
+        )
 
-    def test_codex_variant_uses_claude_path_when_project_exists(self):
-        (self.root / ".codex/sessions").mkdir(parents=True, exist_ok=True)
-        expected = self.root / ".claude/projects/-tmp-project"
-        expected.mkdir(parents=True, exist_ok=True)
+        runtime, sessions = self.codex_candidates()
 
-        with mock.patch("pathlib.Path.home", return_value=self.root):
-            project_dir, skip_reason = self.module.get_project_dir(self.project_path)
+        self.assertEqual("codex", runtime)
+        self.assertEqual([session], sessions)
 
-        self.assertEqual(expected, project_dir)
-        self.assertIsNone(skip_reason)
+    def test_codex_variant_prefers_current_thread_for_same_project(self):
+        previous = self.write_codex_session(
+            "rollout-2026-04-07T00-00-00-previous-thread.jsonl",
+            mtime=200,
+        )
+        current = self.write_codex_session(
+            "rollout-2026-04-07T01-00-00-current-thread.jsonl",
+            mtime=100,
+        )
+
+        runtime, sessions = self.codex_candidates(thread_id="current-thread")
+
+        self.assertEqual("codex", runtime)
+        self.assertEqual([current, previous], sessions)
+
+    def test_codex_variant_skips_small_sessions_and_subagents(self):
+        valid = self.write_codex_session(
+            "rollout-2026-04-07T00-00-00-valid-thread.jsonl",
+            mtime=100,
+        )
+        self.write_codex_session(
+            "rollout-2026-04-07T01-00-00-small-thread.jsonl",
+            substantial=False,
+            mtime=200,
+        )
+        self.write_codex_session(
+            "rollout-2026-04-07T02-00-00-subagent-thread.jsonl",
+            source={"subagent": "worker"},
+            mtime=300,
+        )
+
+        runtime, sessions = self.codex_candidates()
+
+        self.assertEqual("codex", runtime)
+        self.assertEqual([valid], sessions)
+
+    def test_codex_structured_patch_event_marks_planning_update(self):
+        messages = [
+            {
+                "_line_num": 7,
+                "type": "event_msg",
+                "payload": {
+                    "type": "patch_apply_end",
+                    "success": True,
+                    "changes": {"progress.md": {"operation": "modified"}},
+                },
+            }
+        ]
+
+        self.assertEqual(
+            (7, "progress.md"),
+            self.module.find_last_planning_update(messages),
+        )
+
+    def test_messages_without_line_numbers_are_ignored(self):
+        messages = [
+            {
+                "type": "event_msg",
+                "payload": {
+                    "type": "patch_apply_end",
+                    "success": True,
+                    "changes": {"progress.md": {"operation": "modified"}},
+                },
+            },
+            {
+                "type": "response_item",
+                "payload": {
+                    "type": "message",
+                    "role": "assistant",
+                    "content": [{"type": "output_text", "text": "ignored"}],
+                },
+            },
+        ]
+
+        self.assertEqual((-1, None), self.module.find_last_planning_update(messages))
+        self.assertEqual([], self.module.extract_messages_after(messages, -1))
+
+    def test_codex_main_prints_catchup_from_matching_session(self):
+        for filename in self.module.PLANNING_FILES:
+            (self.project_dir / filename).write_text("# test\n", encoding="utf-8")
+        self.write_codex_session(
+            "rollout-2026-04-07T00-00-00-previous-thread.jsonl",
+            records=[
+                {
+                    "timestamp": "2026-04-07T00:00:02.000Z",
+                    "type": "event_msg",
+                    "payload": {
+                        "type": "patch_apply_end",
+                        "success": True,
+                        "changes": {"task_plan.md": {"operation": "modified"}},
+                    },
+                },
+                {
+                    "timestamp": "2026-04-07T00:00:03.000Z",
+                    "type": "response_item",
+                    "payload": {
+                        "type": "message",
+                        "role": "assistant",
+                        "content": [
+                            {
+                                "type": "output_text",
+                                "text": "Codex summary after planning update",
+                            }
+                        ],
+                    },
+                },
+            ],
+        )
+
+        stdout = io.StringIO()
+        with mock.patch.dict(
+            os.environ,
+            {"CODEX_SESSIONS_DIR": str(self.sessions_dir)},
+            clear=False,
+        ):
+            os.environ.pop("CODEX_THREAD_ID", None)
+            with mock.patch("pathlib.Path.home", return_value=self.root):
+                with mock.patch.object(
+                    self.module.sys,
+                    "argv",
+                    ["session-catchup.py", self.project_path],
+                ):
+                    with redirect_stdout(stdout):
+                        self.module.main()
+
+        output = stdout.getvalue()
+        self.assertIn("SESSION CATCHUP DETECTED", output)
+        self.assertIn("Runtime: codex", output)
+        self.assertIn("Last planning update: task_plan.md", output)
+        self.assertIn("CODEX: Codex summary after planning update", output)
 
 
 if __name__ == "__main__":