daggy2/lib.rs
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569 570 571 572 573 574 575 576 577 578 579 580 581 582 583 584 585 586 587 588 589 590 591 592 593 594 595 596 597 598 599 600 601 602 603 604 605 606 607 608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630 631 632 633 634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674 675 676 677 678 679 680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747 748 749 750 751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944
//! **daggy** is a directed acyclic graph data structure library.
//!
//! The most prominent type is [**Dag**][1] - a wrapper around [petgraph][2]'s [**Graph**][3]
//! data structure, exposing a refined API targeted towards directed acyclic graph related
//! functionality.
//!
//! The [**Walker** trait](Walker) defines a variety of useful methods for
//! traversing any graph type. Its methods behave similarly to iterator types, however **Walker**s
//! do not require borrowing the graph. This means that we can still safely mutably borrow from the
//! graph whilst we traverse it.
//!
//!
//! [1]: https://docs.rs/daggy2/latest/daggy2/struct.Dag.html
//! [2]: https://docs.rs/petgraph/0.7.1/petgraph/
//! [3]: https://docs.rs/petgraph/0.7.1/petgraph/graph/struct.Graph.html
#![forbid(unsafe_code)]
#![warn(missing_docs)]
pub use petgraph;
use petgraph as pg;
use petgraph::algo::{has_path_connecting, DfsSpace};
use petgraph::graph::{DefaultIx, DiGraph, GraphIndex, IndexType};
use petgraph::visit::{
GetAdjacencyMatrix, GraphBase, GraphProp, IntoEdgeReferences, IntoEdges, IntoEdgesDirected,
IntoNeighbors, IntoNeighborsDirected, IntoNodeIdentifiers, IntoNodeReferences,
NodeCompactIndexable, NodeCount, NodeIndexable, Visitable,
};
use petgraph::IntoWeightedEdge;
use std::marker::PhantomData;
use std::ops::{Index, IndexMut};
// Petgraph re-exports.
pub use petgraph::graph::{EdgeIndex, EdgeWeightsMut, NodeIndex, NodeWeightsMut};
pub use petgraph::visit::Walker;
#[cfg(feature = "serde-1")]
mod serde;
#[cfg(feature = "stable_dag")]
pub mod stable_dag;
pub mod walker;
/// Read only access into a **Dag**'s internal node array.
pub type RawNodes<'a, N, Ix> = &'a [pg::graph::Node<N, Ix>];
/// Read only access into a **Dag**'s internal edge array.
pub type RawEdges<'a, E, Ix> = &'a [pg::graph::Edge<E, Ix>];
/// An iterator yielding all edges to/from some node.
pub type Edges<'a, E, Ix> = pg::graph::Edges<'a, E, pg::Directed, Ix>;
/// A Directed acyclic graph (DAG) data structure.
///
/// Dag is a thin wrapper around petgraph's `Graph` data structure, providing a refined API for
/// dealing specifically with DAGs.
///
/// Note: The following documentation is adapted from petgraph's [**Graph** documentation][1]
///
/// **Dag** is parameterized over the node weight **N**, edge weight **E** and index type **Ix**.
///
/// **NodeIndex** is a type that acts as a reference to nodes, but these are only stable across
/// certain operations. **Removing nodes may shift other indices.** Adding kids to the **Dag**
/// keeps all indices stable, but removing a node will force the last node to shift its index to
/// take its place.
///
/// The fact that the node indices in the **Dag** are numbered in a compact interval from 0 to *n*-1
/// simplifies some graph algorithms.
///
/// The **Ix** parameter is u32 by default. The goal is that you can ignore this parameter
/// completely unless you need a very large **Dag** -- then you can use usize.
///
/// The **Dag** also offers methods for accessing the underlying **Graph**, which can be useful
/// for taking advantage of petgraph's various graph-related algorithms.
///
///
/// [1]: petgraph::graph::Graph
#[derive(Clone, Debug)]
pub struct Dag<N, E, Ix: IndexType = DefaultIx> {
graph: DiGraph<N, E, Ix>,
cycle_state: DfsSpace<NodeIndex<Ix>, <DiGraph<N, E, Ix> as Visitable>::Map>,
}
/// A **Walker** type that can be used to step through the children of some parent node.
pub struct Children<N, E, Ix: IndexType> {
walk_edges: pg::graph::WalkNeighbors<Ix>,
_node: PhantomData<N>,
_edge: PhantomData<E>,
}
/// A **Walker** type that can be used to step through the parents of some child node.
pub struct Parents<N, E, Ix: IndexType> {
walk_edges: pg::graph::WalkNeighbors<Ix>,
_node: PhantomData<N>,
_edge: PhantomData<E>,
}
/// An iterator yielding multiple `EdgeIndex`s, returned by the `Graph::add_edges` method.
pub struct EdgeIndices<Ix: IndexType> {
indices: std::ops::Range<usize>,
_phantom: PhantomData<Ix>,
}
/// An alias to simplify the **Recursive** **Walker** type returned by **Dag**.
pub type RecursiveWalk<N, E, Ix, F> = walker::Recursive<Dag<N, E, Ix>, F>;
/// An error returned by the `Dag::add_edge` method in the case that adding an edge would have
/// caused the graph to cycle.
#[derive(Copy, Clone)]
pub struct WouldCycle<E>(pub E);
impl<N, E, Ix> Dag<N, E, Ix>
where
Ix: IndexType,
{
/// Create a new, empty `Dag`.
pub fn new() -> Self {
Self::with_capacity(1, 1)
}
/// Create a new `Dag` with estimated capacity for its node and edge Vecs.
pub fn with_capacity(nodes: usize, edges: usize) -> Self {
Dag {
graph: DiGraph::with_capacity(nodes, edges),
cycle_state: DfsSpace::default(),
}
}
/// Create a `Dag` from an iterator yielding edges.
///
/// Node weights `N` are set to default values.
///
/// `Edge` weights `E` may either be specified in the list, or they are filled with default
/// values.
///
/// Nodes are inserted automatically to match the edges.
///
/// Returns an `Err` if adding any of the edges would cause a cycle.
pub fn from_edges<I>(edges: I) -> Result<Self, WouldCycle<E>>
where
I: IntoIterator,
I::Item: IntoWeightedEdge<E>,
<I::Item as IntoWeightedEdge<E>>::NodeId: Into<NodeIndex<Ix>>,
N: Default,
{
let mut dag = Self::default();
dag.extend_with_edges(edges)?;
Ok(dag)
}
/// Extend the `Dag` with the given edges.
///
/// Node weights `N` are set to default values.
///
/// Edge weights `E` may either be specified in the list, or they are filled with default
/// values.
///
/// Nodes are inserted automatically to match the edges.
///
/// Returns an `Err` if adding an edge would cause a cycle.
pub fn extend_with_edges<I>(&mut self, edges: I) -> Result<(), WouldCycle<E>>
where
I: IntoIterator,
I::Item: IntoWeightedEdge<E>,
<I::Item as IntoWeightedEdge<E>>::NodeId: Into<NodeIndex<Ix>>,
N: Default,
{
for edge in edges {
let (source, target, weight) = edge.into_weighted_edge();
let (source, target) = (source.into(), target.into());
let nx = std::cmp::max(source, target);
while nx.index() >= self.node_count() {
self.add_node(N::default());
}
self.add_edge(source, target, weight)?;
}
Ok(())
}
/// Create a `Dag` from an iterator yielding elements.
///
/// Returns an `Err` if an edge would cause a cycle within the graph.
pub fn from_elements<I>(elements: I) -> Result<Self, WouldCycle<E>>
where
Self: Sized,
I: IntoIterator<Item = pg::data::Element<N, E>>,
{
let mut dag = Self::default();
for elem in elements {
match elem {
pg::data::Element::Node { weight } => {
dag.add_node(weight);
}
pg::data::Element::Edge {
source,
target,
weight,
} => {
let n = NodeIndex::new(source);
let e = NodeIndex::new(target);
dag.update_edge(n, e, weight)?;
}
}
}
Ok(dag)
}
/// Create a new `Graph` by mapping node and edge weights to new values.
///
/// The resulting graph has the same structure and the same graph indices as `self`.
pub fn map<'a, F, G, N2, E2>(&'a self, node_map: F, edge_map: G) -> Dag<N2, E2, Ix>
where
F: FnMut(NodeIndex<Ix>, &'a N) -> N2,
G: FnMut(EdgeIndex<Ix>, &'a E) -> E2,
{
let graph = self.graph.map(node_map, edge_map);
let cycle_state = self.cycle_state.clone();
Dag {
graph: graph,
cycle_state: cycle_state,
}
}
/// Create a new `Dag` by mapping node and edge weights. A node or edge may be mapped to `None`
/// to exclude it from the resulting `Dag`.
///
/// Nodes are mapped first with the `node_map` closure, then `edge_map` is called for the edges
/// that have not had any endpoint removed.
///
/// The resulting graph has the structure of a subgraph of the original graph. If no nodes are
/// removed, the resulting graph has compatible node indices.
///
/// If neither nodes nor edges are removed, the resulting graph has compatible node indices. If
/// neither nodes nor edges are removed the result has the same graph indices as `self`.
///
/// The resulting graph has the same structure and the same graph indices as `self`.
pub fn filter_map<'a, F, G, N2, E2>(&'a self, node_map: F, edge_map: G) -> Dag<N2, E2, Ix>
where
F: FnMut(NodeIndex<Ix>, &'a N) -> Option<N2>,
G: FnMut(EdgeIndex<Ix>, &'a E) -> Option<E2>,
{
let graph = self.graph.filter_map(node_map, edge_map);
let cycle_state = DfsSpace::new(&graph);
Dag {
graph: graph,
cycle_state: cycle_state,
}
}
/// Removes all nodes and edges from the **Dag**.
pub fn clear(&mut self) {
self.graph.clear();
}
/// The total number of nodes in the **Dag**.
pub fn node_count(&self) -> usize {
self.graph.node_count()
}
/// The total number of edges in the **Dag**.
pub fn edge_count(&self) -> usize {
self.graph.edge_count()
}
/// Borrow the `Dag`'s underlying `DiGraph<N, Ix>`.
///
/// All existing indices may be used to index into this `DiGraph` the same way they may be
/// used to index into the `Dag`.
pub fn graph(&self) -> &DiGraph<N, E, Ix> {
&self.graph
}
/// Take ownership of the `Dag` and return the internal `DiGraph`.
///
/// All existing indices may be used to index into this `DiGraph` the same way they may be
/// used to index into the `Dag`.
pub fn into_graph(self) -> DiGraph<N, E, Ix> {
let Dag { graph, .. } = self;
graph
}
/// Add a new node to the `Dag` with the given weight.
///
/// Computes in **O(1)** time.
///
/// Returns the index of the new node.
///
/// **Note:** If you're adding a new node and immediately adding a single edge to that node from
/// some other node, consider using the [add_child](./struct.Dag.html#method.add_child) or
/// [add_parent](./struct.Dag.html#method.add_parent) methods instead for better performance.
///
/// **Panics** if the Graph is at the maximum number of nodes for its index type.
pub fn add_node(&mut self, weight: N) -> NodeIndex<Ix> {
self.graph.add_node(weight)
}
/// Add a new directed edge to the `Dag` with the given weight.
///
/// The added edge will be in the direction `a` -> `b`
///
/// Checks if the edge would create a cycle in the Graph.
///
/// If adding the edge **would not** cause the graph to cycle, the edge will be added and its
/// `EdgeIndex` returned.
///
/// If adding the edge **would** cause the graph to cycle, the edge will not be added and
/// instead a `WouldCycle<E>` error with the given weight will be returned.
///
/// In the worst case, petgraph's [`is_cyclic_directed`][1]
/// function is used to check whether or not adding the edge would create a cycle.
///
/// **Note:** Dag allows adding parallel ("duplicate") edges. If you want to avoid this, use
/// [`update_edge`][2] instead.
///
/// **Note:** If you're adding a new node and immediately adding a single edge to that node from
/// some other node, consider using the [add_child][3] or
/// [add_parent][4] methods instead for better performance.
///
/// **Panics** if either `a` or `b` do not exist within the **Dag**.
///
/// **Panics** if the Graph is at the maximum number of edges for its index type.
///
///
/// [1]: petgraph::algo::is_cyclic_directed
/// [2]: Dag::update_edge
/// [3]: Dag::add_child
/// [4]: Dag::add_parent
pub fn add_edge(
&mut self,
a: NodeIndex<Ix>,
b: NodeIndex<Ix>,
weight: E,
) -> Result<EdgeIndex<Ix>, WouldCycle<E>> {
let should_check_for_cycle = must_check_for_cycle(self, a, b);
let state = Some(&mut self.cycle_state);
if should_check_for_cycle && has_path_connecting(&self.graph, b, a, state) {
return Err(WouldCycle(weight));
}
Ok(self.graph.add_edge(a, b, weight))
}
/// Adds the given directed edges to the `Dag`, each with their own given weight.
///
/// The given iterator should yield a `NodeIndex` pair along with a weight for each Edge to be
/// added in a tuple.
///
/// If we were to describe the tuple as *(a, b, weight)*, the connection would be directed as
/// follows:
///
/// *a -> b*
///
/// This method behaves similarly to the [`add_edge`][1]
/// method, however rather than checking whether or not a cycle has been created after adding
/// each edge, it only checks after all edges have been added. This makes it a slightly more
/// performant and ergonomic option that repeatedly calling `add_edge`.
///
/// If adding the edges **would not** cause the graph to cycle, the edges will be added and
/// their indices returned in an `EdgeIndices` iterator, yielding indices for each edge in the
/// same order that they were given.
///
/// If adding the edges **would** cause the graph to cycle, the edges will not be added and
/// instead a `WouldCycle<Vec<E>>` error with the unused weights will be returned. The order of
/// the returned `Vec` will be the reverse of the given order.
///
/// **Note:** Dag allows adding parallel ("duplicate") edges. If you want to avoid this, use
/// [`update_edge`][2] instead.
///
/// **Note:** If you're adding a series of new nodes and edges to a single node, consider using
/// the [add_child][3] or [add_parent][4] methods instead for greater convenience.
///
/// **Panics** if the Graph is at the maximum number of nodes for its index type.
///
///
/// [1]: Dag::add_edge
/// [2]: Dag::update_edge
/// [3]: Dag::add_child
/// [4]: Dag::add_parent
pub fn add_edges<I>(&mut self, edges: I) -> Result<EdgeIndices<Ix>, WouldCycle<Vec<E>>>
where
I: IntoIterator<Item = (NodeIndex<Ix>, NodeIndex<Ix>, E)>,
{
let mut num_edges = 0;
let mut should_check_for_cycle = false;
for (a, b, weight) in edges {
// Check whether or not we'll need to check for cycles.
if !should_check_for_cycle {
if must_check_for_cycle(self, a, b) {
should_check_for_cycle = true;
}
}
self.graph.add_edge(a, b, weight);
num_edges += 1;
}
let total_edges = self.edge_count();
let new_edges_range = total_edges - num_edges..total_edges;
// Check if adding the edges has created a cycle.
if should_check_for_cycle && pg::algo::is_cyclic_directed(&self.graph) {
let removed_edges = new_edges_range.rev().filter_map(|i| {
let idx = EdgeIndex::new(i);
self.graph.remove_edge(idx)
});
Err(WouldCycle(removed_edges.collect()))
} else {
Ok(EdgeIndices {
indices: new_edges_range,
_phantom: std::marker::PhantomData,
})
}
}
/// Update the edge from nodes `a` -> `b` with the given weight.
///
/// If the edge doesn't already exist, it will be added using the `add_edge` method.
///
/// Please read the [`add_edge`](./struct.Dag.html#method.add_edge) for more important details.
///
/// Checks if the edge would create a cycle in the Graph.
///
/// Computes in **O(t + e)** time where "t" is the complexity of `add_edge` and e is the number
/// of edges connected to the nodes a and b.
///
/// Returns the index of the edge, or a `WouldCycle` error if adding the edge would create a
/// cycle.
///
/// **Note:** If you're adding a new node and immediately adding a single edge to that node from
/// some parent node, consider using the [`add_child`](./struct.Dag.html#method.add_child)
/// method instead for greater convenience.
///
/// **Panics** if the Graph is at the maximum number of nodes for its index type.
pub fn update_edge(
&mut self,
a: NodeIndex<Ix>,
b: NodeIndex<Ix>,
weight: E,
) -> Result<EdgeIndex<Ix>, WouldCycle<E>> {
if let Some(edge_idx) = self.find_edge(a, b) {
if let Some(edge) = self.edge_weight_mut(edge_idx) {
*edge = weight;
return Ok(edge_idx);
}
}
self.add_edge(a, b, weight)
}
/// Find and return the index to the edge that describes `a` -> `b` if there is one.
///
/// Computes in **O(e')** time, where **e'** is the number of edges connected to the nodes `a`
/// and `b`.
pub fn find_edge(&self, a: NodeIndex<Ix>, b: NodeIndex<Ix>) -> Option<EdgeIndex<Ix>> {
self.graph.find_edge(a, b)
}
/// Access the parent and child nodes for the given `EdgeIndex`.
pub fn edge_endpoints(&self, e: EdgeIndex<Ix>) -> Option<(NodeIndex<Ix>, NodeIndex<Ix>)> {
self.graph.edge_endpoints(e)
}
/// Remove all edges.
pub fn clear_edges(&mut self) {
self.graph.clear_edges()
}
/// Add a new edge and parent node to the node at the given `NodeIndex`.
///
/// Returns both the edge's `EdgeIndex` and the node's `NodeIndex`.
///
/// node -> edge -> child
///
/// Computes in **O(1)** time.
///
/// This is faster than using `add_node` and `add_edge`. This is because we don't have to check
/// if the graph would cycle when adding an edge to the new node, as we know it it will be the
/// only edge connected to that node.
///
/// **Panics** if the given child node doesn't exist.
///
/// **Panics** if the Graph is at the maximum number of edges for its index.
pub fn add_parent(
&mut self,
child: NodeIndex<Ix>,
edge: E,
node: N,
) -> (EdgeIndex<Ix>, NodeIndex<Ix>) {
let parent_node = self.graph.add_node(node);
let parent_edge = self.graph.add_edge(parent_node, child, edge);
(parent_edge, parent_node)
}
/// Add a new edge and child node to the node at the given `NodeIndex`.
/// Returns both the edge's `EdgeIndex` and the node's `NodeIndex`.
///
/// child -> edge -> node
///
/// Computes in **O(1)** time.
///
/// This is faster than using `add_node` and `add_edge`. This is because we don't have to check
/// if the graph would cycle when adding an edge to the new node, as we know it it will be the
/// only edge connected to that node.
///
/// **Panics** if the given parent node doesn't exist.
///
/// **Panics** if the Graph is at the maximum number of edges for its index.
pub fn add_child(
&mut self,
parent: NodeIndex<Ix>,
edge: E,
node: N,
) -> (EdgeIndex<Ix>, NodeIndex<Ix>) {
let child_node = self.graph.add_node(node);
let child_edge = self.graph.add_edge(parent, child_node, edge);
(child_edge, child_node)
}
/// Borrow the weight from the node at the given index.
pub fn node_weight(&self, node: NodeIndex<Ix>) -> Option<&N> {
self.graph.node_weight(node)
}
/// Mutably borrow the weight from the node at the given index.
pub fn node_weight_mut(&mut self, node: NodeIndex<Ix>) -> Option<&mut N> {
self.graph.node_weight_mut(node)
}
/// Read from the internal node array.
pub fn raw_nodes(&self) -> RawNodes<N, Ix> {
self.graph.raw_nodes()
}
/// An iterator yielding mutable access to all node weights.
///
/// The order in which weights are yielded matches the order of their node indices.
pub fn node_weights_mut(&mut self) -> NodeWeightsMut<N, Ix> {
self.graph.node_weights_mut()
}
/// Borrow the weight from the edge at the given index.
pub fn edge_weight(&self, edge: EdgeIndex<Ix>) -> Option<&E> {
self.graph.edge_weight(edge)
}
/// Mutably borrow the weight from the edge at the given index.
pub fn edge_weight_mut(&mut self, edge: EdgeIndex<Ix>) -> Option<&mut E> {
self.graph.edge_weight_mut(edge)
}
/// Read from the internal edge array.
pub fn raw_edges(&self) -> RawEdges<E, Ix> {
self.graph.raw_edges()
}
/// An iterator yielding mutable access to all edge weights.
///
/// The order in which weights are yielded matches the order of their edge indices.
pub fn edge_weights_mut(&mut self) -> EdgeWeightsMut<E, Ix> {
self.graph.edge_weights_mut()
}
/// Index the `Dag` by two indices.
///
/// Both indices can be either `NodeIndex`s, `EdgeIndex`s or a combination of the two.
///
/// **Panics** if the indices are equal or if they are out of bounds.
pub fn index_twice_mut<A, B>(
&mut self,
a: A,
b: B,
) -> (
&mut <DiGraph<N, E, Ix> as Index<A>>::Output,
&mut <DiGraph<N, E, Ix> as Index<B>>::Output,
)
where
DiGraph<N, E, Ix>: IndexMut<A> + IndexMut<B>,
A: GraphIndex,
B: GraphIndex,
{
self.graph.index_twice_mut(a, b)
}
/// Remove the node at the given index from the `Dag` and return it if it exists.
///
/// Note: Calling this may shift (and in turn invalidate) previously returned node indices!
pub fn remove_node(&mut self, node: NodeIndex<Ix>) -> Option<N> {
self.graph.remove_node(node)
}
/// Remove an edge and return its weight, or `None` if it didn't exist.
///
/// Computes in **O(e')** time, where **e'** is the size of four particular edge lists, for the
/// nodes of **e** and the nodes of another affected edge.
pub fn remove_edge(&mut self, e: EdgeIndex<Ix>) -> Option<E> {
self.graph.remove_edge(e)
}
/// A **Walker** type that may be used to step through the parents of the given child node.
///
/// Unlike iterator types, **Walker**s do not require borrowing the internal **Graph**. This
/// makes them useful for traversing the **Graph** while still being able to mutably borrow it.
///
/// If you require an iterator, use one of the **Walker** methods for converting this
/// **Walker** into a similarly behaving **Iterator** type.
///
/// See the [**Walker**](Walker) trait for more useful methods.
pub fn parents(&self, child: NodeIndex<Ix>) -> Parents<N, E, Ix> {
let walk_edges = self.graph.neighbors_directed(child, pg::Incoming).detach();
Parents {
walk_edges: walk_edges,
_node: PhantomData,
_edge: PhantomData,
}
}
/// A "walker" object that may be used to step through the children of the given parent node.
///
/// Unlike iterator types, **Walker**s do not require borrowing the internal **Graph**. This
/// makes them useful for traversing the **Graph** while still being able to mutably borrow it.
///
/// If you require an iterator, use one of the **Walker** methods for converting this
/// **Walker** into a similarly behaving **Iterator** type.
///
/// See the [**Walker**](Walker) trait for more useful methods.
pub fn children(&self, parent: NodeIndex<Ix>) -> Children<N, E, Ix> {
let walk_edges = self.graph.neighbors_directed(parent, pg::Outgoing).detach();
Children {
walk_edges: walk_edges,
_node: PhantomData,
_edge: PhantomData,
}
}
/// A **Walker** type that recursively walks the **Dag** using the given `recursive_fn`.
///
/// See the [**Walker**](Walker) trait for more useful methods.
pub fn recursive_walk<F>(
&self,
start: NodeIndex<Ix>,
recursive_fn: F,
) -> RecursiveWalk<N, E, Ix, F>
where
F: FnMut(&Self, NodeIndex<Ix>) -> Option<(EdgeIndex<Ix>, NodeIndex<Ix>)>,
{
walker::Recursive::new(start, recursive_fn)
}
}
/// After adding a new edge to the graph, we use this function immediately after to check whether
/// or not we need to check for a cycle.
///
/// If our parent *a* has no parents or our child *b* has no children, or if there was already an
/// edge connecting *a* to *b*, we know that adding this edge has not caused the graph to cycle.
fn must_check_for_cycle<N, E, Ix>(dag: &Dag<N, E, Ix>, a: NodeIndex<Ix>, b: NodeIndex<Ix>) -> bool
where
Ix: IndexType,
{
if a == b {
return true;
}
dag.parents(a).walk_next(dag).is_some()
&& dag.children(b).walk_next(dag).is_some()
&& dag.find_edge(a, b).is_none()
}
// Dag implementations.
impl<N, E, Ix> Into<DiGraph<N, E, Ix>> for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn into(self) -> DiGraph<N, E, Ix> {
self.into_graph()
}
}
impl<N, E, Ix> Default for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn default() -> Self {
Dag::new()
}
}
impl<N, E, Ix> GraphBase for Dag<N, E, Ix>
where
Ix: IndexType,
{
type NodeId = NodeIndex<Ix>;
type EdgeId = EdgeIndex<Ix>;
}
impl<N, E, Ix> NodeCount for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn node_count(&self) -> usize {
Dag::node_count(self)
}
}
impl<N, E, Ix> GraphProp for Dag<N, E, Ix>
where
Ix: IndexType,
{
type EdgeType = pg::Directed;
fn is_directed(&self) -> bool {
true
}
}
impl<N, E, Ix> pg::visit::Visitable for Dag<N, E, Ix>
where
Ix: IndexType,
{
type Map = <DiGraph<N, E, Ix> as Visitable>::Map;
fn visit_map(&self) -> Self::Map {
self.graph.visit_map()
}
fn reset_map(&self, map: &mut Self::Map) {
self.graph.reset_map(map)
}
}
impl<N, E, Ix> pg::visit::Data for Dag<N, E, Ix>
where
Ix: IndexType,
{
type NodeWeight = N;
type EdgeWeight = E;
}
impl<N, E, Ix> pg::data::DataMap for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn node_weight(&self, id: Self::NodeId) -> Option<&Self::NodeWeight> {
self.graph.node_weight(id)
}
fn edge_weight(&self, id: Self::EdgeId) -> Option<&Self::EdgeWeight> {
self.graph.edge_weight(id)
}
}
impl<N, E, Ix> pg::data::DataMapMut for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn node_weight_mut(&mut self, id: Self::NodeId) -> Option<&mut Self::NodeWeight> {
self.graph.node_weight_mut(id)
}
fn edge_weight_mut(&mut self, id: Self::EdgeId) -> Option<&mut Self::EdgeWeight> {
self.graph.edge_weight_mut(id)
}
}
impl<'a, N, E, Ix> IntoNeighbors for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type Neighbors = pg::graph::Neighbors<'a, E, Ix>;
fn neighbors(self, n: NodeIndex<Ix>) -> Self::Neighbors {
self.graph.neighbors(n)
}
}
impl<'a, N, E, Ix> IntoNeighborsDirected for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type NeighborsDirected = pg::graph::Neighbors<'a, E, Ix>;
fn neighbors_directed(self, n: NodeIndex<Ix>, d: pg::Direction) -> Self::Neighbors {
self.graph.neighbors_directed(n, d)
}
}
impl<'a, N, E, Ix> IntoEdgeReferences for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type EdgeRef = pg::graph::EdgeReference<'a, E, Ix>;
type EdgeReferences = pg::graph::EdgeReferences<'a, E, Ix>;
fn edge_references(self) -> Self::EdgeReferences {
self.graph.edge_references()
}
}
impl<'a, N, E, Ix> IntoEdges for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type Edges = Edges<'a, E, Ix>;
fn edges(self, a: Self::NodeId) -> Self::Edges {
self.graph.edges(a)
}
}
impl<'a, N, E, Ix> IntoEdgesDirected for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type EdgesDirected = Edges<'a, E, Ix>;
fn edges_directed(self, a: Self::NodeId, dir: pg::Direction) -> Self::EdgesDirected {
self.graph.edges_directed(a, dir)
}
}
impl<'a, N, E, Ix> IntoNodeIdentifiers for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type NodeIdentifiers = pg::graph::NodeIndices<Ix>;
fn node_identifiers(self) -> Self::NodeIdentifiers {
self.graph.node_identifiers()
}
}
impl<'a, N, E, Ix> IntoNodeReferences for &'a Dag<N, E, Ix>
where
Ix: IndexType,
{
type NodeRef = (NodeIndex<Ix>, &'a N);
type NodeReferences = pg::graph::NodeReferences<'a, N, Ix>;
fn node_references(self) -> Self::NodeReferences {
self.graph.node_references()
}
}
impl<N, E, Ix> NodeIndexable for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn node_bound(&self) -> usize {
self.graph.node_bound()
}
fn to_index(&self, ix: NodeIndex<Ix>) -> usize {
self.graph.to_index(ix)
}
fn from_index(&self, ix: usize) -> Self::NodeId {
self.graph.from_index(ix)
}
}
impl<N, E, Ix> NodeCompactIndexable for Dag<N, E, Ix> where Ix: IndexType {}
impl<N, E, Ix> Index<NodeIndex<Ix>> for Dag<N, E, Ix>
where
Ix: IndexType,
{
type Output = N;
fn index(&self, index: NodeIndex<Ix>) -> &N {
&self.graph[index]
}
}
impl<N, E, Ix> IndexMut<NodeIndex<Ix>> for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn index_mut(&mut self, index: NodeIndex<Ix>) -> &mut N {
&mut self.graph[index]
}
}
impl<N, E, Ix> Index<EdgeIndex<Ix>> for Dag<N, E, Ix>
where
Ix: IndexType,
{
type Output = E;
fn index(&self, index: EdgeIndex<Ix>) -> &E {
&self.graph[index]
}
}
impl<N, E, Ix> IndexMut<EdgeIndex<Ix>> for Dag<N, E, Ix>
where
Ix: IndexType,
{
fn index_mut(&mut self, index: EdgeIndex<Ix>) -> &mut E {
&mut self.graph[index]
}
}
impl<N, E, Ix> GetAdjacencyMatrix for Dag<N, E, Ix>
where
Ix: IndexType,
{
type AdjMatrix = <DiGraph<N, E, Ix> as GetAdjacencyMatrix>::AdjMatrix;
fn adjacency_matrix(&self) -> Self::AdjMatrix {
self.graph.adjacency_matrix()
}
fn is_adjacent(&self, matrix: &Self::AdjMatrix, a: NodeIndex<Ix>, b: NodeIndex<Ix>) -> bool {
self.graph.is_adjacent(matrix, a, b)
}
}
impl<'a, N, E, Ix> Walker<&'a Dag<N, E, Ix>> for Children<N, E, Ix>
where
Ix: IndexType,
{
type Item = (EdgeIndex<Ix>, NodeIndex<Ix>);
#[inline]
fn walk_next(&mut self, dag: &'a Dag<N, E, Ix>) -> Option<Self::Item> {
self.walk_edges.next(&dag.graph)
}
}
impl<'a, N, E, Ix> Walker<&'a Dag<N, E, Ix>> for Parents<N, E, Ix>
where
Ix: IndexType,
{
type Item = (EdgeIndex<Ix>, NodeIndex<Ix>);
#[inline]
fn walk_next(&mut self, dag: &'a Dag<N, E, Ix>) -> Option<Self::Item> {
self.walk_edges.next(&dag.graph)
}
}
impl<Ix> Iterator for EdgeIndices<Ix>
where
Ix: IndexType,
{
type Item = EdgeIndex<Ix>;
fn next(&mut self) -> Option<EdgeIndex<Ix>> {
self.indices.next().map(|i| EdgeIndex::new(i))
}
}
impl<E> std::fmt::Debug for WouldCycle<E> {
fn fmt(&self, f: &mut std::fmt::Formatter) -> std::fmt::Result {
writeln!(f, "WouldCycle")
}
}
impl<E> std::fmt::Display for WouldCycle<E> {
fn fmt(&self, f: &mut std::fmt::Formatter) -> Result<(), std::fmt::Error> {
writeln!(f, "{:?}", self)
}
}
impl<E> std::error::Error for WouldCycle<E> {
fn description(&self) -> &str {
"Adding this edge would have created a cycle"
}
}