@@ -169,7 +169,10 @@ pub async fn create_simulation(cli: &Cli) -> Result<Simulation, anyhow::Error> {
169
169
) )
170
170
} ;
171
171
172
- let validated_activities = validate_activities ( activity, & clients_info, get_node) . await ?;
172
+ let ( pk_node_map, alias_node_map) = add_node_to_maps ( & clients_info) . await ?;
173
+
174
+ let validated_activities =
175
+ validate_activities ( activity, pk_node_map, alias_node_map, get_node) . await ?;
173
176
let tasks = TaskTracker :: new ( ) ;
174
177
175
178
Ok ( Simulation :: new ( cfg, clients, validated_activities, tasks) )
@@ -251,11 +254,11 @@ async fn add_node_to_maps(
251
254
/// have been configured.
252
255
async fn validate_activities (
253
256
activity : Vec < ActivityParser > ,
254
- nodes : & HashMap < PublicKey , NodeInfo > ,
257
+ pk_node_map : HashMap < PublicKey , NodeInfo > ,
258
+ alias_node_map : HashMap < String , NodeInfo > ,
255
259
get_node_info : impl AsyncFn ( & PublicKey ) -> Result < NodeInfo , LightningError > ,
256
260
) -> Result < Vec < ActivityDefinition > , LightningError > {
257
261
let mut validated_activities = vec ! [ ] ;
258
- let ( pk_node_map, alias_node_map) = add_node_to_maps ( nodes) . await ?;
259
262
260
263
// Make all the activities identifiable by PK internally
261
264
for act in activity. into_iter ( ) {
0 commit comments