@@ -17,7 +17,7 @@ ) 
 type ChannelImporter struct {
 	DataPath   string
-	Source     Source
+	Source     *Source
 	SourceFile string
 	Logger     *slog.Logger
 	indexPath  string

@@ -28,7 +28,7 @@ Import(context.Context, *search.WriteIndex) (bool, error) }
 
 func NewNixpkgsChannelImporter(
-	source Source,
+	source *Source,
 	dataPath string,
 	logger *slog.Logger,
 ) *NixpkgsChannelImporter {
@@ -43,7 +43,7 @@ indexPath: indexPath, 	}
 }
 
-func NewChannelImporter(source Source, dataPath string, logger *slog.Logger) *ChannelImporter {
+func NewChannelImporter(source *Source, dataPath string, logger *slog.Logger) *ChannelImporter {
 	indexPath := dataPath
 	fullpath := path.Join(dataPath, source.Channel)
 
@@ -58,7 +58,7 @@ type importConfig struct {
 	IndexPath string
 	Filename  string
-	Source    Source
+	Source    *Source
 	Logger    *slog.Logger
 }
 

@@ -106,14 +106,14 @@ dec     *jstream.Decoder 	ms      *mapstructure.Decoder
 	optJSON nixOptionJSON
 	infile  *os.File
-	source  Source
+	source  *Source
 }
 
 type Ingester[T options.NixOption] interface {
 	Process() (<-chan *T, <-chan error)
 }
 
-func NewOptionProcessor(inpath string, source Source) (*OptionIngester, error) {
+func NewOptionProcessor(inpath string, source *Source) (*OptionIngester, error) {
 	infile, err := os.Open(inpath)
 	if err != nil {
 		return nil, errors.WithMessagef(err, "failed to open input file %s", inpath)

@@ -15,7 +15,7 @@ ) 
 type NixpkgsChannelImporter struct {
 	DataPath  string
-	Source    Source
+	Source    *Source
 	Logger    *slog.Logger
 	indexPath string
 }