reloader.go

//
//  simplecert
//
//  Created by Philipp Mieden
//  Contact: dreadl0ck@protonmail.ch
//  Copyright © 2018 bestbytes. All rights reserved.
//

package simplecert

import (
	"crypto/tls"
	"log"
	"os"
	"os/signal"
	"path/filepath"
	"sync"
	"syscall"
)

/*
 *	CertReloader
 */

// CertReloader manages a hot reload of a new cert
type CertReloader struct {
	sync.RWMutex
	cert     *tls.Certificate
	certPath string
	keyPath  string
}

// NewCertReloader returns a new CertReloader instance
// the optional cleanup func will be called when a syscall.SIGINT, syscall.SIGABRT is received
func NewCertReloader(certPath, keyPath string, logFile *os.File, cleanup func()) (*CertReloader, error) {

	// init reloader
	reloader := &CertReloader{
		certPath: certPath,
		keyPath:  keyPath,
	}

	// Load keypair
	cert, err := tls.LoadX509KeyPair(certPath, keyPath)
	if err != nil {
		return nil, err
	}
	reloader.cert = &cert

	// kickoff routine for handling singals
	go func() {
		sigChan := make(chan os.Signal, 1)
		signal.Notify(sigChan, syscall.SIGHUP, syscall.SIGINT, syscall.SIGABRT)
		for sig := range sigChan {
			if sig == syscall.SIGHUP {
				log.Printf("Received SIGHUP, reloading TLS certificate and key from %q and %q", certPath, keyPath)
				reloader.reload()
			} else {
				// cleanup
				err := logFile.Close()
				if err != nil {
					log.Fatal("[FATAL] simplecert: failed to close logfile handle: ", err)
				}
				log.Println("[INFO] simplecert: closed logfile handle")

				// run custom cleanup func if available
				if cleanup != nil {
					cleanup()
				}

				// keep running.
				// it is up to the caller of simplecert.NewCertReloader()
				// to decide what to do now
			}
		}
	}()

	return reloader, nil
}

func (reloader *CertReloader) maybeReload() error {
	newCert, err := tls.LoadX509KeyPair(reloader.certPath, reloader.keyPath)
	if err != nil {
		return err
	}
	reloader.Lock()
	defer reloader.Unlock()
	reloader.cert = &newCert
	return nil
}

// GetCertificateFunc is needed for hot reload
func (reloader *CertReloader) GetCertificateFunc() func(*tls.ClientHelloInfo) (*tls.Certificate, error) {
	return func(clientHello *tls.ClientHelloInfo) (*tls.Certificate, error) {
		reloader.RLock()
		defer reloader.RUnlock()
		return reloader.cert, nil
	}
}

// ReloadNow will force reloading the cert from disk
func (reloader *CertReloader) ReloadNow() {
	reloader.reload()
}

func (reloader *CertReloader) reload() {
	if err := reloader.maybeReload(); err != nil {

		// there was an error reloading the certificate
		// rollback files from backup dir
		log.Printf("[INFO] simplecert: Keeping old TLS certificate because the new one could not be loaded: %v", err)

		// restore private key
		backupPrivKey := filepath.Join(c.CacheDir, "backup-"+backupDate, keyFileName)
		err = os.Rename(backupPrivKey, filepath.Join(c.CacheDir, keyFileName))
		if err != nil {
			log.Fatal("[FATAL] simplecert: failed to move key into backup dir: ", err)
		}

		// restore certificate
		backupCert := filepath.Join(c.CacheDir, "backup-"+backupDate, certFileName)
		err = os.Rename(backupCert, filepath.Join(c.CacheDir, certFileName))
		if err != nil {
			log.Fatal("[FATAL] simplecert: failed to move cert into backup dir: ", err)
		}

		// remove backup directory
		err = os.Remove(filepath.Join(c.CacheDir, "backup-"+backupDate))
		if err != nil {
			log.Fatal("[FATAL] simplecert: failed to remove backup dir: ", err)
		}
	}
}