Merge pull request #291 from chuksys/report-pathfinding-outcomes

Report Pathfinding Outcomes to Scorer in SimNode

Author: carlaKC

sim-cli/src/parsing.rs

@@ -262,7 +262,7 @@ pub async fn create_simulation_with_network(
     (
         Simulation<SimulationClock>,
         Vec<ActivityDefinition>,
-        HashMap<PublicKey, Arc<Mutex<SimNode<SimGraph>>>>,
+        HashMap<PublicKey, Arc<Mutex<SimNode<SimGraph, SimulationClock>>>>,
     ),
     anyhow::Error,
 > {
@@ -313,7 +313,7 @@ pub async fn create_simulation_with_network(
     // custom actions on the simulated network. For the nodes we'll pass our simulation, cast them
     // to a dyn trait and exclude any nodes that shouldn't be included in random activity
     // generation.
-    let nodes = ln_node_from_graph(simulation_graph.clone(), routing_graph).await;
+    let nodes = ln_node_from_graph(simulation_graph.clone(), routing_graph, clock.clone()).await?;
     let mut nodes_dyn: HashMap<_, Arc<Mutex<dyn LightningNode>>> = nodes
         .iter()
         .map(|(pk, node)| (*pk, Arc::clone(node) as Arc<Mutex<dyn LightningNode>>))

simln-lib/src/lib.rs

@@ -264,6 +264,9 @@ pub enum LightningError {
     /// Error that occurred while getting graph.
     #[error("Get graph error: {0}")]
     GetGraphError(String),
+    /// Error that occured when getting clock info.
+    #[error("SystemTime conversion error: {0}")]
+    SystemTimeConversionError(#[from] SystemTimeError),
 }
 
 /// Information about a Lightning Network node.
@@ -431,7 +434,7 @@ impl Display for PaymentResult {
 }
 
 /// Represents all possible outcomes of a Lightning Network payment attempt.
-#[derive(Debug, Clone, Serialize, Deserialize)]
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
 pub enum PaymentOutcome {
     /// Payment completed successfully, reaching its intended recipient.
     Success,
@@ -457,6 +460,8 @@ pub enum PaymentOutcome {
     NotDispatched,
     /// The payment was dispatched but its final status could not be determined.
     TrackPaymentFailed,
+    /// The payment failed at the provided index in the path.
+    IndexFailure(usize),
 }
 
 /// Describes a payment from a source node to a destination node.