init_secrets.go

package auth

import (
	"context"
	"crypto/rand"
	"crypto/rsa"
	"crypto/x509"
	"encoding/base64"
	"encoding/pem"
	"fmt"
	"io/ioutil"
	"os"
	"path/filepath"

	"github.com/spf13/cobra"

	"github.com/flyteorg/flyte/flyteadmin/auth/config"
	"github.com/flyteorg/flyte/flytestdlib/logger"
)

const (
	SymmetricKeyLength   = 32
	CookieHashKeyLength  = 64
	CookieBlockKeyLength = 32
	rsaPEMType           = "RSA PRIVATE KEY"
)

var (
	localPath string
)

// GetInitSecretsCommand creates a command to issue secrets to be used for Auth settings. It writes the secrets to the
// working directory. The expectation is that they are put in a location and made available to the serve command later.
// To configure where the serve command looks for secrets, update this config:
//
//	secrets:
//	  secrets-prefix: <my custom path>
func GetInitSecretsCommand() *cobra.Command {
	cmd := &cobra.Command{
		Use:   "init",
		Short: "Generates secrets needed for OpenIDC and OAuth2 providers",
		RunE: func(cmd *cobra.Command, args []string) error {
			ctx := context.Background()
			secrets, err := NewSecrets()
			if err != nil {
				return err
			}

			d, err := os.Getwd()
			if err != nil {
				return fmt.Errorf("failed to get working directory. Error: %w", err)
			}

			// If not overridden in cmd flags, use the working directory
			if len(localPath) == 0 {
				localPath = d
			}

			err = os.MkdirAll(localPath, 0755)
			if err != nil {
				return fmt.Errorf("failed to create path [%v]. Error: %w", localPath, err)
			}

			return writeSecrets(ctx, secrets, localPath)
		},
	}

	cmd.Flags().StringVarP(&localPath, "localPath", "p", "", "Specifies where the secrets should be written.")

	return cmd
}

type SecretsSet struct {
	TokenHashKey              []byte
	TokenSigningRSAPrivateKey *rsa.PrivateKey
	CookieHashKey             []byte
	CookieBlockKey            []byte
}

func writeSecrets(ctx context.Context, secrets SecretsSet, path string) error {
	err := ioutil.WriteFile(filepath.Join(path, config.SecretNameClaimSymmetricKey), []byte(base64.RawStdEncoding.EncodeToString(secrets.TokenHashKey)), os.ModePerm)
	if err != nil {
		return fmt.Errorf("failed to persist token hash key. Error: %w", err)
	}

	logger.Infof(ctx, "wrote %v", config.SecretNameClaimSymmetricKey)

	err = ioutil.WriteFile(filepath.Join(path, config.SecretNameCookieHashKey), []byte(base64.RawStdEncoding.EncodeToString(secrets.CookieHashKey)), os.ModePerm)
	if err != nil {
		return fmt.Errorf("failed to persist cookie hash key. Error: %w", err)
	}

	logger.Infof(ctx, "wrote %v", config.SecretNameCookieHashKey)

	err = ioutil.WriteFile(filepath.Join(path, config.SecretNameCookieBlockKey), []byte(base64.RawStdEncoding.EncodeToString(secrets.CookieBlockKey)), os.ModePerm)
	if err != nil {
		return fmt.Errorf("failed to persist cookie block key. Error: %w", err)
	}

	logger.Infof(ctx, "wrote %v", config.SecretNameCookieBlockKey)

	keyOut, err := os.OpenFile(filepath.Join(path, config.SecretNameTokenSigningRSAKey), os.O_WRONLY|os.O_CREATE|os.O_TRUNC, os.ModePerm)
	if err != nil {
		return fmt.Errorf("failed to open key.pem for writing: %w", err)
	}

	privBytes := x509.MarshalPKCS1PrivateKey(secrets.TokenSigningRSAPrivateKey)
	if err := pem.Encode(keyOut, &pem.Block{Type: rsaPEMType, Bytes: privBytes}); err != nil {
		return fmt.Errorf("failed to write data to key.pem: %w", err)
	}

	if err := keyOut.Close(); err != nil {
		return fmt.Errorf("error closing key.pem: %w", err)
	}

	logger.Infof(ctx, "wrote %v", config.SecretNameTokenSigningRSAKey)

	return nil
}

func NewSecrets() (SecretsSet, error) {
	secret := make([]byte, SymmetricKeyLength)
	_, err := rand.Read(secret)
	if err != nil {
		return SecretsSet{}, fmt.Errorf("failed to issue token hash key. Error: %w", err)
	}

	privateKey, err := rsa.GenerateKey(rand.Reader, 2048)
	if err != nil {
		return SecretsSet{}, fmt.Errorf("failed to issue token signing key. Error: %w", err)
	}

	cookieHashKey := make([]byte, CookieHashKeyLength)
	_, err = rand.Read(cookieHashKey)
	if err != nil {
		return SecretsSet{}, fmt.Errorf("failed to issue cookie hash key. Error: %w", err)
	}

	cookieBlockKey := make([]byte, CookieBlockKeyLength)
	_, err = rand.Read(cookieBlockKey)
	if err != nil {
		return SecretsSet{}, fmt.Errorf("failed to issue cookie block key. Error: %w", err)
	}

	return SecretsSet{
		TokenHashKey:              secret,
		TokenSigningRSAPrivateKey: privateKey,
		CookieHashKey:             cookieHashKey,
		CookieBlockKey:            cookieBlockKey,
	}, nil
}