output_slack.py

#!/usr/bin/env python3
"""
Slack Output Module
Posts signal alerts to Slack #taolor channel
Uses Clawdbot's message tool for delivery
"""

import json
import subprocess
from datetime import datetime
from pathlib import Path

SLACK_CHANNEL = "C0AB131GF9V"  # #taolor

def format_signal_message(signals: list) -> str:
    """Format signals into a Slack message"""
    if not signals:
        return ""
    
    timestamp = datetime.now().strftime("%Y-%m-%d %H:%M")
    
    # Group by severity
    critical = [s for s in signals if s.get("severity") == "critical"]
    high = [s for s in signals if s.get("severity") == "high"]
    medium = [s for s in signals if s.get("severity") == "medium"]
    
    lines = [
        f"🔍 *TAOLOR SIGNAL ALERT* — {timestamp}",
        ""
    ]
    
    if critical:
        lines.append("🚨 *CRITICAL — Multi-Signal Alignment*")
        for s in critical:
            lines.append(f"• *{s.get('subnet_name', 'Unknown')}*: {s.get('detail', '')}")
        lines.append("")
    
    if high:
        lines.append("🔥 *HIGH PRIORITY*")
        for s in high:
            signal_type = s.get('type', '').replace('_', ' ').title()
            lines.append(f"• *{s.get('subnet_name', 'Unknown')}* ({signal_type}): {s.get('detail', '')}")
        lines.append("")
    
    if medium:
        lines.append("📊 *SIGNALS*")
        for s in medium:
            signal_type = s.get('type', '').replace('_', ' ').title()
            lines.append(f"• {s.get('subnet_name', 'Unknown')} ({signal_type}): {s.get('detail', '')}")
        lines.append("")
    
    lines.append("_Signals don't wait. Neither should you._")
    
    return "\n".join(lines)

def format_daily_summary(data_path: Path) -> str:
    """Create a daily summary from collected data"""
    lines = [
        f"📊 *TAOLOR DAILY SUMMARY* — {datetime.now().strftime('%Y-%m-%d')}",
        ""
    ]
    
    # GitHub activity
    github_file = data_path / "github_latest.json"
    if github_file.exists():
        with open(github_file) as f:
            github = json.load(f)
        
        total_commits = github.get("aggregate", {}).get("total_commits_7d", 0)
        most_active = github.get("aggregate", {}).get("most_active", [])[:3]
        
        lines.append(f"*🐙 GitHub Activity (7d):* {total_commits} commits")
        for repo in most_active:
            lines.append(f"  • {repo['repo'].split('/')[-1]}: {repo['commits']} commits")
        lines.append("")
    
    # Subnet data
    subnet_file = data_path / "subnets_latest.json"
    if subnet_file.exists():
        with open(subnet_file) as f:
            subnets = json.load(f)
        
        subnet_count = len(subnets.get("subnets", {}))
        lines.append(f"*🌐 Subnets Tracked:* {subnet_count}")
        lines.append("")
    
    # KOL activity
    kol_file = data_path / "kol_tweets_latest.json"
    if kol_file.exists():
        with open(kol_file) as f:
            kols = json.load(f)
        
        tweets_24h = kols.get("aggregate", {}).get("total_tweets_24h", 0)
        top_mentions = list(kols.get("aggregate", {}).get("subnet_mentions", {}).items())[:5]
        
        if tweets_24h > 0:
            lines.append(f"*🐦 KOL Activity (24h):* {tweets_24h} tweets")
            if top_mentions:
                mentions_str = ", ".join([f"{k}: {v}" for k, v in top_mentions])
                lines.append(f"  Top mentions: {mentions_str}")
            lines.append("")
    
    lines.append("_Run `./run.sh` for full analysis_")
    
    return "\n".join(lines)

def post_to_slack(message: str, channel: str = SLACK_CHANNEL) -> bool:
    """Post message to Slack using Clawdbot message tool"""
    if not message:
        return False
    
    # Write message to temp file for Clawdbot to pick up
    output_dir = Path(__file__).parent / "output"
    output_dir.mkdir(exist_ok=True)
    
    pending_file = output_dir / "pending_slack.json"
    with open(pending_file, "w") as f:
        json.dump({
            "channel": channel,
            "message": message,
            "timestamp": datetime.now().isoformat()
        }, f, indent=2)
    
    print(f"📤 Slack message queued: {len(message)} chars")
    return True

def main():
    """Generate and queue daily summary"""
    data_path = Path(__file__).parent / "data"
    
    summary = format_daily_summary(data_path)
    if summary:
        post_to_slack(summary)
        print(summary)

if __name__ == "__main__":
    main()