mirror of
https://github.com/sweetwisdom/everything-claude-code-zh.git
synced 2026-03-22 14:35:09 +00:00
- Add session ID to session filenames (Issue #62) - Add getSessionIdShort() helper for unique per-session tracking - Add async hooks documentation with example - Create iterative-retrieval skill for progressive context refinement - Add continuous-learning-v2 skill with instinct-based learning - Add ecc.tools ecosystem section to README - Update skills list in README All 67 tests passing.
138 lines
3.8 KiB
Bash
Executable File
138 lines
3.8 KiB
Bash
Executable File
#!/bin/bash
|
|
# Continuous Learning v2 - Observation Hook
|
|
#
|
|
# Captures tool use events for pattern analysis.
|
|
# Claude Code passes hook data via stdin as JSON.
|
|
#
|
|
# Hook config (in ~/.claude/settings.json):
|
|
# {
|
|
# "hooks": {
|
|
# "PreToolUse": [{
|
|
# "matcher": "*",
|
|
# "hooks": [{ "type": "command", "command": "~/.claude/skills/continuous-learning-v2/hooks/observe.sh" }]
|
|
# }],
|
|
# "PostToolUse": [{
|
|
# "matcher": "*",
|
|
# "hooks": [{ "type": "command", "command": "~/.claude/skills/continuous-learning-v2/hooks/observe.sh" }]
|
|
# }]
|
|
# }
|
|
# }
|
|
|
|
set -e
|
|
|
|
CONFIG_DIR="${HOME}/.claude/homunculus"
|
|
OBSERVATIONS_FILE="${CONFIG_DIR}/observations.jsonl"
|
|
MAX_FILE_SIZE_MB=10
|
|
|
|
# Ensure directory exists
|
|
mkdir -p "$CONFIG_DIR"
|
|
|
|
# Skip if disabled
|
|
if [ -f "$CONFIG_DIR/disabled" ]; then
|
|
exit 0
|
|
fi
|
|
|
|
# Read JSON from stdin (Claude Code hook format)
|
|
INPUT_JSON=$(cat)
|
|
|
|
# Exit if no input
|
|
if [ -z "$INPUT_JSON" ]; then
|
|
exit 0
|
|
fi
|
|
|
|
# Parse using python (more reliable than jq for complex JSON)
|
|
PARSED=$(python3 << EOF
|
|
import json
|
|
import sys
|
|
|
|
try:
|
|
data = json.loads('''$INPUT_JSON''')
|
|
|
|
# Extract fields - Claude Code hook format
|
|
hook_type = data.get('hook_type', 'unknown') # PreToolUse or PostToolUse
|
|
tool_name = data.get('tool_name', data.get('tool', 'unknown'))
|
|
tool_input = data.get('tool_input', data.get('input', {}))
|
|
tool_output = data.get('tool_output', data.get('output', ''))
|
|
session_id = data.get('session_id', 'unknown')
|
|
|
|
# Truncate large inputs/outputs
|
|
if isinstance(tool_input, dict):
|
|
tool_input_str = json.dumps(tool_input)[:5000]
|
|
else:
|
|
tool_input_str = str(tool_input)[:5000]
|
|
|
|
if isinstance(tool_output, dict):
|
|
tool_output_str = json.dumps(tool_output)[:5000]
|
|
else:
|
|
tool_output_str = str(tool_output)[:5000]
|
|
|
|
# Determine event type
|
|
event = 'tool_start' if 'Pre' in hook_type else 'tool_complete'
|
|
|
|
print(json.dumps({
|
|
'parsed': True,
|
|
'event': event,
|
|
'tool': tool_name,
|
|
'input': tool_input_str if event == 'tool_start' else None,
|
|
'output': tool_output_str if event == 'tool_complete' else None,
|
|
'session': session_id
|
|
}))
|
|
except Exception as e:
|
|
print(json.dumps({'parsed': False, 'error': str(e)}))
|
|
EOF
|
|
)
|
|
|
|
# Check if parsing succeeded
|
|
PARSED_OK=$(echo "$PARSED" | python3 -c "import json,sys; print(json.load(sys.stdin).get('parsed', False))")
|
|
|
|
if [ "$PARSED_OK" != "True" ]; then
|
|
# Fallback: log raw input for debugging
|
|
timestamp=$(date -u +"%Y-%m-%dT%H:%M:%SZ")
|
|
echo "{\"timestamp\":\"$timestamp\",\"event\":\"parse_error\",\"raw\":$(echo "$INPUT_JSON" | python3 -c 'import json,sys; print(json.dumps(sys.stdin.read()[:1000]))')}" >> "$OBSERVATIONS_FILE"
|
|
exit 0
|
|
fi
|
|
|
|
# Archive if file too large
|
|
if [ -f "$OBSERVATIONS_FILE" ]; then
|
|
file_size_mb=$(du -m "$OBSERVATIONS_FILE" 2>/dev/null | cut -f1)
|
|
if [ "${file_size_mb:-0}" -ge "$MAX_FILE_SIZE_MB" ]; then
|
|
archive_dir="${CONFIG_DIR}/observations.archive"
|
|
mkdir -p "$archive_dir"
|
|
mv "$OBSERVATIONS_FILE" "$archive_dir/observations-$(date +%Y%m%d-%H%M%S).jsonl"
|
|
fi
|
|
fi
|
|
|
|
# Build and write observation
|
|
timestamp=$(date -u +"%Y-%m-%dT%H:%M:%SZ")
|
|
|
|
python3 << EOF
|
|
import json
|
|
|
|
parsed = json.loads('''$PARSED''')
|
|
observation = {
|
|
'timestamp': '$timestamp',
|
|
'event': parsed['event'],
|
|
'tool': parsed['tool'],
|
|
'session': parsed['session']
|
|
}
|
|
|
|
if parsed['input']:
|
|
observation['input'] = parsed['input']
|
|
if parsed['output']:
|
|
observation['output'] = parsed['output']
|
|
|
|
with open('$OBSERVATIONS_FILE', 'a') as f:
|
|
f.write(json.dumps(observation) + '\n')
|
|
EOF
|
|
|
|
# Signal observer if running
|
|
OBSERVER_PID_FILE="${CONFIG_DIR}/.observer.pid"
|
|
if [ -f "$OBSERVER_PID_FILE" ]; then
|
|
observer_pid=$(cat "$OBSERVER_PID_FILE")
|
|
if kill -0 "$observer_pid" 2>/dev/null; then
|
|
kill -USR1 "$observer_pid" 2>/dev/null || true
|
|
fi
|
|
fi
|
|
|
|
exit 0
|