647 lines
15 KiB
Go
647 lines
15 KiB
Go
package qemu
|
|
|
|
import (
|
|
"fmt"
|
|
"io/ioutil"
|
|
"os"
|
|
"path/filepath"
|
|
"reflect"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/hashicorp/packer/packer"
|
|
)
|
|
|
|
var testPem = `
|
|
-----BEGIN RSA PRIVATE KEY-----
|
|
MIIEpQIBAAKCAQEAxd4iamvrwRJvtNDGQSIbNvvIQN8imXTRWlRY62EvKov60vqu
|
|
hh+rDzFYAIIzlmrJopvOe0clqmi3mIP9dtkjPFrYflq52a2CF5q+BdwsJXuRHbJW
|
|
LmStZUwW1khSz93DhvhmK50nIaczW63u4EO/jJb3xj+wxR1Nkk9bxi3DDsYFt8SN
|
|
AzYx9kjlEYQ/+sI4/ATfmdV9h78SVotjScupd9KFzzi76gWq9gwyCBLRynTUWlyD
|
|
2UOfJRkOvhN6/jKzvYfVVwjPSfA9IMuooHdScmC4F6KBKJl/zf/zETM0XyzIDNmH
|
|
uOPbCiljq2WoRM+rY6ET84EO0kVXbfx8uxUsqQIDAQABAoIBAQCkPj9TF0IagbM3
|
|
5BSs/CKbAWS4dH/D4bPlxx4IRCNirc8GUg+MRb04Xz0tLuajdQDqeWpr6iLZ0RKV
|
|
BvreLF+TOdV7DNQ4XE4gSdJyCtCaTHeort/aordL3l0WgfI7mVk0L/yfN1PEG4YG
|
|
E9q1TYcyrB3/8d5JwIkjabxERLglCcP+geOEJp+QijbvFIaZR/n2irlKW4gSy6ko
|
|
9B0fgUnhkHysSg49ChHQBPQ+o5BbpuLrPDFMiTPTPhdfsvGGcyCGeqfBA56oHcSF
|
|
K02Fg8OM+Bd1lb48LAN9nWWY4WbwV+9bkN3Ym8hO4c3a/Dxf2N7LtAQqWZzFjvM3
|
|
/AaDvAgBAoGBAPLD+Xn1IYQPMB2XXCXfOuJewRY7RzoVWvMffJPDfm16O7wOiW5+
|
|
2FmvxUDayk4PZy6wQMzGeGKnhcMMZTyaq2g/QtGfrvy7q1Lw2fB1VFlVblvqhoJa
|
|
nMJojjC4zgjBkXMHsRLeTmgUKyGs+fdFbfI6uejBnnf+eMVUMIdJ+6I9AoGBANCn
|
|
kWO9640dttyXURxNJ3lBr2H3dJOkmD6XS+u+LWqCSKQe691Y/fZ/ZL0Oc4Mhy7I6
|
|
hsy3kDQ5k2V0fkaNODQIFJvUqXw2pMewUk8hHc9403f4fe9cPrL12rQ8WlQw4yoC
|
|
v2B61vNczCCUDtGxlAaw8jzSRaSI5s6ax3K7enbdAoGBAJB1WYDfA2CoAQO6y9Sl
|
|
b07A/7kQ8SN5DbPaqrDrBdJziBQxukoMJQXJeGFNUFD/DXFU5Fp2R7C86vXT7HIR
|
|
v6m66zH+CYzOx/YE6EsUJms6UP9VIVF0Rg/RU7teXQwM01ZV32LQ8mswhTH20o/3
|
|
uqMHmxUMEhZpUMhrfq0isyApAoGAe1UxGTXfj9AqkIVYylPIq2HqGww7+jFmVEj1
|
|
9Wi6S6Sq72ffnzzFEPkIQL/UA4TsdHMnzsYKFPSbbXLIWUeMGyVTmTDA5c0e5XIR
|
|
lPhMOKCAzv8w4VUzMnEkTzkFY5JqFCD/ojW57KvDdNZPVB+VEcdxyAW6aKELXMAc
|
|
eHLc1nkCgYEApm/motCTPN32nINZ+Vvywbv64ZD+gtpeMNP3CLrbe1X9O+H52AXa
|
|
1jCoOldWR8i2bs2NVPcKZgdo6fFULqE4dBX7Te/uYEIuuZhYLNzRO1IKU/YaqsXG
|
|
3bfQ8hKYcSnTfE0gPtLDnqCIxTocaGLSHeG3TH9fTw+dA8FvWpUztI4=
|
|
-----END RSA PRIVATE KEY-----
|
|
`
|
|
|
|
func testConfig() map[string]interface{} {
|
|
return map[string]interface{}{
|
|
"iso_checksum": "foo",
|
|
"iso_checksum_type": "md5",
|
|
"iso_url": "http://www.google.com/",
|
|
"ssh_username": "foo",
|
|
packer.BuildNameConfigKey: "foo",
|
|
}
|
|
}
|
|
|
|
func TestBuilder_ImplementsBuilder(t *testing.T) {
|
|
var raw interface{}
|
|
raw = &Builder{}
|
|
if _, ok := raw.(packer.Builder); !ok {
|
|
t.Error("Builder must implement builder.")
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_Defaults(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
if b.config.OutputDir != "output-foo" {
|
|
t.Errorf("bad output dir: %s", b.config.OutputDir)
|
|
}
|
|
|
|
if b.config.SSHHostPortMin != 2222 {
|
|
t.Errorf("bad min ssh host port: %d", b.config.SSHHostPortMin)
|
|
}
|
|
|
|
if b.config.SSHHostPortMax != 4444 {
|
|
t.Errorf("bad max ssh host port: %d", b.config.SSHHostPortMax)
|
|
}
|
|
|
|
if b.config.Comm.SSHPort != 22 {
|
|
t.Errorf("bad ssh port: %d", b.config.Comm.SSHPort)
|
|
}
|
|
|
|
if b.config.VMName != "packer-foo" {
|
|
t.Errorf("bad vm name: %s", b.config.VMName)
|
|
}
|
|
|
|
if b.config.Format != "qcow2" {
|
|
t.Errorf("bad format: %s", b.config.Format)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_VNCBindAddress(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Test a default boot_wait
|
|
delete(config, "vnc_bind_address")
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
|
|
if b.config.VNCBindAddress != "127.0.0.1" {
|
|
t.Fatalf("bad value: %s", b.config.VNCBindAddress)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_DiskCompaction(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Bad
|
|
config["skip_compaction"] = false
|
|
config["disk_compression"] = true
|
|
config["format"] = "img"
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
if b.config.SkipCompaction != true {
|
|
t.Fatalf("SkipCompaction should be true")
|
|
}
|
|
if b.config.DiskCompression != false {
|
|
t.Fatalf("DiskCompression should be false")
|
|
}
|
|
|
|
// Good
|
|
config["skip_compaction"] = false
|
|
config["disk_compression"] = true
|
|
config["format"] = "qcow2"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
if b.config.SkipCompaction != false {
|
|
t.Fatalf("SkipCompaction should be false")
|
|
}
|
|
if b.config.DiskCompression != true {
|
|
t.Fatalf("DiskCompression should be true")
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_DiskSize(t *testing.T) {
|
|
type testcase struct {
|
|
InputSize string
|
|
OutputSize string
|
|
ErrExpected bool
|
|
}
|
|
|
|
testCases := []testcase{
|
|
{"", "40960M", false}, // not provided
|
|
{"12345", "12345M", false}, // no unit given, defaults to M
|
|
{"12345x", "12345x", true}, // invalid unit
|
|
{"12345T", "12345T", false}, // terabytes
|
|
{"12345b", "12345b", false}, // bytes get preserved when set.
|
|
{"60000M", "60000M", false}, // Original test case
|
|
}
|
|
for _, tc := range testCases {
|
|
// Set input disk size
|
|
var b Builder
|
|
config := testConfig()
|
|
delete(config, "disk_size")
|
|
config["disk_size"] = tc.InputSize
|
|
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if (err == nil) == tc.ErrExpected {
|
|
t.Fatalf("bad: error when providing disk size %s; Err expected: %t; err recieved: %v", tc.InputSize, tc.ErrExpected, err)
|
|
}
|
|
|
|
if b.config.DiskSize != tc.OutputSize {
|
|
t.Fatalf("bad size: received: %s but expected %s", b.config.DiskSize, tc.OutputSize)
|
|
}
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_AdditionalDiskSize(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
config["disk_additional_size"] = []string{"1M"}
|
|
config["disk_image"] = true
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatalf("should have error")
|
|
}
|
|
|
|
delete(config, "disk_image")
|
|
config["disk_additional_size"] = []string{"1M"}
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
if b.config.AdditionalDiskSize[0] != "1M" {
|
|
t.Fatalf("bad size: %s", b.config.AdditionalDiskSize)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_Format(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Bad
|
|
config["format"] = "illegal value"
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Good
|
|
config["format"] = "qcow2"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
// Good
|
|
config["format"] = "raw"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_UseBackingFile(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
config["use_backing_file"] = true
|
|
|
|
// Bad: iso_url is not a disk_image
|
|
config["disk_image"] = false
|
|
config["format"] = "qcow2"
|
|
b = Builder{}
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Bad: format is not 'qcow2'
|
|
config["disk_image"] = true
|
|
config["format"] = "raw"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Good: iso_url is a disk image and format is 'qcow2'
|
|
config["disk_image"] = true
|
|
config["format"] = "qcow2"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_FloppyFiles(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
delete(config, "floppy_files")
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("bad err: %s", err)
|
|
}
|
|
|
|
if len(b.config.FloppyFiles) != 0 {
|
|
t.Fatalf("bad: %#v", b.config.FloppyFiles)
|
|
}
|
|
|
|
floppies_path := "../../common/test-fixtures/floppies"
|
|
config["floppy_files"] = []string{fmt.Sprintf("%s/bar.bat", floppies_path), fmt.Sprintf("%s/foo.ps1", floppies_path)}
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
expected := []string{fmt.Sprintf("%s/bar.bat", floppies_path), fmt.Sprintf("%s/foo.ps1", floppies_path)}
|
|
if !reflect.DeepEqual(b.config.FloppyFiles, expected) {
|
|
t.Fatalf("bad: %#v", b.config.FloppyFiles)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_InvalidFloppies(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
config["floppy_files"] = []string{"nonexistent.bat", "nonexistent.ps1"}
|
|
b = Builder{}
|
|
_, _, errs := b.Prepare(config)
|
|
if errs == nil {
|
|
t.Fatalf("Nonexistent floppies should trigger multierror")
|
|
}
|
|
|
|
if len(errs.(*packer.MultiError).Errors) != 2 {
|
|
t.Fatalf("Multierror should work and report 2 errors")
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_InvalidKey(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Add a random key
|
|
config["i_should_not_be_valid"] = true
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_OutputDir(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Test with existing dir
|
|
dir, err := ioutil.TempDir("", "packer")
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
defer os.RemoveAll(dir)
|
|
|
|
config["output_directory"] = dir
|
|
b = Builder{}
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Test with a good one
|
|
config["output_directory"] = "i-hope-i-dont-exist"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_ShutdownTimeout(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Test with a bad value
|
|
config["shutdown_timeout"] = "this is not good"
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Test with a good one
|
|
config["shutdown_timeout"] = "5s"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_SSHHostPort(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Bad
|
|
config["ssh_host_port_min"] = 1000
|
|
config["ssh_host_port_max"] = 500
|
|
b = Builder{}
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Bad
|
|
config["ssh_host_port_min"] = -500
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Good
|
|
config["ssh_host_port_min"] = 500
|
|
config["ssh_host_port_max"] = 1000
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_SSHPrivateKey(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
config["ssh_private_key_file"] = ""
|
|
b = Builder{}
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
config["ssh_private_key_file"] = "/i/dont/exist"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Test bad contents
|
|
tf, err := ioutil.TempFile("", "packer")
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
defer os.Remove(tf.Name())
|
|
defer tf.Close()
|
|
|
|
if _, err := tf.Write([]byte("HELLO!")); err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
|
|
config["ssh_private_key_file"] = tf.Name()
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Test good contents
|
|
tf.Seek(0, 0)
|
|
tf.Truncate(0)
|
|
tf.Write([]byte(testPem))
|
|
config["ssh_private_key_file"] = tf.Name()
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_SSHWaitTimeout(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Test a default boot_wait
|
|
delete(config, "ssh_timeout")
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
|
|
// Test with a bad value
|
|
config["ssh_timeout"] = "this is not good"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err == nil {
|
|
t.Fatal("should have error")
|
|
}
|
|
|
|
// Test with a good one
|
|
config["ssh_timeout"] = "5s"
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_QemuArgs(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
// Test with empty
|
|
delete(config, "qemuargs")
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("err: %s", err)
|
|
}
|
|
|
|
if !reflect.DeepEqual(b.config.QemuArgs, [][]string{}) {
|
|
t.Fatalf("bad: %#v", b.config.QemuArgs)
|
|
}
|
|
|
|
// Test with a good one
|
|
config["qemuargs"] = [][]interface{}{
|
|
{"foo", "bar", "baz"},
|
|
}
|
|
|
|
b = Builder{}
|
|
_, warns, err = b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
expected := [][]string{
|
|
{"foo", "bar", "baz"},
|
|
}
|
|
|
|
if !reflect.DeepEqual(b.config.QemuArgs, expected) {
|
|
t.Fatalf("bad: %#v", b.config.QemuArgs)
|
|
}
|
|
}
|
|
|
|
func TestBuilderPrepare_VNCPassword(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
|
|
config["vnc_use_password"] = true
|
|
config["output_directory"] = "not-a-real-directory"
|
|
b = Builder{}
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
expected := filepath.Join("not-a-real-directory", "packer-foo.monitor")
|
|
if !reflect.DeepEqual(b.config.QMPSocketPath, expected) {
|
|
t.Fatalf("Bad QMP socket Path: %s", b.config.QMPSocketPath)
|
|
}
|
|
}
|
|
|
|
func TestCommConfigPrepare_BackwardsCompatibility(t *testing.T) {
|
|
var b Builder
|
|
config := testConfig()
|
|
sshTimeout := 2 * time.Minute
|
|
config["ssh_wait_timeout"] = sshTimeout
|
|
|
|
_, warns, err := b.Prepare(config)
|
|
if len(warns) > 0 {
|
|
t.Fatalf("bad: %#v", warns)
|
|
}
|
|
if err != nil {
|
|
t.Fatalf("should not have error: %s", err)
|
|
}
|
|
|
|
if b.config.Comm.SSHTimeout != sshTimeout {
|
|
t.Fatalf("SSHTimeout should be %s for backwards compatibility, but it was %s", sshTimeout.String(), b.config.Comm.SSHTimeout.String())
|
|
}
|
|
}
|