1#!/usr/bin/env python3
2"""
3Stale Contacts Finder
4Identifies contacts that haven't been reached out to recently.
5"""
6 
7import json
8from datetime import datetime, timedelta
9from pathlib import Path
10 
11BRAIN_ROOT = Path(__file__).parent.parent.parent
12 
13# Thresholds by circle (in days)
14THRESHOLDS = {
15    'inner': 14,      # 2 weeks
16    'active': 30,     # 1 month
17    'network': 60,    # 2 months
18    'dormant': 180    # 6 months (for potential reactivation)
19}
20 
21def load_jsonl(filepath):
22    """Load JSONL file, skipping schema lines."""
23    items = []
24    if not filepath.exists():
25        return items
26    with open(filepath, 'r') as f:
27        for line in f:
28            line = line.strip()
29            if not line:
30                continue
31            try:
32                data = json.loads(line)
33                if '_schema' not in data:
34                    items.append(data)
35            except json.JSONDecodeError:
36                continue
37    return items
38 
39def days_since(date_str):
40    """Calculate days since a date string."""
41    if not date_str:
42        return 999  # Very stale if no date
43    try:
44        date = datetime.fromisoformat(date_str.replace('Z', '+00:00'))
45        return (datetime.now(date.tzinfo) - date).days
46    except (ValueError, TypeError):
47        return 999
48 
49def find_stale_contacts():
50    """Find contacts needing outreach."""
51    contacts = load_jsonl(BRAIN_ROOT / 'network' / 'contacts.jsonl')
52 
53    stale = {
54        'urgent': [],      # Way overdue
55        'due': [],         # Due for contact
56        'coming_up': []    # Getting close
57    }
58 
59    for contact in contacts:
60        circle = contact.get('circle', 'network')
61        threshold = THRESHOLDS.get(circle, 60)
62        days = days_since(contact.get('last_contact'))
63 
64        contact_info = {
65            'name': contact.get('name', 'Unknown'),
66            'circle': circle,
67            'days_since': days,
68            'threshold': threshold,
69            'handle': contact.get('handle', ''),
70            'notes': contact.get('notes', '')[:100]
71        }
72 
73        if days > threshold * 1.5:
74            stale['urgent'].append(contact_info)
75        elif days > threshold:
76            stale['due'].append(contact_info)
77        elif days > threshold * 0.75:
78            stale['coming_up'].append(contact_info)
79 
80    return stale
81 
82def generate_report():
83    """Generate stale contacts report."""
84    stale = find_stale_contacts()
85 
86    output = f"""
87# Stale Contacts Report
88Generated: {datetime.now().isoformat()}
89 
90## Urgently Overdue ({len(stale['urgent'])})
91"""
92 
93    if stale['urgent']:
94        for c in sorted(stale['urgent'], key=lambda x: -x['days_since']):
95            output += f"- **{c['name']}** ({c['circle']}) - {c['days_since']} days since contact\n"
96            if c['handle']:
97                output += f"  {c['handle']}\n"
98    else:
99        output += "None! You're on top of things.\n"
100 
101    output += f"""
102## Due for Contact ({len(stale['due'])})
103"""
104 
105    if stale['due']:
106        for c in sorted(stale['due'], key=lambda x: -x['days_since']):
107            output += f"- {c['name']} ({c['circle']}) - {c['days_since']} days\n"
108    else:
109        output += "None due right now.\n"
110 
111    output += f"""
112## Coming Up ({len(stale['coming_up'])})
113"""
114 
115    if stale['coming_up']:
116        for c in sorted(stale['coming_up'], key=lambda x: -x['days_since']):
117            output += f"- {c['name']} ({c['circle']}) - {c['days_since']} days (threshold: {c['threshold']})\n"
118    else:
119        output += "No contacts approaching threshold.\n"
120 
121    output += """
122## Suggested Actions
123 
1241. Send a quick "thinking of you" message to urgent contacts
1252. Schedule calls with due inner-circle contacts
1263. Engage with content from coming-up contacts
127 
128## Thresholds
129 
130- Inner circle: Every 2 weeks
131- Active: Every month
132- Network: Every 2 months
133- Dormant: Quarterly check for reactivation
134"""
135 
136    return output
137 
138if __name__ == '__main__':
139    print(generate_report())
140