Utilities

from datetime import datetime
from zoneinfo import ZoneInfo

# During DST (EDT = UTC-4)
summer = datetime(2026, 7, 1, 12, 0, 0, tzinfo=timezone.utc)
eastern_summer = convert_to_eastern(summer, ZoneInfo("America/New_York"))
print(eastern_summer)  # 2026-07-01 08:00:00-04:00 (EDT)

# During Standard Time (EST = UTC-5)
winter = datetime(2026, 1, 1, 12, 0, 0, tzinfo=timezone.utc)
eastern_winter = convert_to_eastern(winter, ZoneInfo("America/New_York"))
print(eastern_winter)  # 2026-01-01 07:00:00-05:00 (EST)

content = """
Hey <@123> and <@!456>, please review PR in <#789>.
<@&999> team should be notified.
"""

cleaned = clean_content(content, guild)
# Output:
# """
# Hey @alice and @bob, please review PR in #code-review.
# @engineering team should be notified.
# """

# Imported from bot.py
USER_MENTION_PATTERN = re.compile(r"<@!?(\d+)>")
CHANNEL_MENTION_PATTERN = re.compile(r"<#(\d+)>")
ROLE_MENTION_PATTERN = re.compile(r"<@&(\d+)>")

import re
from bot import replace_mention

# Only replace channel mentions
channel_content = "Check <#123> and <#456>"
channel_cleaned = replace_mention(
    re.compile(r"<#(\d+)>"),
    channel_content,
    guild,
    guild.get_channel
)

# Only replace role mentions
role_content = "Attention <@&999> and <@&888>"
role_cleaned = replace_mention(
    re.compile(r"<@&(\d+)>"),
    role_content,
    guild,
    guild.get_role
)

from bot import export_channel_messages, filter_bot_messages, Config

config = Config.from_env()

# Export all messages
all_messages = await export_channel_messages(channel, 24, config)
print(f"Total messages: {len(all_messages)}")

# Filter to humans only
human_messages = filter_bot_messages(all_messages)
print(f"Human messages: {len(human_messages)}")

# Calculate human-only statistics
human_authors = {msg["author"]["display_name"] for msg in human_messages}
print(f"Active humans: {len(human_authors)}")

from bot import get_anthropic_client, Config
import asyncio

config = Config.from_env()
client = get_anthropic_client(config.anthropic_api_key)

def analyze_text(text: str) -> str:
    """Analyze text with Claude"""
    response = client.messages.create(
        model=config.digest_model,
        max_tokens=config.digest_max_tokens,
        messages=[{
            "role": "user",
            "content": f"Summarize this:\n\n{text}"
        }]
    )
    return response.content[0].text

# Use in async context
async def analyze_multiple(texts: list[str]):
    """Analyze multiple texts concurrently"""
    loop = asyncio.get_event_loop()
    tasks = [loop.run_in_executor(None, analyze_text, text) for text in texts]
    return await asyncio.gather(*tasks)

# In Dokploy deployment with volume mounted at /data
config.dokploy_volume_path = "/data"
config.digests_dir = "Daily Digests"

path = get_output_path(config)
# Returns: "/data/Daily Digests" (persistent across container restarts)

# In local development without Dokploy
config.dokploy_volume_path = None  # or path doesn't exist
config.digests_dir = "Daily Digests"

path = get_output_path(config)
# Returns: "Daily Digests" (local directory)

from datetime import datetime, timezone
from zoneinfo import ZoneInfo
from bot import (
    Config,
    convert_to_eastern,
    clean_content,
    filter_bot_messages,
    get_anthropic_client,
    get_output_path
)
import discord

# Initialize
config = Config.from_env()
guild = bot.get_guild(config.guild_id)

# Timezone conversion
utc_time = datetime.now(timezone.utc)
eastern_time = convert_to_eastern(utc_time, config.eastern_tz)
print(f"Current time in ET: {eastern_time.strftime('%I:%M %p')}")

# Content cleaning
raw_message = "Hey <@123456> check <#789012>"
clean_message = clean_content(raw_message, guild)
print(f"Clean message: {clean_message}")

# Message filtering
all_messages = [
    {"author": {"bot": False}, "content": "Hello"},
    {"author": {"bot": True}, "content": "[Bot] Automated"},
    {"author": {"bot": False}, "content": "Thanks!"}
]
human_only = filter_bot_messages(all_messages)
print(f"Human messages: {len(human_only)}/

# API client
client = get_anthropic_client(config.anthropic_api_key)
response = client.messages.create(
    model=config.digest_model,
    max_tokens=100,
    messages=[{"role": "user", "content": "Hello Claude!"}]
)
print(f"Claude says: {response.content[0].text}")

# Output path
output = get_output_path(config)
print(f"Digests will be saved to: {output}")