reuse code more

cyverse-de · Sep 23, 2024 · 83a5527 · 83a5527
1 parent ba17c1c
commit 83a5527
Showing 1 changed file with 4 additions and 8 deletions.
diff --git a/main.go b/main.go
@@ -480,14 +480,10 @@ func main() {
 			}
 
 			for _, j := range jl {
-				analysisRecordExists := vicedb.AnalysisRecordExists(ctx, j.ID)
-
-				if !analysisRecordExists {
-					if _, err = vicedb.AddNotifRecord(ctx, &j); err != nil {
-						log.Error(err)
-						span.End()
-						continue
-					}
+				if err = ensureNotifRecord(ctx, vicedb, j); err != nil {
+					log.Error(err)
+					span.End()
+					continue
 				}
 
 				var notifStatuses *NotifStatuses