resource_jenkinsci_plugin.go

package jenkinsci

import (
	"context"
	"fmt"
	"regexp"

	jenkins "github.com/bndr/gojenkins"
	"github.com/hashicorp/terraform-plugin-sdk/v2/diag"
	"github.com/hashicorp/terraform-plugin-sdk/v2/helper/schema"
)

func resourcePlugin() *schema.Resource {
	return &schema.Resource{
		CreateContext: resourcePluginCreate,
		ReadContext:   resourcePluginRead,
		UpdateContext: resourcePluginUpdate,
		DeleteContext: resourcePluginDelete,
		Importer: &schema.ResourceImporter{
			StateContext: schema.ImportStatePassthroughContext,
		},
		Schema: map[string]*schema.Schema{
			"name": {
				Type:     schema.TypeString,
				Required: true,
			},
			"version": {
				Type:         schema.TypeString,
				Required:     true,
				ValidateFunc: validatePluginVersion,
			},
		},
	}
}

func resourcePluginCreate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	client := meta.(*jenkins.Jenkins)
	name := d.Get("name").(string)
	version := d.Get("version").(string)

	err := client.InstallPlugin(ctx, name, version)
	if err != nil {
		return diag.FromErr(fmt.Errorf("error installing the jenkins %s plugin: %s", name, err))
	}

	d.SetId(name)
	return resourcePluginRead(ctx, d, meta)
}

func resourcePluginRead(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	client := meta.(*jenkins.Jenkins)
	name := d.Get("name").(string)

	p, err := client.HasPlugin(ctx, name)
	if err != nil {
		return diag.FromErr(fmt.Errorf("error reading the jenkins %s plugin: %s", name, err))
	}
	if p == nil {
		return diag.FromErr(fmt.Errorf("could not find jenkins plugin: %s: %s", name, err))
	}
	d.SetId(name)

	return nil
}

func resourcePluginUpdate(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	client := meta.(*jenkins.Jenkins)
	name := d.Get("name").(string)
	version := d.Get("version").(string)

	if d.HasChange("version") {
		err := client.InstallPlugin(ctx, name, version)
		if err != nil {
			return diag.FromErr(fmt.Errorf("error updating the jenkins %s plugin: %s", name, err))
		}
	}

	return resourcePluginRead(ctx, d, meta)
}

func resourcePluginDelete(ctx context.Context, d *schema.ResourceData, meta interface{}) diag.Diagnostics {
	client := meta.(*jenkins.Jenkins)
	name := d.Get("name").(string)

	err := client.UninstallPlugin(ctx, name)
	if err != nil {
		return diag.FromErr(fmt.Errorf("error deleting the jenkins %s plugin: %s", name, err))
	}

	return nil
}

func validatePluginVersion(v interface{}, k string) (warnings []string, errors []error) {
	value := v.(string)

	if !regexp.MustCompile(`^[0-9.]+$`).MatchString(value) {
		errors = append(errors, fmt.Errorf("numbers and periods are only are allowed in %q: %q", k, value))
	}

	return warnings, errors
}