File: libvirt.go

package info (click to toggle)
packer 1.6.6%2Bds1-2
  • links: PTS, VCS
  • area: main
  • in suites: bullseye
  • size: 32,016 kB
  • sloc: sh: 1,154; python: 619; makefile: 251; ruby: 205; xml: 97
file content (117 lines) | stat: -rw-r--r-- 2,632 bytes parent folder | download | duplicates (2)
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
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
package vagrant

import (
	"fmt"
	"path/filepath"
	"strconv"
	"strings"

	packersdk "github.com/hashicorp/packer/packer-plugin-sdk/packer"
)

// Lowercase a ascii letter.
func lower(c byte) byte {
	return c | ('a' - 'A')
}

// Convert a string that represents a qemu disk image size to megabytes.
//
// Valid units (case-insensitive):
//
//		B (byte)        1B
//		K (kilobyte) 1024B
//		M (megabyte) 1024K
//		G (gigabyte) 1024M
//		T (terabyte) 1024G
//		P (petabyte) 1024T
//		E (exabyte)  1024P
//
// The default is M.
func sizeInMegabytes(size string) uint64 {
	unit := size[len(size)-1]

	if unit >= '0' && unit <= '9' {
		unit = 'm'
	} else {
		size = size[:len(size)-1]
	}

	value, _ := strconv.ParseUint(size, 10, 64)

	switch lower(unit) {
	case 'b':
		return value / 1024 / 1024
	case 'k':
		return value / 1024
	case 'm':
		return value
	case 'g':
		return value * 1024
	case 't':
		return value * 1024 * 1024
	case 'p':
		return value * 1024 * 1024 * 1024
	case 'e':
		return value * 1024 * 1024 * 1024 * 1024
	default:
		panic(fmt.Sprintf("Unknown size unit %c", unit))
	}
}

type LibVirtProvider struct{}

func (p *LibVirtProvider) KeepInputArtifact() bool {
	return false
}
func (p *LibVirtProvider) Process(ui packersdk.Ui, artifact packersdk.Artifact, dir string) (vagrantfile string, metadata map[string]interface{}, err error) {
	diskName := artifact.State("diskName").(string)

	// Copy the disk image into the temporary directory (as box.img)
	for _, path := range artifact.Files() {
		if strings.HasSuffix(path, "/"+diskName) {
			ui.Message(fmt.Sprintf("Copying from artifact: %s", path))
			dstPath := filepath.Join(dir, "box.img")
			if err = CopyContents(dstPath, path); err != nil {
				return
			}
		}
	}

	format := artifact.State("diskType").(string)
	origSize := sizeInMegabytes(artifact.State("diskSize").(string))
	size := origSize / 1024 // In MB, want GB
	if origSize%1024 > 0 {
		// Make sure we don't make the size smaller
		size++
	}
	domainType := artifact.State("domainType").(string)

	// Convert domain type to libvirt driver
	var driver string
	switch domainType {
	case "none", "tcg", "hvf":
		driver = "qemu"
	case "kvm":
		driver = domainType
	default:
		return "", nil, fmt.Errorf("Unknown libvirt domain type: %s", domainType)
	}

	// Create the metadata
	metadata = map[string]interface{}{
		"provider":     "libvirt",
		"format":       format,
		"virtual_size": size,
	}

	vagrantfile = fmt.Sprintf(libvirtVagrantfile, driver)
	return
}

var libvirtVagrantfile = `
Vagrant.configure("2") do |config|
  config.vm.provider :libvirt do |libvirt|
    libvirt.driver = "%s"
  end
end
`