@@ -103,7 +103,7 @@ func NewFSM(ctx context.Context, deposit *Deposit, cfg *ManagerConfig,
103
103
104
104
if recoverStateMachine {
105
105
depoFsm .StateMachine = fsm .NewStateMachineWithState (
106
- depositStates , deposit .getState (),
106
+ depositStates , deposit .GetState (),
107
107
DefaultObserverSize ,
108
108
)
109
109
} else {
@@ -146,8 +146,8 @@ func (f *FSM) handleBlockNotification(currentHeight uint32) error {
146
146
147
147
// If the deposit is expired but not yet sufficiently confirmed, we
148
148
// republish the expiry sweep transaction.
149
- if f .deposit .isExpired (currentHeight , params .Expiry ) {
150
- if f .deposit .isInState (WaitForExpirySweep ) {
149
+ if f .deposit .IsExpired (currentHeight , params .Expiry ) {
150
+ if f .deposit .IsInState (WaitForExpirySweep ) {
151
151
f .PublishDepositExpirySweepAction (nil )
152
152
} else {
153
153
go func () {
@@ -231,13 +231,13 @@ func (f *FSM) updateDeposit(notification fsm.Notification) {
231
231
notification .Event ,
232
232
)
233
233
234
- f .deposit .setState (notification .NextState )
234
+ f .deposit .SetState (notification .NextState )
235
235
236
236
// Don't update the deposit if we are in an initial state or if we
237
237
// are transitioning from an initial state to a failed state.
238
238
d := f .deposit
239
- if d .isInState (fsm .EmptyState ) || d .isInState (Deposited ) ||
240
- (notification .PreviousState == Deposited && d .isInState (
239
+ if d .IsInState (fsm .EmptyState ) || d .IsInState (Deposited ) ||
240
+ (notification .PreviousState == Deposited && d .IsInState (
241
241
Failed ,
242
242
)) {
243
243
0 commit comments