Function import_graph_first_source

atomic-repository/src/repository/insert.rs:428–473

(
    txn: &T,
    pos: &Position<Option<Hash>>,
    inode_pos: &Position<Option<Hash>>,
    resolved_inode: Option<Inode>,
    old_by_end: &HashMap<Position<NodeId>, GraphNode<NodeId>>,
    current_b

#[allow(clippy::too_many_arguments)]
fn import_graph_first_source<T>(
    txn: &T,
    pos: &Position<Option<Hash>>,
    inode_pos: &Position<Option<Hash>>,
    resolved_inode: Option<Inode>,
    old_by_end: &HashMap<Position<NodeId>, GraphNode<NodeId>>,
    current_by_end: &HashMap<Position<NodeId>, GraphNode<NodeId>>,
    vertex_cache: &mut ImportGraphFirstVertexCache,
    change_id: NodeId,
) -> Result<GraphNode<NodeId>, RepositoryError>
where
    T: GraphTxnT + TreeTxnT + InodeGraphOps,
{
    let resolved = import_graph_first_position(txn, pos, change_id)?;

    if resolved.change == change_id {
        if let Some(node) = current_by_end.get(&resolved) {
            return Ok(*node);
        }
    }

    if let Some(node) = old_by_end.get(&resolved) {
        return Ok(*node);
    }

    let resolved_inode_pos = import_graph_first_position(txn, inode_pos, change_id)?;
    if resolved == resolved_inode_pos {
        return Ok(GraphNode {
            change: resolved.change,
            start: resolved.pos,
            end: resolved.pos,
        });
    }

    if let Some(inode) = resolved_inode {
        if let Some(node) = vertex_cache.find_end(txn, inode, resolved)? {
            return Ok(node);
        }
        if let Some(node) = vertex_cache.load(txn, inode)?.by_end.get(&resolved) {
            return Ok(*node);
        }
    }

    txn.find_block_end(resolved)
        .map_err(|e| RepositoryError::Apply(e.to_string()))
}

fn import_graph_first_successor<T>(
    txn: &T,