package control_plane

import (
	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/runtime"
	"k8s.io/apimachinery/pkg/runtime/serializer"
	utilruntime "k8s.io/apimachinery/pkg/util/runtime"

	configv1 "github.com/openshift/api/config/v1"
)

var (
	scheme  = runtime.NewScheme()
	decoder runtime.Decoder
)

func init() {
	utilruntime.Must(metav1.AddMetaToScheme(scheme))
	utilruntime.Must(configv1.Install(scheme))
	decoder = serializer.NewCodecFactory(scheme).UniversalDecoder(metav1.SchemeGroupVersion, configv1.GroupVersion)
}

func decodeClusterOperators(manifestBytes []byte) (*configv1.ClusterOperatorList, error) {
	decodedObj, err := runtime.Decode(decoder, manifestBytes)
	if err != nil {
		return nil, err
	}
	return decodedObj.(*configv1.ClusterOperatorList), nil
}