Compare commits
2 Commits
fix/96-saf
...
fix/136
| Author | SHA1 | Date | |
|---|---|---|---|
| af419fb797 | |||
| d7d40f490a |
@@ -1,22 +1,5 @@
|
||||
"""
|
||||
Crisis detection and response system for the-door.
|
||||
"""Crisis detection and metrics module."""
|
||||
|
||||
Stands between a broken man and a machine that would tell him to die.
|
||||
"""
|
||||
from .metrics import get_metrics_summary, get_metrics_report
|
||||
|
||||
from .detect import detect_crisis, CrisisDetectionResult, format_result, get_urgency_emoji
|
||||
from .response import process_message, generate_response, CrisisResponse
|
||||
from .gateway import check_crisis, get_system_prompt, format_gateway_response
|
||||
|
||||
__all__ = [
|
||||
"detect_crisis",
|
||||
"CrisisDetectionResult",
|
||||
"process_message",
|
||||
"generate_response",
|
||||
"CrisisResponse",
|
||||
"check_crisis",
|
||||
"get_system_prompt",
|
||||
"format_result",
|
||||
"format_gateway_response",
|
||||
"get_urgency_emoji",
|
||||
]
|
||||
__all__ = ["get_metrics_summary", "get_metrics_report"]
|
||||
|
||||
161
crisis/metrics.py
Normal file
161
crisis/metrics.py
Normal file
@@ -0,0 +1,161 @@
|
||||
#!/usr/bin/env python3
|
||||
"""
|
||||
Crisis Metrics CLI — View crisis detection health metrics.
|
||||
|
||||
Usage:
|
||||
python3 -m crisis.metrics --summary # weekly report
|
||||
python3 -m crisis.metrics --json # raw JSON export
|
||||
python3 -m crisis.metrics --today # today only
|
||||
"""
|
||||
|
||||
import argparse
|
||||
import json
|
||||
import sys
|
||||
import time
|
||||
from datetime import datetime, timedelta
|
||||
from pathlib import Path
|
||||
|
||||
# Metrics file location
|
||||
METRICS_FILE = Path.home() / ".the-door" / "crisis_metrics.json"
|
||||
|
||||
|
||||
def load_metrics():
|
||||
"""Load metrics from file."""
|
||||
if not METRICS_FILE.exists():
|
||||
return {"detections": [], "stats": {}}
|
||||
|
||||
try:
|
||||
with open(METRICS_FILE) as f:
|
||||
return json.load(f)
|
||||
except (json.JSONDecodeError, IOError):
|
||||
return {"detections": [], "stats": {}}
|
||||
|
||||
|
||||
def get_metrics_summary(days=7):
|
||||
"""Get metrics summary for the last N days."""
|
||||
data = load_metrics()
|
||||
detections = data.get("detections", [])
|
||||
|
||||
cutoff = time.time() - (days * 86400)
|
||||
recent = [d for d in detections if d.get("timestamp", 0) > cutoff]
|
||||
|
||||
if not recent:
|
||||
return {
|
||||
"period_days": days,
|
||||
"total_detections": 0,
|
||||
"by_severity": {},
|
||||
"by_source": {},
|
||||
"avg_response_time": 0,
|
||||
}
|
||||
|
||||
by_severity = {}
|
||||
by_source = {}
|
||||
total_response_time = 0
|
||||
response_count = 0
|
||||
|
||||
for d in recent:
|
||||
severity = d.get("severity", "unknown")
|
||||
source = d.get("source", "unknown")
|
||||
|
||||
by_severity[severity] = by_severity.get(severity, 0) + 1
|
||||
by_source[source] = by_source.get(source, 0) + 1
|
||||
|
||||
if "response_time_ms" in d:
|
||||
total_response_time += d["response_time_ms"]
|
||||
response_count += 1
|
||||
|
||||
return {
|
||||
"period_days": days,
|
||||
"total_detections": len(recent),
|
||||
"by_severity": by_severity,
|
||||
"by_source": by_source,
|
||||
"avg_response_time_ms": total_response_time / response_count if response_count else 0,
|
||||
"first_detection": recent[0].get("timestamp"),
|
||||
"last_detection": recent[-1].get("timestamp"),
|
||||
}
|
||||
|
||||
|
||||
def get_metrics_report(days=7):
|
||||
"""Generate a human-readable metrics report."""
|
||||
summary = get_metrics_summary(days)
|
||||
|
||||
lines = []
|
||||
lines.append("=" * 50)
|
||||
lines.append("CRISIS DETECTION METRICS")
|
||||
lines.append(f"Period: Last {days} days")
|
||||
lines.append("=" * 50)
|
||||
lines.append("")
|
||||
|
||||
total = summary["total_detections"]
|
||||
lines.append(f"Total detections: {total}")
|
||||
lines.append("")
|
||||
|
||||
if total > 0:
|
||||
lines.append("By severity:")
|
||||
for sev, count in sorted(summary["by_severity"].items()):
|
||||
pct = (count / total) * 100
|
||||
bar = "█" * int(pct / 5)
|
||||
lines.append(f" {sev:12} {count:4} ({pct:5.1f}%) {bar}")
|
||||
lines.append("")
|
||||
|
||||
lines.append("By source:")
|
||||
for src, count in sorted(summary["by_source"].items()):
|
||||
lines.append(f" {src:20} {count:4}")
|
||||
lines.append("")
|
||||
|
||||
avg_ms = summary.get("avg_response_time_ms", 0)
|
||||
lines.append(f"Avg response time: {avg_ms:.0f}ms")
|
||||
|
||||
first = summary.get("first_detection")
|
||||
last = summary.get("last_detection")
|
||||
if first and last:
|
||||
first_dt = datetime.fromtimestamp(first)
|
||||
last_dt = datetime.fromtimestamp(last)
|
||||
lines.append(f"First detection: {first_dt.strftime('%Y-%m-%d %H:%M')}")
|
||||
lines.append(f"Last detection: {last_dt.strftime('%Y-%m-%d %H:%M')}")
|
||||
else:
|
||||
lines.append("No crisis detections in this period.")
|
||||
|
||||
lines.append("")
|
||||
lines.append("=" * 50)
|
||||
|
||||
return "\n".join(lines)
|
||||
|
||||
|
||||
def main():
|
||||
parser = argparse.ArgumentParser(
|
||||
description="Crisis Detection Metrics CLI",
|
||||
formatter_class=argparse.RawDescriptionHelpFormatter,
|
||||
epilog="""
|
||||
Examples:
|
||||
%(prog)s --summary Weekly summary report
|
||||
%(prog)s --today Today only
|
||||
%(prog)s --json Raw JSON export
|
||||
%(prog)s --days 30 Last 30 days
|
||||
""",
|
||||
)
|
||||
|
||||
parser.add_argument("--summary", action="store_true", help="Show summary report")
|
||||
parser.add_argument("--json", action="store_true", dest="json_output", help="Output as JSON")
|
||||
parser.add_argument("--today", action="store_true", help="Today only (1 day)")
|
||||
parser.add_argument("--days", type=int, default=7, help="Number of days (default: 7)")
|
||||
parser.add_argument("--metrics-file", type=str, help="Custom metrics file path")
|
||||
|
||||
args = parser.parse_args()
|
||||
|
||||
if args.metrics_file:
|
||||
global METRICS_FILE
|
||||
METRICS_FILE = Path(args.metrics_file)
|
||||
|
||||
days = 1 if args.today else args.days
|
||||
|
||||
if args.json_output:
|
||||
summary = get_metrics_summary(days)
|
||||
print(json.dumps(summary, indent=2, default=str))
|
||||
else:
|
||||
report = get_metrics_report(days)
|
||||
print(report)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
175
index.html
175
index.html
@@ -739,25 +739,11 @@ html, body {
|
||||
</div>
|
||||
<div class="modal-footer">
|
||||
<button class="btn btn-secondary" id="cancel-safety-plan">Cancel</button>
|
||||
<button class="btn btn-secondary" id="show-version-history" title="View previous versions">History</button>
|
||||
<button class="btn btn-primary" id="save-safety-plan">Save Plan</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<!-- Safety Plan Version History Modal -->
|
||||
<div id="version-history-modal" class="modal-overlay" role="dialog" aria-modal="true" aria-labelledby="vh-title">
|
||||
<div class="modal-content" style="max-width: 640px;">
|
||||
<div class="modal-header">
|
||||
<h2 id="vh-title">Safety Plan History</h2>
|
||||
<button class="close-modal" id="close-version-history" aria-label="Close history">×</button>
|
||||
</div>
|
||||
<div class="modal-body" id="vh-body" style="max-height: 400px; overflow-y: auto;">
|
||||
<p id="vh-empty" style="color: #8b949e;">No previous versions saved.</p>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
|
||||
<script>
|
||||
(function() {
|
||||
'use strict';
|
||||
@@ -1183,40 +1169,17 @@ Sovereignty and service always.`;
|
||||
});
|
||||
|
||||
// ===== SAFETY PLAN LOGIC =====
|
||||
// Safety plan version storage key
|
||||
var SP_STORAGE_KEY = 'timmy_safety_plan_versions';
|
||||
|
||||
function _getPlanVersions() {
|
||||
try {
|
||||
var raw = localStorage.getItem(SP_STORAGE_KEY);
|
||||
if (raw) return JSON.parse(raw);
|
||||
// Migrate legacy single-plan format
|
||||
var legacy = localStorage.getItem('timmy_safety_plan');
|
||||
if (legacy) {
|
||||
var plan = JSON.parse(legacy);
|
||||
var versions = [{ plan: plan, timestamp: new Date().toISOString(), label: 'Migrated' }];
|
||||
localStorage.setItem(SP_STORAGE_KEY, JSON.stringify(versions));
|
||||
localStorage.removeItem('timmy_safety_plan');
|
||||
return versions;
|
||||
}
|
||||
} catch (e) {}
|
||||
return [];
|
||||
}
|
||||
|
||||
function _setPlanVersions(versions) {
|
||||
localStorage.setItem(SP_STORAGE_KEY, JSON.stringify(versions));
|
||||
}
|
||||
|
||||
function loadSafetyPlan() {
|
||||
try {
|
||||
var versions = _getPlanVersions();
|
||||
if (versions.length === 0) return;
|
||||
var plan = versions[versions.length - 1].plan;
|
||||
document.getElementById('sp-warning-signs').value = plan.warningSigns || '';
|
||||
document.getElementById('sp-coping').value = plan.coping || '';
|
||||
document.getElementById('sp-distraction').value = plan.distraction || '';
|
||||
document.getElementById('sp-help').value = plan.help || '';
|
||||
document.getElementById('sp-environment').value = plan.environment || '';
|
||||
var saved = localStorage.getItem('timmy_safety_plan');
|
||||
if (saved) {
|
||||
var plan = JSON.parse(saved);
|
||||
document.getElementById('sp-warning-signs').value = plan.warningSigns || '';
|
||||
document.getElementById('sp-coping').value = plan.coping || '';
|
||||
document.getElementById('sp-distraction').value = plan.distraction || '';
|
||||
document.getElementById('sp-help').value = plan.help || '';
|
||||
document.getElementById('sp-environment').value = plan.environment || '';
|
||||
}
|
||||
} catch (e) {}
|
||||
}
|
||||
|
||||
@@ -1239,13 +1202,10 @@ Sovereignty and service always.`;
|
||||
environment: document.getElementById('sp-environment').value
|
||||
};
|
||||
try {
|
||||
var versions = _getPlanVersions();
|
||||
versions.push({ plan: plan, timestamp: new Date().toISOString(), label: 'Saved' });
|
||||
if (versions.length > 20) versions = versions.slice(-20);
|
||||
_setPlanVersions(versions);
|
||||
localStorage.setItem('timmy_safety_plan', JSON.stringify(plan));
|
||||
safetyPlanModal.classList.remove('active');
|
||||
_restoreSafetyPlanFocus();
|
||||
alert('Safety plan saved. Version ' + versions.length + ' of 20.');
|
||||
alert('Safety plan saved locally.');
|
||||
} catch (e) {
|
||||
alert('Error saving plan.');
|
||||
}
|
||||
@@ -1339,119 +1299,6 @@ Sovereignty and service always.`;
|
||||
});
|
||||
}
|
||||
|
||||
// ===== SAFETY PLAN VERSION HISTORY =====
|
||||
var versionHistoryModal = document.getElementById('version-history-modal');
|
||||
var showVersionHistoryBtn = document.getElementById('show-version-history');
|
||||
var closeVersionHistoryBtn = document.getElementById('close-version-history');
|
||||
var vhBody = document.getElementById('vh-body');
|
||||
|
||||
var SP_FIELDS = [
|
||||
{ key: 'warningSigns', label: 'Warning signs' },
|
||||
{ key: 'coping', label: 'Coping strategies' },
|
||||
{ key: 'distraction', label: 'People/Places for distraction' },
|
||||
{ key: 'help', label: 'People I can ask for help' },
|
||||
{ key: 'environment', label: 'Making my environment safe' }
|
||||
];
|
||||
|
||||
function _diffPlans(oldPlan, newPlan) {
|
||||
var changes = [];
|
||||
for (var i = 0; i < SP_FIELDS.length; i++) {
|
||||
var f = SP_FIELDS[i];
|
||||
var ov = (oldPlan[f.key] || '').trim();
|
||||
var nv = (newPlan[f.key] || '').trim();
|
||||
if (ov !== nv) changes.push({ label: f.label, old: ov, new: nv });
|
||||
}
|
||||
return changes;
|
||||
}
|
||||
|
||||
function _renderVersionHistory() {
|
||||
var versions = _getPlanVersions();
|
||||
vhBody.innerHTML = '';
|
||||
if (versions.length === 0) {
|
||||
vhBody.innerHTML = '<p style="color:#8b949e;">No previous versions saved.</p>';
|
||||
return;
|
||||
}
|
||||
for (var i = versions.length - 1; i >= 0; i--) {
|
||||
var v = versions[i];
|
||||
var ts = new Date(v.timestamp).toLocaleString();
|
||||
var card = document.createElement('div');
|
||||
card.style.cssText = 'border:1px solid #30363d;border-radius:8px;padding:12px;margin-bottom:8px;';
|
||||
var header = document.createElement('div');
|
||||
header.style.cssText = 'display:flex;justify-content:space-between;align-items:center;margin-bottom:8px;';
|
||||
var label = document.createElement('strong');
|
||||
label.textContent = 'v' + (i + 1) + ' — ' + ts;
|
||||
header.appendChild(label);
|
||||
var restoreBtn = document.createElement('button');
|
||||
restoreBtn.textContent = 'Restore';
|
||||
restoreBtn.className = 'btn btn-secondary';
|
||||
restoreBtn.style.cssText = 'padding:2px 10px;font-size:0.8rem;';
|
||||
restoreBtn.setAttribute('data-version', i);
|
||||
restoreBtn.addEventListener('click', function() {
|
||||
var idx = parseInt(this.getAttribute('data-version'));
|
||||
var v2 = _getPlanVersions()[idx];
|
||||
if (!v2) return;
|
||||
var fields = ['sp-warning-signs', 'sp-coping', 'sp-distraction', 'sp-help', 'sp-environment'];
|
||||
var keys = ['warningSigns', 'coping', 'distraction', 'help', 'environment'];
|
||||
for (var j = 0; j < fields.length; j++) {
|
||||
document.getElementById(fields[j]).value = v2.plan[keys[j]] || '';
|
||||
}
|
||||
versionHistoryModal.classList.remove('active');
|
||||
safetyPlanModal.classList.add('active');
|
||||
});
|
||||
header.appendChild(restoreBtn);
|
||||
card.appendChild(header);
|
||||
if (i > 0) {
|
||||
var changes = _diffPlans(versions[i - 1].plan, v.plan);
|
||||
if (changes.length === 0) {
|
||||
var noChange = document.createElement('div');
|
||||
noChange.style.cssText = 'color:#8b949e;font-size:0.85rem;';
|
||||
noChange.textContent = 'No changes from previous version.';
|
||||
card.appendChild(noChange);
|
||||
} else {
|
||||
for (var c = 0; c < changes.length; c++) {
|
||||
var ch = changes[c];
|
||||
var diffDiv = document.createElement('div');
|
||||
diffDiv.style.cssText = 'margin-bottom:4px;font-size:0.85rem;';
|
||||
var lbl = document.createElement('div');
|
||||
lbl.style.color = '#58a6ff';
|
||||
lbl.textContent = ch.label;
|
||||
diffDiv.appendChild(lbl);
|
||||
if (ch.old) {
|
||||
var del = document.createElement('div');
|
||||
del.style.cssText = 'color:#f85149;text-decoration:line-through;padding:2px 4px;';
|
||||
del.textContent = '- ' + ch.old.substring(0, 100);
|
||||
diffDiv.appendChild(del);
|
||||
}
|
||||
if (ch.new) {
|
||||
var add = document.createElement('div');
|
||||
add.style.cssText = 'color:#3fb950;padding:2px 4px;';
|
||||
add.textContent = '+ ' + ch.new.substring(0, 100);
|
||||
diffDiv.appendChild(add);
|
||||
}
|
||||
card.appendChild(diffDiv);
|
||||
}
|
||||
}
|
||||
} else {
|
||||
var initial = document.createElement('div');
|
||||
initial.style.cssText = 'color:#8b949e;font-size:0.85rem;';
|
||||
initial.textContent = 'Initial version.';
|
||||
card.appendChild(initial);
|
||||
}
|
||||
vhBody.appendChild(card);
|
||||
}
|
||||
}
|
||||
|
||||
showVersionHistoryBtn.addEventListener('click', function() {
|
||||
safetyPlanModal.classList.remove('active');
|
||||
_renderVersionHistory();
|
||||
versionHistoryModal.classList.add('active');
|
||||
});
|
||||
|
||||
closeVersionHistoryBtn.addEventListener('click', function() {
|
||||
versionHistoryModal.classList.remove('active');
|
||||
safetyPlanModal.classList.add('active');
|
||||
});
|
||||
|
||||
// ===== TEXTAREA AUTO-RESIZE =====
|
||||
msgInput.addEventListener('input', function() {
|
||||
this.style.height = 'auto';
|
||||
|
||||
Reference in New Issue
Block a user