d49683fd01
Migrate filesystem operations to use the io.Local abstraction for improved security, testability, and consistency: - pkg/cache: Replace os.ReadFile, WriteFile, Remove, RemoveAll with io.Local equivalents. io.Local.Write creates parent dirs automatically. - pkg/agentic: Migrate config.go and context.go to use io.Local for reading config files and gathering file context. - pkg/repos: Use io.Local.Read, Exists, IsDir, List for registry operations and git repo detection. - pkg/release: Use io.Local for config loading, existence checks, and artifact discovery. - pkg/devops/sources: Use io.Local.EnsureDir for CDN download. All paths are converted to absolute using filepath.Abs() before calling io.Local methods to handle relative paths correctly. Closes #104, closes #106, closes #108, closes #111 Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
113 lines
2.6 KiB
Go
113 lines
2.6 KiB
Go
package sources
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
goio "io"
|
|
"net/http"
|
|
"os"
|
|
"path/filepath"
|
|
|
|
"github.com/host-uk/core/pkg/io"
|
|
)
|
|
|
|
// CDNSource downloads images from a CDN or S3 bucket.
|
|
type CDNSource struct {
|
|
config SourceConfig
|
|
}
|
|
|
|
// Compile-time interface check.
|
|
var _ ImageSource = (*CDNSource)(nil)
|
|
|
|
// NewCDNSource creates a new CDN source.
|
|
func NewCDNSource(cfg SourceConfig) *CDNSource {
|
|
return &CDNSource{config: cfg}
|
|
}
|
|
|
|
// Name returns "cdn".
|
|
func (s *CDNSource) Name() string {
|
|
return "cdn"
|
|
}
|
|
|
|
// Available checks if CDN URL is configured.
|
|
func (s *CDNSource) Available() bool {
|
|
return s.config.CDNURL != ""
|
|
}
|
|
|
|
// LatestVersion fetches version from manifest or returns "latest".
|
|
func (s *CDNSource) LatestVersion(ctx context.Context) (string, error) {
|
|
// Try to fetch manifest.json for version info
|
|
url := fmt.Sprintf("%s/manifest.json", s.config.CDNURL)
|
|
req, err := http.NewRequestWithContext(ctx, "GET", url, nil)
|
|
if err != nil {
|
|
return "latest", nil
|
|
}
|
|
|
|
resp, err := http.DefaultClient.Do(req)
|
|
if err != nil || resp.StatusCode != 200 {
|
|
return "latest", nil
|
|
}
|
|
defer func() { _ = resp.Body.Close() }()
|
|
|
|
// For now, just return latest - could parse manifest for version
|
|
return "latest", nil
|
|
}
|
|
|
|
// Download downloads the image from CDN.
|
|
func (s *CDNSource) Download(ctx context.Context, dest string, progress func(downloaded, total int64)) error {
|
|
url := fmt.Sprintf("%s/%s", s.config.CDNURL, s.config.ImageName)
|
|
|
|
req, err := http.NewRequestWithContext(ctx, "GET", url, nil)
|
|
if err != nil {
|
|
return fmt.Errorf("cdn.Download: %w", err)
|
|
}
|
|
|
|
resp, err := http.DefaultClient.Do(req)
|
|
if err != nil {
|
|
return fmt.Errorf("cdn.Download: %w", err)
|
|
}
|
|
defer func() { _ = resp.Body.Close() }()
|
|
|
|
if resp.StatusCode != 200 {
|
|
return fmt.Errorf("cdn.Download: HTTP %d", resp.StatusCode)
|
|
}
|
|
|
|
// Ensure dest directory exists
|
|
if err := io.Local.EnsureDir(dest); err != nil {
|
|
return fmt.Errorf("cdn.Download: %w", err)
|
|
}
|
|
|
|
// Create destination file
|
|
destPath := filepath.Join(dest, s.config.ImageName)
|
|
f, err := os.Create(destPath)
|
|
if err != nil {
|
|
return fmt.Errorf("cdn.Download: %w", err)
|
|
}
|
|
defer func() { _ = f.Close() }()
|
|
|
|
// Copy with progress
|
|
total := resp.ContentLength
|
|
var downloaded int64
|
|
|
|
buf := make([]byte, 32*1024)
|
|
for {
|
|
n, err := resp.Body.Read(buf)
|
|
if n > 0 {
|
|
if _, werr := f.Write(buf[:n]); werr != nil {
|
|
return fmt.Errorf("cdn.Download: %w", werr)
|
|
}
|
|
downloaded += int64(n)
|
|
if progress != nil {
|
|
progress(downloaded, total)
|
|
}
|
|
}
|
|
if err == goio.EOF {
|
|
break
|
|
}
|
|
if err != nil {
|
|
return fmt.Errorf("cdn.Download: %w", err)
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|