Function add_paper

skills/storage-helper/scripts/db_ops.py:717–746

Add a paper to the database

(paper_data: Dict)

            lookup_sql = "SELECT id FROM papers WHERE title = ?"
            lookup_value = normalized_title

        if lookup_sql and lookup_value is not None:
            cursor.execute(lookup_sql, (lookup_value,))
            row = cursor.fetchone()
            if row:
                return row["id"]
        raise
    finally:
        conn.close()


def get_profile(user_id: str) -> Optional[Dict]:
    """Get user profile by user_id"""
    with connection() as conn:
        row = conn.execute("""
            SELECT profile_json FROM profiles WHERE user_id = ?
        """, (user_id,)).fetchone()
    if row:
        return json.loads(row["profile_json"])
    return None


def get_paper_by_arxiv_id(arxiv_id: str) -> Optional[Dict]:
    """Get paper by arxiv_id"""
    normalized_arxiv_id = _normalize_identifier(arxiv_id)
    if not normalized_arxiv_id:
        return None
    with connection() as conn:
        row = conn.execute("""
            SELECT * FROM papers WHERE arxiv_id = ?
        """, (normalized_arxiv_id,)).fetchone()
    if row:
        return _build_paper_dict(row)