Skip to content

Commit

Permalink
tfexec: Add WorkspaceDelete() (#212)
Browse files Browse the repository at this point in the history
* tfexec: Add WorkspaceDelete()

* add E2E test for workspace deletion
  • Loading branch information
radeksimko authored Oct 21, 2021
1 parent 53bf871 commit 7262075
Show file tree
Hide file tree
Showing 3 changed files with 162 additions and 0 deletions.
29 changes: 29 additions & 0 deletions tfexec/internal/e2etest/workspace_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -104,6 +104,35 @@ func TestWorkspace_multiple(t *testing.T) {
})
}

func TestWorkspace_deletion(t *testing.T) {
runTest(t, "basic", func(t *testing.T, tfv *version.Version, tf *tfexec.Terraform) {
assertWorkspaceList(t, tf, "default")

const testWorkspace = "testws"

t.Run("create and delete workspace", func(t *testing.T) {
err := tf.WorkspaceNew(context.Background(), testWorkspace)
if err != nil {
t.Fatalf("got error creating workspace: %s", err)
}

assertWorkspaceList(t, tf, testWorkspace, testWorkspace)

err = tf.WorkspaceSelect(context.Background(), defaultWorkspace)
if err != nil {
t.Fatalf("got error selecting workspace: %s", err)
}

err = tf.WorkspaceDelete(context.Background(), testWorkspace)
if err != nil {
t.Fatalf("got error deleting workspace: %s", err)
}

assertWorkspaceList(t, tf, defaultWorkspace)
})
})
}

func assertWorkspaceList(t *testing.T, tf *tfexec.Terraform, expectedCurrent string, expectedWorkspaces ...string) {
actualWorkspaces, actualCurrent, err := tf.WorkspaceList(context.Background())
if err != nil {
Expand Down
81 changes: 81 additions & 0 deletions tfexec/workspace_delete.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,81 @@
package tfexec

import (
"context"
"fmt"
"os/exec"
"strconv"
)

type workspaceDeleteConfig struct {
lock bool
lockTimeout string
force bool
}

var defaultWorkspaceDeleteOptions = workspaceDeleteConfig{
lock: true,
lockTimeout: "0s",
}

// WorkspaceDeleteCmdOption represents options that are applicable to the WorkspaceDelete method.
type WorkspaceDeleteCmdOption interface {
configureWorkspaceDelete(*workspaceDeleteConfig)
}

func (opt *LockOption) configureWorkspaceDelete(conf *workspaceDeleteConfig) {
conf.lock = opt.lock
}

func (opt *LockTimeoutOption) configureWorkspaceDelete(conf *workspaceDeleteConfig) {
conf.lockTimeout = opt.timeout
}

func (opt *ForceOption) configureWorkspaceDelete(conf *workspaceDeleteConfig) {
conf.force = opt.force
}

// WorkspaceDelete represents the workspace delete subcommand to the Terraform CLI.
func (tf *Terraform) WorkspaceDelete(ctx context.Context, workspace string, opts ...WorkspaceDeleteCmdOption) error {
cmd, err := tf.workspaceDeleteCmd(ctx, workspace, opts...)
if err != nil {
return err
}
return tf.runTerraformCmd(ctx, cmd)
}

func (tf *Terraform) workspaceDeleteCmd(ctx context.Context, workspace string, opts ...WorkspaceDeleteCmdOption) (*exec.Cmd, error) {
c := defaultWorkspaceDeleteOptions

for _, o := range opts {
switch o.(type) {
case *LockOption, *LockTimeoutOption:
err := tf.compatible(ctx, tf0_12_0, nil)
if err != nil {
return nil, fmt.Errorf("-lock and -lock-timeout were added to workspace delete in Terraform 0.12: %w", err)
}
}

o.configureWorkspaceDelete(&c)
}

args := []string{"workspace", "delete", "-no-color"}

if c.force {
args = append(args, "-force")
}
if c.lockTimeout != "" && c.lockTimeout != defaultWorkspaceDeleteOptions.lockTimeout {
// only pass if not default, so we don't need to worry about the 0.11 version check
args = append(args, "-lock-timeout="+c.lockTimeout)
}
if !c.lock {
// only pass if false, so we don't need to worry about the 0.11 version check
args = append(args, "-lock="+strconv.FormatBool(c.lock))
}

args = append(args, workspace)

cmd := tf.buildTerraformCmd(ctx, nil, args...)

return cmd, nil
}
52 changes: 52 additions & 0 deletions tfexec/workspace_delete_test.go
Original file line number Diff line number Diff line change
@@ -0,0 +1,52 @@
package tfexec

import (
"context"
"testing"

"github.com/hashicorp/terraform-exec/tfexec/internal/testutil"
)

func TestWorkspaceDeleteCmd(t *testing.T) {
td := testTempDir(t)

tf, err := NewTerraform(td, tfVersion(t, testutil.Latest013))
if err != nil {
t.Fatal(err)
}

// empty env, to avoid environ mismatch in testing
tf.SetEnv(map[string]string{})

t.Run("defaults", func(t *testing.T) {
workspaceDeleteCmd, err := tf.workspaceDeleteCmd(context.Background(), "workspace-name")
if err != nil {
t.Fatal(err)
}

assertCmd(t, []string{
"workspace", "delete",
"-no-color",
"workspace-name",
}, nil, workspaceDeleteCmd)
})

t.Run("override all defaults", func(t *testing.T) {
workspaceDeleteCmd, err := tf.workspaceDeleteCmd(context.Background(), "workspace-name",
LockTimeout("200s"),
Force(true),
Lock(false))
if err != nil {
t.Fatal(err)
}

assertCmd(t, []string{
"workspace", "delete",
"-no-color",
"-force",
"-lock-timeout=200s",
"-lock=false",
"workspace-name",
}, nil, workspaceDeleteCmd)
})
}

0 comments on commit 7262075

Please sign in to comment.