implemented getStarred (just for albums, for now)

persistence/album_repository.go

@@ -74,4 +74,10 @@ func (r *albumRepository) PurgeInactive(active *domain.Albums) error {
 	return r.DeleteAll(inactiveIds)
 }
 
+func (r *albumRepository) GetStarred(options domain.QueryOptions) (*domain.Albums, error) {
+	var as = make(domain.Albums, 0)
+	err := r.loadRange("Starred", true, true, &as, options)
+	return &as, err
+}
+
 var _ domain.AlbumRepository = (*albumRepository)(nil)

persistence/ledis_repository.go

@@ -167,23 +167,25 @@ func (r *ledisRepository) saveOrUpdate(id string, entity interface{}) error {
 }
 
 func calcScore(entity interface{}, fieldName string) int64 {
-	var score int64
-
 	dv := reflect.ValueOf(entity).Elem()
 	v := dv.FieldByName(fieldName)
 
-	switch v.Interface().(type) {
+	return toScore(v.Interface())
+}
+
+func toScore(value interface{}) int64 {
+	switch v := value.(type) {
 	case int:
-		score = v.Int()
+		return int64(v)
 	case bool:
-		if v.Bool() {
-			score = 1
+		if v {
+			return 1
 		}
 	case time.Time:
-		score = utils.ToMillis(v.Interface().(time.Time))
+		return utils.ToMillis(v)
 	}
 
-	return score
+	return 0
 }
 
 func (r *ledisRepository) getParentRelationKey(entity interface{}) string {
@@ -243,6 +245,36 @@ func (r *ledisRepository) toEntity(response [][]byte, entity interface{}) error
 	return utils.ToStruct(record, entity)
 }
 
+func (r *ledisRepository) loadRange(idxName string, min interface{}, max interface{}, entities interface{}, qo ...domain.QueryOptions) error {
+	o := domain.QueryOptions{}
+	if len(qo) > 0 {
+		o = qo[0]
+	}
+	if o.Size == 0 {
+		o.Size = -1
+	}
+
+	minS := toScore(min)
+	maxS := toScore(max)
+
+	idxKey := fmt.Sprintf("%s:idx:%s", r.table, idxName)
+	resp, err := Db().ZRangeByScore([]byte(idxKey), minS, maxS, o.Offset, o.Size)
+	if err != nil {
+		return err
+	}
+
+	reflected := reflect.ValueOf(entities).Elem()
+	for _, pair := range resp {
+		e, err := r.readEntity(string(pair.Member))
+		if err != nil {
+			return err
+		}
+		reflected.Set(reflect.Append(reflected, reflect.ValueOf(e).Elem()))
+	}
+
+	return nil
+}
+
 func (r *ledisRepository) loadAll(entities interface{}, qo ...domain.QueryOptions) error {
 	setName := r.table + "s:all"
 	return r.loadFromSet(setName, entities, qo...)