From 01c3d3905cb50ce41fdce0f9b11ee1ed0d33ecce Mon Sep 17 00:00:00 2001 From: SALLEYRON Julien Date: Mon, 3 Dec 2018 11:54:04 +0100 Subject: [PATCH] Remove Deprecated StorageFile --- acme/acme.go | 1 - anonymize/anonymize_config_test.go | 1 - cmd/storeconfig/storeconfig.go | 60 ------------------------------ 3 files changed, 62 deletions(-) diff --git a/acme/acme.go b/acme/acme.go index af3da1a17..61e6ca128 100644 --- a/acme/acme.go +++ b/acme/acme.go @@ -43,7 +43,6 @@ type ACME struct { Email string `description:"Email address used for registration"` Domains []types.Domain `description:"SANs (alternative domains) to each main domain using format: --acme.domains='main.com,san1.com,san2.com' --acme.domains='main.net,san1.net,san2.net'"` Storage string `description:"File or key used for certificates storage."` - StorageFile string // Deprecated OnDemand bool `description:"(Deprecated) Enable on demand certificate generation. This will request a certificate from Let's Encrypt during the first TLS handshake for a hostname that does not yet have a certificate."` // Deprecated OnHostRule bool `description:"Enable certificate generation on frontends Host rules."` CAServer string `description:"CA server to use."` diff --git a/anonymize/anonymize_config_test.go b/anonymize/anonymize_config_test.go index 59133bc8e..c6ce7bdf7 100644 --- a/anonymize/anonymize_config_test.go +++ b/anonymize/anonymize_config_test.go @@ -88,7 +88,6 @@ func TestDo_globalConfiguration(t *testing.T) { }, }, Storage: "Storage", - StorageFile: "StorageFile", OnDemand: true, OnHostRule: true, CAServer: "CAServer", diff --git a/cmd/storeconfig/storeconfig.go b/cmd/storeconfig/storeconfig.go index ea97eb347..8d8f316bd 100644 --- a/cmd/storeconfig/storeconfig.go +++ b/cmd/storeconfig/storeconfig.go @@ -3,9 +3,7 @@ package storeconfig import ( "encoding/json" "fmt" - "io/ioutil" stdlog "log" - "os" "github.com/abronan/valkeyrie/store" "github.com/containous/flaeg" @@ -13,7 +11,6 @@ import ( "github.com/containous/traefik/acme" "github.com/containous/traefik/cluster" "github.com/containous/traefik/cmd" - "github.com/containous/traefik/log" ) // NewCmd builds a new StoreConfig command @@ -77,14 +74,6 @@ func Run(kv *staert.KvSource, traefikConfiguration *cmd.TraefikConfiguration) fu if traefikConfiguration.Configuration.ACME != nil { account := &acme.Account{} - // Migrate ACME data from file to KV store if needed - if len(traefikConfiguration.Configuration.ACME.StorageFile) > 0 { - account, err = migrateACMEData(traefikConfiguration.Configuration.ACME.StorageFile) - if err != nil { - return err - } - } - accountInitialized, err := keyExists(kv, traefikConfiguration.Configuration.ACME.Storage) if err != nil && err != store.ErrKeyNotFound { return err @@ -111,9 +100,6 @@ func Run(kv *staert.KvSource, traefikConfiguration *cmd.TraefikConfiguration) fu return err } } - - // Force to delete storagefile - return kv.Delete(kv.Prefix + "/acme/storagefile") } return nil } @@ -128,52 +114,6 @@ func keyExists(source *staert.KvSource, key string) (bool, error) { return len(list) > 0, nil } -// migrateACMEData allows migrating data from acme.json file to KV store in function of the file format -func migrateACMEData(fileName string) (*acme.Account, error) { - - f, err := os.Open(fileName) - if err != nil { - return nil, err - } - defer f.Close() - - file, err := ioutil.ReadAll(f) - if err != nil { - return nil, err - } - - // Check if the storage file is not empty before to get data - account := &acme.Account{} - if len(file) > 0 { - accountFromNewFormat, err := acme.FromNewToOldFormat(fileName) - if err != nil { - return nil, err - } - - if accountFromNewFormat == nil { - // convert ACME json file to KV store (used for backward compatibility) - localStore := acme.NewLocalStore(fileName) - - account, err = localStore.Get() - if err != nil { - return nil, err - } - - err = account.RemoveAccountV1Values() - if err != nil { - return nil, err - } - } else { - account = accountFromNewFormat - } - } else { - log.Warnf("No data will be imported from the storageFile %q because it is empty.", fileName) - } - - err = account.Init() - return account, err -} - // CreateKvSource creates KvSource // TLS support is enable for Consul and Etcd backends func CreateKvSource(traefikConfiguration *cmd.TraefikConfiguration) (*staert.KvSource, error) {