Function upsert_edge

skills/wiki-store/scripts/wiki_db.py:406–431

(
    *,
    user_id: str,
    src_id: str,
    dst_id: str,
    relation: str,
    weight: float = 1.0,
    metadata: Optional[Dict[str, Any]] = None,
)

def upsert_edge(
    *,
    user_id: str,
    src_id: str,
    dst_id: str,
    relation: str,
    weight: float = 1.0,
    metadata: Optional[Dict[str, Any]] = None,
) -> int:
    init_wiki_schema()
    conn = db_ops.get_connection()
    cursor = conn.cursor()
    cursor.execute(
        """
        INSERT INTO wiki_edges (user_id, src_id, dst_id, relation, weight, metadata_json)
        VALUES (?, ?, ?, ?, ?, ?)
        ON CONFLICT(user_id, src_id, dst_id, relation) DO UPDATE SET
            weight=excluded.weight,
            metadata_json=excluded.metadata_json
        """,
        (user_id, src_id, dst_id, relation, float(weight), _json_dumps(metadata)),
    )
    conn.commit()
    edge_id = int(cursor.lastrowid or 0)
    conn.close()
    return edge_id


def upsert_citation(