Function get_push_for_date

skills/storage-helper/scripts/db_ops.py:1371–1445

Get the latest real push for a user on a specific local date. Args: user_id: User ID target_date: YYYY-MM-DD date string Returns: Push information with papers list, or None when no push exists that day

(user_id: str, target_date: str)

def get_push_for_date(user_id: str, target_date: str) -> Optional[Dict]:
    """
    Get the latest real push for a user on a specific local date.

    Args:
        user_id: User ID
        target_date: YYYY-MM-DD date string

    Returns:
        Push information with papers list, or None when no push exists that day
    """
    conn = get_connection()
    cursor = conn.cursor()

    cursor.execute(
        """
        SELECT push_id, MAX(timestamp) as timestamp
        FROM behavior_logs
        WHERE user_id = ?
          AND action IN ('pushed', 'push_empty')
          AND date(timestamp) = ?
        GROUP BY push_id
        ORDER BY timestamp DESC, push_id DESC
        LIMIT 1
        """,
        (user_id, target_date),
    )

    row = cursor.fetchone()
    if not row:
        conn.close()
        return None

    push_id = row["push_id"]
    push_time = row["timestamp"]

    cursor.execute(
        """
        SELECT p.*, bl.id as behavior_log_id, bl.metadata as bl_metadata FROM papers p
        JOIN behavior_logs bl ON p.id = bl.paper_id
        WHERE bl.user_id = ? AND bl.push_id = ? AND bl.action = 'pushed'
        ORDER BY bl.id ASC
        """,
        (user_id, push_id),
    )

    papers = [_build_paper_dict(row, metadata_key="bl_metadata") for row in cursor.fetchall()]
    papers.sort(key=lambda paper: (paper.get("rank", 10**9), paper.get("behavior_log_id", 10**9)))

    cursor.execute(
        """
        SELECT metadata
        FROM behavior_logs
        WHERE user_id = ?
          AND push_id = ?
          AND action = 'push_empty'
        ORDER BY id DESC
        LIMIT 1