mirror of
https://github.com/outbackdingo/debos.git
synced 2026-01-27 10:18:47 +00:00
f566e04888
Enabled additional linters from fakemachine configuration: - errorlint: Error wrapping with %w - misspell: Spelling checks - revive: Code quality checks - whitespace: Formatting checks Fixed all issues including: - Error handling: Added proper error checks for all function returns - Error wrapping: Changed %v to %w for proper error wrapping - Type assertions: Used errors.As instead of direct type assertions - Unused parameters: Renamed to underscore where appropriate - Variable naming: Fixed ALL_CAPS constants and underscored names - Whitespace: Removed unnecessary leading/trailing newlines - Code flow: Removed unnecessary else blocks Renamed types (breaking internal API changes): - DebosState → State - DebosContext → Context - DownloadHttpUrl → DownloadHTTPURL Fixed struct field naming with proper YAML tags: - Url → URL (with yaml:"url" tag) - TlsClientCertPath → TLSClientCertPath (kept yaml:"tls-client-cert-path") - TlsClientKeyPath → TLSClientKeyPath (kept yaml:"tls-client-key-path") - validateUrl → validateURL method Co-authored-by: sjoerdsimons <22603932+sjoerdsimons@users.noreply.github.com>
115 lines
2.4 KiB
Go
115 lines
2.4 KiB
Go
package debos
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"os"
|
|
"path"
|
|
"path/filepath"
|
|
"strings"
|
|
)
|
|
|
|
func CleanPathAt(path, at string) string {
|
|
if filepath.IsAbs(path) {
|
|
return filepath.Clean(path)
|
|
}
|
|
|
|
return filepath.Join(at, path)
|
|
}
|
|
|
|
func CleanPath(path string) string {
|
|
cwd, _ := os.Getwd()
|
|
return CleanPathAt(path, cwd)
|
|
}
|
|
|
|
func CopyFile(src, dst string, mode os.FileMode) error {
|
|
in, err := os.Open(src)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
defer in.Close()
|
|
tmp, err := os.CreateTemp(filepath.Dir(dst), "")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
_, err = io.Copy(tmp, in)
|
|
if err != nil {
|
|
tmp.Close()
|
|
os.Remove(tmp.Name())
|
|
return err
|
|
}
|
|
if err = tmp.Close(); err != nil {
|
|
os.Remove(tmp.Name())
|
|
return err
|
|
}
|
|
if err = os.Chmod(tmp.Name(), mode); err != nil {
|
|
os.Remove(tmp.Name())
|
|
return err
|
|
}
|
|
|
|
if err = os.Rename(tmp.Name(), dst); err != nil {
|
|
os.Remove(tmp.Name())
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func CopyTree(sourcetree, desttree string) error {
|
|
walker := func(p string, info os.FileInfo, err error) error {
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
suffix, _ := filepath.Rel(sourcetree, p)
|
|
target := path.Join(desttree, suffix)
|
|
switch info.Mode() & os.ModeType {
|
|
case 0:
|
|
err := CopyFile(p, target, info.Mode())
|
|
if err != nil {
|
|
return fmt.Errorf("failed to copy file %s: %w", p, err)
|
|
}
|
|
case os.ModeDir:
|
|
if err := os.Mkdir(target, info.Mode()); err != nil && !os.IsExist(err) {
|
|
return fmt.Errorf("failed to create directory %s: %w", target, err)
|
|
}
|
|
case os.ModeSymlink:
|
|
link, err := os.Readlink(p)
|
|
if err != nil {
|
|
return fmt.Errorf("failed to read symlink %s: %w", suffix, err)
|
|
}
|
|
if err := os.Symlink(link, target); err != nil && !os.IsExist(err) {
|
|
return fmt.Errorf("failed to create symlink %s: %w", target, err)
|
|
}
|
|
default:
|
|
return fmt.Errorf("file %s with mode %v not handled", p, info.Mode())
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
return filepath.Walk(sourcetree, walker)
|
|
}
|
|
|
|
func RealPath(path string) (string, error) {
|
|
p, err := filepath.EvalSymlinks(path)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
return filepath.Abs(p)
|
|
}
|
|
|
|
func RestrictedPath(prefix, dest string) (string, error) {
|
|
var err error
|
|
destination := path.Join(prefix, dest)
|
|
destination, err = filepath.Abs(destination)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
if !strings.HasPrefix(destination, prefix) {
|
|
return "", fmt.Errorf("resulting path points outside of prefix '%s': '%s'", prefix, destination)
|
|
}
|
|
return destination, nil
|
|
}
|