diff options
Diffstat (limited to 'internal/importer')
-rw-r--r-- | internal/importer/channel.go | 16 | ||||
-rw-r--r-- | internal/importer/http.go | 6 | ||||
-rw-r--r-- | internal/importer/importer.go | 12 | ||||
-rw-r--r-- | internal/importer/nixpkgs-channel.go | 5 |
4 files changed, 33 insertions, 6 deletions
diff --git a/internal/importer/channel.go b/internal/importer/channel.go index 4d051cc..b75839b 100644 --- a/internal/importer/channel.go +++ b/internal/importer/channel.go @@ -55,10 +55,22 @@ func (i *ChannelImporter) FetchIfNeeded(parent context.Context) (bool, error) { i.Logger.Debug("nix-build", "output", strings.TrimSpace(string(out))) outPath := path.Join(dest, i.Source.OutputPath) - i.Logger.Debug("checking output path", "outputPath", outPath, "dest", dest, "source", i.Source.OutputPath) + i.Logger.Debug( + "checking output path", + "outputPath", + outPath, + "dest", + dest, + "source", + i.Source.OutputPath, + ) after, err := os.Readlink(dest) if err := file.NeedNotExist(err); err != nil { - return false, errors.WithMessagef(err, "failed to stat output file from nix-build, filename: %s", outPath) + return false, errors.WithMessagef( + err, + "failed to stat output file from nix-build, filename: %s", + outPath, + ) } i.Logger.Debug("stat after", "name", after) diff --git a/internal/importer/http.go b/internal/importer/http.go index 1bf2428..6d60c44 100644 --- a/internal/importer/http.go +++ b/internal/importer/http.go @@ -44,7 +44,11 @@ func fetchFileIfNeeded(ctx context.Context, path string, url string) (needed boo case http.StatusOK: newMtime, err := time.Parse(time.RFC1123, res.Header.Get("Last-Modified")) if err != nil { - slog.Warn("could not parse Last-Modified header from response", "value", res.Header.Get("Last-Modified")) + slog.Warn( + "could not parse Last-Modified header from response", + "value", + res.Header.Get("Last-Modified"), + ) } err = file.WriteToFile(path, res.Body) if err != nil { diff --git a/internal/importer/importer.go b/internal/importer/importer.go index 2318fe4..4d563fd 100644 --- a/internal/importer/importer.go +++ b/internal/importer/importer.go @@ -27,7 +27,11 @@ type Importer interface { Import(context.Context, *search.WriteIndex) (bool, error) } -func NewNixpkgsChannelImporter(source Source, dataPath string, logger *slog.Logger) *NixpkgsChannelImporter { +func NewNixpkgsChannelImporter( + source Source, + dataPath string, + logger *slog.Logger, +) *NixpkgsChannelImporter { indexPath := dataPath fullpath := path.Join(dataPath, source.Channel) @@ -58,7 +62,11 @@ type importConfig struct { Logger *slog.Logger } -func processOptions(parent context.Context, indexer *search.WriteIndex, conf *importConfig) (bool, error) { +func processOptions( + parent context.Context, + indexer *search.WriteIndex, + conf *importConfig, +) (bool, error) { ctx, cancel := context.WithTimeout(parent, conf.Source.ImportTimeout) defer cancel() diff --git a/internal/importer/nixpkgs-channel.go b/internal/importer/nixpkgs-channel.go index 0e5be62..e237246 100644 --- a/internal/importer/nixpkgs-channel.go +++ b/internal/importer/nixpkgs-channel.go @@ -63,7 +63,10 @@ func (i *NixpkgsChannelImporter) FetchIfNeeded(parent context.Context) (bool, er return true, nil } -func (i *NixpkgsChannelImporter) Import(parent context.Context, indexer *search.WriteIndex) (bool, error) { +func (i *NixpkgsChannelImporter) Import( + parent context.Context, + indexer *search.WriteIndex, +) (bool, error) { filename := path.Join(i.DataPath, filesToFetch["options"]) revFilename := path.Join(i.DataPath, filesToFetch["revision"]) bits, err := os.ReadFile(revFilename) |