fix: update jobs (sql if job exists) #18

database.go

 package jobqueue
 
 import (
+	"errors"
 	"gorm.io/gorm"
 	"sync"
 )
@@ -100,14 +101,23 @@ func (s *DBSaver) Start() error {
 					memLogs := permJob.Logs
 					permJob.Logs = nil
 
-					result := tx.FirstOrCreate(&permJob, map[string]interface{}{"id": permJob.GetID()}).
-						Assign(permJob)
-
-					err := result.Error
-
-					// Find or create JobMeta
-					if err != nil {
-						s.logError("Error while saving job", "error", err)
+					var existingJob GenericJob
+					result := tx.Where("id = ?", permJob.GetID()).First(&existingJob)
+
+					if result.Error != nil {
+						if errors.Is(result.Error, gorm.ErrRecordNotFound) {
+							err := tx.Create(&permJob).Error
+							if err != nil {
+								return err
+							}
+						} else {
+							return result.Error
+						}
+					} else {
+						err := tx.Model(&existingJob).Updates(permJob).Error
+						if err != nil {
+							return err
+						}
 					}
 
 					if result.RowsAffected == 0 {

persistence.go

@@ -265,8 +265,8 @@ func CreateJobAndSchedulerFromPersistence(jobImport JobPersistence, manager *Man
 		}
 
 	case "delay":
-		scheduler = &DelayScheduler{Delay: jobImport.Scheduler.Delay}
 
+		scheduler = &DelayScheduler{Delay: jobImport.Scheduler.Delay}
 	case "event":
 		scheduler = &EventScheduler{Event: EventName(jobImport.Scheduler.Event)}