-
Notifications
You must be signed in to change notification settings - Fork 58
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
An xmv command is like a mv command but it allows usage of wildcards (*) in the source of the move command and placeholders ($1, $2, ..., $N) in the destination of the move command. The source will match against the state and the placeholders will correspond to the wildcard values.
- Loading branch information
Showing
6 changed files
with
373 additions
and
0 deletions.
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
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,129 @@ | ||
| package tfmigrate | ||
|
|
||
| import ( | ||
| "context" | ||
| "fmt" | ||
| "regexp" | ||
| "strings" | ||
|
|
||
| "github.com/minamijoyo/tfmigrate/tfexec" | ||
| ) | ||
|
|
||
| // StateXMvAction implements the StateAction interface. | ||
| // StateXMvAction moves a resource from source address to destination address in | ||
| // the same tfstate file. | ||
| type StateXMvAction struct { | ||
| // source is a address of resource or module to be moved which can contain wildcards. | ||
| source string | ||
| // destination is a new address of resource or module to move which can contain placeholders. | ||
| destination string | ||
| } | ||
|
|
||
| var _ StateAction = (*StateXMvAction)(nil) | ||
|
|
||
| // NewStateMvAction returns a new StateXMvAction instance. | ||
| func NewStateXMvAction(source string, destination string) *StateXMvAction { | ||
| return &StateXMvAction{ | ||
| source: source, | ||
| destination: destination, | ||
| } | ||
| } | ||
|
|
||
| // StateUpdate updates a given state and returns a new state. | ||
| // Source resources have wildcards wich should be matched against the tf state. Each occurrence will generate | ||
| // a move command. | ||
| func (a *StateXMvAction) StateUpdate(ctx context.Context, tf tfexec.TerraformCLI, state *tfexec.State) (*tfexec.State, error) { | ||
| stateMvActions, err := a.generateMvActions(ctx, tf, state) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
|
|
||
| for _, action := range stateMvActions { | ||
| state, err = action.StateUpdate(ctx, tf, state) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| } | ||
| return state, err | ||
| } | ||
|
|
||
| func (a *StateXMvAction) generateMvActions(ctx context.Context, tf tfexec.TerraformCLI, state *tfexec.State) (response []*StateMvAction, err error) { | ||
| stateList, err := tf.StateList(ctx, state, nil) | ||
| if err != nil { | ||
| return nil, err | ||
| } | ||
| return a.getStateMvActionsForStateList(stateList) | ||
| } | ||
|
|
||
| // When a wildcardChar is used in a path it should only match a single part of the path | ||
| // It can therefore not contain a dot(.), whitespace nor square brackets | ||
| const matchWildcardRegex = "([^\\]\\[\t\n\v\f\r ]*)" | ||
| const wildcardChar = "*" | ||
|
|
||
| func (a *StateXMvAction) nrOfWildcards() int { | ||
| return strings.Count(a.source, wildcardChar) | ||
| } | ||
|
|
||
| // Return regex pattern that matches the wildcard source and make sure characters are not treated as | ||
| // special meta characters. | ||
| func makeSourceMatchPattern(s string) string { | ||
| safeString := regexp.QuoteMeta(s) | ||
| quotedWildCardChar := regexp.QuoteMeta(wildcardChar) | ||
| return strings.ReplaceAll(safeString, quotedWildCardChar, matchWildcardRegex) | ||
| } | ||
|
|
||
| // Get a regex that will do matching based on the wildcard source that was given. | ||
| func makeSrcRegex(source string) (r *regexp.Regexp, err error) { | ||
| regPattern := makeSourceMatchPattern(source) | ||
| r, err = regexp.Compile(regPattern) | ||
| if err != nil { | ||
| return nil, fmt.Errorf("could not make pattern out of %s (%s) due to %s", source, regPattern, err.Error()) | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // Look into the state and find sources that match pattern with wild cards. | ||
| func (a *StateXMvAction) getMatchingSourcesFromState(stateList []string) (wildcardMatches []string, err error) { | ||
| r, e := makeSrcRegex(a.source) | ||
| if e != nil { | ||
| return nil, e | ||
| } | ||
| wildcardMatches = r.FindAllString(strings.Join(stateList, "\n"), -1) | ||
| if wildcardMatches == nil { | ||
| return []string{}, nil | ||
| } | ||
| return | ||
| } | ||
|
|
||
| // When you have the stateXMvAction with wildcards get the destination for a source | ||
| func (a *StateXMvAction) getDestinationForStateSrc(stateSource string) (destination string, err error) { | ||
| r, e := makeSrcRegex(a.source) | ||
| if e != nil { | ||
| return "", e | ||
| } | ||
| destination = r.ReplaceAllString(stateSource, a.destination) | ||
| return | ||
| } | ||
|
|
||
| // Get actions matching wildcard move actions based on the list of resources. | ||
| func (a *StateXMvAction) getStateMvActionsForStateList(stateList []string) (response []*StateMvAction, err error) { | ||
| if a.nrOfWildcards() == 0 { | ||
| response = make([]*StateMvAction, 1) | ||
| response[0] = NewStateMvAction(a.source, a.destination) | ||
| return response, nil | ||
| } | ||
| matchingSources, e := a.getMatchingSourcesFromState(stateList) | ||
| if e != nil { | ||
| return nil, e | ||
| } | ||
| response = make([]*StateMvAction, len(matchingSources)) | ||
| for i, matchingSource := range matchingSources { | ||
| destination, e2 := a.getDestinationForStateSrc(matchingSource) | ||
| if e2 != nil { | ||
| return nil, e2 | ||
| } | ||
| sma := StateMvAction{matchingSource, destination} | ||
| response[i] = &sma | ||
| } | ||
| return | ||
| } |
Oops, something went wrong.