from apscheduler.schedulers.blocking import BlockingScheduler

sched = BlockingScheduler(timezone="Asia/Tokyo")

@sched.scheduled_job("cron", hour=7, minute=0)
def run_daily_job():
    main()

if __name__ == "__main__":
    sched.start()

from dataclasses import dataclass
from typing import Protocol

@dataclass
class NewsItem:
    title: str
    url: str
    body: str

class Summarizer(Protocol):
    def summarize(self, items: list[NewsItem]) -> str: ...

class ClaudeSummarizer:
    def __init__(self, client, model: str = "claude-opus-4-8"):
        self.client = client
        self.model = model

    def summarize(self, items: list[NewsItem]) -> str:
        joined = "\n\n".join(f"- {i.title}" for i in items)
        prompt = "다음 AI 뉴스를 5줄로 요약:\n" + joined
        resp = self.client.messages.create(
            model=self.model,
            max_tokens=1024,
            messages=[{"role": "user", "content": prompt}],
        )
        return resp.content[0].text

import os, datetime
def save_idempotent(summary: str, out_dir: str = "./daily") -> str:
today = datetime.date.today().isoformat()
path = os.path.join(out_dir, f"{today}.md")
if os.path.exists(path):
    return path # 이미 오늘 날짜의 파일이 있으면 건너뜀 (멱등성)
os.makedirs(out_dir, exist_ok=True)
with open(path, "w", encoding="utf-8") as f:
    f.write(f"# AI News {today}\n\n{summary}\n")
return path

def main():
    items = fetch_news()
    summarizer = ClaudeSummarizer(client=anthropic_client)
    try:
        summary = summarizer.summarize(items)
    except Exception as e:
        log_error(e) # 실패하더라도 놓치지 않고, 다음 실행으로 이월
    return path = save_idempotent(summary)
    notify(f"오늘의 AI 뉴스 요약 저장: {path}")