plugin/scripts/session_end.py

#!/usr/bin/env python
import sys
import os
import json
import time
from hook_utils import is_sdk_child, api_call_bg

def main():
    try:
        input_data = sys.stdin.read()
        if not input_data:
            return
        data = json.loads(input_data)
    except Exception:
        return

    if is_sdk_child(data):
        return

    session_id = data.get("session_id") or data.get("sessionId") or "unknown"

    api_call_bg("session/end", {"sessionId": session_id})

    if os.environ.get("CONSOLIDATION_ENABLED") == "true":
        api_call_bg("crystals/auto", {"olderThanDays": 0})
        api_call_bg("consolidate-pipeline", {"tier": "all", "force": True})

    if os.environ.get("CLAUDE_MEMORY_BRIDGE") == "true":
        api_call_bg("claude-bridge/sync", {})

    time.sleep(1.5)

if __name__ == "__main__":
    main()