third-party-mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-06-10 12:22:19 +03:00
Code Issues Packages Projects Releases Wiki Activity

Implementing sort by number on queries

Browse Source
This commit is contained in:
Deluan 2016-03-02 23:20:17 -05:00
parent 757e1992d7
commit 1f31de589a
5 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
persistence/album_repository.go
View File

@ -29,6 +29,6 @@ func (r *albumRepository) Get(id string) (*domain.Album, error) {
func (r *albumRepository) FindByArtist(artistId string) ([]domain.Album, error) { func (r *albumRepository) FindByArtist(artistId string) ([]domain.Album, error) {
var as = make([]domain.Album, 0) var as = make([]domain.Album, 0)
err := r.loadChildren("artist", artistId, &as, "Year") err := r.loadChildren("artist", artistId, &as, "Year", false)
return as, err return as, err
} }

12
persistence/base_repository.go
View File

@ -127,24 +127,24 @@ func (r *baseRepository) toEntity(response [][]byte, entity interface{}) error {
return utils.ToStruct(record, entity) return utils.ToStruct(record, entity)
} }
func (r *baseRepository) loadAll(entities interface{}, sortBy string) error { func (r *baseRepository) loadAll(entities interface{}, sortBy string, alpha bool) error {
setName := r.table + "s:all" setName := r.table + "s:all"
return r.loadFromSet(setName, entities, sortBy) return r.loadFromSet(setName, entities, sortBy, alpha)
} }
func (r* baseRepository) loadChildren(parentTable string, parentId string, entities interface{}, sortBy string) error { func (r* baseRepository) loadChildren(parentTable string, parentId string, entities interface{}, sortBy string, alpha bool) error {
setName := fmt.Sprintf("%s:%s:%ss", parentTable, parentId, r.table) setName := fmt.Sprintf("%s:%s:%ss", parentTable, parentId, r.table)
return r.loadFromSet(setName, entities, sortBy) return r.loadFromSet(setName, entities, sortBy, alpha)
} }
// TODO Optimize it! Probably very slow (and confusing!) // TODO Optimize it! Probably very slow (and confusing!)
func (r *baseRepository) loadFromSet(setName string, entities interface{}, sortBy string) error { func (r *baseRepository) loadFromSet(setName string, entities interface{}, sortBy string, alpha bool) error {
reflected := reflect.ValueOf(entities).Elem() reflected := reflect.ValueOf(entities).Elem()
var sortKey []byte = nil var sortKey []byte = nil
if sortBy != "" { if sortBy != "" {
sortKey = []byte(fmt.Sprintf("%s:*:%s", r.table, sortBy)) sortKey = []byte(fmt.Sprintf("%s:*:%s", r.table, sortBy))
} }
response, err := db().XSSort([]byte(setName), 0, 0, true, false, sortKey, r.getFieldKeys("*")) response, err := db().XSSort([]byte(setName), 0, 0, alpha, false, sortKey, r.getFieldKeys("*"))
if err != nil { if err != nil {
return err return err
} }

2
persistence/base_repository_test.go
View File

@ -131,7 +131,7 @@ func TestBaseRepository(t *testing.T) {
Convey("When I call loadAll", func() { Convey("When I call loadAll", func() {
var es = make([]TestEntity, 0) var es = make([]TestEntity, 0)
err := repo.loadAll(&es, "") err := repo.loadAll(&es, "", false)
Convey("Then It should not return any error", func() { Convey("Then It should not return any error", func() {
So(err, ShouldBeNil) So(err, ShouldBeNil)
}) })

2
persistence/index_repository.go
View File

@ -33,7 +33,7 @@ func (r *artistIndexRepository) Get(id string) (*domain.ArtistIndex, error) {
func (r *artistIndexRepository) GetAll() ([]domain.ArtistIndex, error) { func (r *artistIndexRepository) GetAll() ([]domain.ArtistIndex, error) {
var indices = make([]domain.ArtistIndex, 0) var indices = make([]domain.ArtistIndex, 0)
err := r.loadAll(&indices, "") err := r.loadAll(&indices, "", true)
return indices, err return indices, err
} }

2
persistence/mediafile_repository.go
View File

@ -20,6 +20,6 @@ func (r *mediaFileRepository) Put(m *domain.MediaFile) error {
func (r *mediaFileRepository) FindByAlbum(albumId string) ([]domain.MediaFile, error) { func (r *mediaFileRepository) FindByAlbum(albumId string) ([]domain.MediaFile, error) {
var mfs = make([]domain.MediaFile, 0) var mfs = make([]domain.MediaFile, 0)
err := r.loadChildren("album", albumId, &mfs, "Track") err := r.loadChildren("album", albumId, &mfs, "Track", false)
return mfs, err return mfs, err
} }