diff --git a/engine/engine.go b/engine/engine.go index 979667e..4a46713 100644 --- a/engine/engine.go +++ b/engine/engine.go @@ -274,7 +274,7 @@ func RunImporter(l *zerolog.Logger, store db.DB, mbzc mbz.MusicBrainzCaller) { } if strings.Contains(file.Name(), "Streaming_History_Audio") { l.Info().Msgf("Importer: Import file %s detecting as being Spotify export", file.Name()) - err := importer.ImportSpotifyFile(logger.NewContext(l), store, file.Name()) + err := importer.ImportSpotifyFile(logger.NewContext(l), store, mbzc, file.Name()) if err != nil { l.Err(err).Msgf("Importer: Failed to import file: %s", file.Name()) } diff --git a/internal/importer/spotify.go b/internal/importer/spotify.go index 5594fc2..1ea71f4 100644 --- a/internal/importer/spotify.go +++ b/internal/importer/spotify.go @@ -12,7 +12,7 @@ import ( "github.com/gabehf/koito/internal/cfg" "github.com/gabehf/koito/internal/db" "github.com/gabehf/koito/internal/logger" - "github.com/gabehf/koito/internal/mbz" + mbz "github.com/gabehf/koito/internal/mbz" ) type SpotifyExportItem struct { @@ -24,7 +24,7 @@ type SpotifyExportItem struct { MsPlayed int32 `json:"ms_played"` } -func ImportSpotifyFile(ctx context.Context, store db.DB, filename string) error { +func ImportSpotifyFile(ctx context.Context, store db.DB, mbzc mbz.MusicBrainzCaller, filename string) error { l := logger.FromContext(ctx) l.Info().Msgf("Beginning spotify import on file: %s", filename) file, err := os.Open(path.Join(cfg.ConfigDir(), "import", filename)) @@ -59,7 +59,7 @@ func ImportSpotifyFile(ctx context.Context, store db.DB, filename string) error continue } opts := catalog.SubmitListenOpts{ - MbzCaller: &mbz.MusicBrainzClient{}, + MbzCaller: mbzc, Artist: item.ArtistName, TrackTitle: item.TrackName, ReleaseTitle: item.AlbumName,