AI Digests

async def generate_daily_digest(export_data: dict, config: Config) -> Optional[str]:
    """Use Claude to generate structured daily digest."""
    if not config.anthropic_api_key:
        logger.error("ANTHROPIC_API_KEY not set")
        return None

    transcript = prepare_transcript(export_data)

    try:
        client = get_anthropic_client(config.anthropic_api_key)

        prompt = f"""Analyze this Discord transcript from the last 24 hours and create a structured daily digest for a team manager.

Focus on extracting:

1. **Individual Updates** - What each team member worked on, completed, or made progress on
2. **Upcoming Work** - What team members mentioned they're planning to work on next
3. **Blockers & Challenges** - Any obstacles, issues, or requests for help
4. **Key Decisions & Ideas** - Important discussions, decisions made, or ideas that shouldn't be lost
5. **Action Items** - Specific TODOs or follow-ups mentioned

Be concise but don't lose important technical details. Organize by person where possible.
If there's very little activity, just note that briefly.

Transcript:
{transcript}
"""

        message = client.messages.create(
            model=config.digest_model,
            max_tokens=config.digest_max_tokens,
            messages=[{"role": "user", "content": prompt}]
        )

        return message.content[0].text

    except Exception as e:
        logger.error(f"Error calling Claude API: {e}")
        return None

def prepare_transcript(export_data: dict) -> str:
    """Prepare transcript for Claude analysis from export data."""
    channel_summaries = []

    for channel_name, channel_data in export_data["channels"].items():
        non_bot_messages = filter_bot_messages(channel_data["messages"])
        if not non_bot_messages:
            continue

        messages_text = "\n".join([
            f"[{msg['timestamp'][:19]}] {msg['author']['display_name']}: {msg['content_clean']}"
            for msg in non_bot_messages
        ])

        channel_summaries.append(f"## Channel: #{channel_name}\n{messages_text}\n")

    return "\n".join(channel_summaries) if channel_summaries else "No messages to analyze."

## Channel: #general
[2026-03-04T09:15:30] John Doe: Finished the authentication refactor, pushing to PR
[2026-03-04T09:17:45] Jane Smith: Great! I'll review it this afternoon
[2026-03-04T10:23:12] John Doe: Thanks! Also starting work on the API rate limiting

## Channel: #engineering
[2026-03-04T11:30:00] Mike Johnson: Hitting an issue with the database migration
[2026-03-04T11:32:15] Sarah Lee: What's the error message?
[2026-03-04T11:35:45] Mike Johnson: Foreign key constraint failing on user_id

def filter_bot_messages(messages: list) -> list:
    """Filter out messages from bots."""
    return [m for m in messages if not m["author"]["bot"]]

# From Config class in bot.py:31-32
digest_model: str = "claude-haiku-4-5-20251001"
digest_max_tokens: int = 4096

def get_anthropic_client(api_key: str) -> anthropic.Anthropic:
    """Get or create Anthropic client (reusable)."""
    return anthropic.Anthropic(api_key=api_key)

prompt = f"""Analyze this Discord transcript from the last 24 hours and create a structured daily digest for a team manager.

Focus on extracting:

1. **Individual Updates** - What each team member worked on, completed, or made progress on
2. **Upcoming Work** - What team members mentioned they're planning to work on next
3. **Blockers & Challenges** - Any obstacles, issues, or requests for help
4. **Key Decisions & Ideas** - Important discussions, decisions made, or ideas that shouldn't be lost
5. **Action Items** - Specific TODOs or follow-ups mentioned

Be concise but don't lose important technical details. Organize by person where possible.
If there's very little activity, just note that briefly.

Transcript:
{transcript}
"""

**John Doe**
- Completed authentication refactor (PR #234)
- Fixed database migration issue with foreign key constraints
- Deployed staging environment updates

**Jane Smith**
- Code review on authentication PR
- Started work on API documentation
- Updated test coverage to 85%

- John: Starting API rate limiting implementation
- Sarah: Planning to tackle the search optimization
- Mike: Will address the mobile responsive issues

- Mike blocked on database migration foreign key issue (resolved by Sarah)
- Team needs decision on which logging framework to use
- Waiting on design mockups for new dashboard

- Decided to use PostgreSQL instead of MySQL for better JSON support
- Idea: Implement feature flags for gradual rollout
- Agreement to move to weekly deploys instead of daily

- [ ] John to create documentation for new API endpoints
- [ ] Sarah to schedule architecture review meeting
- [ ] Team to review and vote on logging framework by Friday

## Individual Updates

**John Doe**
- Completed the authentication refactor and pushed to PR #234
- Fixed the database migration foreign key constraint issue
- Starting work on API rate limiting implementation

**Jane Smith**
- Reviewed authentication PR, left comments on error handling
- Updated API documentation with new endpoints
- Increased test coverage from 72% to 85%

**Mike Johnson**
- Worked through database migration issues (resolved with Sarah's help)
- Fixed mobile responsive issues on dashboard
- Deployed updates to staging environment

## Upcoming Work

- John: API rate limiting and throttling implementation
- Sarah: Search optimization and indexing improvements
- Mike: Dashboard redesign based on new mockups

## Blockers & Challenges

- Migration foreign key constraint (resolved)
- Waiting on design team for dashboard mockups
- Need to decide on logging framework (discussion ongoing)

## Key Decisions & Ideas

- **Decided**: Moving from MySQL to PostgreSQL for better JSON support
- **Idea**: Implement feature flags for gradual feature rollout
- **Agreement**: Shift to weekly deployment cadence

## Action Items

- [ ] John to document new API endpoints
- [ ] Sarah to schedule architecture review
- [ ] Team to vote on logging framework by Friday
- [ ] Mike to follow up with design team on mockups

# In Discord
!digest          # Last 24 hours
!digest 48       # Last 48 hours
!digest 168      # Last week

✅ Daily Digest Generated

## Individual Updates

**John Doe**
- Completed the authentication refactor and pushed to PR #234
- Fixed the database migration foreign key constraint issue...

[truncated preview]

📁 Full digest: `Daily Digests/2026-03-04 - Team Digest.md`

@tasks.loop(hours=24)
async def daily_digest_task():
    """Automatically generate daily digest at scheduled time."""
    logger.info("Running scheduled daily digest")

    result = await run_digest_pipeline(bot, config, config.default_hours)

    if result["success"]:
        logger.info("✅ Daily digest completed successfully")
    else:
        logger.error(f"Daily digest failed: {result.get('error', 'Unknown error')}")