Alphaear News

# AlphaEar News Skill

## Overview

Fetch real-time hot news, generate unified trend reports, and retrieve Polymarket prediction data.

## Capabilities

### 1. Fetch Hot News & Trends

Use `scripts/news_tools.py` via `NewsNowTools`.

-   **Fetch News**: `fetch_hot_news(source_id, count)`
    -   See [sources.md](references/sources.md) for valid `source_id`s (e.g., `cls`, `weibo`).
-   **Unified Report**: `get_unified_trends(sources)`
    -   Aggregates top news from multiple sources.

### 2. Fetch Prediction Markets

Use `scripts/news_tools.py` via `PolymarketTools`.

-   **Market Summary**: `get_market_summary(limit)`
    -   Returns a formatted report of active prediction markets.

## Dependencies

-   `requests`, `loguru`
-   `scripts/database_manager.py` (Local DB)


import sqlite3
import json
from datetime import datetime
from pathlib import Path
from typing import List, Dict, Optional
from loguru import logger

class DatabaseManager:
    """
    AlphaEar News Database Manager
    Reduced version for alphaear-news skill
    """
    
    def __init__(self, db_path: str = "data/signal_flux.db"):
        self.db_path = Path(db_path)
        self.db_path.parent.mkdir(parents=True, exist_ok=True)
        self.conn = sqlite3.connect(str(self.db_path), check_same_thread=False)
        self.conn.row_factory = sqlite3.Row
        self._init_db()
        logger.debug(f"💾 Database initialized at {self.db_path}")

    def _init_db(self):
        """Initialize news-related tables only"""
        cursor = self.conn.cursor()
        
        # Daily News Table
        cursor.execute("""
            CREATE TABLE IF NOT EXISTS daily_news (
                id TEXT PRIMARY KEY,
                source TEXT,
                rank INTEGER,
                title TEXT,
                url TEXT,
                content TEXT,
                publish_time TEXT,
                crawl_time TEXT,
                sentiment_score REAL,
                analysis TEXT,
                meta_data TEXT
            )
        """)
        
        # Indexes
        cursor.execute("CREATE INDEX IF NOT EXISTS idx_news_crawl_time ON daily_news(crawl_time)")
        cursor.execute("CREATE INDEX IF NOT EXISTS idx_news_source ON daily_news(source)")
        
        self.conn.commit()

    # --- News Operations ---
    
    def save_daily_news(self, news_list: List[Dict]) -> int:
        """Save hot news items"""
        cursor = self.conn.cursor()
        count = 0
        crawl_time = datetime.now().isoformat()
        
        for news in news_list:
            try:
                news_id = news.get('id') or f"{news.get('source')}_{news.get('rank')}_{crawl_time[:10]}"
                cursor.execute("""
                    INSERT OR REPLACE INTO daily_news 
                    (id, source, rank, title, url, content, publish_time, crawl_time, sentiment_score, meta_data)
                    VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)
                """, (
                    news_id,
                    news.get('source'),
                    news.get('rank'),
                    news.get('title'),
                    news.get('url'),
                    news.get('content', ''),
                    news.get('publish_time'),
                    crawl_time,
                    news.get('sentiment_score'),
                    json.dumps(news.get('meta_data', {}))
                ))
                count += 1
            except Exception as e:
                logger.error(f"Error saving news item {news.get('title')}: {e}")
        
        self.conn.commit()
        return count

    def get_daily_news(self, source: Optional[str] = None, limit: int = 100, days: int = 1) -> List[Dict]: