Mercurial > gemma
diff pkg/models/scheduler.go @ 1582:dc727824183a
Started with REST API for scheduler.
author | Sascha L. Teichmann <sascha.teichmann@intevation.de> |
---|---|
date | Thu, 13 Dec 2018 18:08:17 +0100 |
parents | |
children | caedd9b176f2 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/pkg/models/scheduler.go Thu Dec 13 18:08:17 2018 +0100 @@ -0,0 +1,63 @@ +// 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> + +package models + +import ( + "encoding/json" + "fmt" + + "github.com/robfig/cron" + + "gemma.intevation.de/gemma/pkg/scheduler" +) + +type ( + CronSpec string + ImportKind string + + ImportConfig struct { + Kind ImportKind `json:"kind"` + Cron CronSpec `json:"cron"` + SendEMail bool `json:"send-email"` + AutoAccept bool `json:"auto-accept"` + URL *string `json:"url"` + } +) + +func (ik *ImportKind) UnmarshalJSON(data []byte) error { + var s string + if err := json.Unmarshal(data, &s); err != nil { + return err + } + + if !scheduler.HasAction(s) { + return fmt.Errorf("Unknown kind '%s'", s) + } + + *ik = ImportKind(s) + + return nil +} + +func (cs *CronSpec) UnmarshalJSON(data []byte) error { + var spec string + if err := json.Unmarshal(data, &spec); err != nil { + return err + } + if _, err := cron.Parse(spec); err != nil { + return err + } + *cs = CronSpec(spec) + return nil +}