mirror of
https://github.com/luxfi/lpm.git
synced 2026-10-30 16:20:57 +00:00
zeekay
83a37a3684
Lux Partners Limited is the Isle of Man company. Lux Industries Inc, a Delaware C corporation, is the company these sites belong to, so it is the one they name — in metadata, copyright, and the press items that record who signed. The fund site names Lux Assets Management LLC, which is its own company. Two sentences were rewritten rather than renamed, because a name was doing work a name cannot do. One claimed an Isle of Man domicile the naming entity does not have. The other said a company acts on behalf of another; with one entity left it said a company acts on behalf of itself. The Isle of Man stays everywhere it is a JURISDICTION the product supports — the regulatory package, the jurisdiction guides, the compliance tables. Only this company's own identity changed.
141 lines
3.6 KiB
Go
141 lines
3.6 KiB
Go
// Copyright (C) 2019-2025, Lux Industries Inc. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package workflow
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"io/fs"
|
|
"path/filepath"
|
|
"strings"
|
|
|
|
"github.com/luxfi/filesystem/perms"
|
|
"github.com/spf13/afero"
|
|
|
|
"github.com/luxfi/lpm/checksum"
|
|
"github.com/luxfi/lpm/state"
|
|
)
|
|
|
|
var _ Workflow = &Install{}
|
|
|
|
type InstallConfig struct {
|
|
Name string
|
|
Plugin string
|
|
Organization string
|
|
Repo string
|
|
TmpPath string
|
|
PluginPath string
|
|
|
|
StateFile state.File
|
|
Repository state.Repository
|
|
Fs afero.Fs
|
|
Installer Installer
|
|
}
|
|
|
|
func NewInstall(config InstallConfig) *Install {
|
|
return &Install{
|
|
name: config.Name,
|
|
plugin: config.Plugin,
|
|
organization: config.Organization,
|
|
repo: config.Repo,
|
|
tmpPath: config.TmpPath,
|
|
pluginPath: config.PluginPath,
|
|
stateFile: config.StateFile,
|
|
repository: config.Repository,
|
|
fs: config.Fs,
|
|
installer: config.Installer,
|
|
checksummer: checksum.NewSHA256(config.Fs),
|
|
}
|
|
}
|
|
|
|
type Install struct {
|
|
name string
|
|
plugin string
|
|
organization string
|
|
repo string
|
|
tmpPath string
|
|
pluginPath string
|
|
|
|
stateFile state.File
|
|
repository state.Repository
|
|
fs afero.Fs
|
|
installer Installer
|
|
checksummer checksum.Checksummer
|
|
}
|
|
|
|
func (i Install) Execute() error {
|
|
definition, err := i.repository.GetVM(i.plugin)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
vm := definition.Definition
|
|
|
|
archiveFile := fmt.Sprintf("%s.tar.gz", i.plugin)
|
|
tmpPath := filepath.Join(i.tmpPath, i.organization, i.repo)
|
|
archiveFilePath := filepath.Join(tmpPath, archiveFile)
|
|
workingDir := filepath.Join(tmpPath, i.plugin)
|
|
|
|
if err := i.installer.Download(vm.URL, archiveFilePath); err != nil {
|
|
// TODO sometimes these aren't cleaned up if we fail before cleanup step
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("Calculating checksums...\n")
|
|
hash := fmt.Sprintf("%x", i.checksummer.Checksum(archiveFilePath))
|
|
if hash != vm.SHA256 {
|
|
return fmt.Errorf("checksums did not match. Expected %s but saw %s", vm.SHA256, hash)
|
|
}
|
|
|
|
fmt.Printf("Saw expected checksum value of %s\n", hash)
|
|
|
|
// Create the directory we'll store the plugin sources in if it doesn't exist.
|
|
if _, err := i.fs.Stat(workingDir); errors.Is(err, fs.ErrNotExist) {
|
|
fmt.Printf("Creating sources directory...\n")
|
|
if err := i.fs.Mkdir(workingDir, perms.ReadWriteExecute); err != nil {
|
|
return err
|
|
}
|
|
} else if err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("Unpacking %s...\n", i.name)
|
|
if err := i.installer.Decompress(archiveFilePath, workingDir); err != nil {
|
|
return err
|
|
}
|
|
|
|
if vm.InstallScript != "" {
|
|
args := strings.Split(vm.InstallScript, " ")
|
|
fmt.Printf("Running install script at %s...\n", vm.InstallScript)
|
|
if err := i.installer.Install(workingDir, args...); err != nil {
|
|
return err
|
|
}
|
|
} else {
|
|
fmt.Printf("No install script found for %s.\n", i.name)
|
|
}
|
|
|
|
fmt.Printf("Moving binary %s into plugin directory...\n", vm.ID)
|
|
if err := i.fs.Rename(filepath.Join(workingDir, vm.BinaryPath), filepath.Join(i.pluginPath, vm.ID)); err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("Cleaning up temporary files...\n")
|
|
if err := i.fs.Remove(filepath.Join(tmpPath, archiveFile)); err != nil {
|
|
return err
|
|
}
|
|
|
|
if err := i.fs.RemoveAll(filepath.Join(tmpPath, i.plugin)); err != nil {
|
|
return err
|
|
}
|
|
|
|
fmt.Printf("Adding virtual machine %s to installation registry...\n", vm.ID)
|
|
i.stateFile.InstallationRegistry[i.name] = &state.InstallInfo{
|
|
ID: vm.ID,
|
|
Commit: definition.Commit,
|
|
}
|
|
|
|
fmt.Printf("Successfully installed %s@%s in %s\n", i.name, definition.Commit, filepath.Join(i.pluginPath, vm.ID))
|
|
return nil
|
|
}
|