HashiCorp Packer Golden Image testen mit benutzerdefinierten mondoo-Richtlinien

 1package test
 2
 3import (
 4//...
 5)
 6
 7const (
 8    remotePort           = 22
 9    remoteUser           = "coder"
10)
11
12func TestMondooBased(t *testing.T) {
13
14    expectedName := fmt.Sprintf("terratest-mondoo-%s", random.UniqueId())
15    cloud := os.Getenv("CLOUD")
16
17    terraformOptions := terraform.WithDefaultRetryableErrors(t, &terraform.Options{
18        // Pfad zum Terraform-Code, der getestet wird.
19        TerraformDir: fmt.Sprintf("./fixtures/%s/", cloud),
20        Vars: map[string]interface{}{
21            "vm_image_id": os.Getenv("PACKER_IMAGE_ID"),
22            "location":    os.Getenv("PACKER_LOCATION"),
23            "subnet_id":   os.Getenv("PACKER_SUBNET_ID"),
24            "vpc_id":      os.Getenv("PACKER_VPC_ID"),
25            "vm_name":     expectedName,
26        },
27    })
28
29    defer terraform.Destroy(t, terraformOptions)
30
31    terraform.InitAndApply(t, terraformOptions)
32
33    target_ipaddress := terraform.Output(t, terraformOptions, "target_ipaddress")
34
35    assert.NotEmpty(t, target_ipaddress)
36
37    runMondooTests(t, target_ipaddress, expectedName, "core")
38    runMondooTests(t, target_ipaddress, expectedName, os.Getenv("TESTNAME"))
39
40}

 1func runMondooTests(t *testing.T, target_address string, expectedName string, profile string) {
 2
 3    policyBundleFile := fmt.Sprintf("./%s.mql.yaml", profile)
 4    if _, err := os.Stat(policyBundleFile); err != nil {
 5        t.Logf("Richtlinienbündeldatei nicht gefunden: %s", policyBundleFile)
 6        return
 7    }
 8    logFile := fmt.Sprintf("%s_%s.log", expectedName, profile)
 9
10    var policyFilters []string
11
12    assetConfig := &inventory.Config{
13        Type:        "ssh",
14        Host:        target_address,
15        Port:        int32(22),
16        Options:     map[string]string{},
17        Credentials: []*vault.Credential{},
18    }
19
20    bundleLoader := policy.DefaultBundleLoader()
21    policyBundle, err := bundleLoader.BundleFromPaths(policyBundleFile)
22    if err != nil {
23        t.Error(errors.Wrap(err, "Konnte das Richtlinienbündel nicht aus "+policyBundleFile+" laden"))
24        return
25    }
26
27    conf := inventory.New(inventory.WithAssets(&inventory.Asset{
28        Name:        expectedName,
29        Connections: []*inventory.Config{assetConfig},
30        Annotations: map[string]string{},
31        Labels:      map[string]string{},
32    }))
33
34    scanJob := &scan.Job{
35        Inventory:     conf,
36        Bundle:        policyBundle,
37        PolicyFilters: policyFilters,
38        ReportType:    scan.ReportType_FULL,
39    }
40
41    scanService := scan.NewLocalScanner()
42    res, err := scanService.RunIncognito(context.Background(), scanJob)
43    if err != nil {
44        t.Error("Scan fehlgeschlagen: " + err.Error())
45        return
46    }
47
48    if res == nil || res.GetFull() == nil {
49        t.Error("Scan fehlgeschlagen: Kein Ergebnis zurückgegeben, verwenden Sie `debug: true` Protokollierung für weitere Details")
50        return
51    }
52
53    report := res.GetFull()
54    handlerConf := reporter.HandlerConfig{
55        Format:       "compact",
56        OutputTarget: logFile,
57        Incognito:    true,
58    }
59    outputHandler, err := reporter.NewOutputHandler(handlerConf)
60    if err != nil {
61        t.Error("Fehler beim Erstellen eines Ausgabehandlers: " + err.Error())
62        return
63    }
64
65    buf := &bytes.Buffer{}
66    if x, ok := outputHandler.(*reporter.Reporter); ok {
67        x.WithOutput(buf)
68    }
69
70    if err := outputHandler.WriteReport(context.Background(), report); err != nil {
71        t.Error("Fehler beim Schreiben des Berichts auf das Ausgabemedium: " + err.Error())
72        return
73    }
74
75    scoreThreshold := uint64(100)
76    if os.Getenv("SCORE_THRESHOLD") != "" {
77        scoreThreshold, _ = strconv.ParseUint(os.Getenv("SCORE_THRESHOLD"), 10, 32)
78    }
79
80    if report.GetWorstScore() < uint32(scoreThreshold) {
81        t.Errorf("Scan %s wurde mit %d Punkten abgeschlossen und hat die Punktegrenze von %d nicht bestanden", profile, report.GetWorstScore(), scoreThreshold)
82        return
83    }
84
85    t.Logf("Scan %s wurde mit %d Punkten abgeschlossen und hat die Punktegrenze von %d bestanden", profile, report.GetWorstScore(), scoreThreshold)
86}