diff --git a/cmd/eksterd/fetch.go b/cmd/eksterd/fetch.go index 2b7506f..10a15d1 100644 --- a/cmd/eksterd/fetch.go +++ b/cmd/eksterd/fetch.go @@ -365,6 +365,10 @@ func (b *memoryBackend) channelAddItem(channel string, item microsub.Item) { channelKey := fmt.Sprintf("channel:%s:posts", channel) zchannelKey := fmt.Sprintf("zchannel:%s:posts", channel) + if item.Published == "" { + item.Published = time.Now().Format(time.RFC3339) + } + data, err := json.Marshal(item) if err != nil { log.Printf("error while creating item for redis: %v\n", err)