clawd
d81e403f01
COMPLETED TASKS: ✅ 06-01: Workout Swap System - Added swapped_from_id to workout_logs - Created workout_swaps table for history - POST /api/workouts/:id/swap endpoint - GET /api/workouts/available endpoint - Reversible swaps with audit trail ✅ 06-02: Muscle Group Recovery Tracking - Created muscle_group_recovery table - Implemented calculateRecoveryScore() function - GET /api/recovery/muscle-groups endpoint - GET /api/recovery/most-recovered endpoint - Auto-tracking on workout log completion ✅ 06-03: Smart Workout Recommendations - GET /api/recommendations/smart-workout endpoint - 7-day workout analysis algorithm - Recovery-based filtering (>30% threshold) - Top 3 recommendations with context - Context-aware reasoning messages DATABASE CHANGES: - Added 4 new tables: muscle_group_recovery, workout_swaps, custom_workouts, custom_workout_exercises - Extended workout_logs with: swapped_from_id, source_type, custom_workout_id, custom_workout_exercise_id - Created 7 new indexes for performance IMPLEMENTATION: - Recovery service with 4 core functions - 2 new route handlers (recovery, smartRecommendations) - Updated workouts router with swap endpoints - Integrated recovery tracking into POST /api/logs - Full error handling and logging TESTING: - Test file created: /backend/test/phase-06-tests.js - Ready for E2E and staging validation STATUS: Ready for frontend integration and production review Branch: feature/06-phase-06
87 lines
3.0 KiB
Bash
Executable File
87 lines
3.0 KiB
Bash
Executable File
#!/bin/bash
|
|
# Claude Flow V3 - Pattern Consolidator Worker
|
|
# Deduplicates patterns, prunes old ones, improves quality scores
|
|
|
|
set -euo pipefail
|
|
|
|
SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
|
|
PROJECT_ROOT="$(cd "$SCRIPT_DIR/../.." && pwd)"
|
|
PATTERNS_DB="$PROJECT_ROOT/.claude-flow/learning/patterns.db"
|
|
METRICS_DIR="$PROJECT_ROOT/.claude-flow/metrics"
|
|
LAST_RUN_FILE="$METRICS_DIR/.consolidator-last-run"
|
|
|
|
mkdir -p "$METRICS_DIR"
|
|
|
|
should_run() {
|
|
if [ ! -f "$LAST_RUN_FILE" ]; then return 0; fi
|
|
local last_run=$(cat "$LAST_RUN_FILE" 2>/dev/null || echo "0")
|
|
local now=$(date +%s)
|
|
[ $((now - last_run)) -ge 900 ] # 15 minutes
|
|
}
|
|
|
|
consolidate_patterns() {
|
|
if [ ! -f "$PATTERNS_DB" ] || ! command -v sqlite3 &>/dev/null; then
|
|
echo "[$(date +%H:%M:%S)] No patterns database found"
|
|
return 0
|
|
fi
|
|
|
|
echo "[$(date +%H:%M:%S)] Consolidating patterns..."
|
|
|
|
# Count before
|
|
local before=$(sqlite3 "$PATTERNS_DB" "SELECT COUNT(*) FROM short_term_patterns" 2>/dev/null || echo "0")
|
|
|
|
# Remove duplicates (keep highest quality)
|
|
sqlite3 "$PATTERNS_DB" "
|
|
DELETE FROM short_term_patterns
|
|
WHERE rowid NOT IN (
|
|
SELECT MIN(rowid) FROM short_term_patterns
|
|
GROUP BY strategy, domain
|
|
)
|
|
" 2>/dev/null || true
|
|
|
|
# Prune old low-quality patterns (older than 7 days, quality < 0.3)
|
|
sqlite3 "$PATTERNS_DB" "
|
|
DELETE FROM short_term_patterns
|
|
WHERE quality < 0.3
|
|
AND created_at < datetime('now', '-7 days')
|
|
" 2>/dev/null || true
|
|
|
|
# Promote high-quality patterns to long-term (quality > 0.8, used > 5 times)
|
|
sqlite3 "$PATTERNS_DB" "
|
|
INSERT OR IGNORE INTO long_term_patterns (strategy, domain, quality, source)
|
|
SELECT strategy, domain, quality, 'consolidated'
|
|
FROM short_term_patterns
|
|
WHERE quality > 0.8
|
|
" 2>/dev/null || true
|
|
|
|
# Decay quality of unused patterns
|
|
sqlite3 "$PATTERNS_DB" "
|
|
UPDATE short_term_patterns
|
|
SET quality = quality * 0.95
|
|
WHERE updated_at < datetime('now', '-1 day')
|
|
" 2>/dev/null || true
|
|
|
|
# Count after
|
|
local after=$(sqlite3 "$PATTERNS_DB" "SELECT COUNT(*) FROM short_term_patterns" 2>/dev/null || echo "0")
|
|
local removed=$((before - after))
|
|
|
|
echo "[$(date +%H:%M:%S)] ✓ Consolidated: $before → $after patterns (removed $removed)"
|
|
|
|
date +%s > "$LAST_RUN_FILE"
|
|
}
|
|
|
|
case "${1:-check}" in
|
|
"run"|"consolidate") consolidate_patterns ;;
|
|
"check") should_run && consolidate_patterns || echo "[$(date +%H:%M:%S)] Skipping (throttled)" ;;
|
|
"force") rm -f "$LAST_RUN_FILE"; consolidate_patterns ;;
|
|
"status")
|
|
if [ -f "$PATTERNS_DB" ] && command -v sqlite3 &>/dev/null; then
|
|
local short=$(sqlite3 "$PATTERNS_DB" "SELECT COUNT(*) FROM short_term_patterns" 2>/dev/null || echo "0")
|
|
local long=$(sqlite3 "$PATTERNS_DB" "SELECT COUNT(*) FROM long_term_patterns" 2>/dev/null || echo "0")
|
|
local avg_q=$(sqlite3 "$PATTERNS_DB" "SELECT ROUND(AVG(quality), 2) FROM short_term_patterns" 2>/dev/null || echo "0")
|
|
echo "Patterns: $short short-term, $long long-term, avg quality: $avg_q"
|
|
fi
|
|
;;
|
|
*) echo "Usage: $0 [run|check|force|status]" ;;
|
|
esac
|