Method UpsertSetting

backend/store/setting.go:322–370

UpsertSetting upserts the setting by name.

(ctx context.Context, update *SettingMessage)

// UpsertSetting upserts the setting by name.
func (s *Store) UpsertSetting(ctx context.Context, update *SettingMessage) (*SettingMessage, error) {
	valueBytes, err := protojson.Marshal(update.Value)
	if err != nil {
		return nil, errors.Wrap(err, "failed to marshal setting value")
	}

	q := qb.Q().Space(`
		INSERT INTO setting (name, workspace, value)
		VALUES (?, ?, ?)
		ON CONFLICT (name, workspace) DO UPDATE SET value = EXCLUDED.value
		RETURNING name, workspace, value
	`, update.Name.String(), update.Workspace, string(valueBytes))

	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	var setting SettingMessage
	var nameString string
	var valueString string
	if err := s.GetDB().QueryRowContext(ctx, query, args...).Scan(
		&nameString,
		&setting.Workspace,
		&valueString,
	); err != nil {
		if err == sql.ErrNoRows {
			return nil, &common.Error{Code: common.NotFound, Err: errors.Errorf("setting not found: %s", update.Name)}
		}
		return nil, err
	}
	value, ok := storepb.SettingName_value[nameString]
	if !ok {
		return nil, errors.Errorf("invalid setting name string: %s", nameString)
	}
	setting.Name = storepb.SettingName(value)

	msg, err := getSettingMessage(setting.Name)
	if err != nil {
		return nil, err
	}
	if err := common.ProtojsonUnmarshaler.Unmarshal([]byte(valueString), msg); err != nil {
		return nil, err
	}
	setting.Value = msg

	s.settingCache.Add(getSettingCacheKey(setting.Workspace, setting.Name), &setting)
	return &setting, nil
}

// DeleteSetting deletes a setting by the name.
func (s *Store) DeleteSetting(ctx context.Context, workspace string, name storepb.SettingName) error {