Skip to content

Commit c4b0acf

Browse files
committed
refactor: enhance coverage and refactor code
1 parent b056d5c commit c4b0acf

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

event_sourced_actor.go

+9-9
Original file line numberDiff line numberDiff line change
@@ -107,18 +107,18 @@ func (entity *eventSourcedActor) recoverFromSnapshot(ctx context.Context) error
107107
return fmt.Errorf("failed to recover the latest journal: %w", err)
108108
}
109109

110-
// we do have the latest state just recover from it
111-
if event != nil {
112-
currentState := entity.InitialState()
113-
if err := event.GetResultingState().UnmarshalTo(currentState); err != nil {
114-
return fmt.Errorf("failed unmarshal the latest state: %w", err)
115-
}
116-
entity.currentState = currentState
117-
entity.eventsCounter = event.GetSequenceNumber()
110+
if event == nil || event.GetResultingState() == nil {
111+
entity.currentState = entity.InitialState()
118112
return nil
119113
}
120114

121-
entity.currentState = entity.InitialState()
115+
currentState := entity.InitialState()
116+
if err := event.GetResultingState().UnmarshalTo(currentState); err != nil {
117+
return fmt.Errorf("failed to unmarshal the latest state: %w", err)
118+
}
119+
120+
entity.currentState = currentState
121+
entity.eventsCounter = event.GetSequenceNumber()
122122
return nil
123123
}
124124

0 commit comments

Comments
 (0)