/
olm.go
52 lines (43 loc) · 1.53 KB
/
olm.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
package operators
import (
"reflect"
g "github.com/onsi/ginkgo"
o "github.com/onsi/gomega"
yaml "gopkg.in/yaml.v2"
e2e "k8s.io/kubernetes/test/e2e/framework"
exutil "github.com/openshift/origin/test/extended/util"
)
var _ = g.Describe("[Feature:Platform] OLM should", func() {
defer g.GinkgoRecover()
var oc = exutil.NewCLI("olm", exutil.KubeConfigPath())
// The list of all available OLM resources
olmResources := []string{
"packagemanifests", "catalogsources", "clusterserviceversions",
"installplans", "operatorgroups", "subscriptions",
}
for i := range olmResources {
g.It("list "+olmResources[i], func() {
var resourceList map[string]interface{}
// Get resource yaml and parse
output, err := oc.AsAdmin().Run("get").Args(olmResources[i], "--all-namespaces", "-o", "yaml").Output()
o.Expect(err).NotTo(o.HaveOccurred())
err = yaml.Unmarshal([]byte(output), &resourceList)
if err != nil {
e2e.Logf("Unable to parse %s yaml list", olmResources[i])
}
// Verify resource items list has at least one item
o.Expect(isResourceItemsEmpty(resourceList)).To(o.BeFalse(), olmResources[i]+" list should have at least one item")
e2e.Logf("Successfully list %s", olmResources[i])
})
}
})
func isResourceItemsEmpty(resourceList map[string]interface{}) bool {
// Get resource items and check if it is empty
items, err := resourceList["items"].([]interface{})
o.Expect(err).To(o.BeTrue(), "Unable to verify items is a slice")
if reflect.ValueOf(items).Len() > 0 {
return false
} else {
return true
}
}