2015-03-12 22:21:11 +00:00
package command
import (
2018-01-19 06:44:44 +00:00
"context"
2018-03-28 21:36:55 +00:00
"crypto/sha256"
2016-08-15 20:01:15 +00:00
"encoding/base64"
2018-03-28 21:36:55 +00:00
"encoding/hex"
2015-03-12 22:30:07 +00:00
"fmt"
2018-03-28 21:36:55 +00:00
"io"
2017-07-31 15:28:06 +00:00
"io/ioutil"
2015-03-13 17:09:38 +00:00
"net"
"net/http"
2015-05-02 22:57:40 +00:00
"net/url"
2015-04-04 19:06:41 +00:00
"os"
2017-07-31 15:28:06 +00:00
"path/filepath"
2015-10-28 17:05:56 +00:00
"runtime"
2021-04-16 19:55:05 +00:00
"runtime/pprof"
2015-04-04 19:06:41 +00:00
"sort"
2015-05-02 22:57:40 +00:00
"strconv"
2015-03-12 22:21:11 +00:00
"strings"
2016-07-30 17:17:29 +00:00
"sync"
2015-04-15 01:44:09 +00:00
"time"
2015-03-12 22:21:11 +00:00
2021-05-04 19:47:16 +00:00
systemd "github.com/coreos/go-systemd/daemon"
2016-04-04 14:44:22 +00:00
"github.com/hashicorp/errwrap"
2020-02-15 01:50:47 +00:00
"github.com/hashicorp/go-hclog"
2022-08-23 19:37:16 +00:00
wrapping "github.com/hashicorp/go-kms-wrapping/v2"
aeadwrapper "github.com/hashicorp/go-kms-wrapping/wrappers/aead/v2"
2019-10-04 07:29:51 +00:00
"github.com/hashicorp/go-multierror"
2021-07-16 00:17:31 +00:00
"github.com/hashicorp/go-secure-stdlib/gatedwriter"
"github.com/hashicorp/go-secure-stdlib/mlock"
2022-11-29 14:07:04 +00:00
"github.com/hashicorp/go-secure-stdlib/parseutil"
2021-07-16 00:17:31 +00:00
"github.com/hashicorp/go-secure-stdlib/reloadutil"
2015-04-05 01:07:53 +00:00
"github.com/hashicorp/vault/audit"
2021-09-07 22:36:58 +00:00
config2 "github.com/hashicorp/vault/command/config"
2015-03-12 22:30:07 +00:00
"github.com/hashicorp/vault/command/server"
2018-11-07 01:21:24 +00:00
"github.com/hashicorp/vault/helper/builtinplugins"
2022-06-08 12:57:48 +00:00
"github.com/hashicorp/vault/helper/constants"
2022-11-29 14:07:04 +00:00
loghelper "github.com/hashicorp/vault/helper/logging"
2020-10-13 23:38:21 +00:00
"github.com/hashicorp/vault/helper/metricsutil"
2019-04-13 07:44:06 +00:00
"github.com/hashicorp/vault/helper/namespace"
2022-12-07 18:29:51 +00:00
"github.com/hashicorp/vault/helper/useragent"
2019-04-13 07:44:06 +00:00
vaulthttp "github.com/hashicorp/vault/http"
2020-10-13 23:38:21 +00:00
"github.com/hashicorp/vault/internalshared/configutil"
"github.com/hashicorp/vault/internalshared/listenerutil"
2022-09-29 18:35:52 +00:00
"github.com/hashicorp/vault/sdk/helper/consts"
2019-04-12 21:54:35 +00:00
"github.com/hashicorp/vault/sdk/helper/jsonutil"
2022-06-08 21:15:28 +00:00
"github.com/hashicorp/vault/sdk/helper/strutil"
2019-04-12 21:54:35 +00:00
"github.com/hashicorp/vault/sdk/logical"
"github.com/hashicorp/vault/sdk/physical"
2019-12-06 14:46:39 +00:00
sr "github.com/hashicorp/vault/serviceregistration"
2015-03-13 17:09:38 +00:00
"github.com/hashicorp/vault/vault"
2022-09-06 18:11:04 +00:00
"github.com/hashicorp/vault/vault/hcp_link"
2018-10-29 13:30:24 +00:00
vaultseal "github.com/hashicorp/vault/vault/seal"
2022-12-07 18:29:51 +00:00
"github.com/hashicorp/vault/version"
2018-10-31 18:11:45 +00:00
"github.com/mitchellh/cli"
2019-10-04 07:29:51 +00:00
"github.com/mitchellh/go-testing-interface"
2021-09-30 11:33:14 +00:00
"github.com/pkg/errors"
2018-10-31 18:11:45 +00:00
"github.com/posener/complete"
2019-11-07 16:54:34 +00:00
"go.uber.org/atomic"
2019-10-04 07:29:51 +00:00
"golang.org/x/net/http/httpproxy"
2018-10-31 18:11:45 +00:00
"google.golang.org/grpc/grpclog"
2015-03-12 22:21:11 +00:00
)
2021-04-08 16:43:39 +00:00
var (
_ cli . Command = ( * ServerCommand ) ( nil )
_ cli . CommandAutocomplete = ( * ServerCommand ) ( nil )
)
2017-09-08 02:03:44 +00:00
2018-10-31 18:11:45 +00:00
var memProfilerEnabled = false
2019-08-23 15:53:18 +00:00
var enableFourClusterDev = func ( c * ServerCommand , base * vault . CoreConfig , info map [ string ] string , infoKeys [ ] string , devListenAddress , tempDir string ) int {
c . logger . Error ( "-dev-four-cluster only supported in enterprise Vault" )
return 1
}
2020-06-23 19:04:13 +00:00
const (
storageMigrationLock = "core/migration"
// Even though there are more types than the ones below, the following consts
// are declared internally for value comparison and reusability.
2022-11-10 21:46:59 +00:00
storageTypeRaft = "raft"
storageTypeConsul = "consul"
2020-06-23 19:04:13 +00:00
)
2018-09-25 23:18:22 +00:00
2015-03-12 22:21:11 +00:00
type ServerCommand struct {
2017-09-22 00:51:12 +00:00
* BaseCommand
2022-11-29 14:07:04 +00:00
logFlags logFlags
2017-09-22 00:51:12 +00:00
2015-04-05 01:07:53 +00:00
AuditBackends map [ string ] audit . Factory
2015-04-01 22:48:13 +00:00
CredentialBackends map [ string ] logical . Factory
LogicalBackends map [ string ] logical . Factory
2017-08-03 17:24:27 +00:00
PhysicalBackends map [ string ] physical . Factory
2015-03-20 18:32:18 +00:00
2019-12-06 14:46:39 +00:00
ServiceRegistrations map [ string ] sr . Factory
2016-03-14 18:05:47 +00:00
ShutdownCh chan struct { }
SighupCh chan struct { }
2019-03-15 13:27:53 +00:00
SigUSR2Ch chan struct { }
2016-03-11 21:46:56 +00:00
2016-07-30 17:17:29 +00:00
WaitGroup * sync . WaitGroup
2022-11-29 14:07:04 +00:00
logWriter io . Writer
logGate * gatedwriter . Writer
logger hclog . InterceptLogger
2016-06-02 16:40:25 +00:00
2016-10-10 17:18:19 +00:00
cleanupGuard sync . Once
2021-06-11 16:08:19 +00:00
reloadFuncsLock * sync . RWMutex
reloadFuncs * map [ string ] [ ] reloadutil . ReloadFunc
startedCh chan ( struct { } ) // for tests
reloadedCh chan ( struct { } ) // for tests
licenseReloadedCh chan ( error ) // for tests
2017-09-08 02:03:44 +00:00
2021-09-30 11:33:14 +00:00
allLoggers [ ] hclog . Logger
2021-02-02 20:15:10 +00:00
2020-02-15 19:58:05 +00:00
flagConfigs [ ] string
flagRecovery bool
flagDev bool
2022-07-22 18:04:03 +00:00
flagDevTLS bool
flagDevTLSCertDir string
2020-02-15 19:58:05 +00:00
flagDevRootTokenID string
flagDevListenAddr string
flagDevNoStoreToken bool
flagDevPluginDir string
flagDevPluginInit bool
flagDevHA bool
flagDevLatency int
flagDevLatencyJitter int
flagDevLeasedKV bool
flagDevKVV1 bool
flagDevSkipInit bool
flagDevThreeNode bool
flagDevFourCluster bool
flagDevTransactional bool
flagDevAutoSeal bool
flagTestVerifyOnly bool
flagTestServerConfig bool
flagDevConsul bool
flagExitOnCoreShutdown bool
2017-09-08 02:03:44 +00:00
}
func ( c * ServerCommand ) Synopsis ( ) string {
return "Start a Vault server"
}
func ( c * ServerCommand ) Help ( ) string {
helpText := `
Usage : vault server [ options ]
This command starts a Vault server that responds to API requests . By default ,
Vault will start in a "sealed" state . The Vault cluster must be initialized
2018-06-07 04:11:21 +00:00
before use , usually by the "vault operator init" command . Each Vault server must
also be unsealed using the "vault operator unseal" command or the API before the
server can respond to requests .
2017-09-08 02:03:44 +00:00
Start a server with a configuration file :
$ vault server - config = / etc / vault / config . hcl
Run in "dev" mode :
$ vault server - dev - dev - root - token - id = "root"
For a full list of examples , please see the documentation .
` + c . Flags ( ) . Help ( )
return strings . TrimSpace ( helpText )
}
func ( c * ServerCommand ) Flags ( ) * FlagSets {
set := c . flagSet ( FlagSetHTTP )
f := set . NewFlagSet ( "Command Options" )
2022-11-29 14:07:04 +00:00
// Augment with the log flags
f . addLogFlags ( & c . logFlags )
2017-09-08 02:03:44 +00:00
f . StringSliceVar ( & StringSliceVar {
Name : "config" ,
Target : & c . flagConfigs ,
Completion : complete . PredictOr (
complete . PredictFiles ( "*.hcl" ) ,
complete . PredictFiles ( "*.json" ) ,
complete . PredictDirs ( "*" ) ,
) ,
Usage : "Path to a configuration file or directory of configuration " +
"files. This flag can be specified multiple times to load multiple " +
"configurations. If the path is a directory, all files which end in " +
".hcl or .json are loaded." ,
} )
2020-02-15 02:07:31 +00:00
f . BoolVar ( & BoolVar {
Name : "exit-on-core-shutdown" ,
Target : & c . flagExitOnCoreShutdown ,
Default : false ,
Usage : "Exit the vault server if the vault core is shutdown." ,
} )
2019-10-15 04:55:31 +00:00
f . BoolVar ( & BoolVar {
Name : "recovery" ,
Target : & c . flagRecovery ,
Usage : "Enable recovery mode. In this mode, Vault is used to perform recovery actions." +
"Using a recovery operation token, \"sys/raw\" API can be used to manipulate the storage." ,
} )
2017-09-08 02:03:44 +00:00
f = set . NewFlagSet ( "Dev Options" )
f . BoolVar ( & BoolVar {
Name : "dev" ,
Target : & c . flagDev ,
Usage : "Enable development mode. In this mode, Vault runs in-memory and " +
"starts unsealed. As the name implies, do not run \"dev\" mode in " +
"production." ,
} )
2022-07-22 18:04:03 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-tls" ,
Target : & c . flagDevTLS ,
Usage : "Enable TLS development mode. In this mode, Vault runs in-memory and " +
"starts unsealed, with a generated TLS CA, certificate and key. " +
"As the name implies, do not run \"dev-tls\" mode in " +
"production." ,
} )
f . StringVar ( & StringVar {
Name : "dev-tls-cert-dir" ,
Target : & c . flagDevTLSCertDir ,
Default : "" ,
Usage : "Directory where generated TLS files are created if `-dev-tls` is " +
"specified. If left unset, files are generated in a temporary directory." ,
} )
2017-09-08 02:03:44 +00:00
f . StringVar ( & StringVar {
Name : "dev-root-token-id" ,
Target : & c . flagDevRootTokenID ,
Default : "" ,
EnvVar : "VAULT_DEV_ROOT_TOKEN_ID" ,
Usage : "Initial root token. This only applies when running in \"dev\" " +
"mode." ,
} )
f . StringVar ( & StringVar {
Name : "dev-listen-address" ,
Target : & c . flagDevListenAddr ,
Default : "127.0.0.1:8200" ,
EnvVar : "VAULT_DEV_LISTEN_ADDRESS" ,
Usage : "Address to bind to in \"dev\" mode." ,
} )
2019-07-24 16:41:07 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-no-store-token" ,
Target : & c . flagDevNoStoreToken ,
Default : false ,
Usage : "Do not persist the dev root token to the token helper " +
"(usually the local filesystem) for use in future requests. " +
"The token will only be displayed in the command output." ,
} )
2017-09-08 02:03:44 +00:00
// Internal-only flags to follow.
//
// Why hello there little source code reader! Welcome to the Vault source
// code. The remaining options are intentionally undocumented and come with
2019-03-19 13:32:45 +00:00
// no warranty or backwards-compatibility promise. Do not use these flags
2017-09-08 02:03:44 +00:00
// in production. Do not build automation using these flags. Unless you are
// developing against Vault, you should not need any of these flags.
f . StringVar ( & StringVar {
Name : "dev-plugin-dir" ,
Target : & c . flagDevPluginDir ,
Default : "" ,
Completion : complete . PredictDirs ( "*" ) ,
Hidden : true ,
} )
2018-03-28 21:36:55 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-plugin-init" ,
Target : & c . flagDevPluginInit ,
Default : true ,
Hidden : true ,
} )
2017-09-08 02:03:44 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-ha" ,
Target : & c . flagDevHA ,
Default : false ,
Hidden : true ,
} )
f . BoolVar ( & BoolVar {
Name : "dev-transactional" ,
Target : & c . flagDevTransactional ,
Default : false ,
Hidden : true ,
} )
2017-09-20 20:05:00 +00:00
f . IntVar ( & IntVar {
Name : "dev-latency" ,
Target : & c . flagDevLatency ,
Hidden : true ,
} )
f . IntVar ( & IntVar {
Name : "dev-latency-jitter" ,
Target : & c . flagDevLatencyJitter ,
Hidden : true ,
} )
2017-09-08 02:03:44 +00:00
f . BoolVar ( & BoolVar {
2017-09-20 20:05:00 +00:00
Name : "dev-leased-kv" ,
2017-09-08 02:03:44 +00:00
Target : & c . flagDevLeasedKV ,
Default : false ,
Hidden : true ,
} )
2018-12-12 20:07:18 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-kv-v1" ,
Target : & c . flagDevKVV1 ,
Default : false ,
Hidden : true ,
} )
2018-10-29 13:30:24 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-auto-seal" ,
Target : & c . flagDevAutoSeal ,
Default : false ,
Hidden : true ,
} )
2017-09-22 00:51:12 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-skip-init" ,
Target : & c . flagDevSkipInit ,
Default : false ,
Hidden : true ,
} )
2017-09-08 02:03:44 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-three-node" ,
Target : & c . flagDevThreeNode ,
Default : false ,
Hidden : true ,
} )
2018-02-22 05:23:37 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-four-cluster" ,
Target : & c . flagDevFourCluster ,
Default : false ,
Hidden : true ,
} )
2019-06-24 17:29:47 +00:00
f . BoolVar ( & BoolVar {
Name : "dev-consul" ,
Target : & c . flagDevConsul ,
Default : false ,
Hidden : true ,
} )
2018-06-15 18:47:37 +00:00
// TODO: should the below flags be public?
2017-09-08 02:03:44 +00:00
f . BoolVar ( & BoolVar {
Name : "test-verify-only" ,
Target : & c . flagTestVerifyOnly ,
Default : false ,
Hidden : true ,
} )
2019-05-10 17:41:42 +00:00
f . BoolVar ( & BoolVar {
Name : "test-server-config" ,
Target : & c . flagTestServerConfig ,
Default : false ,
Hidden : true ,
} )
2017-09-08 02:03:44 +00:00
// End internal-only flags.
return set
}
func ( c * ServerCommand ) AutocompleteArgs ( ) complete . Predictor {
return complete . PredictNothing
}
func ( c * ServerCommand ) AutocompleteFlags ( ) complete . Flags {
return c . Flags ( ) . Completions ( )
2015-03-12 22:21:11 +00:00
}
2020-09-28 21:06:49 +00:00
func ( c * ServerCommand ) flushLog ( ) {
c . logger . ( hclog . OutputResettable ) . ResetOutputWithFlush ( & hclog . LoggerOptions {
2022-11-29 14:07:04 +00:00
Output : c . logWriter ,
} , c . logGate )
2020-09-28 21:06:49 +00:00
}
2021-06-17 18:09:37 +00:00
func ( c * ServerCommand ) parseConfig ( ) ( * server . Config , [ ] configutil . ConfigError , error ) {
var configErrors [ ] configutil . ConfigError
2015-03-12 22:21:11 +00:00
// Load the configuration
2015-03-12 22:30:07 +00:00
var config * server . Config
2017-09-22 00:51:12 +00:00
for _ , path := range c . flagConfigs {
2019-07-18 19:59:27 +00:00
current , err := server . LoadConfig ( path )
2015-03-12 22:30:07 +00:00
if err != nil {
2021-06-17 18:09:37 +00:00
return nil , nil , fmt . Errorf ( "error loading configuration from %s: %w" , path , err )
2015-03-12 22:30:07 +00:00
}
2021-06-17 18:09:37 +00:00
configErrors = append ( configErrors , current . Validate ( path ) ... )
2015-03-12 22:30:07 +00:00
if config == nil {
config = current
} else {
config = config . Merge ( current )
}
}
2022-06-08 12:57:48 +00:00
2022-06-08 19:45:46 +00:00
if config != nil && config . Entropy != nil && config . Entropy . Mode == configutil . EntropyAugmentation && constants . IsFIPS ( ) {
2022-06-08 12:57:48 +00:00
c . UI . Warn ( "WARNING: Entropy Augmentation is not supported in FIPS 140-2 Inside mode; disabling from server configuration!\n" )
config . Entropy = nil
}
2021-06-17 18:09:37 +00:00
return config , configErrors , nil
2019-10-15 04:55:31 +00:00
}
func ( c * ServerCommand ) runRecoveryMode ( ) int {
2022-04-01 14:34:27 +00:00
config , configErrors , err := c . parseConfig ( )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2015-03-12 22:30:07 +00:00
2016-02-13 00:39:28 +00:00
// Ensure at least one config was found.
if config == nil {
2017-09-22 00:51:12 +00:00
c . UI . Output ( wrapAtLength (
"No configuration files found. Please provide configurations with the " +
2019-07-24 16:58:48 +00:00
"-config flag. If you are supplying the path to a directory, please " +
2017-09-22 00:51:12 +00:00
"ensure the directory contains files with the .hcl or .json " +
"extension." ) )
2016-02-13 00:39:28 +00:00
return 1
}
2022-11-29 14:07:04 +00:00
// Update the 'log' related aspects of shared config based on config/env var/cli
c . Flags ( ) . updateLogConfig ( config . SharedConfig )
l , err := c . configureLogging ( config )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2022-11-29 14:07:04 +00:00
c . logger = l
c . allLoggers = append ( c . allLoggers , l )
2019-10-15 04:55:31 +00:00
2022-04-01 14:34:27 +00:00
// reporting Errors found in the config
for _ , cErr := range configErrors {
c . logger . Warn ( cErr . String ( ) )
}
2020-09-28 21:06:49 +00:00
// Ensure logging is flushed if initialization fails
defer c . flushLog ( )
2019-10-15 04:55:31 +00:00
// create GRPC logger
namedGRPCLogFaker := c . logger . Named ( "grpclogfaker" )
grpclog . SetLogger ( & grpclogFaker {
logger : namedGRPCLogFaker ,
log : os . Getenv ( "VAULT_GRPC_LOGGING" ) != "" ,
} )
if config . Storage == nil {
c . UI . Output ( "A storage backend must be specified" )
return 1
}
if config . DefaultMaxRequestDuration != 0 {
vault . DefaultMaxRequestDuration = config . DefaultMaxRequestDuration
}
2020-05-19 14:07:46 +00:00
logProxyEnvironmentVariables ( c . logger )
2019-10-15 04:55:31 +00:00
// Initialize the storage backend
factory , exists := c . PhysicalBackends [ config . Storage . Type ]
if ! exists {
c . UI . Error ( fmt . Sprintf ( "Unknown storage type %s" , config . Storage . Type ) )
return 1
}
2020-06-23 19:04:13 +00:00
if config . Storage . Type == storageTypeRaft || ( config . HAStorage != nil && config . HAStorage . Type == storageTypeRaft ) {
2019-10-15 04:55:31 +00:00
if envCA := os . Getenv ( "VAULT_CLUSTER_ADDR" ) ; envCA != "" {
config . ClusterAddr = envCA
}
if len ( config . ClusterAddr ) == 0 {
c . UI . Error ( "Cluster address must be set when using raft storage" )
return 1
}
}
namedStorageLogger := c . logger . Named ( "storage." + config . Storage . Type )
backend , err := factory ( config . Storage . Config , namedStorageLogger )
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error initializing storage of type %s: %s" , config . Storage . Type , err ) )
return 1
}
infoKeys := make ( [ ] string , 0 , 10 )
info := make ( map [ string ] string )
2022-11-29 14:07:04 +00:00
info [ "log level" ] = config . LogLevel
2019-10-15 04:55:31 +00:00
infoKeys = append ( infoKeys , "log level" )
var barrierSeal vault . Seal
var sealConfigError error
2020-05-14 13:19:27 +00:00
var wrapper wrapping . Wrapper
2019-10-15 04:55:31 +00:00
if len ( config . Seals ) == 0 {
2022-08-23 19:37:16 +00:00
config . Seals = append ( config . Seals , & configutil . KMS { Type : wrapping . WrapperTypeShamir . String ( ) } )
2019-10-15 04:55:31 +00:00
}
if len ( config . Seals ) > 1 {
c . UI . Error ( "Only one seal block is accepted in recovery mode" )
return 1
}
configSeal := config . Seals [ 0 ]
2022-08-23 19:37:16 +00:00
sealType := wrapping . WrapperTypeShamir . String ( )
2019-10-15 04:55:31 +00:00
if ! configSeal . Disabled && os . Getenv ( "VAULT_SEAL_TYPE" ) != "" {
sealType = os . Getenv ( "VAULT_SEAL_TYPE" )
configSeal . Type = sealType
} else {
sealType = configSeal . Type
}
2020-05-14 13:19:27 +00:00
infoKeys = append ( infoKeys , "Seal Type" )
info [ "Seal Type" ] = sealType
2019-10-15 04:55:31 +00:00
var seal vault . Seal
2020-05-14 13:19:27 +00:00
defaultSeal := vault . NewDefaultSeal ( & vaultseal . Access {
2022-08-23 19:37:16 +00:00
Wrapper : aeadwrapper . NewShamirWrapper ( ) ,
2020-05-14 13:19:27 +00:00
} )
sealLogger := c . logger . ResetNamed ( fmt . Sprintf ( "seal.%s" , sealType ) )
wrapper , sealConfigError = configutil . ConfigureWrapper ( configSeal , & infoKeys , & info , sealLogger )
2019-10-15 04:55:31 +00:00
if sealConfigError != nil {
if ! errwrap . ContainsType ( sealConfigError , new ( logical . KeyNotFoundError ) ) {
c . UI . Error ( fmt . Sprintf (
"Error parsing Seal configuration: %s" , sealConfigError ) )
return 1
}
}
2020-05-14 13:19:27 +00:00
if wrapper == nil {
seal = defaultSeal
} else {
2022-08-23 19:37:16 +00:00
seal , err = vault . NewAutoSeal ( & vaultseal . Access {
2020-05-14 13:19:27 +00:00
Wrapper : wrapper ,
} )
2022-08-23 19:37:16 +00:00
if err != nil {
c . UI . Error ( fmt . Sprintf ( "error creating auto seal: %v" , err ) )
}
2019-10-15 04:55:31 +00:00
}
barrierSeal = seal
// Ensure that the seal finalizer is called, even if using verify-only
defer func ( ) {
err = seal . Finalize ( context . Background ( ) )
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error finalizing seals: %v" , err ) )
}
} ( )
coreConfig := & vault . CoreConfig {
Physical : backend ,
StorageType : config . Storage . Type ,
Seal : barrierSeal ,
2022-11-29 14:07:04 +00:00
LogLevel : config . LogLevel ,
2019-10-15 04:55:31 +00:00
Logger : c . logger ,
DisableMlock : config . DisableMlock ,
RecoveryMode : c . flagRecovery ,
ClusterAddr : config . ClusterAddr ,
}
core , newCoreError := vault . NewCore ( coreConfig )
if newCoreError != nil {
if vault . IsFatalError ( newCoreError ) {
c . UI . Error ( fmt . Sprintf ( "Error initializing core: %s" , newCoreError ) )
return 1
}
}
if err := core . InitializeRecovery ( context . Background ( ) ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Error initializing core in recovery mode: %s" , err ) )
return 1
}
// Compile server information for output later
infoKeys = append ( infoKeys , "storage" )
info [ "storage" ] = config . Storage . Type
if coreConfig . ClusterAddr != "" {
info [ "cluster address" ] = coreConfig . ClusterAddr
infoKeys = append ( infoKeys , "cluster address" )
}
// Initialize the listeners
2020-05-14 13:19:27 +00:00
lns := make ( [ ] listenerutil . Listener , 0 , len ( config . Listeners ) )
2019-10-15 04:55:31 +00:00
for _ , lnConfig := range config . Listeners {
2022-11-29 14:07:04 +00:00
ln , _ , _ , err := server . NewListener ( lnConfig , c . logGate , c . UI )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error initializing listener of type %s: %s" , lnConfig . Type , err ) )
return 1
}
2020-05-14 13:19:27 +00:00
lns = append ( lns , listenerutil . Listener {
2019-10-15 04:55:31 +00:00
Listener : ln ,
2020-05-14 13:19:27 +00:00
Config : lnConfig ,
2019-10-15 04:55:31 +00:00
} )
}
listenerCloseFunc := func ( ) {
for _ , ln := range lns {
ln . Listener . Close ( )
}
}
defer c . cleanupGuard . Do ( listenerCloseFunc )
infoKeys = append ( infoKeys , "version" )
verInfo := version . GetVersion ( )
info [ "version" ] = verInfo . FullVersionNumber ( false )
2020-05-26 16:28:51 +00:00
2019-10-15 04:55:31 +00:00
if verInfo . Revision != "" {
info [ "version sha" ] = strings . Trim ( verInfo . Revision , "'" )
infoKeys = append ( infoKeys , "version sha" )
}
infoKeys = append ( infoKeys , "recovery mode" )
info [ "recovery mode" ] = "true"
2020-05-26 16:28:51 +00:00
infoKeys = append ( infoKeys , "go version" )
info [ "go version" ] = runtime . Version ( )
2022-02-17 18:03:57 +00:00
fipsStatus := getFIPSInfoKey ( )
if fipsStatus != "" {
infoKeys = append ( infoKeys , "fips" )
info [ "fips" ] = fipsStatus
}
2019-10-15 04:55:31 +00:00
// Server configuration output
padding := 24
2020-05-26 16:28:51 +00:00
2019-10-15 04:55:31 +00:00
sort . Strings ( infoKeys )
c . UI . Output ( "==> Vault server configuration:\n" )
2020-05-26 16:28:51 +00:00
2019-10-15 04:55:31 +00:00
for _ , k := range infoKeys {
c . UI . Output ( fmt . Sprintf (
"%s%s: %s" ,
strings . Repeat ( " " , padding - len ( k ) ) ,
strings . Title ( k ) ,
info [ k ] ) )
}
2020-05-26 16:28:51 +00:00
2019-10-15 04:55:31 +00:00
c . UI . Output ( "" )
for _ , ln := range lns {
2022-11-29 19:38:33 +00:00
handler := vaulthttp . Handler . Handler ( & vault . HandlerProperties {
2019-10-15 04:55:31 +00:00
Core : core ,
2020-05-14 13:19:27 +00:00
ListenerConfig : ln . Config ,
2019-10-15 04:55:31 +00:00
DisablePrintableCheck : config . DisablePrintableCheck ,
RecoveryMode : c . flagRecovery ,
RecoveryToken : atomic . NewString ( "" ) ,
} )
server := & http . Server {
Handler : handler ,
ReadHeaderTimeout : 10 * time . Second ,
ReadTimeout : 30 * time . Second ,
IdleTimeout : 5 * time . Minute ,
ErrorLog : c . logger . StandardLogger ( nil ) ,
}
go server . Serve ( ln . Listener )
}
if sealConfigError != nil {
2020-12-08 18:55:34 +00:00
init , err := core . InitializedLocally ( context . Background ( ) )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error checking if core is initialized: %v" , err ) )
return 1
}
if init {
c . UI . Error ( "Vault is initialized but no Seal key could be loaded" )
return 1
}
}
if newCoreError != nil {
c . UI . Warn ( wrapAtLength (
"WARNING! A non-fatal error occurred during initialization. Please " +
"check the logs for more information." ) )
c . UI . Warn ( "" )
}
2022-11-29 14:07:04 +00:00
if ! c . logFlags . flagCombineLogs {
2019-10-15 04:55:31 +00:00
c . UI . Output ( "==> Vault server started! Log data will stream in below:\n" )
}
2020-09-28 21:06:49 +00:00
c . flushLog ( )
2019-10-15 04:55:31 +00:00
for {
select {
case <- c . ShutdownCh :
c . UI . Output ( "==> Vault shutdown triggered" )
c . cleanupGuard . Do ( listenerCloseFunc )
if err := core . Shutdown ( ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Error with core shutdown: %s" , err ) )
}
return 0
case <- c . SigUSR2Ch :
buf := make ( [ ] byte , 32 * 1024 * 1024 )
n := runtime . Stack ( buf [ : ] , true )
c . logger . Info ( "goroutine trace" , "stack" , string ( buf [ : n ] ) )
}
}
}
2020-05-19 14:07:46 +00:00
func logProxyEnvironmentVariables ( logger hclog . Logger ) {
proxyCfg := httpproxy . FromEnvironment ( )
cfgMap := map [ string ] string {
"http_proxy" : proxyCfg . HTTPProxy ,
"https_proxy" : proxyCfg . HTTPSProxy ,
"no_proxy" : proxyCfg . NoProxy ,
}
for k , v := range cfgMap {
u , err := url . Parse ( v )
if err != nil {
// Env vars may contain URLs or host:port values. We only care
// about the former.
continue
}
if _ , ok := u . User . Password ( ) ; ok {
u . User = url . UserPassword ( "redacted-username" , "redacted-password" )
} else if user := u . User . Username ( ) ; user != "" {
u . User = url . User ( "redacted-username" )
}
cfgMap [ k ] = u . String ( )
}
logger . Info ( "proxy environment" , "http_proxy" , cfgMap [ "http_proxy" ] ,
"https_proxy" , cfgMap [ "https_proxy" ] , "no_proxy" , cfgMap [ "no_proxy" ] )
}
2020-08-31 15:45:50 +00:00
type quiescenceSink struct {
t * time . Timer
}
2021-09-30 11:33:14 +00:00
func ( q quiescenceSink ) Accept ( name string , level hclog . Level , msg string , args ... interface { } ) {
2020-08-31 15:45:50 +00:00
q . t . Reset ( 100 * time . Millisecond )
}
2021-02-02 20:15:10 +00:00
func ( c * ServerCommand ) setupStorage ( config * server . Config ) ( physical . Backend , error ) {
// Ensure that a backend is provided
if config . Storage == nil {
2021-09-30 11:33:14 +00:00
return nil , errors . New ( "A storage backend must be specified" )
2021-02-02 20:15:10 +00:00
}
// Initialize the backend
factory , exists := c . PhysicalBackends [ config . Storage . Type ]
if ! exists {
return nil , fmt . Errorf ( "Unknown storage type %s" , config . Storage . Type )
}
// Do any custom configuration needed per backend
switch config . Storage . Type {
case storageTypeConsul :
if config . ServiceRegistration == nil {
// If Consul is configured for storage and service registration is unconfigured,
// use Consul for service registration without requiring additional configuration.
// This maintains backward-compatibility.
config . ServiceRegistration = & server . ServiceRegistration {
Type : "consul" ,
Config : config . Storage . Config ,
}
}
case storageTypeRaft :
if envCA := os . Getenv ( "VAULT_CLUSTER_ADDR" ) ; envCA != "" {
config . ClusterAddr = envCA
}
if len ( config . ClusterAddr ) == 0 {
2021-09-30 11:33:14 +00:00
return nil , errors . New ( "Cluster address must be set when using raft storage" )
2021-02-02 20:15:10 +00:00
}
}
namedStorageLogger := c . logger . Named ( "storage." + config . Storage . Type )
c . allLoggers = append ( c . allLoggers , namedStorageLogger )
backend , err := factory ( config . Storage . Config , namedStorageLogger )
if err != nil {
return nil , fmt . Errorf ( "Error initializing storage of type %s: %w" , config . Storage . Type , err )
}
return backend , nil
}
2021-05-25 22:23:20 +00:00
func beginServiceRegistration ( c * ServerCommand , config * server . Config ) ( sr . ServiceRegistration , error ) {
sdFactory , ok := c . ServiceRegistrations [ config . ServiceRegistration . Type ]
if ! ok {
return nil , fmt . Errorf ( "Unknown service_registration type %s" , config . ServiceRegistration . Type )
}
namedSDLogger := c . logger . Named ( "service_registration." + config . ServiceRegistration . Type )
c . allLoggers = append ( c . allLoggers , namedSDLogger )
// Since we haven't even begun starting Vault's core yet,
// we know that Vault is in its pre-running state.
state := sr . State {
VaultVersion : version . GetVersion ( ) . VersionNumber ( ) ,
IsInitialized : false ,
IsSealed : true ,
IsActive : false ,
IsPerformanceStandby : false ,
}
var err error
configSR , err := sdFactory ( config . ServiceRegistration . Config , namedSDLogger , state )
if err != nil {
return nil , fmt . Errorf ( "Error initializing service_registration of type %s: %s" , config . ServiceRegistration . Type , err )
}
return configSR , nil
}
2021-04-06 23:40:43 +00:00
// InitListeners returns a response code, error message, Listeners, and a TCP Address list.
func ( c * ServerCommand ) InitListeners ( config * server . Config , disableClustering bool , infoKeys * [ ] string , info * map [ string ] string ) ( int , [ ] listenerutil . Listener , [ ] * net . TCPAddr , error ) {
clusterAddrs := [ ] * net . TCPAddr { }
// Initialize the listeners
lns := make ( [ ] listenerutil . Listener , 0 , len ( config . Listeners ) )
c . reloadFuncsLock . Lock ( )
defer c . reloadFuncsLock . Unlock ( )
var errMsg error
for i , lnConfig := range config . Listeners {
2022-11-29 14:07:04 +00:00
ln , props , reloadFunc , err := server . NewListener ( lnConfig , c . logGate , c . UI )
2021-04-06 23:40:43 +00:00
if err != nil {
errMsg = fmt . Errorf ( "Error initializing listener of type %s: %s" , lnConfig . Type , err )
return 1 , nil , nil , errMsg
}
if reloadFunc != nil {
relSlice := ( * c . reloadFuncs ) [ "listener|" + lnConfig . Type ]
relSlice = append ( relSlice , reloadFunc )
( * c . reloadFuncs ) [ "listener|" + lnConfig . Type ] = relSlice
}
if ! disableClustering && lnConfig . Type == "tcp" {
addr := lnConfig . ClusterAddress
if addr != "" {
tcpAddr , err := net . ResolveTCPAddr ( "tcp" , lnConfig . ClusterAddress )
if err != nil {
errMsg = fmt . Errorf ( "Error resolving cluster_address: %s" , err )
return 1 , nil , nil , errMsg
}
clusterAddrs = append ( clusterAddrs , tcpAddr )
} else {
tcpAddr , ok := ln . Addr ( ) . ( * net . TCPAddr )
if ! ok {
errMsg = fmt . Errorf ( "Failed to parse tcp listener" )
return 1 , nil , nil , errMsg
}
clusterAddr := & net . TCPAddr {
IP : tcpAddr . IP ,
Port : tcpAddr . Port + 1 ,
}
clusterAddrs = append ( clusterAddrs , clusterAddr )
addr = clusterAddr . String ( )
}
props [ "cluster address" ] = addr
}
if lnConfig . MaxRequestSize == 0 {
lnConfig . MaxRequestSize = vaulthttp . DefaultMaxRequestSize
}
props [ "max_request_size" ] = fmt . Sprintf ( "%d" , lnConfig . MaxRequestSize )
if lnConfig . MaxRequestDuration == 0 {
lnConfig . MaxRequestDuration = vault . DefaultMaxRequestDuration
}
props [ "max_request_duration" ] = lnConfig . MaxRequestDuration . String ( )
lns = append ( lns , listenerutil . Listener {
Listener : ln ,
Config : lnConfig ,
} )
// Store the listener props for output later
key := fmt . Sprintf ( "listener %d" , i + 1 )
propsList := make ( [ ] string , 0 , len ( props ) )
for k , v := range props {
propsList = append ( propsList , fmt . Sprintf (
"%s: %q" , k , v ) )
}
sort . Strings ( propsList )
* infoKeys = append ( * infoKeys , key )
( * info ) [ key ] = fmt . Sprintf (
"%s (%s)" , lnConfig . Type , strings . Join ( propsList , ", " ) )
}
if ! disableClustering {
if c . logger . IsDebug ( ) {
c . logger . Debug ( "cluster listener addresses synthesized" , "cluster_addresses" , clusterAddrs )
}
}
return 0 , lns , clusterAddrs , nil
}
2019-10-15 04:55:31 +00:00
func ( c * ServerCommand ) Run ( args [ ] string ) int {
f := c . Flags ( )
if err := f . Parse ( args ) ; err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2022-11-29 14:07:04 +00:00
c . logGate = gatedwriter . NewWriter ( os . Stderr )
c . logWriter = c . logGate
if c . logFlags . flagCombineLogs {
c . logWriter = os . Stdout
}
2019-10-15 04:55:31 +00:00
if c . flagRecovery {
return c . runRecoveryMode ( )
}
// Automatically enable dev mode if other dev flags are provided.
2022-07-22 18:04:03 +00:00
if c . flagDevConsul || c . flagDevHA || c . flagDevTransactional || c . flagDevLeasedKV || c . flagDevThreeNode || c . flagDevFourCluster || c . flagDevAutoSeal || c . flagDevKVV1 || c . flagDevTLS {
2019-10-15 04:55:31 +00:00
c . flagDev = true
}
// Validation
if ! c . flagDev {
switch {
case len ( c . flagConfigs ) == 0 :
c . UI . Error ( "Must specify at least one config path using -config" )
2019-07-18 19:59:27 +00:00
return 1
2019-10-15 04:55:31 +00:00
case c . flagDevRootTokenID != "" :
c . UI . Warn ( wrapAtLength (
"You cannot specify a custom root token ID outside of \"dev\" mode. " +
"Your request has been ignored." ) )
c . flagDevRootTokenID = ""
2019-07-18 19:59:27 +00:00
}
}
2019-10-15 04:55:31 +00:00
// Load the configuration
var config * server . Config
2020-05-14 13:19:27 +00:00
var err error
2022-07-22 18:04:03 +00:00
var certDir string
2019-10-15 04:55:31 +00:00
if c . flagDev {
var devStorageType string
switch {
case c . flagDevConsul :
devStorageType = "consul"
case c . flagDevHA && c . flagDevTransactional :
devStorageType = "inmem_transactional_ha"
case ! c . flagDevHA && c . flagDevTransactional :
devStorageType = "inmem_transactional"
case c . flagDevHA && ! c . flagDevTransactional :
devStorageType = "inmem_ha"
default :
devStorageType = "inmem"
}
2022-07-22 18:04:03 +00:00
if c . flagDevTLS {
if c . flagDevTLSCertDir != "" {
_ , err := os . Stat ( c . flagDevTLSCertDir )
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
certDir = c . flagDevTLSCertDir
} else {
certDir , err = os . MkdirTemp ( "" , "vault-tls" )
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
}
config , err = server . DevTLSConfig ( devStorageType , certDir )
defer func ( ) {
err := os . Remove ( fmt . Sprintf ( "%s/%s" , certDir , server . VaultDevCAFilename ) )
if err != nil {
c . UI . Error ( err . Error ( ) )
}
err = os . Remove ( fmt . Sprintf ( "%s/%s" , certDir , server . VaultDevCertFilename ) )
if err != nil {
c . UI . Error ( err . Error ( ) )
}
err = os . Remove ( fmt . Sprintf ( "%s/%s" , certDir , server . VaultDevKeyFilename ) )
if err != nil {
c . UI . Error ( err . Error ( ) )
}
// Only delete temp directories we made.
if c . flagDevTLSCertDir == "" {
err = os . Remove ( certDir )
if err != nil {
c . UI . Error ( err . Error ( ) )
}
}
} ( )
} else {
config , err = server . DevConfig ( devStorageType )
}
2020-05-14 13:19:27 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2022-07-22 18:04:03 +00:00
2019-10-15 04:55:31 +00:00
if c . flagDevListenAddr != "" {
2020-05-14 13:19:27 +00:00
config . Listeners [ 0 ] . Address = c . flagDevListenAddr
2019-10-15 04:55:31 +00:00
}
2021-02-24 19:04:23 +00:00
config . Listeners [ 0 ] . Telemetry . UnauthenticatedMetricsAccess = true
2019-10-15 04:55:31 +00:00
}
2022-04-01 14:34:27 +00:00
parsedConfig , configErrors , err := c . parseConfig ( )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
if config == nil {
config = parsedConfig
} else {
config = config . Merge ( parsedConfig )
}
// Ensure at least one config was found.
if config == nil {
c . UI . Output ( wrapAtLength (
"No configuration files found. Please provide configurations with the " +
"-config flag. If you are supplying the path to a directory, please " +
"ensure the directory contains files with the .hcl or .json " +
"extension." ) )
return 1
}
2022-11-29 14:07:04 +00:00
f . updateLogConfig ( config . SharedConfig )
// Set 'trace' log level for the following 'dev' clusters
if c . flagDevThreeNode || c . flagDevFourCluster {
config . LogLevel = "trace"
}
l , err := c . configureLogging ( config )
2019-10-15 04:55:31 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2022-11-29 14:07:04 +00:00
c . logger = l
c . allLoggers = append ( c . allLoggers , l )
2019-07-18 19:59:27 +00:00
2022-04-01 14:34:27 +00:00
// reporting Errors found in the config
for _ , cErr := range configErrors {
c . logger . Warn ( cErr . String ( ) )
}
2020-09-28 21:06:49 +00:00
// Ensure logging is flushed if initialization fails
defer c . flushLog ( )
2019-07-18 19:59:27 +00:00
// create GRPC logger
2018-09-05 19:52:54 +00:00
namedGRPCLogFaker := c . logger . Named ( "grpclogfaker" )
2021-02-02 20:15:10 +00:00
c . allLoggers = append ( c . allLoggers , namedGRPCLogFaker )
2018-09-05 19:52:54 +00:00
grpclog . SetLogger ( & grpclogFaker {
logger : namedGRPCLogFaker ,
log : os . Getenv ( "VAULT_GRPC_LOGGING" ) != "" ,
} )
2018-10-31 18:11:45 +00:00
if memProfilerEnabled {
c . startMemProfiler ( )
}
2018-07-24 21:50:49 +00:00
if config . DefaultMaxRequestDuration != 0 {
vault . DefaultMaxRequestDuration = config . DefaultMaxRequestDuration
}
2020-05-19 14:07:46 +00:00
logProxyEnvironmentVariables ( c . logger )
2019-09-30 15:46:42 +00:00
2020-09-11 16:56:30 +00:00
if envMlock := os . Getenv ( "VAULT_DISABLE_MLOCK" ) ; envMlock != "" {
var err error
config . DisableMlock , err = strconv . ParseBool ( envMlock )
if err != nil {
c . UI . Output ( "Error parsing the environment variable VAULT_DISABLE_MLOCK" )
return 1
}
}
2021-06-07 18:44:20 +00:00
if envLicensePath := os . Getenv ( EnvVaultLicensePath ) ; envLicensePath != "" {
2021-05-07 12:55:41 +00:00
config . LicensePath = envLicensePath
}
2021-06-07 18:44:20 +00:00
if envLicense := os . Getenv ( EnvVaultLicense ) ; envLicense != "" {
2021-05-07 12:55:41 +00:00
config . License = envLicense
}
2022-02-17 19:43:07 +00:00
if disableSSC := os . Getenv ( DisableSSCTokens ) ; disableSSC != "" {
var err error
config . DisableSSCTokens , err = strconv . ParseBool ( disableSSC )
if err != nil {
c . UI . Warn ( wrapAtLength ( "WARNING! failed to parse " +
"VAULT_DISABLE_SERVER_SIDE_CONSISTENT_TOKENS env var: " +
"setting to default value false" ) )
}
}
2021-05-07 12:55:41 +00:00
2018-02-14 20:11:33 +00:00
// If mlockall(2) isn't supported, show a warning. We disable this in dev
// because it is quite scary to see when first using Vault. We also disable
// this if the user has explicitly disabled mlock in configuration.
if ! c . flagDev && ! config . DisableMlock && ! mlock . Supported ( ) {
2017-09-22 00:51:12 +00:00
c . UI . Warn ( wrapAtLength (
"WARNING! mlock is not supported on this system! An mlockall(2)-like " +
"syscall to prevent memory from being swapped to disk is not " +
"supported on this system. For better security, only run Vault on " +
"systems where this call is supported. If you are running Vault " +
"in a Docker container, provide the IPC_LOCK cap to the container." ) )
2015-04-28 22:04:40 +00:00
}
2020-05-14 13:19:27 +00:00
inmemMetrics , metricSink , prometheusEnabled , err := configutil . SetupTelemetry ( & configutil . SetupTelemetryOpts {
Config : config . Telemetry ,
Ui : c . UI ,
ServiceName : "vault" ,
DisplayName : "Vault" ,
UserAgent : useragent . String ( ) ,
ClusterName : config . ClusterName ,
} )
2019-02-14 20:46:59 +00:00
if err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error initializing telemetry: %s" , err ) )
2015-12-17 21:38:17 +00:00
return 1
}
2020-05-14 13:19:27 +00:00
metricsHelper := metricsutil . NewMetricsHelper ( inmemMetrics , prometheusEnabled )
2015-12-17 21:38:17 +00:00
2021-02-02 20:15:10 +00:00
// Initialize the storage backend
backend , err := c . setupStorage ( config )
2015-03-13 17:09:38 +00:00
if err != nil {
2021-02-02 20:15:10 +00:00
c . UI . Error ( err . Error ( ) )
2015-03-13 17:09:38 +00:00
return 1
}
2018-10-01 21:35:35 +00:00
// Prevent server startup if migration is active
2021-04-28 15:55:18 +00:00
// TODO: Use OpenTelemetry to integrate this into Diagnose
2018-10-23 06:34:02 +00:00
if c . storageMigrationActive ( backend ) {
2018-09-25 23:18:22 +00:00
return 1
}
2019-12-06 14:46:39 +00:00
// Initialize the Service Discovery, if there is one
var configSR sr . ServiceRegistration
if config . ServiceRegistration != nil {
2021-05-25 22:23:20 +00:00
configSR , err = beginServiceRegistration ( c , config )
2019-12-06 14:46:39 +00:00
if err != nil {
2021-05-25 22:23:20 +00:00
c . UI . Output ( err . Error ( ) )
2019-12-06 14:46:39 +00:00
return 1
}
}
2016-04-04 17:46:33 +00:00
infoKeys := make ( [ ] string , 0 , 10 )
info := make ( map [ string ] string )
2022-11-29 14:07:04 +00:00
info [ "log level" ] = config . LogLevel
2017-11-02 14:30:04 +00:00
infoKeys = append ( infoKeys , "log level" )
2022-12-02 14:49:24 +00:00
// returns a slice of env vars formatted as "key=value"
envVars := os . Environ ( )
var envVarKeys [ ] string
for _ , v := range envVars {
splitEnvVars := strings . Split ( v , "=" )
envVarKeys = append ( envVarKeys , splitEnvVars [ 0 ] )
}
sort . Strings ( envVarKeys )
key := "environment variables"
info [ key ] = strings . Join ( envVarKeys , ", " )
infoKeys = append ( infoKeys , key )
2021-05-25 22:23:20 +00:00
barrierSeal , barrierWrapper , unwrapSeal , seals , sealConfigError , err := setSeal ( c , config , infoKeys , info )
// Check error here
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2019-03-04 22:11:56 +00:00
2022-10-04 13:23:37 +00:00
for _ , seal := range seals {
// There is always one nil seal. We need to skip it so we don't start an empty Finalize-Seal-Shamir
// section.
if seal == nil {
continue
2016-04-28 18:04:31 +00:00
}
2022-10-04 13:23:37 +00:00
seal := seal // capture range variable
// Ensure that the seal finalizer is called, even if using verify-only
defer func ( seal * vault . Seal ) {
err = ( * seal ) . Finalize ( context . Background ( ) )
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error finalizing seals: %v" , err ) )
}
} ( & seal )
2019-03-04 22:11:56 +00:00
}
2016-04-28 18:04:31 +00:00
2019-03-04 22:11:56 +00:00
if barrierSeal == nil {
2021-09-30 11:33:14 +00:00
c . UI . Error ( "Could not create barrier seal! Most likely proper Seal configuration information was not set, but no error was generated." )
2016-12-05 17:28:12 +00:00
return 1
}
2019-10-17 17:33:00 +00:00
// prepare a secure random reader for core
2020-05-14 13:19:27 +00:00
secureRandomReader , err := configutil . CreateSecureRandomReaderFunc ( config . SharedConfig , barrierWrapper )
2019-10-17 17:33:00 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
}
2021-05-25 22:23:20 +00:00
coreConfig := createCoreConfig ( c , config , backend , configSR , barrierSeal , unwrapSeal , metricsHelper , metricSink , secureRandomReader )
2017-09-22 00:51:12 +00:00
if c . flagDevThreeNode {
2021-05-25 22:23:20 +00:00
return c . enableThreeNodeDevCluster ( & coreConfig , info , infoKeys , c . flagDevListenAddr , os . Getenv ( "VAULT_DEV_TEMP_DIR" ) )
2017-07-31 15:28:06 +00:00
}
2018-09-18 03:03:00 +00:00
if c . flagDevFourCluster {
2021-05-25 22:23:20 +00:00
return enableFourClusterDev ( c , & coreConfig , info , infoKeys , c . flagDevListenAddr , os . Getenv ( "VAULT_DEV_TEMP_DIR" ) )
2018-09-18 03:03:00 +00:00
}
2022-12-14 18:06:33 +00:00
if allowPendingRemoval := os . Getenv ( consts . EnvVaultAllowPendingRemovalMounts ) ; allowPendingRemoval != "" {
var err error
coreConfig . PendingRemovalMountsAllowed , err = strconv . ParseBool ( allowPendingRemoval )
if err != nil {
c . UI . Warn ( wrapAtLength ( "WARNING! failed to parse " +
consts . EnvVaultAllowPendingRemovalMounts + " env var: " +
"defaulting to false." ) )
}
}
2017-03-08 14:17:00 +00:00
// Initialize the separate HA storage backend, if it exists
2021-05-25 22:23:20 +00:00
disableClustering , err := initHaBackend ( c , config , & coreConfig , backend )
if err != nil {
c . UI . Output ( err . Error ( ) )
return 1
2015-12-15 02:22:55 +00:00
}
2021-05-25 22:23:20 +00:00
// Determine the redirect address from environment variables
err = determineRedirectAddr ( c , & coreConfig , config )
if err != nil {
c . UI . Output ( err . Error ( ) )
2017-02-24 15:45:29 +00:00
}
2015-05-02 22:57:40 +00:00
2016-08-15 13:42:42 +00:00
// After the redirect bits are sorted out, if no cluster address was
// explicitly given, derive one from the redirect addr
2021-05-25 22:23:20 +00:00
err = findClusterAddress ( c , & coreConfig , config , disableClustering )
if err != nil {
c . UI . Output ( err . Error ( ) )
2018-04-04 20:15:07 +00:00
return 1
}
2018-03-27 20:23:33 +00:00
// Override the UI enabling config by the environment variable
if enableUI := os . Getenv ( "VAULT_UI" ) ; enableUI != "" {
var err error
coreConfig . EnableUI , err = strconv . ParseBool ( enableUI )
if err != nil {
c . UI . Output ( "Error parsing the environment variable VAULT_UI" )
return 1
}
}
2019-12-06 14:46:39 +00:00
// If ServiceRegistration is configured, then the backend must support HA
isBackendHA := coreConfig . HAPhysical != nil && coreConfig . HAPhysical . HAEnabled ( )
2020-05-15 18:06:58 +00:00
if ! c . flagDev && ( coreConfig . GetServiceRegistration ( ) != nil ) && ! isBackendHA {
2019-12-06 14:46:39 +00:00
c . UI . Output ( "service_registration is configured, but storage does not support HA" )
return 1
}
2020-02-15 00:39:13 +00:00
// Apply any enterprise configuration onto the coreConfig.
2021-05-25 22:23:20 +00:00
adjustCoreConfigForEnt ( config , & coreConfig )
2020-02-15 00:39:13 +00:00
2022-11-10 21:46:59 +00:00
if ! storageSupportedForEnt ( & coreConfig ) {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength ( fmt . Sprintf ( "WARNING: storage configured to use %q which is not supported for Vault Enterprise, must be \"raft\" or \"consul\"" , coreConfig . StorageType ) ) )
c . UI . Warn ( "" )
}
if ! c . flagDev {
2022-06-08 21:15:28 +00:00
inMemStorageTypes := [ ] string {
"inmem" , "inmem_ha" , "inmem_transactional" , "inmem_transactional_ha" ,
}
if strutil . StrListContains ( inMemStorageTypes , coreConfig . StorageType ) {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength ( fmt . Sprintf ( "WARNING: storage configured to use %q which should NOT be used in production" , coreConfig . StorageType ) ) )
c . UI . Warn ( "" )
}
}
2016-08-15 13:42:42 +00:00
// Initialize the core
2021-05-25 22:23:20 +00:00
core , newCoreError := vault . NewCore ( & coreConfig )
2016-08-15 13:42:42 +00:00
if newCoreError != nil {
2019-01-23 21:34:34 +00:00
if vault . IsFatalError ( newCoreError ) {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error initializing core: %s" , newCoreError ) )
2016-08-15 13:42:42 +00:00
return 1
}
2021-05-25 22:23:20 +00:00
c . UI . Warn ( wrapAtLength (
"WARNING! A non-fatal error occurred during initialization. Please " +
"check the logs for more information." ) )
c . UI . Warn ( "" )
2015-03-31 23:44:47 +00:00
}
2016-09-30 04:06:40 +00:00
// Copy the reload funcs pointers back
c . reloadFuncs = coreConfig . ReloadFuncs
c . reloadFuncsLock = coreConfig . ReloadFuncsLock
2015-04-04 19:06:41 +00:00
// Compile server information for output later
2017-03-08 14:17:00 +00:00
info [ "storage" ] = config . Storage . Type
2015-04-28 22:11:39 +00:00
info [ "mlock" ] = fmt . Sprintf (
"supported: %v, enabled: %v" ,
2016-11-22 17:56:36 +00:00
mlock . Supported ( ) , ! config . DisableMlock && mlock . Supported ( ) )
2017-11-02 14:30:04 +00:00
infoKeys = append ( infoKeys , "mlock" , "storage" )
2015-04-04 19:06:41 +00:00
2017-02-24 15:45:29 +00:00
if coreConfig . ClusterAddr != "" {
info [ "cluster address" ] = coreConfig . ClusterAddr
infoKeys = append ( infoKeys , "cluster address" )
}
if coreConfig . RedirectAddr != "" {
2018-04-04 20:15:07 +00:00
info [ "api address" ] = coreConfig . RedirectAddr
infoKeys = append ( infoKeys , "api address" )
2017-02-24 15:45:29 +00:00
}
2017-03-08 14:17:00 +00:00
if config . HAStorage != nil {
info [ "HA storage" ] = config . HAStorage . Type
infoKeys = append ( infoKeys , "HA storage" )
2015-12-11 20:58:10 +00:00
} else {
2017-03-08 14:17:00 +00:00
// If the storage supports HA, then note it
2015-12-14 22:58:30 +00:00
if coreConfig . HAPhysical != nil {
2016-07-18 17:19:58 +00:00
if coreConfig . HAPhysical . HAEnabled ( ) {
2017-03-08 14:17:00 +00:00
info [ "storage" ] += " (HA available)"
2016-07-18 17:19:58 +00:00
} else {
2017-03-08 14:17:00 +00:00
info [ "storage" ] += " (HA disabled)"
2016-07-18 17:19:58 +00:00
}
2015-12-11 20:58:10 +00:00
}
2015-04-17 17:50:37 +00:00
}
2021-04-06 23:40:43 +00:00
status , lns , clusterAddrs , errMsg := c . InitListeners ( config , disableClustering , & infoKeys , & info )
2016-08-15 13:42:42 +00:00
2021-04-06 23:40:43 +00:00
if status != 0 {
c . UI . Output ( "Error parsing listener configuration." )
c . UI . Error ( errMsg . Error ( ) )
return 1
2015-03-13 17:09:38 +00:00
}
2016-06-02 16:40:25 +00:00
// Make sure we close all listeners from this point on
2016-10-10 17:18:19 +00:00
listenerCloseFunc := func ( ) {
2016-06-02 16:40:25 +00:00
for _ , ln := range lns {
2018-04-17 22:52:09 +00:00
ln . Listener . Close ( )
2016-06-02 16:40:25 +00:00
}
2016-10-10 17:18:19 +00:00
}
defer c . cleanupGuard . Do ( listenerCloseFunc )
2016-06-02 16:40:25 +00:00
2016-11-28 00:16:44 +00:00
infoKeys = append ( infoKeys , "version" )
2016-11-22 21:43:05 +00:00
verInfo := version . GetVersion ( )
2016-11-28 00:28:35 +00:00
info [ "version" ] = verInfo . FullVersionNumber ( false )
2016-11-28 00:16:44 +00:00
if verInfo . Revision != "" {
2016-11-28 00:28:35 +00:00
info [ "version sha" ] = strings . Trim ( verInfo . Revision , "'" )
infoKeys = append ( infoKeys , "version sha" )
}
2020-05-26 16:28:51 +00:00
2016-11-28 00:28:35 +00:00
infoKeys = append ( infoKeys , "cgo" )
info [ "cgo" ] = "disabled"
if version . CgoEnabled {
info [ "cgo" ] = "enabled"
2016-11-28 00:16:44 +00:00
}
2015-11-09 18:52:55 +00:00
2019-10-15 04:55:31 +00:00
infoKeys = append ( infoKeys , "recovery mode" )
info [ "recovery mode" ] = "false"
2020-05-26 16:28:51 +00:00
infoKeys = append ( infoKeys , "go version" )
info [ "go version" ] = runtime . Version ( )
2022-02-17 18:03:57 +00:00
fipsStatus := getFIPSInfoKey ( )
if fipsStatus != "" {
infoKeys = append ( infoKeys , "fips" )
info [ "fips" ] = fipsStatus
}
2022-12-12 19:01:02 +00:00
if config . HCPLinkConf != nil {
infoKeys = append ( infoKeys , "HCP organization" )
info [ "HCP organization" ] = config . HCPLinkConf . Resource . Organization
infoKeys = append ( infoKeys , "HCP project" )
info [ "HCP project" ] = config . HCPLinkConf . Resource . Project
infoKeys = append ( infoKeys , "HCP resource ID" )
info [ "HCP resource ID" ] = config . HCPLinkConf . Resource . ID
}
2016-03-30 16:31:47 +00:00
sort . Strings ( infoKeys )
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault server configuration:\n" )
2020-05-26 16:28:51 +00:00
2015-04-04 19:06:41 +00:00
for _ , k := range infoKeys {
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2020-08-07 12:54:23 +00:00
"%24s: %s" ,
2015-04-04 19:06:41 +00:00
strings . Title ( k ) ,
info [ k ] ) )
}
2020-05-26 16:28:51 +00:00
2017-09-22 00:51:12 +00:00
c . UI . Output ( "" )
2015-04-04 19:06:41 +00:00
2017-09-22 00:51:12 +00:00
// Tests might not want to start a vault server and just want to verify
// the configuration.
if c . flagTestVerifyOnly {
2016-02-02 22:47:02 +00:00
return 0
}
2017-10-10 16:27:51 +00:00
// This needs to happen before we first unseal, so before we trigger dev
// mode if it's set
core . SetClusterListenerAddrs ( clusterAddrs )
2022-11-29 19:38:33 +00:00
core . SetClusterHandler ( vaulthttp . Handler . Handler ( & vault . HandlerProperties {
2018-07-06 19:44:56 +00:00
Core : core ,
} ) )
2017-10-10 16:27:51 +00:00
2019-01-23 21:34:34 +00:00
// Attempt unsealing in a background goroutine. This is needed for when a
// Vault cluster with multiple servers is configured with auto-unseal but is
// uninitialized. Once one server initializes the storage backend, this
// goroutine will pick up the unseal keys and unseal this instance.
2020-10-23 18:16:04 +00:00
if ! core . IsInSealMigrationMode ( ) {
2021-05-25 22:23:20 +00:00
go runUnseal ( c , core , context . Background ( ) )
2019-03-04 22:11:56 +00:00
}
2017-10-23 21:39:21 +00:00
2020-01-14 01:02:16 +00:00
// When the underlying storage is raft, kick off retry join if it was specified
// in the configuration
2020-06-23 19:04:13 +00:00
// TODO: Should we also support retry_join for ha_storage?
if config . Storage . Type == storageTypeRaft {
2020-01-14 01:02:16 +00:00
if err := core . InitiateRetryJoin ( context . Background ( ) ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Failed to initiate raft retry join, %q" , err . Error ( ) ) )
return 1
}
}
2020-01-24 17:42:03 +00:00
// Perform initialization of HTTP server after the verifyOnly check.
2020-05-15 18:06:58 +00:00
// Instantiate the wait group
c . WaitGroup = & sync . WaitGroup { }
// If service discovery is available, run service discovery
2021-05-25 22:23:20 +00:00
err = runListeners ( c , & coreConfig , config , configSR )
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
2020-05-15 18:06:58 +00:00
}
2017-03-25 17:51:12 +00:00
// If we're in Dev mode, then initialize the core
2022-07-22 18:04:03 +00:00
err = initDevCore ( c , & coreConfig , config , core , certDir )
2021-05-25 22:23:20 +00:00
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
2016-08-15 13:42:42 +00:00
}
2017-11-02 14:30:04 +00:00
// Initialize the HTTP servers
2021-05-25 22:23:20 +00:00
err = startHttpServers ( c , core , config , lns )
if err != nil {
c . UI . Error ( err . Error ( ) )
return 1
2016-02-02 22:47:02 +00:00
}
2022-12-12 19:01:02 +00:00
hcpLogger := c . logger . Named ( "hcp-connectivity" )
2022-09-06 18:11:04 +00:00
hcpLink , err := hcp_link . NewHCPLink ( config . HCPLinkConf , core , hcpLogger )
if err != nil {
2022-12-12 19:01:02 +00:00
c . logger . Error ( "failed to establish HCP connection" , "error" , err )
2022-09-06 18:11:04 +00:00
} else if hcpLink != nil {
2022-12-12 19:01:02 +00:00
c . logger . Trace ( "established HCP connection" )
2022-09-06 18:11:04 +00:00
}
2019-05-10 17:41:42 +00:00
if c . flagTestServerConfig {
return 0
}
2018-09-18 03:03:00 +00:00
if sealConfigError != nil {
2020-12-08 18:55:34 +00:00
init , err := core . InitializedLocally ( context . Background ( ) )
2018-09-18 03:03:00 +00:00
if err != nil {
c . UI . Error ( fmt . Sprintf ( "Error checking if core is initialized: %v" , err ) )
return 1
}
if init {
c . UI . Error ( "Vault is initialized but no Seal key could be loaded" )
return 1
}
}
2015-04-04 19:06:41 +00:00
// Output the header that the server has started
2022-11-29 14:07:04 +00:00
if ! c . logFlags . flagCombineLogs {
2018-06-15 18:47:37 +00:00
c . UI . Output ( "==> Vault server started! Log data will stream in below:\n" )
}
2017-09-22 00:51:12 +00:00
// Inform any tests that the server is ready
select {
case c . startedCh <- struct { } { } :
default :
}
2015-04-04 19:06:41 +00:00
// Release the log gate.
2020-09-28 21:06:49 +00:00
c . flushLog ( )
2015-04-04 19:06:41 +00:00
2017-09-16 21:09:37 +00:00
// Write out the PID to the file now that server has successfully started
if err := c . storePidFile ( config . PidFile ) ; err != nil {
2017-09-20 20:05:00 +00:00
c . UI . Error ( fmt . Sprintf ( "Error storing PID: %s" , err ) )
2017-09-16 21:09:37 +00:00
return 1
}
2021-05-04 19:47:16 +00:00
// Notify systemd that the server is ready (if applicable)
c . notifySystemd ( systemd . SdNotifyReady )
2017-09-16 21:09:37 +00:00
defer func ( ) {
if err := c . removePidFile ( config . PidFile ) ; err != nil {
2017-09-20 20:05:00 +00:00
c . UI . Error ( fmt . Sprintf ( "Error deleting the PID file: %s" , err ) )
2017-09-16 21:09:37 +00:00
}
} ( )
2020-02-15 02:07:31 +00:00
var coreShutdownDoneCh <- chan struct { }
if c . flagExitOnCoreShutdown {
coreShutdownDoneCh = core . ShutdownDone ( )
}
2016-08-01 15:58:45 +00:00
// Wait for shutdown
shutdownTriggered := false
2020-02-15 02:07:31 +00:00
retCode := 0
2016-08-01 15:58:45 +00:00
2016-03-11 22:01:26 +00:00
for ! shutdownTriggered {
2016-03-11 21:46:56 +00:00
select {
2020-02-15 02:07:31 +00:00
case <- coreShutdownDoneCh :
c . UI . Output ( "==> Vault core was shut down" )
retCode = 1
shutdownTriggered = true
2016-03-11 21:46:56 +00:00
case <- c . ShutdownCh :
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault shutdown triggered" )
2016-03-11 21:46:56 +00:00
shutdownTriggered = true
case <- c . SighupCh :
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault reload triggered" )
2018-09-05 19:52:54 +00:00
2021-05-04 19:47:16 +00:00
// Notify systemd that the server is reloading config
c . notifySystemd ( systemd . SdNotifyReloading )
2018-09-05 19:52:54 +00:00
// Check for new log level
var config * server . Config
2022-04-01 14:34:27 +00:00
var configErrors [ ] configutil . ConfigError
2018-09-05 19:52:54 +00:00
for _ , path := range c . flagConfigs {
2019-07-18 19:59:27 +00:00
current , err := server . LoadConfig ( path )
2018-09-05 19:52:54 +00:00
if err != nil {
c . logger . Error ( "could not reload config" , "path" , path , "error" , err )
goto RUNRELOADFUNCS
}
2022-04-01 14:34:27 +00:00
configErrors = append ( configErrors , current . Validate ( path ) ... )
2018-09-05 19:52:54 +00:00
if config == nil {
config = current
} else {
config = config . Merge ( current )
}
}
// Ensure at least one config was found.
if config == nil {
c . logger . Error ( "no config found at reload time" )
goto RUNRELOADFUNCS
}
2022-04-01 14:34:27 +00:00
// reporting Errors found in the config
for _ , cErr := range configErrors {
c . logger . Warn ( cErr . String ( ) )
}
2019-10-08 17:57:15 +00:00
core . SetConfig ( config )
2021-10-13 15:06:33 +00:00
// reloading custom response headers to make sure we have
// the most up to date headers after reloading the config file
if err = core . ReloadCustomResponseHeaders ( ) ; err != nil {
c . logger . Error ( err . Error ( ) )
}
2021-12-08 22:34:42 +00:00
// Setting log request with the new value in the config after reload
core . ReloadLogRequestsLevel ( )
2022-09-06 18:11:04 +00:00
// reloading HCP link
hcpLink , err = c . reloadHCPLink ( hcpLink , config , core , hcpLogger )
if err != nil {
c . logger . Error ( err . Error ( ) )
}
2022-11-29 14:07:04 +00:00
// Reload log level for loggers
2018-09-05 19:52:54 +00:00
if config . LogLevel != "" {
2022-11-29 14:07:04 +00:00
level , err := loghelper . ParseLogLevel ( config . LogLevel )
if err != nil {
2018-09-05 19:52:54 +00:00
c . logger . Error ( "unknown log level found on reload" , "level" , config . LogLevel )
goto RUNRELOADFUNCS
}
core . SetLogLevel ( level )
}
RUNRELOADFUNCS :
2017-09-22 00:51:12 +00:00
if err := c . Reload ( c . reloadFuncsLock , c . reloadFuncs , c . flagConfigs ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Error(s) were encountered during reload: %s" , err ) )
2016-03-11 21:46:56 +00:00
}
2019-03-15 13:27:53 +00:00
2021-06-04 17:24:35 +00:00
// Reload license file
2021-06-11 16:08:19 +00:00
if err = vault . LicenseReload ( core ) ; err != nil {
c . UI . Error ( err . Error ( ) )
}
select {
case c . licenseReloadedCh <- err :
default :
2021-06-04 17:24:35 +00:00
}
2022-02-21 14:55:44 +00:00
// Let the managedKeyRegistry react to configuration changes (i.e.
// changes in kms_libraries)
core . ReloadManagedKeyRegistryConfig ( )
2022-05-03 12:34:11 +00:00
// Notify systemd that the server has completed reloading config
c . notifySystemd ( systemd . SdNotifyReady )
2019-03-15 13:27:53 +00:00
case <- c . SigUSR2Ch :
2021-04-16 19:55:05 +00:00
logWriter := c . logger . StandardWriter ( & hclog . StandardLoggerOptions { } )
pprof . Lookup ( "goroutine" ) . WriteTo ( logWriter , 2 )
2022-11-15 17:03:17 +00:00
if os . Getenv ( "VAULT_STACKTRACE_WRITE_TO_FILE" ) != "" {
c . logger . Info ( "Writing stacktrace to file" )
dir := ""
path := os . Getenv ( "VAULT_STACKTRACE_FILE_PATH" )
if path != "" {
if _ , err := os . Stat ( path ) ; err != nil {
c . logger . Error ( "Checking stacktrace path failed" , "error" , err )
continue
}
dir = path
} else {
dir , err = os . MkdirTemp ( "" , "vault-stacktrace" )
if err != nil {
c . logger . Error ( "Could not create temporary directory for stacktrace" , "error" , err )
continue
}
}
f , err := os . CreateTemp ( dir , "stacktrace" )
if err != nil {
c . logger . Error ( "Could not create stacktrace file" , "error" , err )
continue
}
if err := pprof . Lookup ( "goroutine" ) . WriteTo ( f , 2 ) ; err != nil {
f . Close ( )
c . logger . Error ( "Could not write stacktrace to file" , "error" , err )
continue
}
c . logger . Info ( fmt . Sprintf ( "Wrote stacktrace to: %s" , f . Name ( ) ) )
f . Close ( )
}
2016-03-11 21:46:56 +00:00
}
2015-06-18 01:24:56 +00:00
}
2021-05-04 19:47:16 +00:00
// Notify systemd that the server is shutting down
c . notifySystemd ( systemd . SdNotifyStopping )
2016-04-14 01:12:58 +00:00
2020-02-15 02:07:31 +00:00
// Stop the listeners so that we don't process further client requests.
c . cleanupGuard . Do ( listenerCloseFunc )
2022-09-06 18:11:04 +00:00
if hcpLink != nil {
if err := hcpLink . Shutdown ( ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Error with HCP Link shutdown: %v" , err . Error ( ) ) )
}
}
2021-04-29 18:32:41 +00:00
// Finalize will wait until after Vault is sealed, which means the
2020-02-15 02:07:31 +00:00
// request forwarding listeners will also be closed (and also
// waited for).
if err := core . Shutdown ( ) ; err != nil {
c . UI . Error ( fmt . Sprintf ( "Error with core shutdown: %s" , err ) )
}
2016-08-01 15:15:25 +00:00
// Wait for dependent goroutines to complete
2016-07-30 17:17:29 +00:00
c . WaitGroup . Wait ( )
2020-02-15 02:07:31 +00:00
return retCode
2015-03-12 22:21:11 +00:00
}
2022-11-29 14:07:04 +00:00
// configureLogging takes the configuration and attempts to parse config values into 'log' friendly configuration values
// If all goes to plan, a logger is created and setup.
func ( c * ServerCommand ) configureLogging ( config * server . Config ) ( hclog . InterceptLogger , error ) {
// Parse all the log related config
logLevel , err := loghelper . ParseLogLevel ( config . LogLevel )
if err != nil {
return nil , err
}
logFormat , err := loghelper . ParseLogFormat ( config . LogFormat )
if err != nil {
return nil , err
}
logRotateDuration , err := parseutil . ParseDurationSecond ( config . LogRotateDuration )
if err != nil {
return nil , err
}
logRotateBytes , err := parseutil . ParseInt ( config . LogRotateBytes )
if err != nil {
return nil , err
}
logRotateMaxFiles , err := parseutil . ParseInt ( config . LogRotateMaxFiles )
if err != nil {
return nil , err
}
logCfg := & loghelper . LogConfig {
Name : "vault" ,
LogLevel : logLevel ,
LogFormat : logFormat ,
LogFilePath : config . LogFile ,
LogRotateDuration : logRotateDuration ,
LogRotateBytes : int ( logRotateBytes ) ,
LogRotateMaxFiles : int ( logRotateMaxFiles ) ,
}
return loghelper . Setup ( logCfg , c . logWriter )
}
2022-12-08 20:02:18 +00:00
func ( c * ServerCommand ) reloadHCPLink ( hcpLinkVault * hcp_link . HCPLinkVault , conf * server . Config , core * vault . Core , hcpLogger hclog . Logger ) ( * hcp_link . HCPLinkVault , error ) {
2022-09-06 18:11:04 +00:00
// trigger a shutdown
if hcpLinkVault != nil {
err := hcpLinkVault . Shutdown ( )
if err != nil {
return nil , err
}
}
if conf . HCPLinkConf == nil {
// if cloud stanza is not configured, we should not show anything
// in the seal-status related to HCP link
core . SetHCPLinkStatus ( "" , "" )
return nil , nil
}
// starting HCP link
hcpLink , err := hcp_link . NewHCPLink ( conf . HCPLinkConf , core , hcpLogger )
if err != nil {
return nil , fmt . Errorf ( "failed to restart HCP Link and it is no longer running, %w" , err )
}
return hcpLink , nil
}
2021-05-04 19:47:16 +00:00
func ( c * ServerCommand ) notifySystemd ( status string ) {
sent , err := systemd . SdNotify ( false , status )
if err != nil {
c . logger . Error ( "error notifying systemd" , "error" , err )
} else {
if sent {
c . logger . Debug ( "sent systemd notification" , "notification" , status )
} else {
c . logger . Debug ( "would have sent systemd notification (systemd not present)" , "notification" , status )
}
}
}
2017-07-31 15:28:06 +00:00
func ( c * ServerCommand ) enableDev ( core * vault . Core , coreConfig * vault . CoreConfig ) ( * vault . InitResult , error ) {
2018-09-18 03:03:00 +00:00
ctx := namespace . ContextWithNamespace ( context . Background ( ) , namespace . RootNamespace )
2017-09-21 19:23:29 +00:00
var recoveryConfig * vault . SealConfig
barrierConfig := & vault . SealConfig {
SecretShares : 1 ,
SecretThreshold : 1 ,
}
2018-01-19 08:44:06 +00:00
if core . SealAccess ( ) . RecoveryKeySupported ( ) {
2017-09-21 19:23:29 +00:00
recoveryConfig = & vault . SealConfig {
2016-09-13 22:42:24 +00:00
SecretShares : 1 ,
SecretThreshold : 1 ,
2017-09-21 19:23:29 +00:00
}
2015-03-31 23:44:47 +00:00
}
2020-01-11 01:39:52 +00:00
if core . SealAccess ( ) . StoredKeysSupported ( ) != vaultseal . StoredKeysNotSupported {
2017-09-21 19:23:29 +00:00
barrierConfig . StoredShares = 1
}
2015-03-31 23:44:47 +00:00
2017-09-21 19:23:29 +00:00
// Initialize it with a basic single key
2018-01-19 06:44:44 +00:00
init , err := core . Initialize ( ctx , & vault . InitParams {
2017-09-21 19:23:29 +00:00
BarrierConfig : barrierConfig ,
RecoveryConfig : recoveryConfig ,
} )
2015-03-31 23:44:47 +00:00
if err != nil {
return nil , err
}
2017-09-21 19:23:29 +00:00
// Handle unseal with stored keys
2020-01-11 01:39:52 +00:00
if core . SealAccess ( ) . StoredKeysSupported ( ) == vaultseal . StoredKeysSupportedGeneric {
2018-01-19 06:44:44 +00:00
err := core . UnsealWithStoredKeys ( ctx )
2017-09-21 19:23:29 +00:00
if err != nil {
return nil , err
}
} else {
// Copy the key so that it can be zeroed
key := make ( [ ] byte , len ( init . SecretShares [ 0 ] ) )
copy ( key , init . SecretShares [ 0 ] )
// Unseal the core
unsealed , err := core . Unseal ( key )
if err != nil {
return nil , err
}
if ! unsealed {
return nil , fmt . Errorf ( "failed to unseal Vault for dev mode" )
}
2015-03-31 23:44:47 +00:00
}
2017-07-31 22:25:27 +00:00
isLeader , _ , _ , err := core . Leader ( )
2016-08-15 13:42:42 +00:00
if err != nil && err != vault . ErrHANotEnabled {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "failed to check active status: %w" , err )
2016-08-15 13:42:42 +00:00
}
if err == nil {
leaderCount := 5
for ! isLeader {
if leaderCount == 0 {
buf := make ( [ ] byte , 1 << 16 )
runtime . Stack ( buf , true )
2021-09-30 11:33:14 +00:00
return nil , fmt . Errorf ( "failed to get active status after five seconds; call stack is\n%s" , buf )
2016-08-15 13:42:42 +00:00
}
time . Sleep ( 1 * time . Second )
2017-07-31 22:25:27 +00:00
isLeader , _ , _ , err = core . Leader ( )
2016-08-15 13:42:42 +00:00
if err != nil {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "failed to check active status: %w" , err )
2016-08-15 13:42:42 +00:00
}
leaderCount --
}
}
2017-09-21 19:23:29 +00:00
// Generate a dev root token if one is provided in the flag
2017-07-31 15:28:06 +00:00
if coreConfig . DevToken != "" {
2016-03-02 16:53:23 +00:00
req := & logical . Request {
2016-08-19 20:45:17 +00:00
ID : "dev-gen-root" ,
2016-03-02 16:53:23 +00:00
Operation : logical . UpdateOperation ,
ClientToken : init . RootToken ,
Path : "auth/token/create" ,
Data : map [ string ] interface { } {
2017-07-31 15:28:06 +00:00
"id" : coreConfig . DevToken ,
2016-03-02 16:53:23 +00:00
"policies" : [ ] string { "root" } ,
"no_parent" : true ,
"no_default_policy" : true ,
} ,
}
2018-09-18 03:03:00 +00:00
resp , err := core . HandleRequest ( ctx , req )
2016-03-02 16:53:23 +00:00
if err != nil {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "failed to create root token with ID %q: %w" , coreConfig . DevToken , err )
2016-03-02 16:53:23 +00:00
}
if resp == nil {
2018-04-05 15:49:21 +00:00
return nil , fmt . Errorf ( "nil response when creating root token with ID %q" , coreConfig . DevToken )
2016-03-02 16:53:23 +00:00
}
if resp . Auth == nil {
2018-04-05 15:49:21 +00:00
return nil , fmt . Errorf ( "nil auth when creating root token with ID %q" , coreConfig . DevToken )
2016-03-02 16:53:23 +00:00
}
init . RootToken = resp . Auth . ClientToken
2016-08-19 20:45:17 +00:00
req . ID = "dev-revoke-init-root"
2016-03-02 16:53:23 +00:00
req . Path = "auth/token/revoke-self"
req . Data = nil
2021-09-30 11:33:14 +00:00
_ , err = core . HandleRequest ( ctx , req )
2016-03-02 16:53:23 +00:00
if err != nil {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "failed to revoke initial root token: %w" , err )
2016-03-02 16:53:23 +00:00
}
}
2015-03-31 23:44:47 +00:00
// Set the token
2019-07-24 16:41:07 +00:00
if ! c . flagDevNoStoreToken {
tokenHelper , err := c . TokenHelper ( )
if err != nil {
return nil , err
}
if err := tokenHelper . Store ( init . RootToken ) ; err != nil {
return nil , err
}
2015-03-31 23:44:47 +00:00
}
2019-02-14 19:55:32 +00:00
kvVer := "2"
2019-03-04 22:11:56 +00:00
if c . flagDevKVV1 || c . flagDevLeasedKV {
2019-02-14 19:55:32 +00:00
kvVer = "1"
}
req := & logical . Request {
Operation : logical . UpdateOperation ,
ClientToken : init . RootToken ,
Path : "sys/mounts/secret" ,
Data : map [ string ] interface { } {
"type" : "kv" ,
"path" : "secret/" ,
"description" : "key/value secret storage" ,
"options" : map [ string ] string {
"version" : kvVer ,
2018-04-09 19:35:49 +00:00
} ,
2019-02-14 19:55:32 +00:00
} ,
}
resp , err := core . HandleRequest ( ctx , req )
if err != nil {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "error creating default K/V store: %w" , err )
2019-02-14 19:55:32 +00:00
}
if resp . IsError ( ) {
2021-06-02 13:22:31 +00:00
return nil , fmt . Errorf ( "failed to create default K/V store: %w" , resp . Error ( ) )
2018-04-09 19:35:49 +00:00
}
2015-03-31 23:44:47 +00:00
return init , nil
}
2017-12-11 23:02:35 +00:00
func ( c * ServerCommand ) enableThreeNodeDevCluster ( base * vault . CoreConfig , info map [ string ] string , infoKeys [ ] string , devListenAddress , tempDir string ) int {
2017-08-01 18:07:08 +00:00
testCluster := vault . NewTestCluster ( & testing . RuntimeT { } , base , & vault . TestClusterOptions {
2017-07-31 15:28:06 +00:00
HandlerFunc : vaulthttp . Handler ,
2017-09-22 00:51:12 +00:00
BaseListenAddress : c . flagDevListenAddr ,
2018-04-03 00:46:59 +00:00
Logger : c . logger ,
2017-12-11 23:02:35 +00:00
TempDir : tempDir ,
2017-07-31 15:28:06 +00:00
} )
defer c . cleanupGuard . Do ( testCluster . Cleanup )
info [ "cluster parameters path" ] = testCluster . TempDir
2017-11-10 21:33:16 +00:00
infoKeys = append ( infoKeys , "cluster parameters path" )
2017-07-31 15:28:06 +00:00
for i , core := range testCluster . Cores {
2018-04-04 20:15:07 +00:00
info [ fmt . Sprintf ( "node %d api address" , i ) ] = fmt . Sprintf ( "https://%s" , core . Listeners [ 0 ] . Address . String ( ) )
infoKeys = append ( infoKeys , fmt . Sprintf ( "node %d api address" , i ) )
2017-07-31 15:28:06 +00:00
}
infoKeys = append ( infoKeys , "version" )
verInfo := version . GetVersion ( )
info [ "version" ] = verInfo . FullVersionNumber ( false )
if verInfo . Revision != "" {
info [ "version sha" ] = strings . Trim ( verInfo . Revision , "'" )
infoKeys = append ( infoKeys , "version sha" )
}
2020-05-26 16:28:51 +00:00
2017-07-31 15:28:06 +00:00
infoKeys = append ( infoKeys , "cgo" )
info [ "cgo" ] = "disabled"
if version . CgoEnabled {
info [ "cgo" ] = "enabled"
}
2020-05-26 16:28:51 +00:00
infoKeys = append ( infoKeys , "go version" )
info [ "go version" ] = runtime . Version ( )
2022-02-17 18:03:57 +00:00
fipsStatus := getFIPSInfoKey ( )
if fipsStatus != "" {
infoKeys = append ( infoKeys , "fips" )
info [ "fips" ] = fipsStatus
}
2017-07-31 15:28:06 +00:00
// Server configuration output
padding := 24
2020-05-26 16:28:51 +00:00
2017-07-31 15:28:06 +00:00
sort . Strings ( infoKeys )
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault server configuration:\n" )
2020-05-26 16:28:51 +00:00
2017-07-31 15:28:06 +00:00
for _ , k := range infoKeys {
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2017-07-31 15:28:06 +00:00
"%s%s: %s" ,
strings . Repeat ( " " , padding - len ( k ) ) ,
strings . Title ( k ) ,
info [ k ] ) )
}
2020-05-26 16:28:51 +00:00
2017-09-22 00:51:12 +00:00
c . UI . Output ( "" )
2017-07-31 15:28:06 +00:00
for _ , core := range testCluster . Cores {
2022-11-29 19:38:33 +00:00
core . Server . Handler = vaulthttp . Handler . Handler ( & vault . HandlerProperties {
2018-07-06 19:44:56 +00:00
Core : core . Core ,
} )
2017-07-31 15:28:06 +00:00
core . SetClusterHandler ( core . Server . Handler )
}
testCluster . Start ( )
2018-09-18 03:03:00 +00:00
ctx := namespace . ContextWithNamespace ( context . Background ( ) , namespace . RootNamespace )
2017-07-31 15:28:06 +00:00
if base . DevToken != "" {
req := & logical . Request {
ID : "dev-gen-root" ,
Operation : logical . UpdateOperation ,
ClientToken : testCluster . RootToken ,
Path : "auth/token/create" ,
Data : map [ string ] interface { } {
"id" : base . DevToken ,
"policies" : [ ] string { "root" } ,
"no_parent" : true ,
"no_default_policy" : true ,
} ,
}
2018-09-18 03:03:00 +00:00
resp , err := testCluster . Cores [ 0 ] . HandleRequest ( ctx , req )
2017-07-31 15:28:06 +00:00
if err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "failed to create root token with ID %s: %s" , base . DevToken , err ) )
2017-07-31 15:28:06 +00:00
return 1
}
if resp == nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "nil response when creating root token with ID %s" , base . DevToken ) )
2017-07-31 15:28:06 +00:00
return 1
}
if resp . Auth == nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "nil auth when creating root token with ID %s" , base . DevToken ) )
2017-07-31 15:28:06 +00:00
return 1
}
testCluster . RootToken = resp . Auth . ClientToken
req . ID = "dev-revoke-init-root"
req . Path = "auth/token/revoke-self"
req . Data = nil
2021-09-30 11:33:14 +00:00
_ , err = testCluster . Cores [ 0 ] . HandleRequest ( ctx , req )
2017-07-31 15:28:06 +00:00
if err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf ( "failed to revoke initial root token: %s" , err ) )
2017-07-31 15:28:06 +00:00
return 1
}
}
// Set the token
tokenHelper , err := c . TokenHelper ( )
if err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error getting token helper: %s" , err ) )
2017-07-31 15:28:06 +00:00
return 1
}
if err := tokenHelper . Store ( testCluster . RootToken ) ; err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error storing in token helper: %s" , err ) )
2017-07-31 15:28:06 +00:00
return 1
}
2022-04-01 16:57:38 +00:00
if err := ioutil . WriteFile ( filepath . Join ( testCluster . TempDir , "root_token" ) , [ ] byte ( testCluster . RootToken ) , 0 o600 ) ; err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error writing token to tempfile: %s" , err ) )
2017-07-31 15:28:06 +00:00
return 1
}
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2017-07-31 15:28:06 +00:00
"==> Three node dev mode is enabled\n\n" +
"The unseal key and root token are reproduced below in case you\n" +
"want to seal/unseal the Vault or play with authentication.\n" ,
) )
for i , key := range testCluster . BarrierKeys {
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2017-07-31 15:28:06 +00:00
"Unseal Key %d: %s" ,
2017-08-01 15:12:45 +00:00
i + 1 , base64 . StdEncoding . EncodeToString ( key ) ,
2017-07-31 15:28:06 +00:00
) )
}
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2017-07-31 15:28:06 +00:00
"\nRoot Token: %s\n" , testCluster . RootToken ,
) )
2017-09-22 00:51:12 +00:00
c . UI . Output ( fmt . Sprintf (
2017-08-01 15:50:41 +00:00
"\nUseful env vars:\n" +
"VAULT_TOKEN=%s\n" +
"VAULT_ADDR=%s\n" +
"VAULT_CACERT=%s/ca_cert.pem\n" ,
testCluster . RootToken ,
testCluster . Cores [ 0 ] . Client . Address ( ) ,
testCluster . TempDir ,
) )
2017-07-31 15:28:06 +00:00
// Output the header that the server has started
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault server started! Log data will stream in below:\n" )
// Inform any tests that the server is ready
select {
case c . startedCh <- struct { } { } :
default :
}
2017-07-31 15:28:06 +00:00
// Release the log gate.
2020-09-28 21:06:49 +00:00
c . flushLog ( )
2017-07-31 15:28:06 +00:00
// Wait for shutdown
shutdownTriggered := false
for ! shutdownTriggered {
select {
case <- c . ShutdownCh :
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault shutdown triggered" )
2017-07-31 15:28:06 +00:00
2018-03-20 18:54:10 +00:00
// Stop the listeners so that we don't process further client requests.
2017-07-31 15:28:06 +00:00
c . cleanupGuard . Do ( testCluster . Cleanup )
2021-04-29 18:32:41 +00:00
// Finalize will wait until after Vault is sealed, which means the
2017-07-31 15:28:06 +00:00
// request forwarding listeners will also be closed (and also
// waited for).
for _ , core := range testCluster . Cores {
if err := core . Shutdown ( ) ; err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error with core shutdown: %s" , err ) )
2017-07-31 15:28:06 +00:00
}
}
shutdownTriggered = true
case <- c . SighupCh :
2017-09-22 00:51:12 +00:00
c . UI . Output ( "==> Vault reload triggered" )
2017-07-31 15:28:06 +00:00
for _ , core := range testCluster . Cores {
if err := c . Reload ( core . ReloadFuncsLock , core . ReloadFuncs , nil ) ; err != nil {
2017-09-22 00:51:12 +00:00
c . UI . Error ( fmt . Sprintf ( "Error(s) were encountered during reload: %s" , err ) )
2017-07-31 15:28:06 +00:00
}
}
}
}
return 0
}
2018-03-28 21:36:55 +00:00
// addPlugin adds any plugins to the catalog
func ( c * ServerCommand ) addPlugin ( path , token string , core * vault . Core ) error {
// Get the sha256 of the file at the given path.
pluginSum := func ( p string ) ( string , error ) {
hasher := sha256 . New ( )
f , err := os . Open ( p )
if err != nil {
return "" , err
}
defer f . Close ( )
if _ , err := io . Copy ( hasher , f ) ; err != nil {
return "" , err
}
return hex . EncodeToString ( hasher . Sum ( nil ) ) , nil
}
// Mount any test plugins. We do this explicitly before we inform tests of
// a completely booted server intentionally.
sha256sum , err := pluginSum ( path )
if err != nil {
return err
}
// Default the name to the basename of the binary
name := filepath . Base ( path )
// File a request against core to enable the plugin
req := & logical . Request {
Operation : logical . UpdateOperation ,
ClientToken : token ,
2018-11-07 01:21:24 +00:00
Path : fmt . Sprintf ( "sys/plugins/catalog/%s" , name ) ,
2018-03-28 21:36:55 +00:00
Data : map [ string ] interface { } {
"sha256" : sha256sum ,
"command" : name ,
} ,
}
2018-09-18 03:03:00 +00:00
ctx := namespace . ContextWithNamespace ( context . Background ( ) , namespace . RootNamespace )
if _ , err := core . HandleRequest ( ctx , req ) ; err != nil {
2018-03-28 21:36:55 +00:00
return err
}
return nil
}
2016-08-15 13:42:42 +00:00
// detectRedirect is used to attempt redirect address detection
func ( c * ServerCommand ) detectRedirect ( detect physical . RedirectDetect ,
2022-06-08 21:15:28 +00:00
config * server . Config ,
) ( string , error ) {
2015-05-02 22:57:40 +00:00
// Get the hostname
host , err := detect . DetectHostAddr ( )
if err != nil {
return "" , err
}
2015-12-22 20:40:36 +00:00
// set [] for ipv6 addresses
if strings . Contains ( host , ":" ) && ! strings . Contains ( host , "]" ) {
host = "[" + host + "]"
}
2015-05-02 22:57:40 +00:00
// Default the port and scheme
scheme := "https"
port := 8200
// Attempt to detect overrides
for _ , list := range config . Listeners {
// Only attempt TCP
if list . Type != "tcp" {
continue
}
// Check if TLS is disabled
2020-05-14 13:19:27 +00:00
if list . TLSDisable {
scheme = "http"
2015-05-02 22:57:40 +00:00
}
// Check for address override
2020-05-14 13:19:27 +00:00
addr := list . Address
if addr == "" {
2015-05-02 22:57:40 +00:00
addr = "127.0.0.1:8200"
}
// Check for localhost
hostStr , portStr , err := net . SplitHostPort ( addr )
if err != nil {
continue
}
if hostStr == "127.0.0.1" {
host = hostStr
}
// Check for custom port
listPort , err := strconv . Atoi ( portStr )
if err != nil {
continue
}
port = listPort
}
// Build a URL
url := & url . URL {
Scheme : scheme ,
Host : fmt . Sprintf ( "%s:%d" , host , port ) ,
}
// Return the URL string
return url . String ( ) , nil
}
2020-02-15 19:58:05 +00:00
func ( c * ServerCommand ) Reload ( lock * sync . RWMutex , reloadFuncs * map [ string ] [ ] reloadutil . ReloadFunc , configPath [ ] string ) error {
2017-07-31 15:28:06 +00:00
lock . RLock ( )
defer lock . RUnlock ( )
2016-09-30 19:04:50 +00:00
var reloadErrors * multierror . Error
2017-07-31 15:28:06 +00:00
for k , relFuncs := range * reloadFuncs {
switch {
case strings . HasPrefix ( k , "listener|" ) :
for _ , relFunc := range relFuncs {
if relFunc != nil {
2020-05-14 13:19:27 +00:00
if err := relFunc ( ) ; err != nil {
2021-06-02 13:22:31 +00:00
reloadErrors = multierror . Append ( reloadErrors , fmt . Errorf ( "error encountered reloading listener: %w" , err ) )
2017-07-31 15:28:06 +00:00
}
}
2016-09-30 19:04:50 +00:00
}
2017-07-31 15:28:06 +00:00
case strings . HasPrefix ( k , "audit_file|" ) :
for _ , relFunc := range relFuncs {
if relFunc != nil {
2020-05-14 13:19:27 +00:00
if err := relFunc ( ) ; err != nil {
2021-06-02 13:22:31 +00:00
reloadErrors = multierror . Append ( reloadErrors , fmt . Errorf ( "error encountered reloading file audit device at path %q: %w" , strings . TrimPrefix ( k , "audit_file|" ) , err ) )
2017-07-31 15:28:06 +00:00
}
2016-09-30 19:04:50 +00:00
}
2016-03-11 21:46:56 +00:00
}
}
}
2017-09-22 00:51:12 +00:00
// Send a message that we reloaded. This prevents "guessing" sleep times
// in tests.
select {
case c . reloadedCh <- struct { } { } :
default :
2017-08-24 22:23:40 +00:00
}
2017-09-20 20:05:00 +00:00
return reloadErrors . ErrorOrNil ( )
2017-08-24 22:23:40 +00:00
}
2017-09-16 21:09:37 +00:00
// storePidFile is used to write out our PID to a file if necessary
func ( c * ServerCommand ) storePidFile ( pidPath string ) error {
// Quit fast if no pidfile
if pidPath == "" {
return nil
}
// Open the PID file
2022-04-01 16:57:38 +00:00
pidFile , err := os . OpenFile ( pidPath , os . O_CREATE | os . O_WRONLY | os . O_TRUNC , 0 o600 )
2017-09-16 21:09:37 +00:00
if err != nil {
2021-06-02 13:22:31 +00:00
return fmt . Errorf ( "could not open pid file: %w" , err )
2017-09-16 21:09:37 +00:00
}
defer pidFile . Close ( )
// Write out the PID
pid := os . Getpid ( )
_ , err = pidFile . WriteString ( fmt . Sprintf ( "%d" , pid ) )
if err != nil {
2021-06-02 13:22:31 +00:00
return fmt . Errorf ( "could not write to pid file: %w" , err )
2017-09-16 21:09:37 +00:00
}
return nil
}
// removePidFile is used to cleanup the PID file if necessary
func ( c * ServerCommand ) removePidFile ( pidPath string ) error {
if pidPath == "" {
return nil
}
return os . Remove ( pidPath )
}
2018-10-23 06:34:02 +00:00
// storageMigrationActive checks and warns against in-progress storage migrations.
2018-10-01 21:35:35 +00:00
// This function will block until storage is available.
2018-10-23 06:34:02 +00:00
func ( c * ServerCommand ) storageMigrationActive ( backend physical . Backend ) bool {
2018-10-01 21:35:35 +00:00
first := true
for {
2018-10-23 06:34:02 +00:00
migrationStatus , err := CheckStorageMigration ( backend )
2018-10-01 21:35:35 +00:00
if err == nil {
if migrationStatus != nil {
startTime := migrationStatus . Start . Format ( time . RFC3339 )
c . UI . Error ( wrapAtLength ( fmt . Sprintf ( "ERROR! Storage migration in progress (started: %s). " +
"Server startup is prevented until the migration completes. Use 'vault operator migrate -reset' " +
"to force clear the migration lock." , startTime ) ) )
return true
}
return false
}
if first {
first = false
2018-10-23 06:34:02 +00:00
c . UI . Warn ( "\nWARNING! Unable to read storage migration status." )
2018-10-01 21:35:35 +00:00
// unexpected state, so stop buffering log messages
2020-09-28 21:06:49 +00:00
c . flushLog ( )
2018-10-01 21:35:35 +00:00
}
2018-10-23 06:34:02 +00:00
c . logger . Warn ( "storage migration check error" , "error" , err . Error ( ) )
2018-10-01 21:35:35 +00:00
select {
case <- time . After ( 2 * time . Second ) :
case <- c . ShutdownCh :
return true
}
}
}
2018-10-23 06:34:02 +00:00
type StorageMigrationStatus struct {
2018-09-25 23:18:22 +00:00
Start time . Time ` json:"start" `
}
2018-10-23 06:34:02 +00:00
func CheckStorageMigration ( b physical . Backend ) ( * StorageMigrationStatus , error ) {
entry , err := b . Get ( context . Background ( ) , storageMigrationLock )
2018-09-25 23:18:22 +00:00
if err != nil {
return nil , err
}
if entry == nil {
return nil , nil
}
2018-10-23 06:34:02 +00:00
var status StorageMigrationStatus
2018-09-25 23:18:22 +00:00
if err := jsonutil . DecodeJSON ( entry . Value , & status ) ; err != nil {
return nil , err
}
return & status , nil
}
2021-05-25 22:23:20 +00:00
// setSeal return barrierSeal, barrierWrapper, unwrapSeal, and all the created seals from the configs so we can close them in Run
// The two errors are the sealConfigError and the regular error
func setSeal ( c * ServerCommand , config * server . Config , infoKeys [ ] string , info map [ string ] string ) ( vault . Seal , wrapping . Wrapper , vault . Seal , [ ] vault . Seal , error , error ) {
var barrierSeal vault . Seal
var unwrapSeal vault . Seal
var sealConfigError error
var wrapper wrapping . Wrapper
var barrierWrapper wrapping . Wrapper
if c . flagDevAutoSeal {
2022-08-23 19:37:16 +00:00
var err error
barrierSeal , err = vault . NewAutoSeal ( vaultseal . NewTestSeal ( nil ) )
if err != nil {
return nil , nil , nil , nil , nil , err
}
2021-05-25 22:23:20 +00:00
return barrierSeal , nil , nil , nil , nil , nil
}
// Handle the case where no seal is provided
switch len ( config . Seals ) {
case 0 :
2022-08-23 19:37:16 +00:00
config . Seals = append ( config . Seals , & configutil . KMS { Type : wrapping . WrapperTypeShamir . String ( ) } )
2021-05-25 22:23:20 +00:00
case 1 :
// If there's only one seal and it's disabled assume they want to
// migrate to a shamir seal and simply didn't provide it
if config . Seals [ 0 ] . Disabled {
2022-08-23 19:37:16 +00:00
config . Seals = append ( config . Seals , & configutil . KMS { Type : wrapping . WrapperTypeShamir . String ( ) } )
2021-05-25 22:23:20 +00:00
}
}
var createdSeals [ ] vault . Seal = make ( [ ] vault . Seal , len ( config . Seals ) )
for _ , configSeal := range config . Seals {
2022-08-23 19:37:16 +00:00
sealType := wrapping . WrapperTypeShamir . String ( )
2021-05-25 22:23:20 +00:00
if ! configSeal . Disabled && os . Getenv ( "VAULT_SEAL_TYPE" ) != "" {
sealType = os . Getenv ( "VAULT_SEAL_TYPE" )
configSeal . Type = sealType
} else {
sealType = configSeal . Type
}
var seal vault . Seal
sealLogger := c . logger . ResetNamed ( fmt . Sprintf ( "seal.%s" , sealType ) )
c . allLoggers = append ( c . allLoggers , sealLogger )
defaultSeal := vault . NewDefaultSeal ( & vaultseal . Access {
2022-08-23 19:37:16 +00:00
Wrapper : aeadwrapper . NewShamirWrapper ( ) ,
2021-05-25 22:23:20 +00:00
} )
var sealInfoKeys [ ] string
sealInfoMap := map [ string ] string { }
wrapper , sealConfigError = configutil . ConfigureWrapper ( configSeal , & sealInfoKeys , & sealInfoMap , sealLogger )
if sealConfigError != nil {
if ! errwrap . ContainsType ( sealConfigError , new ( logical . KeyNotFoundError ) ) {
return barrierSeal , barrierWrapper , unwrapSeal , createdSeals , sealConfigError , fmt . Errorf (
"Error parsing Seal configuration: %s" , sealConfigError )
}
}
if wrapper == nil {
seal = defaultSeal
} else {
2022-08-23 19:37:16 +00:00
var err error
seal , err = vault . NewAutoSeal ( & vaultseal . Access {
2021-05-25 22:23:20 +00:00
Wrapper : wrapper ,
} )
2022-08-23 19:37:16 +00:00
if err != nil {
return nil , nil , nil , nil , nil , err
}
2021-05-25 22:23:20 +00:00
}
infoPrefix := ""
if configSeal . Disabled {
unwrapSeal = seal
infoPrefix = "Old "
} else {
barrierSeal = seal
barrierWrapper = wrapper
}
for _ , k := range sealInfoKeys {
infoKeys = append ( infoKeys , infoPrefix + k )
info [ infoPrefix + k ] = sealInfoMap [ k ]
}
createdSeals = append ( createdSeals , seal )
}
return barrierSeal , barrierWrapper , unwrapSeal , createdSeals , sealConfigError , nil
}
func initHaBackend ( c * ServerCommand , config * server . Config , coreConfig * vault . CoreConfig , backend physical . Backend ) ( bool , error ) {
// Initialize the separate HA storage backend, if it exists
var ok bool
if config . HAStorage != nil {
if config . Storage . Type == storageTypeRaft && config . HAStorage . Type == storageTypeRaft {
return false , fmt . Errorf ( "Raft cannot be set both as 'storage' and 'ha_storage'. Setting 'storage' to 'raft' will automatically set it up for HA operations as well" )
}
if config . Storage . Type == storageTypeRaft {
return false , fmt . Errorf ( "HA storage cannot be declared when Raft is the storage type" )
}
factory , exists := c . PhysicalBackends [ config . HAStorage . Type ]
if ! exists {
return false , fmt . Errorf ( "Unknown HA storage type %s" , config . HAStorage . Type )
}
namedHALogger := c . logger . Named ( "ha." + config . HAStorage . Type )
c . allLoggers = append ( c . allLoggers , namedHALogger )
habackend , err := factory ( config . HAStorage . Config , namedHALogger )
if err != nil {
return false , fmt . Errorf ( "Error initializing HA storage of type %s: %s" , config . HAStorage . Type , err )
}
if coreConfig . HAPhysical , ok = habackend . ( physical . HABackend ) ; ! ok {
return false , fmt . Errorf ( "Specified HA storage does not support HA" )
}
if ! coreConfig . HAPhysical . HAEnabled ( ) {
return false , fmt . Errorf ( "Specified HA storage has HA support disabled; please consult documentation" )
}
coreConfig . RedirectAddr = config . HAStorage . RedirectAddr
disableClustering := config . HAStorage . DisableClustering
if config . HAStorage . Type == storageTypeRaft && disableClustering {
return disableClustering , fmt . Errorf ( "Disable clustering cannot be set to true when Raft is the HA storage type" )
}
if ! disableClustering {
coreConfig . ClusterAddr = config . HAStorage . ClusterAddr
}
} else {
if coreConfig . HAPhysical , ok = backend . ( physical . HABackend ) ; ok {
coreConfig . RedirectAddr = config . Storage . RedirectAddr
disableClustering := config . Storage . DisableClustering
if ( config . Storage . Type == storageTypeRaft ) && disableClustering {
return disableClustering , fmt . Errorf ( "Disable clustering cannot be set to true when Raft is the storage type" )
}
if ! disableClustering {
coreConfig . ClusterAddr = config . Storage . ClusterAddr
}
}
}
return config . DisableClustering , nil
}
func determineRedirectAddr ( c * ServerCommand , coreConfig * vault . CoreConfig , config * server . Config ) error {
var retErr error
if envRA := os . Getenv ( "VAULT_API_ADDR" ) ; envRA != "" {
coreConfig . RedirectAddr = envRA
} else if envRA := os . Getenv ( "VAULT_REDIRECT_ADDR" ) ; envRA != "" {
coreConfig . RedirectAddr = envRA
} else if envAA := os . Getenv ( "VAULT_ADVERTISE_ADDR" ) ; envAA != "" {
coreConfig . RedirectAddr = envAA
}
// Attempt to detect the redirect address, if possible
if coreConfig . RedirectAddr == "" {
c . logger . Warn ( "no `api_addr` value specified in config or in VAULT_API_ADDR; falling back to detection if possible, but this value should be manually set" )
}
var ok bool
var detect physical . RedirectDetect
if coreConfig . HAPhysical != nil && coreConfig . HAPhysical . HAEnabled ( ) {
detect , ok = coreConfig . HAPhysical . ( physical . RedirectDetect )
} else {
detect , ok = coreConfig . Physical . ( physical . RedirectDetect )
}
if ok && coreConfig . RedirectAddr == "" {
redirect , err := c . detectRedirect ( detect , config )
// the following errors did not cause Run to return, so I'm not returning these
// as errors.
if err != nil {
retErr = fmt . Errorf ( "Error detecting api address: %s" , err )
} else if redirect == "" {
retErr = fmt . Errorf ( "Failed to detect api address" )
} else {
coreConfig . RedirectAddr = redirect
}
}
if coreConfig . RedirectAddr == "" && c . flagDev {
2022-07-22 18:04:03 +00:00
protocol := "http"
if c . flagDevTLS {
protocol = "https"
}
coreConfig . RedirectAddr = fmt . Sprintf ( "%s://%s" , protocol , config . Listeners [ 0 ] . Address )
2021-05-25 22:23:20 +00:00
}
return retErr
}
func findClusterAddress ( c * ServerCommand , coreConfig * vault . CoreConfig , config * server . Config , disableClustering bool ) error {
if disableClustering {
coreConfig . ClusterAddr = ""
} else if envCA := os . Getenv ( "VAULT_CLUSTER_ADDR" ) ; envCA != "" {
coreConfig . ClusterAddr = envCA
} else {
var addrToUse string
switch {
case coreConfig . ClusterAddr == "" && coreConfig . RedirectAddr != "" :
addrToUse = coreConfig . RedirectAddr
case c . flagDev :
addrToUse = fmt . Sprintf ( "http://%s" , config . Listeners [ 0 ] . Address )
default :
goto CLUSTER_SYNTHESIS_COMPLETE
}
u , err := url . ParseRequestURI ( addrToUse )
if err != nil {
return fmt . Errorf ( "Error parsing synthesized cluster address %s: %v" , addrToUse , err )
}
host , port , err := net . SplitHostPort ( u . Host )
if err != nil {
// This sucks, as it's a const in the function but not exported in the package
if strings . Contains ( err . Error ( ) , "missing port in address" ) {
host = u . Host
port = "443"
} else {
return fmt . Errorf ( "Error parsing api address: %v" , err )
}
}
nPort , err := strconv . Atoi ( port )
if err != nil {
return fmt . Errorf ( "Error parsing synthesized address; failed to convert %q to a numeric: %v" , port , err )
}
u . Host = net . JoinHostPort ( host , strconv . Itoa ( nPort + 1 ) )
// Will always be TLS-secured
u . Scheme = "https"
coreConfig . ClusterAddr = u . String ( )
}
CLUSTER_SYNTHESIS_COMPLETE :
if coreConfig . RedirectAddr == coreConfig . ClusterAddr && len ( coreConfig . RedirectAddr ) != 0 {
return fmt . Errorf ( "Address %q used for both API and cluster addresses" , coreConfig . RedirectAddr )
}
if coreConfig . ClusterAddr != "" {
2022-01-19 15:56:04 +00:00
rendered , err := configutil . ParseSingleIPTemplate ( coreConfig . ClusterAddr )
if err != nil {
return fmt . Errorf ( "Error parsing cluster address %s: %v" , coreConfig . ClusterAddr , err )
}
coreConfig . ClusterAddr = rendered
2021-05-25 22:23:20 +00:00
// Force https as we'll always be TLS-secured
u , err := url . ParseRequestURI ( coreConfig . ClusterAddr )
if err != nil {
return fmt . Errorf ( "Error parsing cluster address %s: %v" , coreConfig . ClusterAddr , err )
}
u . Scheme = "https"
coreConfig . ClusterAddr = u . String ( )
}
return nil
}
func runUnseal ( c * ServerCommand , core * vault . Core , ctx context . Context ) {
for {
err := core . UnsealWithStoredKeys ( ctx )
if err == nil {
return
}
if vault . IsFatalError ( err ) {
c . logger . Error ( "error unsealing core" , "error" , err )
return
}
c . logger . Warn ( "failed to unseal core" , "error" , err )
select {
case <- c . ShutdownCh :
return
case <- time . After ( 5 * time . Second ) :
}
}
}
func createCoreConfig ( c * ServerCommand , config * server . Config , backend physical . Backend , configSR sr . ServiceRegistration , barrierSeal , unwrapSeal vault . Seal ,
2022-06-08 21:15:28 +00:00
metricsHelper * metricsutil . MetricsHelper , metricSink * metricsutil . ClusterMetricSink , secureRandomReader io . Reader ,
) vault . CoreConfig {
2021-05-25 22:23:20 +00:00
coreConfig := & vault . CoreConfig {
RawConfig : config ,
Physical : backend ,
RedirectAddr : config . Storage . RedirectAddr ,
StorageType : config . Storage . Type ,
HAPhysical : nil ,
ServiceRegistration : configSR ,
Seal : barrierSeal ,
UnwrapSeal : unwrapSeal ,
AuditBackends : c . AuditBackends ,
CredentialBackends : c . CredentialBackends ,
LogicalBackends : c . LogicalBackends ,
Logger : c . logger ,
DisableSentinelTrace : config . DisableSentinelTrace ,
DisableCache : config . DisableCache ,
DisableMlock : config . DisableMlock ,
MaxLeaseTTL : config . MaxLeaseTTL ,
DefaultLeaseTTL : config . DefaultLeaseTTL ,
ClusterName : config . ClusterName ,
CacheSize : config . CacheSize ,
PluginDirectory : config . PluginDirectory ,
2022-04-04 16:45:41 +00:00
PluginFileUid : config . PluginFileUid ,
PluginFilePermissions : config . PluginFilePermissions ,
2021-05-25 22:23:20 +00:00
EnableUI : config . EnableUI ,
EnableRaw : config . EnableRawEndpoint ,
DisableSealWrap : config . DisableSealWrap ,
DisablePerformanceStandby : config . DisablePerformanceStandby ,
DisableIndexing : config . DisableIndexing ,
AllLoggers : c . allLoggers ,
BuiltinRegistry : builtinplugins . Registry ,
DisableKeyEncodingChecks : config . DisablePrintableCheck ,
MetricsHelper : metricsHelper ,
MetricSink : metricSink ,
SecureRandomReader : secureRandomReader ,
EnableResponseHeaderHostname : config . EnableResponseHeaderHostname ,
EnableResponseHeaderRaftNodeID : config . EnableResponseHeaderRaftNodeID ,
2021-06-01 12:42:30 +00:00
License : config . License ,
LicensePath : config . LicensePath ,
2022-02-17 19:43:07 +00:00
DisableSSCTokens : config . DisableSSCTokens ,
2021-05-25 22:23:20 +00:00
}
2022-04-04 16:45:41 +00:00
2021-05-25 22:23:20 +00:00
if c . flagDev {
coreConfig . EnableRaw = true
coreConfig . DevToken = c . flagDevRootTokenID
if c . flagDevLeasedKV {
coreConfig . LogicalBackends [ "kv" ] = vault . LeasedPassthroughBackendFactory
}
if c . flagDevPluginDir != "" {
coreConfig . PluginDirectory = c . flagDevPluginDir
}
if c . flagDevLatency > 0 {
injectLatency := time . Duration ( c . flagDevLatency ) * time . Millisecond
if _ , txnOK := backend . ( physical . Transactional ) ; txnOK {
coreConfig . Physical = physical . NewTransactionalLatencyInjector ( backend , injectLatency , c . flagDevLatencyJitter , c . logger )
} else {
coreConfig . Physical = physical . NewLatencyInjector ( backend , injectLatency , c . flagDevLatencyJitter , c . logger )
}
}
}
return * coreConfig
}
func runListeners ( c * ServerCommand , coreConfig * vault . CoreConfig , config * server . Config , configSR sr . ServiceRegistration ) error {
if sd := coreConfig . GetServiceRegistration ( ) ; sd != nil {
if err := configSR . Run ( c . ShutdownCh , c . WaitGroup , coreConfig . RedirectAddr ) ; err != nil {
return fmt . Errorf ( "Error running service_registration of type %s: %s" , config . ServiceRegistration . Type , err )
}
}
return nil
}
2022-07-22 18:04:03 +00:00
func initDevCore ( c * ServerCommand , coreConfig * vault . CoreConfig , config * server . Config , core * vault . Core , certDir string ) error {
2021-05-25 22:23:20 +00:00
if c . flagDev && ! c . flagDevSkipInit {
init , err := c . enableDev ( core , coreConfig )
if err != nil {
return fmt . Errorf ( "Error initializing Dev mode: %s" , err )
}
var plugins , pluginsNotLoaded [ ] string
if c . flagDevPluginDir != "" && c . flagDevPluginInit {
f , err := os . Open ( c . flagDevPluginDir )
if err != nil {
return fmt . Errorf ( "Error reading plugin dir: %s" , err )
}
list , err := f . Readdirnames ( 0 )
f . Close ( )
if err != nil {
return fmt . Errorf ( "Error listing plugins: %s" , err )
}
for _ , name := range list {
path := filepath . Join ( f . Name ( ) , name )
if err := c . addPlugin ( path , init . RootToken , core ) ; err != nil {
if ! errwrap . Contains ( err , vault . ErrPluginBadType . Error ( ) ) {
return fmt . Errorf ( "Error enabling plugin %s: %s" , name , err )
}
pluginsNotLoaded = append ( pluginsNotLoaded , name )
continue
}
plugins = append ( plugins , name )
}
sort . Strings ( plugins )
}
var qw * quiescenceSink
var qwo sync . Once
qw = & quiescenceSink {
t : time . AfterFunc ( 100 * time . Millisecond , func ( ) {
qwo . Do ( func ( ) {
c . logger . DeregisterSink ( qw )
// Print the big dev mode warning!
c . UI . Warn ( wrapAtLength (
"WARNING! dev mode is enabled! In this mode, Vault runs entirely " +
"in-memory and starts unsealed with a single unseal key. The root " +
"token is already authenticated to the CLI, so you can immediately " +
"begin using Vault." ) )
c . UI . Warn ( "" )
2022-07-22 18:04:03 +00:00
c . UI . Warn ( "You may need to set the following environment variables:" )
2021-05-25 22:23:20 +00:00
c . UI . Warn ( "" )
2022-07-22 18:04:03 +00:00
protocol := "http://"
if c . flagDevTLS {
protocol = "https://"
}
endpointURL := protocol + config . Listeners [ 0 ] . Address
2021-05-25 22:23:20 +00:00
if runtime . GOOS == "windows" {
c . UI . Warn ( "PowerShell:" )
c . UI . Warn ( fmt . Sprintf ( " $env:VAULT_ADDR=\"%s\"" , endpointURL ) )
c . UI . Warn ( "cmd.exe:" )
c . UI . Warn ( fmt . Sprintf ( " set VAULT_ADDR=%s" , endpointURL ) )
} else {
c . UI . Warn ( fmt . Sprintf ( " $ export VAULT_ADDR='%s'" , endpointURL ) )
}
2022-07-22 18:04:03 +00:00
if c . flagDevTLS {
if runtime . GOOS == "windows" {
c . UI . Warn ( "PowerShell:" )
c . UI . Warn ( fmt . Sprintf ( " $env:VAULT_CACERT=\"%s/vault-ca.pem\"" , certDir ) )
c . UI . Warn ( "cmd.exe:" )
c . UI . Warn ( fmt . Sprintf ( " set VAULT_CACERT=%s/vault-ca.pem" , certDir ) )
} else {
c . UI . Warn ( fmt . Sprintf ( " $ export VAULT_CACERT='%s/vault-ca.pem'" , certDir ) )
}
c . UI . Warn ( "" )
}
2021-05-25 22:23:20 +00:00
// Unseal key is not returned if stored shares is supported
if len ( init . SecretShares ) > 0 {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength (
"The unseal key and root token are displayed below in case you want " +
"to seal/unseal the Vault or re-authenticate." ) )
c . UI . Warn ( "" )
c . UI . Warn ( fmt . Sprintf ( "Unseal Key: %s" , base64 . StdEncoding . EncodeToString ( init . SecretShares [ 0 ] ) ) )
}
if len ( init . RecoveryShares ) > 0 {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength (
"The recovery key and root token are displayed below in case you want " +
"to seal/unseal the Vault or re-authenticate." ) )
c . UI . Warn ( "" )
c . UI . Warn ( fmt . Sprintf ( "Recovery Key: %s" , base64 . StdEncoding . EncodeToString ( init . RecoveryShares [ 0 ] ) ) )
}
c . UI . Warn ( fmt . Sprintf ( "Root Token: %s" , init . RootToken ) )
if len ( plugins ) > 0 {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength (
"The following dev plugins are registered in the catalog:" ) )
for _ , p := range plugins {
c . UI . Warn ( fmt . Sprintf ( " - %s" , p ) )
}
}
if len ( pluginsNotLoaded ) > 0 {
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength (
"The following dev plugins FAILED to be registered in the catalog due to unknown type:" ) )
for _ , p := range pluginsNotLoaded {
c . UI . Warn ( fmt . Sprintf ( " - %s" , p ) )
}
}
c . UI . Warn ( "" )
c . UI . Warn ( wrapAtLength (
"Development mode should NOT be used in production installations!" ) )
c . UI . Warn ( "" )
} )
} ) ,
}
c . logger . RegisterSink ( qw )
}
return nil
}
// Initialize the HTTP servers
func startHttpServers ( c * ServerCommand , core * vault . Core , config * server . Config , lns [ ] listenerutil . Listener ) error {
for _ , ln := range lns {
if ln . Config == nil {
return fmt . Errorf ( "Found nil listener config after parsing" )
}
2021-09-07 22:36:58 +00:00
if err := config2 . IsValidListener ( ln . Config ) ; err != nil {
return err
}
2022-11-29 19:38:33 +00:00
handler := vaulthttp . Handler . Handler ( & vault . HandlerProperties {
2021-05-25 22:23:20 +00:00
Core : core ,
ListenerConfig : ln . Config ,
DisablePrintableCheck : config . DisablePrintableCheck ,
RecoveryMode : c . flagRecovery ,
} )
if len ( ln . Config . XForwardedForAuthorizedAddrs ) > 0 {
handler = vaulthttp . WrapForwardedForHandler ( handler , ln . Config )
}
// server defaults
server := & http . Server {
Handler : handler ,
ReadHeaderTimeout : 10 * time . Second ,
ReadTimeout : 30 * time . Second ,
IdleTimeout : 5 * time . Minute ,
ErrorLog : c . logger . StandardLogger ( nil ) ,
}
// override server defaults with config values for read/write/idle timeouts if configured
if ln . Config . HTTPReadHeaderTimeout > 0 {
server . ReadHeaderTimeout = ln . Config . HTTPReadHeaderTimeout
}
if ln . Config . HTTPReadTimeout > 0 {
server . ReadTimeout = ln . Config . HTTPReadTimeout
}
if ln . Config . HTTPWriteTimeout > 0 {
server . WriteTimeout = ln . Config . HTTPWriteTimeout
}
if ln . Config . HTTPIdleTimeout > 0 {
server . IdleTimeout = ln . Config . HTTPIdleTimeout
}
// server config tests can exit now
if c . flagTestServerConfig {
continue
}
go server . Serve ( ln . Listener )
}
return nil
}
2018-10-23 06:34:02 +00:00
func SetStorageMigration ( b physical . Backend , active bool ) error {
2018-09-25 23:18:22 +00:00
if ! active {
2018-10-23 06:34:02 +00:00
return b . Delete ( context . Background ( ) , storageMigrationLock )
2018-09-25 23:18:22 +00:00
}
2018-10-23 06:34:02 +00:00
status := StorageMigrationStatus {
2018-09-25 23:18:22 +00:00
Start : time . Now ( ) ,
}
enc , err := jsonutil . EncodeJSON ( status )
if err != nil {
return err
}
entry := & physical . Entry {
2018-10-23 06:34:02 +00:00
Key : storageMigrationLock ,
2018-09-25 23:18:22 +00:00
Value : enc ,
}
return b . Put ( context . Background ( ) , entry )
}
2016-08-19 20:45:17 +00:00
type grpclogFaker struct {
2021-09-30 11:33:14 +00:00
logger hclog . Logger
2017-10-10 16:27:51 +00:00
log bool
2016-08-19 20:45:17 +00:00
}
func ( g * grpclogFaker ) Fatal ( args ... interface { } ) {
g . logger . Error ( fmt . Sprint ( args ... ) )
os . Exit ( 1 )
}
func ( g * grpclogFaker ) Fatalf ( format string , args ... interface { } ) {
g . logger . Error ( fmt . Sprintf ( format , args ... ) )
os . Exit ( 1 )
}
func ( g * grpclogFaker ) Fatalln ( args ... interface { } ) {
g . logger . Error ( fmt . Sprintln ( args ... ) )
os . Exit ( 1 )
}
func ( g * grpclogFaker ) Print ( args ... interface { } ) {
2018-04-03 00:46:59 +00:00
if g . log && g . logger . IsDebug ( ) {
g . logger . Debug ( fmt . Sprint ( args ... ) )
2017-10-10 16:27:51 +00:00
}
2016-08-19 20:45:17 +00:00
}
func ( g * grpclogFaker ) Printf ( format string , args ... interface { } ) {
2018-04-03 00:46:59 +00:00
if g . log && g . logger . IsDebug ( ) {
g . logger . Debug ( fmt . Sprintf ( format , args ... ) )
2017-10-10 16:27:51 +00:00
}
2016-08-19 20:45:17 +00:00
}
func ( g * grpclogFaker ) Println ( args ... interface { } ) {
2018-04-03 00:46:59 +00:00
if g . log && g . logger . IsDebug ( ) {
g . logger . Debug ( fmt . Sprintln ( args ... ) )
2017-10-10 16:27:51 +00:00
}
2016-08-19 20:45:17 +00:00
}