-
Notifications
You must be signed in to change notification settings - Fork 547
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Swap the use of the go-tuf v0.7.0 client from sigstore/sigstore to the v2.0.0 client from sigstore/sigstore-go. Sigstore-go provides a way to check for a trusted root and automatically use it if available, but can also fetch individual targets as needed if the provided TUF mirror does not supply a trusted_root.json. This change is intended to be backwards compatible and transparent. TODO: - e2e tests - deprecate `cosign initialize` Signed-off-by: Colleen Murphy <[email protected]>
- Loading branch information
Showing
15 changed files
with
366 additions
and
182 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,124 @@ | ||
| package cosign | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "crypto/x509" | ||
| "fmt" | ||
| "os" | ||
|
|
||
| "github.com/sigstore/cosign/v2/pkg/cosign/env" | ||
| "github.com/sigstore/sigstore-go/pkg/root" | ||
| "github.com/sigstore/sigstore-go/pkg/tuf" | ||
| "github.com/sigstore/sigstore/pkg/cryptoutils" | ||
| ) | ||
|
|
||
| const ( | ||
| // This is the root in the fulcio project. | ||
| fulcioTargetStr = `fulcio.crt.pem` | ||
| // This is the v1 migrated root. | ||
| fulcioV1TargetStr = `fulcio_v1.crt.pem` | ||
| // This is the untrusted v1 intermediate CA certificate, used or chain building. | ||
| fulcioV1IntermediateTargetStr = `fulcio_intermediate_v1.crt.pem` | ||
| ) | ||
|
|
||
| func GetFulcioCerts() (*x509.CertPool, *x509.CertPool, error) { | ||
| rootEnv := env.Getenv(env.VariableSigstoreRootFile) | ||
|
|
||
| if rootEnv != "" { | ||
| return getFulcioCertsFromFile(rootEnv) | ||
| } | ||
|
|
||
| opts, err := setTUFOpts() | ||
| if err != nil { | ||
| return nil, nil, err | ||
| } | ||
|
|
||
| trustedRoot, _ := root.NewLiveTrustedRoot(opts) | ||
| if trustedRoot == nil { | ||
| return getFulcioCertsFromTUF(opts) | ||
| } | ||
| cas := trustedRoot.FulcioCertificateAuthorities() | ||
| if len(cas) < 1 { | ||
| return nil, nil, fmt.Errorf("could not find fulcio certificate authorities") | ||
| } | ||
| rootPool := x509.NewCertPool() | ||
| var intermediatePool *x509.CertPool | ||
| for _, ca := range cas { | ||
| rootPool.AddCert(ca.Root) | ||
| for _, i := range ca.Intermediates { | ||
| if intermediatePool == nil { | ||
| intermediatePool = x509.NewCertPool() | ||
| } | ||
| intermediatePool.AddCert(i) | ||
| } | ||
| } | ||
| return rootPool, intermediatePool, nil | ||
| } | ||
|
|
||
| func getFulcioCertsFromFile(path string) (*x509.CertPool, *x509.CertPool, error) { | ||
| rootPool := x509.NewCertPool() | ||
| // intermediatePool should be nil if no intermediates are found | ||
| var intermediatePool *x509.CertPool | ||
| raw, err := os.ReadFile(path) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error reading root PEM file: %w", err) | ||
| } | ||
| certs, err := cryptoutils.UnmarshalCertificatesFromPEM(raw) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error unmarshalling certificates: %w", err) | ||
| } | ||
| for _, cert := range certs { | ||
| // root certificates are self-signed | ||
| if bytes.Equal(cert.RawSubject, cert.RawIssuer) { | ||
| rootPool.AddCert(cert) | ||
| } else { | ||
| if intermediatePool == nil { | ||
| intermediatePool = x509.NewCertPool() | ||
| } | ||
| intermediatePool.AddCert(cert) | ||
| } | ||
| } | ||
| return rootPool, intermediatePool, nil | ||
| } | ||
|
|
||
| func getFulcioCertsFromTUF(opts *tuf.Options) (*x509.CertPool, *x509.CertPool, error) { | ||
| tufClient, err := tuf.New(opts) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error creating TUF client: %w", err) | ||
| } | ||
| rootPool := x509.NewCertPool() | ||
| fulcioCertBytes, _ := tufClient.GetTarget(fulcioTargetStr) | ||
| fulcioV1CertBytes, _ := tufClient.GetTarget(fulcioV1TargetStr) | ||
| if len(fulcioCertBytes) > 0 { | ||
| fulcioCert, err := cryptoutils.UnmarshalCertificatesFromPEM(fulcioCertBytes) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error unmarshalling fulcio cert: %w", err) | ||
| } | ||
| for _, c := range fulcioCert { | ||
| rootPool.AddCert(c) | ||
| } | ||
| } | ||
| if len(fulcioV1CertBytes) > 0 { | ||
| fulcioV1Cert, err := cryptoutils.UnmarshalCertificatesFromPEM(fulcioV1CertBytes) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error unmarshalling fulcio v1 cert: %w", err) | ||
| } | ||
| for _, c := range fulcioV1Cert { | ||
| rootPool.AddCert(c) | ||
| } | ||
| } | ||
|
|
||
| var intermediatePool *x509.CertPool | ||
| fulcioIntermediateBytes, _ := tufClient.GetTarget(fulcioV1IntermediateTargetStr) | ||
| if len(fulcioIntermediateBytes) == 0 { | ||
| fulcioIntermediate, err := cryptoutils.UnmarshalCertificatesFromPEM(fulcioIntermediateBytes) | ||
| if err != nil { | ||
| return nil, nil, fmt.Errorf("error unmarshalling fulcio intermediate cert: %w", err) | ||
| } | ||
| intermediatePool = x509.NewCertPool() | ||
| for _, c := range fulcioIntermediate { | ||
| intermediatePool.AddCert(c) | ||
| } | ||
| } | ||
| return rootPool, intermediatePool, nil | ||
| } |
Oops, something went wrong.