peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Check if item was really added
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2019-08-17 19:59:19 +02:00
parent c232fbc828
commit a684c0c6af
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/timeline/redisset.go
View File

@ -147,12 +147,12 @@ func (timeline *redisSortedSetTimeline) AddItem(item microsub.Item) (bool, error
return false, fmt.Errorf("can't parse %s as time", item.Published) return false, fmt.Errorf("can't parse %s as time", item.Published)
} }
_, err = redis.Int64(conn.Do("ZADD", zchannelKey, score.Unix()*1.0, itemKey)) n, err := redis.Int64(conn.Do("ZADD", zchannelKey, score.Unix()*1.0, itemKey))
if err != nil { if err != nil {
return false, fmt.Errorf("zadding failed item %s to channel %s for redis: %v", itemKey, zchannelKey, err) return false, fmt.Errorf("zadding failed item %s to channel %s for redis: %v", itemKey, zchannelKey, err)
} }
return true, nil return n == 1, nil
} }
func (timeline *redisSortedSetTimeline) Count() (int, error) { func (timeline *redisSortedSetTimeline) Count() (int, error) {