async fn handle_nodes_update(reflector: &str, nodes: &[NodeInfo], pool: &PgPool)
Processes a nodes update: clears stale entries and upserts the fresh snapshot.