Generates a Self signed certificate for default vhost if the secret doesn't exists

Generates a Self signed certificate for default vhost if the secret doesn't exists

	modified:   core/pkg/ingress/controller/backend_ssl.go
	modified:   core/pkg/ingress/controller/controller.go
	modified:   core/pkg/net/ssl/ssl.go
This commit is contained in:
Ricardo Pchevuzinske Katz 2017-02-28 21:11:16 -03:00
parent de8b9b8df2
commit 6c1b45a663
3 changed files with 66 additions and 24 deletions

View file

@ -56,7 +56,7 @@ func (ic *GenericController) syncSecret(k interface{}) error {
} }
} else { } else {
defCert, defKey := ssl.GetFakeSSLCert() defCert, defKey := ssl.GetFakeSSLCert()
cert, err = ssl.AddOrUpdateCertAndKey("system-snake-oil-certificate", defCert, defKey, []byte{}) cert, err = ssl.AddOrUpdateCertAndKey("default-fake-certificate", defCert, defKey, []byte{})
if err != nil { if err != nil {
return nil return nil
} }

View file

@ -18,6 +18,7 @@ package controller
import ( import (
"fmt" "fmt"
"os"
"reflect" "reflect"
"sort" "sort"
"strconv" "strconv"
@ -843,13 +844,23 @@ func (ic *GenericController) createServers(data []interface{},
// If no default Certificate was supplied, tries to generate a new dumb one // If no default Certificate was supplied, tries to generate a new dumb one
if err != nil { if err != nil {
var cert *ingress.SSLCert var cert *ingress.SSLCert
fakeCertificate := "default-fake-certificate"
fakeCertificatePath := fmt.Sprintf("%v/%v.pem", ingress.DefaultSSLDirectory, fakeCertificate)
// Only generates a new certificate if it doesn't exists physically
_, err := os.Stat(fakeCertificatePath)
if err != nil {
defCert, defKey := ssl.GetFakeSSLCert() defCert, defKey := ssl.GetFakeSSLCert()
cert, err = ssl.AddOrUpdateCertAndKey("system-snake-oil-certificate", defCert, defKey, []byte{}) cert, err = ssl.AddOrUpdateCertAndKey(fakeCertificate, defCert, defKey, []byte{})
if err != nil { if err != nil {
glog.Fatalf("Error generating self signed certificate: %v", err) glog.Fatalf("Error generating self signed certificate: %v", err)
} else { }
defaultPemFileName = cert.PemFileName defaultPemFileName = cert.PemFileName
defaultPemSHA = cert.PemSHA defaultPemSHA = cert.PemSHA
} else {
defaultPemFileName = fakeCertificatePath
defaultPemSHA = ssl.PemSHA1(fakeCertificatePath)
} }
} else { } else {
defaultPemFileName = defaultCertificate.PemFileName defaultPemFileName = defaultCertificate.PemFileName
@ -944,9 +955,6 @@ func (ic *GenericController) createServers(data []interface{},
servers[host].SSLCertificate = cert.PemFileName servers[host].SSLCertificate = cert.PemFileName
servers[host].SSLPemChecksum = cert.PemSHA servers[host].SSLPemChecksum = cert.PemSHA
} }
} else {
servers[host].SSLCertificate = defaultPemFileName
servers[host].SSLPemChecksum = defaultPemSHA
} }
} }
} }

View file

@ -17,14 +17,19 @@ limitations under the License.
package ssl package ssl
import ( import (
"crypto/rand"
"crypto/rsa"
"crypto/sha1" "crypto/sha1"
"crypto/x509" "crypto/x509"
"crypto/x509/pkix"
"encoding/hex" "encoding/hex"
"encoding/pem" "encoding/pem"
"errors" "errors"
"fmt" "fmt"
"io/ioutil" "io/ioutil"
"math/big"
"os" "os"
"time"
"github.com/golang/glog" "github.com/golang/glog"
@ -120,14 +125,14 @@ func AddOrUpdateCertAndKey(name string, cert, key, ca []byte) (*ingress.SSLCert,
return &ingress.SSLCert{ return &ingress.SSLCert{
CAFileName: pemFileName, CAFileName: pemFileName,
PemFileName: pemFileName, PemFileName: pemFileName,
PemSHA: pemSHA1(pemFileName), PemSHA: PemSHA1(pemFileName),
CN: cn, CN: cn,
}, nil }, nil
} }
return &ingress.SSLCert{ return &ingress.SSLCert{
PemFileName: pemFileName, PemFileName: pemFileName,
PemSHA: pemSHA1(pemFileName), PemSHA: PemSHA1(pemFileName),
CN: cn, CN: cn,
}, nil }, nil
} }
@ -162,7 +167,7 @@ func AddCertAuth(name string, ca []byte) (*ingress.SSLCert, error) {
return &ingress.SSLCert{ return &ingress.SSLCert{
CAFileName: caFileName, CAFileName: caFileName,
PemFileName: caFileName, PemFileName: caFileName,
PemSHA: pemSHA1(caFileName), PemSHA: PemSHA1(caFileName),
}, nil }, nil
} }
@ -187,9 +192,9 @@ func SearchDHParamFile(baseDir string) string {
return "" return ""
} }
// pemSHA1 returns the SHA1 of a pem file. This is used to // PemSHA1 returns the SHA1 of a pem file. This is used to
// reload NGINX in case a secret with a SSL certificate changed. // reload NGINX in case a secret with a SSL certificate changed.
func pemSHA1(filename string) string { func PemSHA1(filename string) string {
hasher := sha1.New() hasher := sha1.New()
s, err := ioutil.ReadFile(filename) s, err := ioutil.ReadFile(filename)
if err != nil { if err != nil {
@ -200,23 +205,52 @@ func pemSHA1(filename string) string {
return hex.EncodeToString(hasher.Sum(nil)) return hex.EncodeToString(hasher.Sum(nil))
} }
const ( // GetFakeSSLCert creates a Self Signed Certificate
snakeOilPem = "/etc/ssl/certs/ssl-cert-snakeoil.pem" // Based in the code https://golang.org/src/crypto/tls/generate_cert.go
snakeOilKey = "/etc/ssl/private/ssl-cert-snakeoil.key"
)
// GetFakeSSLCert returns the snake oil ssl certificate created by the command
// make-ssl-cert generate-default-snakeoil --force-overwrite
func GetFakeSSLCert() ([]byte, []byte) { func GetFakeSSLCert() ([]byte, []byte) {
cert, err := ioutil.ReadFile(snakeOilPem)
var priv interface{}
var err error
priv, err = rsa.GenerateKey(rand.Reader, 2048)
if err != nil { if err != nil {
return nil, nil glog.Fatalf("failed to generate fake private key: %s", err)
} }
key, err := ioutil.ReadFile(snakeOilKey) notBefore := time.Now()
// This certificate is valid for 365 days
notAfter := notBefore.Add(365 * 24 * time.Hour)
serialNumberLimit := new(big.Int).Lsh(big.NewInt(1), 128)
serialNumber, err := rand.Int(rand.Reader, serialNumberLimit)
if err != nil { if err != nil {
return nil, nil glog.Fatalf("failed to generate fake serial number: %s", err)
} }
template := x509.Certificate{
SerialNumber: serialNumber,
Subject: pkix.Name{
Organization: []string{"Acme Co"},
CommonName: "Kubernetes Ingress Controller Fake Certificate",
},
NotBefore: notBefore,
NotAfter: notAfter,
KeyUsage: x509.KeyUsageKeyEncipherment | x509.KeyUsageDigitalSignature,
ExtKeyUsage: []x509.ExtKeyUsage{x509.ExtKeyUsageServerAuth},
BasicConstraintsValid: true,
DNSNames: []string{"ingress.local"},
}
derBytes, err := x509.CreateCertificate(rand.Reader, &template, &template, &priv.(*rsa.PrivateKey).PublicKey, priv)
if err != nil {
glog.Fatalf("Failed to create fake certificate: %s", err)
}
cert := pem.EncodeToMemory(&pem.Block{Type: "CERTIFICATE", Bytes: derBytes})
key := pem.EncodeToMemory(&pem.Block{Type: "RSA PRIVATE KEY", Bytes: x509.MarshalPKCS1PrivateKey(priv.(*rsa.PrivateKey))})
return cert, key return cert, key
} }