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

Cleanup error messages in timeline.go

Browse Source
This commit is contained in:
Peter Stuifzand 2018-12-29 10:34:31 +01:00
parent 91e9add76a
commit 0c88e90853
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/eksterd/timeline.go
View File

@ -157,8 +157,7 @@ func (timeline *redisSortedSetTimeline) AddItem(item microsub.Item) error {
data, err := json.Marshal(item) data, err := json.Marshal(item)
if err != nil { if err != nil {
log.Printf("error while creating item for redis: %v\n", err) return fmt.Errorf("couldn't marshall item for redis: %s", err)
return err
} }
forRedis := redisItem{ forRedis := redisItem{
@ -171,7 +170,7 @@ func (timeline *redisSortedSetTimeline) AddItem(item microsub.Item) error {
itemKey := fmt.Sprintf("item:%s", item.ID) itemKey := fmt.Sprintf("item:%s", item.ID)
_, err = redis.String(conn.Do("HMSET", redis.Args{}.Add(itemKey).AddFlat(&forRedis)...)) _, err = redis.String(conn.Do("HMSET", redis.Args{}.Add(itemKey).AddFlat(&forRedis)...))
if err != nil { if err != nil {
return fmt.Errorf("error while writing item for redis: %v", err) return fmt.Errorf("writing failed for item to redis: %v", err)
} }
readChannelKey := fmt.Sprintf("channel:%s:read", channel) readChannelKey := fmt.Sprintf("channel:%s:read", channel)
@ -186,12 +185,12 @@ func (timeline *redisSortedSetTimeline) AddItem(item microsub.Item) error {
score, err := time.Parse(time.RFC3339, item.Published) score, err := time.Parse(time.RFC3339, item.Published)
if err != nil { if err != nil {
return fmt.Errorf("error can't parse %s as time", item.Published) return fmt.Errorf("can't parse %s as time", item.Published)
} }
_, err = redis.Int64(conn.Do("ZADD", zchannelKey, score.Unix()*1.0, itemKey)) _, err = redis.Int64(conn.Do("ZADD", zchannelKey, score.Unix()*1.0, itemKey))
if err != nil { if err != nil {
return fmt.Errorf("error while zadding item %s to channel %s for redis: %v", itemKey, zchannelKey, err) return fmt.Errorf("zadding failed item %s to channel %s for redis: %v", itemKey, zchannelKey, err)
} }
// FIXME: send message to events... // FIXME: send message to events...