Mercurial > gemma
view pkg/controllers/manualimports.go @ 5123:eeb45e3e0a5a queued-stage-done
Added mechanism to have sync import jobs on import queue.
Review jobs are now sync with a controller waiting for 20 secs before returning.
If all reviews return earlier the controller extists earlier, too.
If one or more decisions took longer they are run in background till they are
decided and the the controller returns a error message for these imports
that the process is st still running.
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Thu, 26 Mar 2020 22:24:45 +0100 |
parents | 4394daeea96a |
children | 5f47eeea988d |
line wrap: on
line source
// This is Free Software under GNU Affero General Public License v >= 3.0 // without warranty, see README.md and license for details. // // SPDX-License-Identifier: AGPL-3.0-or-later // License-Filename: LICENSES/AGPL-3.0.txt // // Copyright (C) 2018 by via donau // – Österreichische Wasserstraßen-Gesellschaft mbH // Software engineering by Intevation GmbH // // Author(s): // * Sascha L. Teichmann <sascha.teichmann@intevation.de> // * Raimund Renkert <raimund.renkert@intevation.de> package controllers import ( "log" "net/http" "time" "github.com/gorilla/mux" "gemma.intevation.de/gemma/pkg/auth" "gemma.intevation.de/gemma/pkg/common" "gemma.intevation.de/gemma/pkg/imports" "gemma.intevation.de/gemma/pkg/models" mw "gemma.intevation.de/gemma/pkg/middleware" ) func importModel(req *http.Request) interface{} { kind := mux.Vars(req)["kind"] ctor := imports.ImportModelForJobKind(imports.JobKind(kind)) if ctor == nil { log.Printf("error: Unknown job kind '%s'.\n", kind) panic(http.ErrAbortHandler) } return ctor() } func manualImport(req *http.Request) (jr mw.JSONResult, err error) { kind := imports.JobKind(mux.Vars(req)["kind"]) input := mw.JSONInput(req) what := imports.ConvertToInternal(kind, input) if what == nil { err = mw.JSONError{ Code: http.StatusInternalServerError, Message: "Unable to convert import models", } return } var serialized string if serialized, err = common.ToJSONString(what); err != nil { return } var ( due time.Time trys *int waitRetry *time.Duration email bool ) if qctg, ok := input.(models.QueueConfigurationGetter); ok { qct := qctg.GetQueueConfiguration() if qct.Due != nil { due = qct.Due.Time } trys = qct.Trys if qct.WaitRetry != nil { waitRetry = &qct.WaitRetry.Duration } } if etg, ok := input.(models.EmailTypeGetter); ok { email = etg.GetEmailType().Email } session, _ := auth.GetSession(req) var jobID int64 if jobID, err = imports.AddJob( kind, due, trys, waitRetry, session.User, email, serialized, ); err != nil { return } log.Printf("info: added import #%d to queue\n", jobID) result := struct { ID int64 `json:"id"` }{ ID: jobID, } jr = mw.JSONResult{ Code: http.StatusCreated, Result: &result, } return }