diskless-workstation/files/enrol/tpmkey/tpmkey.go

// Package tpmkey — TPM 2.0 operations via go-tpm (pure Go, no CGO, no tpm2-tools
// / no openssl tpm2 provider). Provides: ensure a persistent ECDSA signing key
// at 0x81010001, a crypto.Signer backed by it (for CSR signing), and NV cert
// read-presence + write at 0x01800001. Talks to any transport.TPM, so the same
// code runs against /dev/tpmrm0 (production) and the software simulator (tests).
//
// Exported so the ceremony can be tested against the go-tpm simulator from a
// SEPARATE module (simtest/), keeping this module's vendored deps lean (go-tpm
// only) — the simulator (CGO + the MS TPM reference C) never enters the image build.
package tpmkey

import (
	"crypto"
	"crypto/ecdsa"
	"encoding/asn1"
	"fmt"
	"io"
	"math/big"

	"github.com/google/go-tpm/tpm2"
	"github.com/google/go-tpm/tpm2/transport"
)

// eccSigningTemplate: a NON-restricted ECC P-256 ECDSA-SHA256 signing key.
// Non-restricted so it can sign an externally-computed digest (the CSR TBS) with
// a NULL validation ticket; Symmetric/KDF are explicitly NULL (sign-only key).
func eccSigningTemplate() tpm2.TPMTPublic {
	return tpm2.TPMTPublic{
		Type:    tpm2.TPMAlgECC,
		NameAlg: tpm2.TPMAlgSHA256,
		ObjectAttributes: tpm2.TPMAObject{
			FixedTPM:            true,
			FixedParent:         true,
			SensitiveDataOrigin: true,
			UserWithAuth:        true,
			SignEncrypt:         true,
			NoDA:                true,
		},
		Parameters: tpm2.NewTPMUPublicParms(tpm2.TPMAlgECC, &tpm2.TPMSECCParms{
			Symmetric: tpm2.TPMTSymDefObject{Algorithm: tpm2.TPMAlgNull},
			Scheme: tpm2.TPMTECCScheme{
				Scheme: tpm2.TPMAlgECDSA,
				Details: tpm2.NewTPMUAsymScheme(tpm2.TPMAlgECDSA, &tpm2.TPMSSigSchemeECDSA{
					HashAlg: tpm2.TPMAlgSHA256,
				}),
			},
			CurveID: tpm2.TPMECCNistP256,
			KDF:     tpm2.TPMTKDFScheme{Scheme: tpm2.TPMAlgNull},
		}),
	}
}

// Signer implements crypto.Signer using a persistent TPM key.
type Signer struct {
	tpm    transport.TPM
	handle tpm2.TPMHandle
	name   tpm2.TPM2BName
	pub    *ecdsa.PublicKey
}

func (s *Signer) Public() crypto.PublicKey { return s.pub }

func (s *Signer) Sign(_ io.Reader, digest []byte, _ crypto.SignerOpts) ([]byte, error) {
	rsp, err := tpm2.Sign{
		KeyHandle: tpm2.NamedHandle{Handle: s.handle, Name: s.name},
		Digest:    tpm2.TPM2BDigest{Buffer: digest},
		InScheme: tpm2.TPMTSigScheme{
			Scheme: tpm2.TPMAlgECDSA,
			Details: tpm2.NewTPMUSigScheme(tpm2.TPMAlgECDSA, &tpm2.TPMSSchemeHash{
				HashAlg: tpm2.TPMAlgSHA256,
			}),
		},
		Validation: tpm2.TPMTTKHashCheck{Tag: tpm2.TPMSTHashCheck},
	}.Execute(s.tpm)
	if err != nil {
		return nil, fmt.Errorf("tpm sign: %w", err)
	}
	ecc, err := rsp.Signature.Signature.ECDSA()
	if err != nil {
		return nil, fmt.Errorf("tpm sign: not ECDSA: %w", err)
	}
	r := new(big.Int).SetBytes(ecc.SignatureR.Buffer)
	sInt := new(big.Int).SetBytes(ecc.SignatureS.Buffer)
	// x509 expects an ASN.1 DER ECDSA-Sig-Value{ r, s }.
	return asn1.Marshal(struct{ R, S *big.Int }{r, sInt})
}

func signerFromPub(tpm transport.TPM, handle tpm2.TPMHandle, name tpm2.TPM2BName, pub2b tpm2.TPM2BPublic) (*Signer, error) {
	pub, err := pub2b.Contents()
	if err != nil {
		return nil, err
	}
	det, err := pub.Parameters.ECCDetail()
	if err != nil {
		return nil, fmt.Errorf("key at handle is not ECC: %w", err)
	}
	uniq, err := pub.Unique.ECC()
	if err != nil {
		return nil, err
	}
	pk, err := tpm2.ECDSAPub(det, uniq)
	if err != nil {
		return nil, err
	}
	return &Signer{tpm: tpm, handle: handle, name: name, pub: pk}, nil
}

// ensureKey returns a signer for the persistent key at handle, creating +
// persisting a fresh ECDSA key there if none exists. Returns created=true when
// a new key was generated.
//
// If the handle already holds an object that is NOT our ECC signing key (e.g. an
// RSA key left by an older tpm2-tools/openssl provisioning path — go-tpm reports
// "key at handle is not ECC"), it is treated as STALE and evicted, then a fresh
// ECC key is created. Safe on the enrol path: this only runs on an empty-NV host,
// so no issued cert references the old key. Only a valid ECC key is reused.
func EnsureKey(tpm transport.TPM, handle tpm2.TPMHandle) (signer *Signer, created bool, err error) {
	if rp, e := (tpm2.ReadPublic{ObjectHandle: handle}).Execute(tpm); e == nil {
		if s, e2 := signerFromPub(tpm, handle, rp.Name, rp.OutPublic); e2 == nil {
			return s, false, nil // our ECC key is already there — reuse it
		}
		// Stale/wrong-type key occupying the handle — evict so we can recreate.
		if _, e2 := (tpm2.EvictControl{
			Auth:             tpm2.TPMRHOwner,
			ObjectHandle:     &tpm2.NamedHandle{Handle: handle, Name: rp.Name},
			PersistentHandle: handle,
		}).Execute(tpm); e2 != nil {
			return nil, false, fmt.Errorf("evict stale (non-ECC) key at handle: %w", e2)
		}
	}

	cp, err := tpm2.CreatePrimary{
		PrimaryHandle: tpm2.TPMRHOwner,
		InPublic:      tpm2.New2B(eccSigningTemplate()),
	}.Execute(tpm)
	if err != nil {
		return nil, false, fmt.Errorf("createprimary: %w", err)
	}
	// Persist at the well-known handle, then flush the transient object.
	_, err = tpm2.EvictControl{
		Auth:             tpm2.TPMRHOwner,
		ObjectHandle:     &tpm2.NamedHandle{Handle: cp.ObjectHandle, Name: cp.Name},
		PersistentHandle: handle,
	}.Execute(tpm)
	_, _ = (tpm2.FlushContext{FlushHandle: cp.ObjectHandle}).Execute(tpm)
	if err != nil {
		return nil, false, fmt.Errorf("evictcontrol: %w", err)
	}
	rp, err := (tpm2.ReadPublic{ObjectHandle: handle}).Execute(tpm)
	if err != nil {
		return nil, false, fmt.Errorf("readpublic after persist: %w", err)
	}
	s, err := signerFromPub(tpm, handle, rp.Name, rp.OutPublic)
	return s, true, err
}

// nvPresent reports whether a defined NV index exists (our enrol NV is defined
// and written atomically, so "defined" means "has a cert").
func NVPresent(tpm transport.TPM, index tpm2.TPMHandle) bool {
	_, err := (tpm2.NVReadPublic{NVIndex: index}).Execute(tpm)
	return err == nil
}

// nvWriteCert (re)defines the NV index sized to der and writes it under owner
// auth. Chunks the write to stay within the TPM's NV buffer limit.
func WriteNVCert(tpm transport.TPM, index tpm2.TPMHandle, der []byte) error {
	// Undefine a stale index first (re-enrolment / resized cert).
	if rp, err := (tpm2.NVReadPublic{NVIndex: index}).Execute(tpm); err == nil {
		if _, err := (tpm2.NVUndefineSpace{
			AuthHandle: tpm2.TPMRHOwner,
			NVIndex:    tpm2.NamedHandle{Handle: index, Name: rp.NVName},
		}).Execute(tpm); err != nil {
			return fmt.Errorf("nv undefine: %w", err)
		}
	}

	def := tpm2.NVDefineSpace{
		AuthHandle: tpm2.TPMRHOwner,
		PublicInfo: tpm2.New2B(tpm2.TPMSNVPublic{
			NVIndex: index,
			NameAlg: tpm2.TPMAlgSHA256,
			Attributes: tpm2.TPMANV{
				OwnerWrite: true,
				OwnerRead:  true,
				AuthWrite:  true,
				AuthRead:   true,
				NT:         tpm2.TPMNTOrdinary,
				NoDA:       true,
			},
			DataSize: uint16(len(der)),
		}),
	}
	if _, err := def.Execute(tpm); err != nil {
		return fmt.Errorf("nv define: %w", err)
	}
	rp, err := (tpm2.NVReadPublic{NVIndex: index}).Execute(tpm)
	if err != nil {
		return fmt.Errorf("nv readpublic: %w", err)
	}

	const chunk = 512 // conservatively under TPM_MAX_NV_BUFFER_SIZE
	for off := 0; off < len(der); off += chunk {
		end := min(off+chunk, len(der))
		if _, err := (tpm2.NVWrite{
			AuthHandle: tpm2.AuthHandle{Handle: index, Name: rp.NVName, Auth: tpm2.PasswordAuth(nil)},
			NVIndex:    tpm2.NamedHandle{Handle: index, Name: rp.NVName},
			Data:       tpm2.TPM2BMaxNVBuffer{Buffer: der[off:end]},
			Offset:     uint16(off),
		}).Execute(tpm); err != nil {
			return fmt.Errorf("nv write @%d: %w", off, err)
		}
	}
	return nil
}