Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
ce7bc1f
commit 1d716ac
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "io" | ||
| "os" | ||
| "strings" | ||
| ) | ||
|
|
||
| func doDetach(statePath string, upPath string, resource string) error { | ||
| stateFile, err := os.Open(statePath) | ||
| if err != nil { | ||
| return fmt.Errorf("detach: opening the state file: %s", err) | ||
| } | ||
| defer stateFile.Close() | ||
|
|
||
| upFile, err := os.Create(upPath) | ||
| if err != nil { | ||
| return fmt.Errorf("detach: creating the up file: %s", err) | ||
| } | ||
| defer upFile.Close() | ||
|
|
||
| addresses, err := matchResources(stateFile, resource) | ||
| if err != nil { | ||
| return fmt.Errorf("detach: finding matches: %s", err) | ||
| } | ||
|
|
||
| var bld strings.Builder | ||
| generateDetachScript(&bld, addresses) | ||
| _, err = upFile.WriteString(bld.String()) | ||
| if err != nil { | ||
| return fmt.Errorf("detach: writing script file: %s", err) | ||
| } | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| // TerraformState is a subset of the fields in the output of | ||
| // terraform show -no-color -json | ||
| type TerraformState struct { | ||
| FormatVersion string `json:"format_version"` | ||
| TerraformVersion string `json:"terraform_version"` | ||
| Values struct { | ||
| RootModule struct { | ||
| ChildModules []struct { | ||
| Resources []struct { | ||
| Address string `json:"address"` | ||
| Index string `json:"index"` | ||
| } `json:"resources"` | ||
| } `json:"child_modules"` | ||
| } `json:"root_module"` | ||
| } `json:"values"` | ||
| } | ||
|
|
||
| func matchResources(rd io.Reader, resource string) ([]string, error) { | ||
| dec := json.NewDecoder(rd) | ||
| var state TerraformState | ||
| if err := dec.Decode(&state); err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| var addresses []string | ||
| for _, child := range state.Values.RootModule.ChildModules { | ||
| for _, res := range child.Resources { | ||
| if matchResource(res.Index, resource) { | ||
| addresses = append(addresses, res.Address) | ||
| } | ||
| } | ||
| } | ||
| return addresses, nil | ||
| } | ||
|
|
||
| func matchResource(index, resource string) bool { | ||
| if index == resource { | ||
| return true | ||
| } | ||
| after, found := strings.CutPrefix(index, resource) | ||
| if !found { | ||
| return false | ||
| } | ||
| if strings.IndexAny(after, ".:") == 0 { | ||
| return true | ||
| } | ||
| return false | ||
| } | ||
|
|
||
| func generateDetachScript(wr io.Writer, addresses []string) { | ||
| fmt.Fprintf(wr, `#! /bin/sh | ||
| # DO NOT EDIT. Generated by https://github.com/pix4D/terravalet | ||
| # | ||
| # This script will detach %d items. | ||
| set -e | ||
| `, len(addresses)) | ||
| for _, addr := range addresses { | ||
| fmt.Fprintf(wr, "\nterraform state rm '%s'\n", addr) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,128 @@ | ||
| package main | ||
|
|
||
| import ( | ||
| "os" | ||
| "strings" | ||
| "testing" | ||
|
|
||
| "github.com/go-quicktest/qt" | ||
| ) | ||
|
|
||
| func TestMatchResourceSuccess(t *testing.T) { | ||
| type testCase struct { | ||
| name string | ||
| index string | ||
| resource string | ||
| } | ||
|
|
||
| test := func(t *testing.T, tc testCase) { | ||
| qt.Assert(t, qt.IsTrue(matchResource(tc.index, tc.resource))) | ||
| } | ||
|
|
||
| testCases := []testCase{ | ||
| { | ||
| name: "exact match", | ||
| index: "foo", | ||
| resource: "foo", | ||
| }, | ||
| { | ||
| name: "dot after match", | ||
| index: "foo.AN-", | ||
| resource: "foo", | ||
| }, | ||
| { | ||
| // FIXME this currently passes. Maybe we should err on the side of | ||
| // caution and change the signature to return an error instead, since | ||
| // we are not expecting this case??? | ||
| name: "FIXME multiple dots after match", | ||
| index: "foo.banana.AN-", | ||
| resource: "foo", | ||
| }, | ||
| { | ||
| name: "colon after match", | ||
| index: "foo:master", | ||
| resource: "foo", | ||
| }, | ||
| } | ||
|
|
||
| for _, tc := range testCases { | ||
| t.Run(tc.name, func(t *testing.T) { test(t, tc) }) | ||
| } | ||
| } | ||
|
|
||
| func TestMatchResourceFailure(t *testing.T) { | ||
| type testCase struct { | ||
| name string | ||
| index string | ||
| resource string | ||
| } | ||
|
|
||
| test := func(t *testing.T, tc testCase) { | ||
| qt.Assert(t, qt.IsFalse(matchResource(tc.index, tc.resource)), | ||
| qt.Commentf("index=%s resource=%s", tc.index, tc.resource)) | ||
| } | ||
|
|
||
| testCases := []testCase{ | ||
| { | ||
| name: "plain no match", | ||
| index: "foo", | ||
| resource: "bar", | ||
| }, | ||
| { | ||
| name: "prefix match is not enough", | ||
| index: "foobar", | ||
| resource: "foo", | ||
| }, | ||
| { | ||
| name: "wrong separator after prefix", | ||
| index: "foo_master", | ||
| resource: "foo", | ||
| }, | ||
| } | ||
|
|
||
| for _, tc := range testCases { | ||
| t.Run(tc.name, func(t *testing.T) { test(t, tc) }) | ||
| } | ||
| } | ||
|
|
||
| func TestMatchResources(t *testing.T) { | ||
| fi, err := os.Open("testdata/detach/01_pre_detach.json") | ||
| qt.Assert(t, qt.IsNil(err)) | ||
| defer fi.Close() | ||
|
|
||
| want := []string{ | ||
| `module.a.b.c["foo"]`, | ||
| `module.a.b.d["foo.AN-"]`, | ||
| `module.a.b.e["foo:master*"]`, | ||
| `module.x.y.z["foo"]`, | ||
| `module.x.y.k["foo.AN-"]`, | ||
| `module.x.y.z.j["foo:master*"]`, | ||
| } | ||
|
|
||
| have, err := matchResources(fi, "foo") | ||
|
|
||
| qt.Assert(t, qt.IsNil(err)) | ||
| qt.Assert(t, qt.DeepEquals(have, want)) | ||
| } | ||
|
|
||
| func TestGenerateDetachScript(t *testing.T) { | ||
| addresses := []string{ | ||
| `module.a.b.c["foo"]`, | ||
| `module.a.b.d["foo.AN-"]`, | ||
| } | ||
| var bld strings.Builder | ||
| want := `#! /bin/sh | ||
| # DO NOT EDIT. Generated by https://github.com/pix4D/terravalet | ||
| # | ||
| # This script will detach 2 items. | ||
| set -e | ||
| terraform state rm 'module.a.b.c["foo"]' | ||
| terraform state rm 'module.a.b.d["foo.AN-"]' | ||
| ` | ||
|
|
||
| generateDetachScript(&bld, addresses) | ||
| qt.Assert(t, qt.Equals(bld.String(), want)) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,32 +1,36 @@ | ||
| github.com/alexflint/go-arg v1.4.3 h1:9rwwEBpMXfKQKceuZfYcwuc/7YY7tWJbFsgG5cAU/uo= | ||
| github.com/alexflint/go-arg v1.4.3/go.mod h1:3PZ/wp/8HuqRZMUUgu7I+e1qcpUbvmS258mRXkFH4IA= | ||
| github.com/alexflint/go-scalar v1.1.0/go.mod h1:LoFvNMqS1CPrMVltza4LvnGKhaSpc3oyLEBUZVhhS2o= | ||
| github.com/alexflint/go-scalar v1.2.0 h1:WR7JPKkeNpnYIOfHRa7ivM21aWAdHD0gEWHCx+WQBRw= | ||
| github.com/alexflint/go-scalar v1.2.0/go.mod h1:LoFvNMqS1CPrMVltza4LvnGKhaSpc3oyLEBUZVhhS2o= | ||
| github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= | ||
| github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= | ||
| github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= | ||
| github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= | ||
| github.com/dexyk/stringosim v0.0.0-20170922105913-9d0b3e91a842 h1:FWXGhOthNyZKdK0YVyDrkg5dCXOfKvexcRG37U1v6AQ= | ||
| github.com/dexyk/stringosim v0.0.0-20170922105913-9d0b3e91a842/go.mod h1:PfVoEMbmPGFArz22/wIefW9CzuQhdnE+C9ikEzJvb9Q= | ||
| github.com/fatih/set v0.2.1 h1:nn2CaJyknWE/6txyUDGwysr3G5QC6xWB/PtVjPBbeaA= | ||
| github.com/fatih/set v0.2.1/go.mod h1:+RKtMCH+favT2+3YecHGxcc0b4KyVWA1QWWJUs4E0CI= | ||
| github.com/go-quicktest/qt v1.101.0 h1:O1K29Txy5P2OK0dGo59b7b0LR6wKfIhttaAhHUyn7eI= | ||
| github.com/go-quicktest/qt v1.101.0/go.mod h1:14Bz/f7NwaXPtdYEgzsx46kqSxVwTbzVZsDC26tQJow= | ||
| github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= | ||
| github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY= | ||
| github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE= | ||
| github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk= | ||
| github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY= | ||
| github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= | ||
| github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= | ||
| github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= | ||
| github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= | ||
| github.com/rogpeppe/go-internal v1.9.0/go.mod h1:WtVeX8xhTBvf0smdhujwtBcq4Qrzq/fJaraNFVN+nFs= | ||
| github.com/rogpeppe/go-internal v1.11.0 h1:cWPaGQEPrBb5/AsnsZesgZZ9yb1OQ+GOISoDNXVBh4M= | ||
| github.com/rogpeppe/go-internal v1.11.0/go.mod h1:ddIwULY96R17DhadqLgMfk9H9tvdUzkipdSkR5nkCZA= | ||
| github.com/scylladb/go-set v1.0.3-0.20200225121959-cc7b2070d91e h1:7q6NSFZDeGfvvtIRwBrU/aegEYJYmvev0cHAwo17zZQ= | ||
| github.com/scylladb/go-set v1.0.3-0.20200225121959-cc7b2070d91e/go.mod h1:DkpGd78rljTxKAnTDPFqXSGxvETQnJyuSOQwsHycqfs= | ||
| github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME= | ||
| github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs= | ||
| github.com/stretchr/testify v1.7.0 h1:nwc3DEeHmmLAfoZucVR881uASk0Mfjw8xYJ99tb5CcY= | ||
| github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= | ||
| gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= | ||
| gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c h1:dUUwHk2QECo/6vqA44rthZ8ie2QXMNeKRTHCNY2nXvo= | ||
| gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.