Function get_push_papers

skills/storage-helper/scripts/db_ops.py:1772–1836

Get all papers for a specific push ID Args: push_id: Push ID Returns: Push information with papers list

(push_id: str)

def get_push_papers(push_id: str) -> Optional[Dict]:
    """
    Get all papers for a specific push ID

    Args:
        push_id: Push ID

    Returns:
        Push information with papers list
    """
    conn = get_connection()
    cursor = conn.cursor()

    # Get push time
    cursor.execute("""
        SELECT DISTINCT push_id, timestamp
        FROM behavior_logs
        WHERE push_id = ?
        ORDER BY timestamp ASC
        LIMIT 1
    """, (push_id,))

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

    push_time = row['timestamp']

    # Get all papers in this push with metadata.
    cursor.execute("""
        SELECT p.*, bl.id as behavior_log_id, bl.metadata
        FROM papers p
        JOIN behavior_logs bl ON p.id = bl.paper_id
        WHERE bl.push_id = ? AND bl.action = 'pushed'
        ORDER BY bl.id ASC
    """, (push_id,))

    papers = [_build_paper_dict(row) 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 push_id = ?
          AND action = 'push_empty'
        ORDER BY id DESC
        LIMIT 1
        """,
        (push_id,),
    )
    metadata_row = cursor.fetchone()
    push_metadata = _load_json_metadata(metadata_row["metadata"]) if metadata_row else {}
    if not push_metadata:
        push_metadata = _derive_push_metadata_from_papers(papers)

    conn.close()