Compare commits
3 Commits
e9d1d20c63
...
e79e364ff9
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
e79e364ff9 | ||
|
|
6bd957b09e | ||
|
|
4eab2bb874 |
@@ -100,16 +100,12 @@ func interpretCommand(command string, store musicObjectStore) (musicObjectStore,
|
||||
|
||||
current := currentMusicObjects[index]
|
||||
|
||||
if len(current.GetSources()) <= 0 {
|
||||
return store, errors.New("selected object has no sources to download")
|
||||
}
|
||||
|
||||
currentMusicObjects, err = plugin.FetchList(current.GetSources()[0])
|
||||
fetched, err := plugin.Fetch(current)
|
||||
if err != nil {
|
||||
return store, err
|
||||
}
|
||||
|
||||
return append(store, currentMusicObjects), nil
|
||||
return append(store, fetched.Related()), nil
|
||||
}
|
||||
|
||||
// search in every other case
|
||||
|
||||
@@ -11,6 +11,7 @@ type MusicObject interface {
|
||||
Compile() MusicObject
|
||||
GetIndices() []string
|
||||
Merge(other MusicObject) MusicObject
|
||||
Related() []MusicObject
|
||||
}
|
||||
|
||||
func dedupeMusicObjects[T MusicObject](inputMusicObjects []T) []T {
|
||||
@@ -71,6 +72,20 @@ type Song struct {
|
||||
Sources []Source
|
||||
}
|
||||
|
||||
func (m Song) Related() []MusicObject {
|
||||
res := []MusicObject{}
|
||||
|
||||
for _, a := range m.Artists {
|
||||
res = append(res, a)
|
||||
}
|
||||
if m.Album.Name != "" {
|
||||
res = append(res, m.Album)
|
||||
}
|
||||
|
||||
res = append(res, m)
|
||||
return res
|
||||
}
|
||||
|
||||
func (m Song) GetSources() []Source {
|
||||
return m.Sources
|
||||
}
|
||||
@@ -127,6 +142,20 @@ type Album struct {
|
||||
Sources []Source
|
||||
}
|
||||
|
||||
func (m Album) Related() []MusicObject {
|
||||
res := []MusicObject{}
|
||||
|
||||
for _, a := range m.Artists {
|
||||
res = append(res, a)
|
||||
}
|
||||
res = append(res, m)
|
||||
for _, a := range m.Songs {
|
||||
res = append(res, a)
|
||||
}
|
||||
|
||||
return res
|
||||
}
|
||||
|
||||
func (m Album) GetSources() []Source {
|
||||
return m.Sources
|
||||
}
|
||||
@@ -183,6 +212,16 @@ type Artist struct {
|
||||
Sources []Source
|
||||
}
|
||||
|
||||
func (m Artist) Related() []MusicObject {
|
||||
res := []MusicObject{m}
|
||||
|
||||
for _, a := range m.Albums {
|
||||
res = append(res, a)
|
||||
}
|
||||
|
||||
return res
|
||||
}
|
||||
|
||||
func (m Artist) GetSources() []Source {
|
||||
return m.Sources
|
||||
}
|
||||
|
||||
@@ -99,7 +99,7 @@ func compileSource(source data.Source) (data.Source, error) {
|
||||
return source, errors.New("couldn't find corresponding object source on " + sourceType.Name + " for " + source.Url)
|
||||
}
|
||||
|
||||
func Fetch(source data.Source) (data.MusicObject, error) {
|
||||
func FetchSource(source data.Source) (data.MusicObject, error) {
|
||||
// the fetch function without the post processing of the music objects
|
||||
source, err := compileSource(source)
|
||||
if err != nil {
|
||||
@@ -147,39 +147,23 @@ func Fetch(source data.Source) (data.MusicObject, error) {
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
func FetchList(source data.Source) ([]data.MusicObject, error) {
|
||||
res := []data.MusicObject{}
|
||||
func Fetch(musicObject data.MusicObject) (data.MusicObject, error) {
|
||||
sources := musicObject.GetSources()
|
||||
|
||||
musicObject, err := Fetch(source)
|
||||
if err != nil {
|
||||
return res, err
|
||||
if len(sources) <= 0 {
|
||||
return musicObject, errors.New("didn't find a source for object")
|
||||
}
|
||||
|
||||
if a, ok := musicObject.(data.Song); ok {
|
||||
for _, ar := range a.Artists {
|
||||
res = append(res, ar)
|
||||
for _, source := range sources {
|
||||
newMusicObject, err := FetchSource(source)
|
||||
if err != nil {
|
||||
return musicObject, err
|
||||
}
|
||||
if a.Album.Name != "" {
|
||||
res = append(res, a.Album, a)
|
||||
}
|
||||
} else if a, ok := musicObject.(data.Album); ok {
|
||||
for _, ar := range a.Artists {
|
||||
res = append(res, ar)
|
||||
}
|
||||
res = append(res, a)
|
||||
for _, s := range a.Songs {
|
||||
res = append(res, s)
|
||||
}
|
||||
} else if a, ok := musicObject.(data.Artist); ok {
|
||||
res = append(res, a)
|
||||
for _, al := range a.Albums {
|
||||
res = append(res, al)
|
||||
}
|
||||
} else {
|
||||
res = append(res, musicObject)
|
||||
|
||||
musicObject = musicObject.Merge(newMusicObject)
|
||||
}
|
||||
|
||||
return res, nil
|
||||
return musicObject, nil
|
||||
}
|
||||
|
||||
type SearchConfig struct {
|
||||
|
||||
@@ -2,7 +2,6 @@ package plugin
|
||||
|
||||
import (
|
||||
"errors"
|
||||
"fmt"
|
||||
"regexp"
|
||||
"strings"
|
||||
|
||||
@@ -328,8 +327,6 @@ func (m *Musify) FetchSong(source data.Source) (data.Song, error) {
|
||||
return song, errors.New("too many breadcrumbs on page")
|
||||
}
|
||||
|
||||
fmt.Println("found breadcrumbs")
|
||||
|
||||
if artistAnchor := listPoints.Eq(2).Find("a"); artistAnchor != nil && artistAnchor.Length() > 0 {
|
||||
artist := data.Artist{}
|
||||
useArtist := true
|
||||
@@ -357,8 +354,6 @@ func (m *Musify) FetchSong(source data.Source) (data.Song, error) {
|
||||
}
|
||||
|
||||
if albumAnchor := listPoints.Eq(3).Find("a"); albumAnchor != nil && albumAnchor.Length() > 0 {
|
||||
fmt.Println("found album")
|
||||
|
||||
if href, exists := albumAnchor.Attr("href"); exists {
|
||||
song.Album.Sources = append(song.Album.Sources, data.Source{
|
||||
Url: musifyHost + href,
|
||||
|
||||
@@ -87,7 +87,7 @@ func TestRegister(t *testing.T) {
|
||||
func TestFetchSong(t *testing.T) {
|
||||
RegisterPlugin(&MusifyTest{})
|
||||
|
||||
s, err := Fetch(data.Source{
|
||||
s, err := FetchSource(data.Source{
|
||||
Url: "https://musify.club/track/linkin-park-in-the-end-3058",
|
||||
})
|
||||
|
||||
@@ -108,7 +108,7 @@ func TestFetchSong(t *testing.T) {
|
||||
func TestFetchAlbum(t *testing.T) {
|
||||
RegisterPlugin(&MusifyTest{})
|
||||
|
||||
a, err := Fetch(data.Source{
|
||||
a, err := FetchSource(data.Source{
|
||||
Url: "https://musify.club/release/linkin-park-hybrid-theory-2000-188",
|
||||
})
|
||||
|
||||
@@ -129,7 +129,7 @@ func TestFetchAlbum(t *testing.T) {
|
||||
func TestFetchArtist(t *testing.T) {
|
||||
RegisterPlugin(&MusifyTest{})
|
||||
|
||||
a, err := Fetch(data.Source{
|
||||
a, err := FetchSource(data.Source{
|
||||
Url: "https://musify.club/artist/linkin-park-5",
|
||||
})
|
||||
|
||||
@@ -150,7 +150,7 @@ func TestFetchArtist(t *testing.T) {
|
||||
func TestFetchWrongUrl(t *testing.T) {
|
||||
RegisterPlugin(&MusifyTest{})
|
||||
|
||||
_, err := Fetch(data.Source{
|
||||
_, err := FetchSource(data.Source{
|
||||
Url: "https://musify.club/",
|
||||
})
|
||||
|
||||
@@ -162,7 +162,7 @@ func TestFetchWrongUrl(t *testing.T) {
|
||||
func TestNonExistentSourceType(t *testing.T) {
|
||||
RegisterPlugin(&MusifyTest{})
|
||||
|
||||
_, err := Fetch(data.Source{
|
||||
_, err := FetchSource(data.Source{
|
||||
Url: "https://musify.club/",
|
||||
SourceType: &data.SourceType{
|
||||
Name: "doesn't exist",
|
||||
|
||||
Reference in New Issue
Block a user