58e2745838
Add a PUT method for `/api/v3/configuration/file`, which entirely replaces `flamenco-manager.yaml` with the received JSON payload. This will be used in the future to store configuration edited in the web frontend. Ref: #99426 Reviewed-on: https://projects.blender.org/studio/flamenco/pulls/104406
87 lines
2.2 KiB
Go
87 lines
2.2 KiB
Go
package config
|
|
|
|
// SPDX-License-Identifier: GPL-3.0-or-later
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"io/fs"
|
|
|
|
"github.com/rs/zerolog/log"
|
|
)
|
|
|
|
// Service provides access to Flamenco Manager configuration.
|
|
type Service struct {
|
|
config Conf
|
|
forceFirstRun bool
|
|
}
|
|
|
|
func NewService() *Service {
|
|
return &Service{
|
|
config: DefaultConfig(),
|
|
}
|
|
}
|
|
|
|
func (s *Service) ForceFirstRun() {
|
|
s.forceFirstRun = true
|
|
}
|
|
|
|
func (s *Service) Replace(config Conf) error {
|
|
if err := config.Overwrite(); err != nil {
|
|
return err
|
|
}
|
|
|
|
// Replace the in-memory config with the new one
|
|
s.config = config
|
|
log.Info().Str("filename", configFilename).Msg("in-memory configuration file replaced")
|
|
return nil
|
|
}
|
|
|
|
// Load parses the flamenco-manager.yaml file, and returns whether this is
|
|
// likely to be the first run or not.
|
|
func (s *Service) Load() (bool, error) {
|
|
config, err := getConf()
|
|
s.config = config
|
|
|
|
switch {
|
|
case errors.Is(err, fs.ErrNotExist):
|
|
// No configuration means first run.
|
|
return true, nil
|
|
case err != nil:
|
|
return false, fmt.Errorf("loading %s: %w", configFilename, err)
|
|
}
|
|
|
|
// No shared storage configured means first run.
|
|
return s.forceFirstRun || config.SharedStoragePath == "", nil
|
|
}
|
|
|
|
func (s *Service) Get() *Conf {
|
|
return &s.config
|
|
}
|
|
|
|
// Save writes the in-memory configuration to the config file.
|
|
func (s *Service) Save() error {
|
|
err := s.config.Write(configFilename)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// Do the logging here, as our caller doesn't know `configFilename``.
|
|
log.Info().Str("filename", configFilename).Msg("configuration file written")
|
|
return nil
|
|
}
|
|
|
|
// Expose some functions of Conf here, for easier mocking of functionality via interfaces.
|
|
func (s *Service) NewVariableExpander(audience VariableAudience, platform VariablePlatform) *VariableExpander {
|
|
return s.config.NewVariableExpander(audience, platform)
|
|
}
|
|
func (s *Service) NewVariableToValueConverter(audience VariableAudience, platform VariablePlatform) *ValueToVariableReplacer {
|
|
return s.config.NewVariableToValueConverter(audience, platform)
|
|
}
|
|
func (s *Service) ResolveVariables(audience VariableAudience, platform VariablePlatform) map[string]ResolvedVariable {
|
|
return s.config.ResolveVariables(audience, platform)
|
|
}
|
|
func (s *Service) EffectiveStoragePath() string {
|
|
return s.config.EffectiveStoragePath()
|
|
}
|