@@ -274,24 +274,33 @@ func (r *Store) GetEntryByID(id string) (*shared.Entry, error) {
274274func (r * Store ) GetUserEntries (userIdentifier string ) (map [string ]shared.Entry , error ) {
275275 logrus .Debugf ("Getting all entries for user %s" , userIdentifier )
276276 entries := map [string ]shared.Entry {}
277- key := userToEntriesPrefix + userIdentifier
278- result := r .c .SMembers (key )
279- if result .Err () != nil {
280- msg := fmt .Sprintf ("Could not fetch set of entries for user '%s': %v" , userIdentifier , result .Err ())
281- logrus .Errorf (msg )
282- return nil , errors .Wrap (result .Err (), msg )
283- }
284- for _ , v := range result .Val () {
285- logrus .Debugf ("got entry: %s" , v )
286- entry , err := r .GetEntryByID (string (v ))
287- if err != nil {
288- msg := fmt .Sprintf ("Could not get entry '%s': %s" , v , err )
289- logrus .Warn (msg )
290- } else {
291- entries [string (v )] = * entry
277+
278+ users := r .c .Keys (userToEntriesPrefix + "*" )
279+ for _ , v := range users .Val () {
280+ logrus .Debugf ("got userEntry: %s" , v )
281+ // user, err := r.GetEntryByID(string(v))
282+
283+ key := v
284+ result := r .c .SMembers (key )
285+ // result := r.c.Keys(entryPathPrefix + user)
286+
287+ if result .Err () != nil {
288+ msg := fmt .Sprintf ("Could not fetch set of entries for user '%s': %v" , userIdentifier , result .Err ())
289+ logrus .Errorf (msg )
290+ return nil , errors .Wrap (result .Err (), msg )
291+ }
292+ for _ , v := range result .Val () {
293+ logrus .Debugf ("got entry: %s" , v )
294+ entry , err := r .GetEntryByID (string (v ))
295+ if err != nil {
296+ msg := fmt .Sprintf ("Could not get entry '%s': %s" , v , err )
297+ logrus .Warn (msg )
298+ } else {
299+ entries [string (v )] = * entry
300+ }
292301 }
302+ logrus .Debugf ("all out of entries" )
293303 }
294- logrus .Debugf ("all out of entries" )
295304 return entries , nil
296305}
297306
0 commit comments