Browse Source

En cours de développement

master
losyme 2 months ago
parent
commit
aacc9af2bd
  1. 17
      internal/model/storage.go

17
internal/model/storage.go

@ -7,6 +7,7 @@
package model
import (
"errors"
"fmt"
"forge.chapril.org/dune/jw"
@ -37,6 +38,10 @@ func (m *Model) logJob(job *jw.Job) {
func (m *Model) storageInsertJob(job *jw.Job) (bool, error) {
done, err := m.Storage.InsertJob(job)
if err != nil {
if errors.Is(err, jw.ErrStorage) {
return false, err
}
// AFINIR
return false, err
}
@ -53,6 +58,10 @@ func (m *Model) storageInsertJob(job *jw.Job) (bool, error) {
func (m *Model) storageUpdateJob(job *jw.Job) error {
if err := m.Storage.UpdateJob(job); err != nil {
if errors.Is(err, jw.ErrStorage) {
return err
}
// AFINIR
return err
}
@ -79,6 +88,10 @@ func (m *Model) logWorkflow(wf *jw.Workflow) {
func (m *Model) storageInsertWorkflow(wf *jw.Workflow, job *jw.Job) error {
// Cette insertion doit être faite dans une transaction.
if err := m.Storage.InsertWorkflow(wf, job); err != nil {
if errors.Is(err, jw.ErrStorage) {
return err
}
// AFINIR
return err
}
@ -92,6 +105,10 @@ func (m *Model) storageInsertWorkflow(wf *jw.Workflow, job *jw.Job) error {
func (m *Model) storageUpdateWorkflow(wf *jw.Workflow, job, nextJob *jw.Job) error {
// Cette mise à jour doit être faite dans une transaction.
if err := m.Storage.UpdateWorkflow(wf, job, nextJob); err != nil {
if errors.Is(err, jw.ErrStorage) {
return err
}
// AFINIR
return err
}

Loading…
Cancel
Save