Tests for new retrieve full uris in grafeas

pkg/chains/formats/simple/simple.go

@@ -70,6 +70,7 @@ func (i *SimpleSigning) Type() config.PayloadType {
 	return formats.PayloadTypeSimpleSigning
 }
 
-func (i *SimpleSigning) RetrieveAllArtifactURIs(ctx context.Context, obj interface{}) ([]string, error) {
+// RetrieveAllArtifactURIs returns always an error, feature not available for simplesigning formatter.
+func (i *SimpleSigning) RetrieveAllArtifactURIs(_ context.Context, _ interface{}) ([]string, error) {
 	return nil, fmt.Errorf("RetrieveAllArtifactURIs not supported for simeplesining formatter")
 }

pkg/chains/formats/slsa/v1/intotoite6.go

@@ -96,6 +96,7 @@ func (i *InTotoIte6) Type() config.PayloadType {
 	return formats.PayloadTypeSlsav1
 }
 
+// RetrieveAllArtifactURIs returns the full URI of all artifacts detected as subjects.
 func (i *InTotoIte6) RetrieveAllArtifactURIs(ctx context.Context, obj interface{}) ([]string, error) {
 	tkObj, ok := obj.(objects.TektonObject)
 	if !ok {

pkg/chains/formats/slsa/v2alpha3/slsav2.go

@@ -70,6 +70,7 @@ func (s *Slsa) Type() config.PayloadType {
 	return formats.PayloadTypeSlsav2alpha3
 }
 
+// RetrieveAllArtifactURIs returns the full URI of all artifacts detected as subjects.
 func (s *Slsa) RetrieveAllArtifactURIs(ctx context.Context, obj interface{}) ([]string, error) {
 	tkObj, ok := obj.(objects.TektonObject)
 	if !ok {

pkg/chains/formats/slsa/v2alpha4/internal/pipelinerun/pipelinerun.go

@@ -74,6 +74,7 @@ func byproducts(pro *objects.PipelineRunObjectV1, slsaconfig *slsaconfig.SlsaCon
 	return byProd, nil
 }
 
+// SubjectDigests calculates the subjects associated with the given PipelineRun.
 func SubjectDigests(ctx context.Context, pro *objects.PipelineRunObjectV1, slsaconfig *slsaconfig.SlsaConfig) []*intoto.ResourceDescriptor {
 	subjects := extract.SubjectsFromBuildArtifact(ctx, pro.GetResults())
 

pkg/chains/formats/slsa/v2alpha4/slsav2.go

@@ -76,6 +76,7 @@ func (s *Slsa) Type() config.PayloadType {
 	return payloadTypeSlsav2alpha4
 }
 
+// RetrieveAllArtifactURIs returns the full URI of all artifacts detected as subjects.
 func (s *Slsa) RetrieveAllArtifactURIs(ctx context.Context, obj interface{}) ([]string, error) {
 	var subjects []*intoto.ResourceDescriptor
 	var fullURIs []string

pkg/chains/storage/grafeas/grafeas.go

@@ -265,15 +265,18 @@ func (b *Backend) createOccurrence(ctx context.Context, obj objects.TektonObject
 }
 
 func (b *Backend) getAllArtifactURIs(ctx context.Context, payloadFormat config.PayloadType, obj objects.TektonObject) []string {
+	logger := logging.FromContext(ctx)
 	payloader, err := formats.GetPayloader(payloadFormat, b.cfg)
 	if err != nil {
+		logger.Infof("couldn't get payloader for %v format, will use extract.RetrieveAllArtifactURIs method instead", payloadFormat)
 		return extract.RetrieveAllArtifactURIs(ctx, obj, b.cfg.Artifacts.PipelineRuns.DeepInspectionEnabled)
 	}
 
 	if uris, err := payloader.RetrieveAllArtifactURIs(ctx, obj); err == nil {
 		return uris
 	}
 
+	logger.Infof("couldn't get URIs from payloader %v, will use extract.RetrieveAllArtifactURIs method instead", payloadFormat)
 	return extract.RetrieveAllArtifactURIs(ctx, obj, b.cfg.Artifacts.PipelineRuns.DeepInspectionEnabled)
 }
 
@@ -377,7 +380,7 @@ func (b *Backend) getBuildNotePath(obj objects.TektonObject) string {
 func (b *Backend) getAllOccurrences(ctx context.Context, obj objects.TektonObject, opts config.StorageOpts) ([]*pb.Occurrence, error) {
 	result := []*pb.Occurrence{}
 	// step 1: get all resource URIs created under the taskrun
-	uriFilters := extract.RetrieveAllArtifactURIs(ctx, obj, b.cfg.Artifacts.PipelineRuns.DeepInspectionEnabled)
+	uriFilters := b.getAllArtifactURIs(ctx, opts.PayloadFormat, obj)
 
 	// step 2: find all build occurrences
 	if _, ok := formats.IntotoAttestationSet[opts.PayloadFormat]; ok {