Merge pull request #18243 from masonyc/cleanup-unneeded-logger-check

etcd-client: Clean up unnecessary nil Logger check
This commit is contained in:
James Blair 2024-06-28 21:42:11 +12:00 committed by GitHub
commit 1c22e7b36b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -232,12 +232,10 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
} }
err = fileutil.TouchDirAll(lg, dirpath) err = fileutil.TouchDirAll(lg, dirpath)
if err != nil { if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"cannot create cert directory", "cannot create cert directory",
zap.Error(err), zap.Error(err),
) )
}
return info, err return info, err
} }
@ -263,12 +261,10 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128) serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128)
serialNumber, err := rand.Int(rand.Reader, serialNumberLimit) serialNumber, err := rand.Int(rand.Reader, serialNumberLimit)
if err != nil { if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"cannot generate random number", "cannot generate random number",
zap.Error(err), zap.Error(err),
) )
}
return info, err return info, err
} }
@ -284,12 +280,10 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
IsCA: true, IsCA: true,
} }
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"automatically generate certificates", "automatically generate certificates",
zap.Time("certificate-validity-bound-not-after", tmpl.NotAfter), zap.Time("certificate-validity-bound-not-after", tmpl.NotAfter),
) )
}
for _, host := range hosts { for _, host := range hosts {
h, _, _ := net.SplitHostPort(host) h, _, _ := net.SplitHostPort(host)
@ -302,23 +296,19 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
priv, err := ecdsa.GenerateKey(elliptic.P521(), rand.Reader) priv, err := ecdsa.GenerateKey(elliptic.P521(), rand.Reader)
if err != nil { if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"cannot generate ECDSA key", "cannot generate ECDSA key",
zap.Error(err), zap.Error(err),
) )
}
return info, err return info, err
} }
derBytes, err := x509.CreateCertificate(rand.Reader, &tmpl, &tmpl, &priv.PublicKey, priv) derBytes, err := x509.CreateCertificate(rand.Reader, &tmpl, &tmpl, &priv.PublicKey, priv)
if err != nil { if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"cannot generate x509 certificate", "cannot generate x509 certificate",
zap.Error(err), zap.Error(err),
) )
}
return info, err return info, err
} }
@ -333,9 +323,8 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
} }
pem.Encode(certOut, &pem.Block{Type: "CERTIFICATE", Bytes: derBytes}) pem.Encode(certOut, &pem.Block{Type: "CERTIFICATE", Bytes: derBytes})
certOut.Close() certOut.Close()
if info.Logger != nil {
info.Logger.Info("created cert file", zap.String("path", certPath)) info.Logger.Info("created cert file", zap.String("path", certPath))
}
b, err := x509.MarshalECPrivateKey(priv) b, err := x509.MarshalECPrivateKey(priv)
if err != nil { if err != nil {
@ -343,20 +332,16 @@ func SelfCert(lg *zap.Logger, dirpath string, hosts []string, selfSignedCertVali
} }
keyOut, err := os.OpenFile(keyPath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600) keyOut, err := os.OpenFile(keyPath, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0600)
if err != nil { if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"cannot key file", "cannot key file",
zap.String("path", keyPath), zap.String("path", keyPath),
zap.Error(err), zap.Error(err),
) )
}
return info, err return info, err
} }
pem.Encode(keyOut, &pem.Block{Type: "EC PRIVATE KEY", Bytes: b}) pem.Encode(keyOut, &pem.Block{Type: "EC PRIVATE KEY", Bytes: b})
keyOut.Close() keyOut.Close()
if info.Logger != nil {
info.Logger.Info("created key file", zap.String("path", keyPath)) info.Logger.Info("created key file", zap.String("path", keyPath))
}
return SelfCert(lg, dirpath, hosts, selfSignedCertValidity) return SelfCert(lg, dirpath, hosts, selfSignedCertValidity)
} }
@ -489,16 +474,13 @@ func (info TLSInfo) baseConfig() (*tls.Config, error) {
cfg.GetCertificate = func(clientHello *tls.ClientHelloInfo) (cert *tls.Certificate, err error) { cfg.GetCertificate = func(clientHello *tls.ClientHelloInfo) (cert *tls.Certificate, err error) {
cert, err = tlsutil.NewCert(info.CertFile, info.KeyFile, info.parseFunc) cert, err = tlsutil.NewCert(info.CertFile, info.KeyFile, info.parseFunc)
if os.IsNotExist(err) { if os.IsNotExist(err) {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"failed to find peer cert files", "failed to find peer cert files",
zap.String("cert-file", info.CertFile), zap.String("cert-file", info.CertFile),
zap.String("key-file", info.KeyFile), zap.String("key-file", info.KeyFile),
zap.Error(err), zap.Error(err),
) )
}
} else if err != nil { } else if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"failed to create peer certificate", "failed to create peer certificate",
zap.String("cert-file", info.CertFile), zap.String("cert-file", info.CertFile),
@ -506,7 +488,6 @@ func (info TLSInfo) baseConfig() (*tls.Config, error) {
zap.Error(err), zap.Error(err),
) )
} }
}
return cert, err return cert, err
} }
cfg.GetClientCertificate = func(unused *tls.CertificateRequestInfo) (cert *tls.Certificate, err error) { cfg.GetClientCertificate = func(unused *tls.CertificateRequestInfo) (cert *tls.Certificate, err error) {
@ -516,16 +497,13 @@ func (info TLSInfo) baseConfig() (*tls.Config, error) {
} }
cert, err = tlsutil.NewCert(certfile, keyfile, info.parseFunc) cert, err = tlsutil.NewCert(certfile, keyfile, info.parseFunc)
if os.IsNotExist(err) { if os.IsNotExist(err) {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"failed to find client cert files", "failed to find client cert files",
zap.String("cert-file", certfile), zap.String("cert-file", certfile),
zap.String("key-file", keyfile), zap.String("key-file", keyfile),
zap.Error(err), zap.Error(err),
) )
}
} else if err != nil { } else if err != nil {
if info.Logger != nil {
info.Logger.Warn( info.Logger.Warn(
"failed to create client certificate", "failed to create client certificate",
zap.String("cert-file", certfile), zap.String("cert-file", certfile),
@ -533,7 +511,6 @@ func (info TLSInfo) baseConfig() (*tls.Config, error) {
zap.Error(err), zap.Error(err),
) )
} }
}
return cert, err return cert, err
} }
return cfg, nil return cfg, nil