This repository was archived by the owner on Mar 11, 2025. It is now read-only.
File tree 3 files changed +5
-3
lines changed
chains/evm/listener/handlers
3 files changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -72,7 +72,7 @@ func NewRotateHandler(
72
72
// period and rotates the committee if it is
73
73
func (h * RotateHandler ) HandleEvents (checkpoint * apiv1.Finality ) error {
74
74
currentPeriod := uint64 (checkpoint .Finalized .Epoch ) / h .committeePeriodLength
75
- if currentPeriod < h .latestPeriod .Uint64 () {
75
+ if currentPeriod <= h .latestPeriod .Uint64 () {
76
76
return nil
77
77
}
78
78
@@ -94,7 +94,7 @@ func (h *RotateHandler) HandleEvents(checkpoint *apiv1.Finality) error {
94
94
Spec : args .Spec ,
95
95
}
96
96
97
- log .Info ().Uint8 ("domainID" , h .domainID ).Uint64 ("period" , targetPeriod .Uint64 ()).Msgf ("Rotating committee" )
97
+ log .Info ().Uint8 ("domainID" , h .domainID ).Uint64 ("period" , targetPeriod .Uint64 ()+ 1 ).Msgf ("Rotating committee" )
98
98
99
99
rotateProof , err := h .prover .RotateProof (args )
100
100
if err != nil {
Original file line number Diff line number Diff line change @@ -91,7 +91,7 @@ func (s *RotateHandlerTestSuite) Test_HandleEvents_ValidPeriod() {
91
91
92
92
err := s .handler .HandleEvents (& apiv1.Finality {
93
93
Finalized : & phase0.Checkpoint {
94
- Epoch : phase0 .Epoch (768 ),
94
+ Epoch : phase0 .Epoch (1024 ),
95
95
},
96
96
})
97
97
s .Nil (err )
Original file line number Diff line number Diff line change @@ -81,6 +81,8 @@ func (h *StepEventHandler) HandleEvents(checkpoint *apiv1.Finality) error {
81
81
return err
82
82
}
83
83
84
+ log .Info ().Uint8 ("domainID" , h .domainID ).Uint64 ("slot" , args .Update .FinalizedHeader .Header .Slot ).Msgf ("Executing sync step" )
85
+
84
86
proof , err := h .prover .StepProof (args )
85
87
if err != nil {
86
88
return err
You can’t perform that action at this time.
0 commit comments