Skip to content

Commit

Permalink
add: new datasource and documentation
Browse files Browse the repository at this point in the history
  • Loading branch information
castorsky authored and Ryan Johnson committed Dec 8, 2024
1 parent 05133be commit 08527f1
Show file tree
Hide file tree
Showing 17 changed files with 1,246 additions and 0 deletions.
6 changes: 6 additions & 0 deletions .web-docs/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,12 @@ packer plugins install github.com/hashicorp/vsphere
This builder deploys and publishes new virtual machine to a vSphere Supervisor cluster using VM
Service.

#### Data Sources

- [vsphere-virtual_machine](/packer/integrations/hashicorp/vsphere/latest/components/data-source/vsphere-virtual_machine) -
This datasource returns name of existing virtual machine that matches all defined filters to use
it as a builder source for `vsphere-clone`.

#### Post-Processors

- [vsphere](/packer/integrations/hashicorp/vsphere/latest/components/post-processor/vsphere) -
Expand Down
155 changes: 155 additions & 0 deletions .web-docs/components/data-source/virtual_machine/README.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,155 @@
Type: `vsphere-virtual_machine`
Artifact BuilderId: `vsphere.virtual_machine`

This datasource is able to get information about existing virtual machines from vSphere
and return name of one virtual machine that matches all specified filters. This virtual
machine can later be used in the vSphere Clone builder to select template.

## Configuration Reference

### Filters Configuration

**Optional:**

<!-- Code generated from the comments of the Config struct in datasource/virtual_machine/data.go; DO NOT EDIT MANUALLY -->

- `name` (string) - Basic filter with glob support (e.g. `nginx_basic*`). Defaults to `*`.
Using strict globs will not reduce execution time because vSphere API returns the full inventory.
But can be used for better readability over regular expressions.

- `name_regex` (string) - Extended name filter with regular expressions support (e.g. `nginx[-_]basic[0-9]*`). Default is empty.
The match of the regular expression is checked by substring. Use `^` and `$` to define a full string.
E.g. the `^[^_]+$` filter will search names without any underscores.
The expression must use [Go Regex Syntax](https://pkg.go.dev/regexp/syntax).

- `template` (bool) - Filter to return only objects that are virtual machine templates.
Defaults to `false` and returns all VMs.

- `node` (string) - Filter to search virtual machines only on the specified node.

- `vm_tags` ([]Tag) - Filter to return only that virtual machines that have attached all specifies tags.
Specify one or more `vm_tags` blocks to define list of tags that will make up the filter.
Should work since vCenter 6.7. To avoid incompatibility, REST client is being
initialized only when at least one tag has been defined in the config.

- `latest` (bool) - This filter determines how to handle multiple machines that were matched with all
previous filters. Machine creation time is being used to find latest.
By default, multiple matching machines results in an error.

<!-- End of code generated from the comments of the Config struct in datasource/virtual_machine/data.go; -->


### Tags Filter Configuration

<!-- Code generated from the comments of the Tag struct in datasource/virtual_machine/data.go; DO NOT EDIT MANUALLY -->

Example of multiple vm_tags blocks in HCL format:
```
vm_tags {
category = "team"
name = "operations"
}
vm_tags {
category = "SLA"
name = "gold"
}
```

<!-- End of code generated from the comments of the Tag struct in datasource/virtual_machine/data.go; -->


**Required:**

<!-- Code generated from the comments of the Tag struct in datasource/virtual_machine/data.go; DO NOT EDIT MANUALLY -->

- `name` (string) - Tag with this name must be attached to virtual machine which should pass the Tags Filter.

- `category` (string) - Name of the category that contains this tag. Both tag and category must be specified.

<!-- End of code generated from the comments of the Tag struct in datasource/virtual_machine/data.go; -->


### Connection Configuration

**Optional:**

<!-- Code generated from the comments of the ConnectConfig struct in builder/vsphere/common/step_connect.go; DO NOT EDIT MANUALLY -->

- `vcenter_server` (string) - The fully qualified domain name or IP address of the vCenter Server
instance.

- `username` (string) - The username to authenticate with the vCenter Server instance.

- `password` (string) - The password to authenticate with the vCenter Server instance.

- `insecure_connection` (bool) - Do not validate the certificate of the vCenter Server instance.
Defaults to `false`.

-> **Note:** This option is beneficial in scenarios where the certificate
is self-signed or does not meet standard validation criteria.

- `datacenter` (string) - The name of the datacenter object in the vSphere inventory.

-> **Note:** Required if more than one datacenter object exists in the
vSphere inventory.

<!-- End of code generated from the comments of the ConnectConfig struct in builder/vsphere/common/step_connect.go; -->


## Output

<!-- Code generated from the comments of the DatasourceOutput struct in datasource/virtual_machine/data.go; DO NOT EDIT MANUALLY -->

- `vm_name` (string) - Name of the found virtual machine.

<!-- End of code generated from the comments of the DatasourceOutput struct in datasource/virtual_machine/data.go; -->


## Example Usage

This is a very basic example that connects to vSphere cluster and tries to search
the latest virtual machine that matches all filters. The machine name is then printed
to console as output variable.
```hcl
data "vsphere-virtual_machine" "default" {
vcenter_server = "vcenter.example.org"
insecure_connection = true
username = "[email protected]"
password = "St4ongPa$$w0rd"
datacenter = "AZ1"
latest = true
vm_tags {
category = "team"
name = "operations"
}
vm_tags {
category = "SLA"
name = "gold"
}
}
locals {
vm_name = data.vsphere-virtual_machine.default.vm_name
}
source "null" "basic-example" {
communicator = "none"
}
build {
sources = [
"source.null.basic-example"
]
provisioner "shell-local" {
inline = [
"echo vm_name: ${local.vm_name}",
]
}
}
```
5 changes: 5 additions & 0 deletions .web-docs/metadata.hcl
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,9 @@ integration {
name = "vSphere Template"
slug = "vsphere-template"
}
component {
type = "data-source"
name = "vSphere Virtual Machine"
slug = "vsphere-virtual_machine"
}
}
182 changes: 182 additions & 0 deletions datasource/virtual_machine/data.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,182 @@
// Copyright (c) HashiCorp, Inc.
// SPDX-License-Identifier: MPL-2.0

//go:generate packer-sdc struct-markdown
//go:generate packer-sdc mapstructure-to-hcl2 -type Config,Tag,DatasourceOutput
package virtual_machine

import (
"github.com/hashicorp/hcl/v2/hcldec"
"github.com/hashicorp/packer-plugin-sdk/common"
"github.com/hashicorp/packer-plugin-sdk/hcl2helper"
packersdk "github.com/hashicorp/packer-plugin-sdk/packer"
"github.com/hashicorp/packer-plugin-sdk/template/config"
vsCommon "github.com/hashicorp/packer-plugin-vsphere/builder/vsphere/common"
"github.com/pkg/errors"
"github.com/zclconf/go-cty/cty"
)

// Example of multiple vm_tags blocks in HCL format:
// ```
//
// vm_tags {
// category = "team"
// name = "operations"
// }
// vm_tags {
// category = "SLA"
// name = "gold"
// }
//
// ```
type Tag struct {
// Tag with this name must be attached to virtual machine which should pass the Tags Filter.
Name string `mapstructure:"name" required:"true"`
// Name of the category that contains this tag. Both tag and category must be specified.
Category string `mapstructure:"category" required:"true"`
}

type Config struct {
common.PackerConfig `mapstructure:",squash"`
vsCommon.ConnectConfig `mapstructure:",squash"`

// Basic filter with glob support (e.g. `nginx_basic*`). Defaults to `*`.
// Using strict globs will not reduce execution time because vSphere API returns the full inventory.
// But can be used for better readability over regular expressions.
Name string `mapstructure:"name"`
// Extended name filter with regular expressions support (e.g. `nginx[-_]basic[0-9]*`). Default is empty.
// The match of the regular expression is checked by substring. Use `^` and `$` to define a full string.
// E.g. the `^[^_]+$` filter will search names without any underscores.
// The expression must use [Go Regex Syntax](https://pkg.go.dev/regexp/syntax).
NameRegex string `mapstructure:"name_regex"`
// Filter to return only objects that are virtual machine templates.
// Defaults to `false` and returns all VMs.
Template bool `mapstructure:"template"`
// Filter to search virtual machines only on the specified node.
Node string `mapstructure:"node"`
// Filter to return only that virtual machines that have attached all specifies tags.
// Specify one or more `vm_tags` blocks to define list of tags that will make up the filter.
// Should work since vCenter 6.7. To avoid incompatibility, REST client is being
// initialized only when at least one tag has been defined in the config.
VmTags []Tag `mapstructure:"vm_tags"`
// This filter determines how to handle multiple machines that were matched with all
// previous filters. Machine creation time is being used to find latest.
// By default, multiple matching machines results in an error.
Latest bool `mapstructure:"latest"`
}

type Datasource struct {
config Config
}

type DatasourceOutput struct {
// Name of the found virtual machine.
VmName string `mapstructure:"vm_name"`
}

func (d *Datasource) ConfigSpec() hcldec.ObjectSpec {
return d.config.FlatMapstructure().HCL2Spec()
}

func (d *Datasource) Configure(raws ...interface{}) error {
err := config.Decode(&d.config, nil, raws...)
if err != nil {
return err
}

if d.config.Name == "" {
d.config.Name = "*"
}

var errs *packersdk.MultiError
if d.config.VCenterServer == "" {
errs = packersdk.MultiErrorAppend(errs, errors.New("'vcenter_server' is required"))
}
if d.config.Username == "" {
errs = packersdk.MultiErrorAppend(errs, errors.New("'username' is required"))
}
if d.config.Password == "" {
errs = packersdk.MultiErrorAppend(errs, errors.New("'password' is required"))
}
if len(d.config.VmTags) > 0 {
for _, tag := range d.config.VmTags {
if tag.Name == "" || tag.Category == "" {
errs = packersdk.MultiErrorAppend(errs, errors.New("both name and category are required for tag"))
}
}
}

if errs != nil && len(errs.Errors) > 0 {
return errs
}

return nil
}

func (d *Datasource) OutputSpec() hcldec.ObjectSpec {
return (&DatasourceOutput{}).FlatMapstructure().HCL2Spec()
}

func (d *Datasource) Execute() (cty.Value, error) {
driver, err := newDriver(d.config)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to initialize driver")
}

// This is the first level of filters
// (the finder with glob will return filtered list or drop an error if found nothing).
filteredVms, err := driver.finder.VirtualMachineList(driver.ctx, d.config.Name)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to retrieve virtual machines list")
}

// Chain of other filters that will be executed only when defined
// and previous filter in chain left some virtual machines in the list.
if d.config.NameRegex != "" {
filteredVms = filterByNameRegex(filteredVms, d.config.NameRegex)
}

if len(filteredVms) > 0 && d.config.Template {
filteredVms, err = filterByTemplate(driver, filteredVms)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to filter by template attribute")
}
}

if len(filteredVms) > 0 && d.config.Node != "" {
filteredVms, err = filterByNode(driver, d.config, filteredVms)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to filter by node attribute")
}
}

if len(filteredVms) > 0 && d.config.VmTags != nil {
filteredVms, err = filterByTags(driver, d.config.VmTags, filteredVms)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to filter by tags")
}
}

// No VMs passed the filter chain. Nothing to return.
if len(filteredVms) == 0 {
return cty.NullVal(cty.EmptyObject), errors.New("not a single VM matches the configured filters")
}

if len(filteredVms) > 1 {
if d.config.Latest {
filteredVms, err = filterByLatest(driver, filteredVms)
if err != nil {
return cty.NullVal(cty.EmptyObject), errors.Wrap(err, "failed to find the latest VM")
}
} else {
// Too many machines passed the filter chain. Cannot decide which machine to return.
return cty.NullVal(cty.EmptyObject), errors.New("multiple VMs match the configured filters")
}
}

output := DatasourceOutput{
VmName: filteredVms[0].Name(),
}

return hcl2helper.HCL2ValueFromConfig(output, d.OutputSpec()), nil
}
Loading

0 comments on commit 08527f1

Please sign in to comment.