@@ -274,24 +274,33 @@ func (r *Store) GetEntryByID(id string) (*shared.Entry, error) {
274
274
func (r * Store ) GetUserEntries (userIdentifier string ) (map [string ]shared.Entry , error ) {
275
275
logrus .Debugf ("Getting all entries for user %s" , userIdentifier )
276
276
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
+ }
292
301
}
302
+ logrus .Debugf ("all out of entries" )
293
303
}
294
- logrus .Debugf ("all out of entries" )
295
304
return entries , nil
296
305
}
297
306
0 commit comments