package predicate

import (
	"fmt"

	acmapi "gitbucket.jerxie.com/yangyangxie/AnthosCertManager/pkg/apis/anthoscertmanager/v1"
	"k8s.io/apimachinery/pkg/runtime"
)

// CertificateRequestRevision returns a predicate that used to filter
// CertificateRequest to only those with a given 'revision' number.
func CertificateRequestRevision(revision int) Func {
	return func(obj runtime.Object) bool {
		req := obj.(*acmapi.CertificateRequest)
		if req.Annotations == nil {
			return false
		}

		return req.Annotations[acmapi.CertificateRequestRevisionAnnotationKey] == fmt.Sprintf("%d", revision)
	}
}