75 lines
2.1 KiB
Rust
75 lines
2.1 KiB
Rust
mod graph;
|
|
mod model;
|
|
mod networkx_model;
|
|
mod runner;
|
|
mod spring_model;
|
|
mod utils;
|
|
|
|
use pyo3::exceptions;
|
|
use pyo3::{prelude::*, types::PyIterator};
|
|
|
|
#[pyfunction(
|
|
number_of_nodes,
|
|
edges,
|
|
"*",
|
|
iter = 500,
|
|
threads = 0,
|
|
model = "\"spring_model\""
|
|
)]
|
|
fn layout_from_edge_list(
|
|
number_of_nodes: usize,
|
|
edges: &PyAny,
|
|
iter: usize,
|
|
threads: usize,
|
|
model: &str,
|
|
) -> PyResult<Vec<(f32, f32)>> {
|
|
let model: Box<dyn model::ForceModel + Send + Sync> = match model {
|
|
"spring_model" => Box::new(spring_model::SimpleSpringModel::new(1.0)),
|
|
"networkx_model" => Box::new(networkx_model::NetworkXModel::new()),
|
|
_ => {
|
|
return Err(PyErr::new::<exceptions::PyValueError, _>(
|
|
"model must be either 'spring_model' or 'networkx_model'",
|
|
))
|
|
}
|
|
};
|
|
|
|
let mut edge_matrix = graph::new_edge_matrix(number_of_nodes);
|
|
match edges.extract::<&PyIterator>() {
|
|
Ok(iter) => {
|
|
iter.iter()?
|
|
.map(|edge| edge.and_then(PyAny::extract::<(usize, usize)>))
|
|
.for_each(|edge| {
|
|
if let Ok((u, v)) = edge {
|
|
graph::add_edge(&mut edge_matrix, u, v);
|
|
}
|
|
});
|
|
for edge in iter {
|
|
let edge = edge?;
|
|
let edge = edge.extract::<(usize, usize)>()?;
|
|
graph::add_edge(&mut edge_matrix, edge.0, edge.1);
|
|
}
|
|
}
|
|
Err(_) => match edges.extract::<Vec<(usize, usize)>>() {
|
|
Ok(edge) => {
|
|
for edge in edge {
|
|
graph::add_edge(&mut edge_matrix, edge.0, edge.1);
|
|
}
|
|
}
|
|
Err(_) => {
|
|
return Err(PyErr::new::<exceptions::PyTypeError, _>(
|
|
"Edges must be an iterable of (int, int)",
|
|
));
|
|
}
|
|
},
|
|
}
|
|
|
|
let r = runner::Runner::new(iter, threads);
|
|
Ok(r.layout(number_of_nodes, edge_matrix, model))
|
|
}
|
|
|
|
#[pymodule]
|
|
fn graph_force(_py: Python, m: &PyModule) -> PyResult<()> {
|
|
m.add_function(wrap_pyfunction!(layout_from_edge_list, m)?)?;
|
|
Ok(())
|
|
}
|