gemma: pkg/imports/config.go annotate

annotate pkg/imports/config.go @ 1995:59055c8301df

Move import queue to its own database namespace Authorisation of the import queue has to be handled differently from the waterway-related data in the waterway schema. This is easier to handle, if both are in their own schema/namespace.

author	Tom Gottfried <tom@intevation.de>
date	Thu, 24 Jan 2019 12:56:31 +0100
parents	807569b08513
children	25967829cf00

rev	line source
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	1 // This is Free Software under GNU Affero General Public License v >= 3.0
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	2 // without warranty, see README.md and license for details.
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	3 //
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	4 // SPDX-License-Identifier: AGPL-3.0-or-later
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	5 // License-Filename: LICENSES/AGPL-3.0.txt
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	6 //
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	7 // Copyright (C) 2018 by via donau
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	8 // – Österreichische Wasserstraßen-Gesellschaft mbH
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	9 // Software engineering by Intevation GmbH
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	10 //
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	11 // Author(s):
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	12 // * Sascha L. Teichmann <sascha.teichmann@intevation.de>
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	13
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	14 package imports
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	15
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	16 import (
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	17 "context"
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	18 "database/sql"
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	19 "encoding/json"
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	20 "fmt"
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	21
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	22 "github.com/robfig/cron"
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	23
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	24 "gemma.intevation.de/gemma/pkg/auth"
1708 49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	25 "gemma.intevation.de/gemma/pkg/common"
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	26 )
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	27
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	28 type (
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	29 // CronSpec is a string containing a cron line.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	30 CronSpec string
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	31
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	32 // ImportKind is a string which has to be one
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	33 // of the registered import types.
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	34 ImportKind string
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	35
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	36 // Config is JSON serialized form of a import configuration.
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	37 Config struct {
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	38 // Kind is the import type.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	39 Kind ImportKind `json:"kind"`
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	40 // SendEMail indicates if a mail should be be send
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	41 // when the import was changed to states
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	42 // 'pending' or 'failed'.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	43 SendEMail bool `json:"send-email"`
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	44 // Cron is the cron schedule
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	45 // of this configuration if this value is not
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	46 // nil. If nil the import is not scheduled.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	47 Cron *CronSpec `json:"cron"`
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	48 // URL is an optional URL used by the import.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	49 URL *string `json:"url"`
1702 49b89575ab31 Import configuration: [WIP] Added table for extra configuration attributes. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1696 diff changeset	50 // Attributes are optional key/value pairs for a configuration.
1708 49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	51 Attributes common.Attributes `json:"attributes,omitempty"`
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	52 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	53
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	54 // IDConfig is the same as Config with an ID.
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	55 // Mainly used for server delivered configurations.
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	56 IDConfig struct {
1708 49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	57 ID int64 `json:"id"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	58 User string `json:"user"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	59 Kind ImportKind `json:"kind"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	60 SendEMail bool `json:"send-email"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	61 Cron *CronSpec `json:"cron,omitempty"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	62 URL *string `json:"url,omitempty"`
49e047c2106e Imports: Made imports re-runnable if they fail. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1705 diff changeset	63 Attributes common.Attributes `json:"attributes,omitempty"`
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	64 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	65 )
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	66
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	67 // UnmarshalJSON checks if the incoming string
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	68 // is a registered import type.
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	69 func (ik *ImportKind) UnmarshalJSON(data []byte) error {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	70 var s string
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	71 if err := json.Unmarshal(data, &s); err != nil {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	72 return err
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	73 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	74
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	75 if !HasImportKindName(s) {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	76 return fmt.Errorf("Unknown kind '%s'", s)
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	77 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	78
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	79 *ik = ImportKind(s)
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	80
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	81 return nil
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	82 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	83
1696 ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	84 // UnmarshalJSON checks if the incoming string is
ad5e1cddaa09 Imports: Resolved the remaining golint issues with this package. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1653 diff changeset	85 // a valid cron line.
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	86 func (cs *CronSpec) UnmarshalJSON(data []byte) error {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	87 var spec string
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	88 if err := json.Unmarshal(data, &spec); err != nil {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	89 return err
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	90 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	91 if _, err := cron.Parse(spec); err != nil {
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	92 return err
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	93 }
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	94 *cs = CronSpec(spec)
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	95
1627 b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	96 return nil
b10aa02d7819 Refactored: Moved REST /api/imports/scheduler to /api/imports/config Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: diff changeset	97 }
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	98
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	99 const (
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	100 configUser = "sys_admin"
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	101
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	102 loadConfigSQL = `
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	103 SELECT
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	104 username,
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	105 kind,
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	106 send_email,
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	107 cron,
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	108 url
1995 59055c8301df Move import queue to its own database namespace Tom Gottfried <tom@intevation.de> parents: 1754 diff changeset	109 FROM import.import_configuration
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	110 WHERE id = $1`
1702 49b89575ab31 Import configuration: [WIP] Added table for extra configuration attributes. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1696 diff changeset	111
49b89575ab31 Import configuration: [WIP] Added table for extra configuration attributes. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1696 diff changeset	112 loadConfigAttributesSQL = `
49b89575ab31 Import configuration: [WIP] Added table for extra configuration attributes. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1696 diff changeset	113 SELECT k, v
1995 59055c8301df Move import queue to its own database namespace Tom Gottfried <tom@intevation.de> parents: 1754 diff changeset	114 FROM import.import_configuration_attributes
1702 49b89575ab31 Import configuration: [WIP] Added table for extra configuration attributes. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1696 diff changeset	115 WHERE import_configuration_id = $1`
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	116 )
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	117
1739 61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	118 // LoadIDConfigContext loads an import configuration from database.
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	119 func LoadIDConfigContext(ctx context.Context, conn sql.Conn, id int64) (IDConfig, error) {
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	120
1739 61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	121 cfg := &IDConfig{ID: id}
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	122 var kind ImportKind
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	123 var cron, url sql.NullString
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	124 err := conn.QueryRowContext(ctx, loadConfigSQL, id).Scan(
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	125 &cfg.User,
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	126 &kind,
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	127 &cfg.SendEMail,
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	128 &cron,
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	129 &url,
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	130 )
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	131
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	132 switch {
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	133 case err == sql.ErrNoRows:
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	134 return nil, nil
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	135 case err != nil:
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	136 return nil, err
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	137 }
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	138
1739 61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	139 cfg.Kind = ImportKind(kind)
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	140 if cron.Valid {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	141 c := CronSpec(cron.String)
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	142 cfg.Cron = &c
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	143 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	144 if url.Valid {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	145 cfg.URL = &url.String
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	146 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	147 // load the extra attributes.
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	148 rows, err := conn.QueryContext(ctx, loadConfigAttributesSQL, id)
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	149 if err != nil {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	150 return nil, err
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	151 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	152 defer rows.Close()
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	153 var attributes common.Attributes
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	154 for rows.Next() {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	155 var k, v string
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	156 if err = rows.Scan(&k, &v); err != nil {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	157 return nil, err
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	158 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	159 if attributes == nil {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	160 attributes = common.Attributes{}
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	161 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	162 attributes[k] = v
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	163 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	164 if err = rows.Err(); err != nil {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	165 return nil, err
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	166 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	167 if len(attributes) > 0 {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	168 cfg.Attributes = attributes
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	169 }
1653 06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	170 return cfg, nil
06f08458d666 Scheduled imports: Load configuration from database when triggered by cron. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1627 diff changeset	171 }
1739 61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	172
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	173 func loadIDConfig(id int64) (*IDConfig, error) {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	174 return loadIDConfigContext(context.Background(), id)
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	175 }
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	176
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	177 func loadIDConfigContext(ctx context.Context, id int64) (*IDConfig, error) {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	178 var cfg *IDConfig
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	179 err := auth.RunAs(ctx, configUser, func(conn *sql.Conn) error {
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	180 var err error
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	181 cfg, err = LoadIDConfigContext(ctx, conn, id)
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	182 return err
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	183 })
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	184 return cfg, err
61fa62f01f20 Configured imports: When GET an import deliver the extra attributes, too. Sascha L. Teichmann <sascha.teichmann@intevation.de> parents: 1708 diff changeset	185 }

Mercurial > gemma

annotate pkg/imports/config.go @ 1995:59055c8301df