marc/scotty
1
0
Fork 0
mirror of https://git.sr.ht/~phw/scotty synced 2025-04-16 01:59:29 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Renamed ImportBackend methods to StartImport / FinishImport

Browse source
This commit is contained in:
Philipp Wolfer 2023-11-20 07:43:54 +01:00
parent 14d944c7ad
commit c13c9175e3
No known key found for this signature in database
GPG key ID: 8FDF744D4919943B
7 changed files with 16 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
backends/dump/dump.go
View file

@ -32,8 +32,8 @@ func (b *DumpBackend) FromConfig(config *viper.Viper) models.Backend {
return b return b
} }
func (b *DumpBackend) Init() error { return nil } func (b *DumpBackend) StartImport() error { return nil }
func (b *DumpBackend) Finish() error { return nil } func (b *DumpBackend) FinishImport() error { return nil }
func (b *DumpBackend) ImportListens(export models.ListensResult, importResult models.ImportResult, progress chan models.Progress) (models.ImportResult, error) { func (b *DumpBackend) ImportListens(export models.ListensResult, importResult models.ImportResult, progress chan models.Progress) (models.ImportResult, error) {
for _, listen := range export.Listens { for _, listen := range export.Listens {

4
backends/jspf/jspf.go
View file

@ -48,8 +48,8 @@ func (b *JspfBackend) FromConfig(config *viper.Viper) models.Backend {
return b return b
} }
func (b *JspfBackend) Init() error { return nil } func (b *JspfBackend) StartImport() error { return nil }
func (b *JspfBackend) Finish() error { func (b *JspfBackend) FinishImport() error {
err := b.writeJspf(b.tracks) err := b.writeJspf(b.tracks)
return err return err
} }

4
backends/listenbrainz/listenbrainz.go
View file

@ -43,8 +43,8 @@ func (b *ListenBrainzApiBackend) FromConfig(config *viper.Viper) models.Backend
return b return b
} }
func (b *ListenBrainzApiBackend) Init() error { return nil } func (b *ListenBrainzApiBackend) StartImport() error { return nil }
func (b *ListenBrainzApiBackend) Finish() error { return nil } func (b *ListenBrainzApiBackend) FinishImport() error { return nil }
func (b *ListenBrainzApiBackend) ExportListens(oldestTimestamp time.Time, results chan models.ListensResult, progress chan models.Progress) { func (b *ListenBrainzApiBackend) ExportListens(oldestTimestamp time.Time, results chan models.ListensResult, progress chan models.Progress) {
startTime := time.Now() startTime := time.Now()

4
backends/maloja/maloja.go
View file

@ -45,8 +45,8 @@ func (b *MalojaApiBackend) FromConfig(config *viper.Viper) models.Backend {
return b return b
} }
func (b *MalojaApiBackend) Init() error { return nil } func (b *MalojaApiBackend) StartImport() error { return nil }
func (b *MalojaApiBackend) Finish() error { return nil } func (b *MalojaApiBackend) FinishImport() error { return nil }
func (b *MalojaApiBackend) ExportListens(oldestTimestamp time.Time, results chan models.ListensResult, progress chan models.Progress) { func (b *MalojaApiBackend) ExportListens(oldestTimestamp time.Time, results chan models.ListensResult, progress chan models.Progress) {
page := 0 page := 0

8
backends/process.go
View file

@ -29,7 +29,7 @@ func ProcessListensImports(importer models.ListensImport, results chan models.Li
defer close(progress) defer close(progress)
result := models.ImportResult{} result := models.ImportResult{}
err := importer.Init() err := importer.StartImport()
if err != nil { if err != nil {
handleError(result, err, out, progress) handleError(result, err, out, progress)
return return
@ -52,7 +52,7 @@ func ProcessListensImports(importer models.ListensImport, results chan models.Li
progress <- models.Progress{}.FromImportResult(result) progress <- models.Progress{}.FromImportResult(result)
} }
err = importer.Finish() err = importer.FinishImport()
if err != nil { if err != nil {
handleError(result, err, out, progress) handleError(result, err, out, progress)
return return
@ -67,7 +67,7 @@ func ProcessLovesImports(importer models.LovesImport, results chan models.LovesR
defer close(progress) defer close(progress)
result := models.ImportResult{} result := models.ImportResult{}
err := importer.Init() err := importer.StartImport()
if err != nil { if err != nil {
handleError(result, err, out, progress) handleError(result, err, out, progress)
return return
@ -90,7 +90,7 @@ func ProcessLovesImports(importer models.LovesImport, results chan models.LovesR
progress <- models.Progress{}.FromImportResult(result) progress <- models.Progress{}.FromImportResult(result)
} }
err = importer.Finish() err = importer.FinishImport()
if err != nil { if err != nil {
handleError(result, err, out, progress) handleError(result, err, out, progress)
return return

4
backends/scrobblerlog/scrobblerlog.go
View file

@ -43,7 +43,7 @@ func (b *ScrobblerLogBackend) FromConfig(config *viper.Viper) models.Backend {
return b return b
} }
func (b *ScrobblerLogBackend) Init() error { func (b *ScrobblerLogBackend) StartImport() error {
file, err := os.Create(b.filePath) file, err := os.Create(b.filePath)
if err != nil { if err != nil {
return err return err
@ -64,7 +64,7 @@ func (b *ScrobblerLogBackend) Init() error {
return nil return nil
} }
func (b *ScrobblerLogBackend) Finish() error { func (b *ScrobblerLogBackend) FinishImport() error {
return b.file.Close() return b.file.Close()
} }

4
models/interfaces.go
View file

@ -39,11 +39,11 @@ type ImportBackend interface {
// If the backend needs to setup resources before starting to import, // If the backend needs to setup resources before starting to import,
// this can be done here. // this can be done here.
Init() error StartImport() error
// The implementation can perform all steps here to finalize the // The implementation can perform all steps here to finalize the
// export/import and free used resources. // export/import and free used resources.
Finish() error FinishImport() error
} }
// Must be implemented by services supporting the export of listens. // Must be implemented by services supporting the export of listens.