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
f2724df
commit 351af25
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,84 @@ | ||
| package provider | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "github.com/hashicorp/terraform-plugin-log/tflog" | ||
| ) | ||
|
|
||
| type InstanceClient ClientContext[InstanceResourceModel] | ||
|
|
||
| func (ic *InstanceClient) DataDir() string { | ||
| return ic.data.Compose.DataDir.ValueString() | ||
| } | ||
|
|
||
| func (ic *InstanceClient) Close() error { | ||
| return ic.cl.Disconnect() | ||
| } | ||
|
|
||
| // TODO chown data dir to ssh user or 'aem' user (create him maybe) | ||
|
Check failure on line 18 in internal/provider/instance_client.go
|
||
| func (ic *InstanceClient) prepareDataDir() error { | ||
|
Check failure on line 19 in internal/provider/instance_client.go
|
||
| if _, err := ic.cl.RunShell(fmt.Sprintf("rm -fr %s", ic.DataDir())); err != nil { | ||
| return fmt.Errorf("cannot clean up AEM data directory: %w", err) | ||
| } | ||
| if _, err := ic.cl.RunShell(fmt.Sprintf("mkdir -p %s", ic.DataDir())); err != nil { | ||
| return fmt.Errorf("cannot create AEM data directory: %w", err) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (ic *InstanceClient) installCompose() error { | ||
|
Check failure on line 29 in internal/provider/instance_client.go
|
||
| out, err := ic.cl.RunShellWithEnv(fmt.Sprintf("cd %s && curl -s https://raw.githubusercontent.com/wttech/aemc/main/project-init.sh | sh", ic.DataDir())) | ||
| tflog.Info(ic.ctx, string(out)) | ||
| if err != nil { | ||
| return fmt.Errorf("cannot install AEM Compose CLI: %w", err) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (ic *InstanceClient) copyConfigFile() error { | ||
| configFile := ic.data.Compose.ConfigFile.ValueString() | ||
| if err := ic.cl.FileCopy(configFile, fmt.Sprintf("%s/aem/default/etc/aem.yml", ic.DataDir()), true); err != nil { | ||
| return fmt.Errorf("unable to copy AEM configuration file: %w", err) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (ic *InstanceClient) copyLibraryDir() error { | ||
| localLibDir := ic.data.Compose.LibDir.ValueString() | ||
| remoteLibDir := fmt.Sprintf("%s/aem/home/lib", ic.DataDir()) | ||
| if err := ic.cl.DirCopy(localLibDir, remoteLibDir, false); err != nil { | ||
| return fmt.Errorf("unable to copy AEM library dir: %w", err) | ||
| } | ||
| return nil | ||
| } | ||
|
|
||
| func (ic *InstanceClient) create() error { | ||
| tflog.Info(ic.ctx, "Creating AEM instance(s)") | ||
|
|
||
| textOut, err := ic.cl.RunShellWithEnv(fmt.Sprintf("cd %s && sh aemw instance create", ic.DataDir())) | ||
| if err != nil { | ||
| return fmt.Errorf("unable to create AEM instance: %w", err) | ||
| } | ||
|
|
||
| textStr := string(textOut) // TODO how about streaming it line by line to tflog ;) | ||
| tflog.Info(ic.ctx, "Created AEM instance(s)") | ||
| tflog.Info(ic.ctx, textStr) // TODO consider checking 'changed' flag here if needed | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (ic *InstanceClient) launch() error { | ||
|
Check failure on line 70 in internal/provider/instance_client.go
|
||
| tflog.Info(ic.ctx, "Launching AEM instance(s)") | ||
|
|
||
| // TODO register systemd service instead and start it | ||
| textOut, err := ic.cl.RunShellWithEnv(fmt.Sprintf("cd %s && sh aemw instance launch", ic.DataDir())) | ||
| if err != nil { | ||
| return fmt.Errorf("unable to launch AEM instance: %w", err) | ||
| } | ||
|
|
||
| textStr := string(textOut) // TODO how about streaming it line by line to tflog ;) | ||
| tflog.Info(ic.ctx, "Launched AEM instance(s)") | ||
| tflog.Info(ic.ctx, textStr) // TODO consider checking 'changed' flag here if needed | ||
|
|
||
| return nil | ||
| } | ||
Oops, something went wrong.