fixed sqlstore

go-foreman · May 29, 2021 · a74af46 · a74af46
1 parent aeff8f5
commit a74af46
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/saga/sagainst.go b/saga/sagainst.go
@@ -144,10 +144,8 @@ func (s *sagaInstance) update() {
 
 func (s *sagaInstance) AddHistoryEvent(ev message.Object, opts ...AddEvOpt) {
 	attachOpts := &addEvOpts{}
-	if len(opts) > 0 {
-		for _, o := range opts {
-			o(attachOpts)
-		}
+	for _, o := range opts {
+		o(attachOpts)
 	}
 
 	historyEv := HistoryEvent{

diff --git a/saga/sqlstore.go b/saga/sqlstore.go
@@ -142,7 +142,7 @@ func (s sqlStore) Update(ctx context.Context, sagaInstance Instance) error {
 
 	if len(eventsIDs) < len(sagaInstance.HistoryEvents()) {
 		for _, ev := range sagaInstance.HistoryEvents() {
-			if _, exists := eventsIDs[ev.UID]; !exists {
+			if _, exists := eventsIDs[ev.UID]; exists {
 				continue
 			}