Skip to content

Commit 2bc828b

Browse files
CaglankaanCaglankaan
committed
chore(movement-hubble): fixed comments
Signed-off-by: Kaan Caglan <[email protected]>
1 parent a64d05f commit 2bc828b

File tree

1 file changed

+29
-29
lines changed
  • voyager/plugins/event-source/movement/src

1 file changed

+29
-29
lines changed

‎voyager/plugins/event-source/movement/src/main.rs

+29-29
Original file line numberDiff line numberDiff line change
@@ -368,7 +368,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
368368
Ordering::Less => {
369369
let next_height = (latest_height - height).clamp(1, 10) + height;
370370
conc(
371-
(height + 1..next_height)
371+
((height + 1)..next_height)
372372
.map(|height| {
373373
call(PluginMessage::new(
374374
self.plugin_name(),
@@ -404,58 +404,58 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
404404
}) => {
405405
let (full_event, client_id): (FullEvent, u32) = match event {
406406
events::IbcEvent::CreateClient(event) => (
407-
(CreateClient {
407+
CreateClient {
408408
client_id: event.client_id,
409409
client_type: ClientType::new(event.client_type),
410-
})
410+
}
411411
.into(),
412412
event.client_id,
413413
),
414414
events::IbcEvent::UpdateClient(event) => (
415-
(UpdateClient {
415+
UpdateClient {
416416
client_id: event.client_id,
417417
client_type: ClientType::new(event.client_type),
418418
height: event.counterparty_height,
419-
})
419+
}
420420
.into(),
421421
event.client_id,
422422
),
423423
events::IbcEvent::ConnectionOpenInit(event) => (
424-
(ConnectionOpenInit {
424+
ConnectionOpenInit {
425425
client_id: event.client_id,
426426
connection_id: event.connection_id,
427427
counterparty_client_id: event.counterparty_client_id,
428-
})
428+
}
429429
.into(),
430430
event.client_id,
431431
),
432432
events::IbcEvent::ConnectionOpenTry(event) => (
433-
(ConnectionOpenTry {
433+
ConnectionOpenTry {
434434
client_id: event.client_id,
435435
connection_id: event.connection_id,
436436
counterparty_client_id: event.counterparty_client_id,
437437
counterparty_connection_id: event.counterparty_connection_id,
438-
})
438+
}
439439
.into(),
440440
event.client_id,
441441
),
442442
events::IbcEvent::ConnectionOpenAck(event) => (
443-
(ConnectionOpenAck {
443+
ConnectionOpenAck {
444444
client_id: event.client_id,
445445
connection_id: event.connection_id,
446446
counterparty_client_id: event.counterparty_client_id,
447447
counterparty_connection_id: event.counterparty_connection_id,
448-
})
448+
}
449449
.into(),
450450
event.client_id,
451451
),
452452
events::IbcEvent::ConnectionOpenConfirm(event) => (
453-
(ConnectionOpenConfirm {
453+
ConnectionOpenConfirm {
454454
client_id: event.client_id,
455455
connection_id: event.connection_id,
456456
counterparty_client_id: event.counterparty_client_id,
457457
counterparty_connection_id: event.counterparty_connection_id,
458-
})
458+
}
459459
.into(),
460460
event.client_id,
461461
),
@@ -476,13 +476,13 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
476476
let client_id = connection.client_id;
477477

478478
(
479-
(ChannelOpenInit {
479+
ChannelOpenInit {
480480
port_id: event.port_id.parse().unwrap(),
481481
channel_id: event.channel_id,
482482
counterparty_port_id: event.counterparty_port_id.into(),
483483
connection,
484484
version: event.version,
485-
})
485+
}
486486
.into(),
487487
client_id,
488488
)
@@ -505,14 +505,14 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
505505
let client_id = connection.client_id;
506506

507507
(
508-
(ChannelOpenTry {
508+
ChannelOpenTry {
509509
port_id: event.port_id.parse().unwrap(),
510510
channel_id: event.channel_id,
511511
counterparty_port_id: event.counterparty_port_id.into(),
512512
counterparty_channel_id: event.counterparty_channel_id,
513513
connection,
514514
version: event.version,
515-
})
515+
}
516516
.into(),
517517
client_id,
518518
)
@@ -545,14 +545,14 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
545545
let client_id = connection.client_id;
546546

547547
(
548-
(ChannelOpenAck {
548+
ChannelOpenAck {
549549
port_id: event.port_id.parse().unwrap(),
550550
channel_id: event.channel_id,
551551
counterparty_port_id: event.counterparty_port_id.into(),
552552
counterparty_channel_id: event.counterparty_channel_id,
553553
connection,
554554
version: channel.version,
555-
})
555+
}
556556
.into(),
557557
client_id,
558558
)
@@ -585,14 +585,14 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
585585
let client_id = connection.client_id;
586586

587587
(
588-
(ChannelOpenConfirm {
588+
ChannelOpenConfirm {
589589
port_id: event.port_id.parse().unwrap(),
590590
channel_id: event.channel_id,
591591
counterparty_port_id: event.counterparty_port_id.into(),
592592
counterparty_channel_id: event.counterparty_channel_id,
593593
connection,
594594
version: channel.version,
595-
})
595+
}
596596
.into(),
597597
client_id,
598598
)
@@ -614,7 +614,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
614614
let client_id = destination_channel.connection.client_id;
615615

616616
(
617-
(WriteAck {
617+
WriteAck {
618618
packet_data: event.packet.data.into(),
619619
acknowledgement: event.acknowledgement.into(),
620620
packet: PacketMetadata {
@@ -623,7 +623,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
623623
timeout_height: event.packet.timeout_height,
624624
timeout_timestamp: event.packet.timeout_timestamp,
625625
},
626-
})
626+
}
627627
.into(),
628628
client_id,
629629
)
@@ -645,7 +645,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
645645
let client_id = destination_channel.connection.client_id;
646646

647647
(
648-
(PacketRecv {
648+
PacketRecv {
649649
packet_data: event.packet.data.into(),
650650
packet: PacketMetadata {
651651
source_channel,
@@ -654,7 +654,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
654654
timeout_timestamp: event.packet.timeout_timestamp,
655655
},
656656
maker_msg: Default::default(),
657-
})
657+
}
658658
.into(),
659659
client_id,
660660
)
@@ -676,15 +676,15 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
676676
let client_id = source_channel.connection.client_id;
677677

678678
(
679-
(PacketSend {
679+
PacketSend {
680680
packet_data: event.data.into(),
681681
packet: PacketMetadata {
682682
source_channel,
683683
destination_channel,
684684
timeout_height: event.timeout_height,
685685
timeout_timestamp: event.timeout_timestamp,
686686
},
687-
})
687+
}
688688
.into(),
689689
client_id,
690690
)
@@ -706,7 +706,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
706706
let client_id = source_channel.connection.client_id;
707707

708708
(
709-
(PacketAck {
709+
PacketAck {
710710
packet_data: event.packet.data.into(),
711711
packet: PacketMetadata {
712712
source_channel,
@@ -715,7 +715,7 @@ impl PluginServer<ModuleCall, ModuleCallback> for Module {
715715
timeout_timestamp: event.packet.timeout_timestamp,
716716
},
717717
acknowledgement: event.acknowledgement.into(),
718-
})
718+
}
719719
.into(),
720720
client_id,
721721
)

0 commit comments

Comments
 (0)