diff --git a/event/eventQueue.go b/event/eventQueue.go index f65ec77..94b40eb 100644 --- a/event/eventQueue.go +++ b/event/eventQueue.go @@ -19,7 +19,7 @@ type simpleQueue struct { // the event.Manager. type Queue interface { Publish(event Event) - Next() *Event + Next() Event Shutdown() OutChan() <-chan Event Len() int @@ -52,9 +52,9 @@ func (sq *simpleQueue) Len() int { } // Next returns the next available event from the front of the queue -func (sq *simpleQueue) Next() *Event { +func (sq *simpleQueue) Next() Event { event := <-sq.eventChannel - return &event + return event } // Shutdown closes our eventChannel @@ -83,9 +83,9 @@ func (iq *queue) OutChan() <-chan Event { } // Out returns the next available event from the front of the queue -func (iq *queue) Next() *Event { +func (iq *queue) Next() Event { event := <-iq.infChan.Out() - return &event + return event } func (iq *queue) Len() int { diff --git a/event/eventmanager.go b/event/eventmanager.go index 3ce621e..be1c19f 100644 --- a/event/eventmanager.go +++ b/event/eventmanager.go @@ -7,7 +7,8 @@ import ( "sync" ) -// Event is a structure which binds a given set of data to an Type +// Event is the core struct type passed around between various subsystems. Events consist of a type which can be +// filtered on, an event ID for tracing and a map of Fields to string values. type Event struct { EventType Type EventID string diff --git a/storage/v1/profile_store.go b/storage/v1/profile_store.go index b26b485..4947773 100644 --- a/storage/v1/profile_store.go +++ b/storage/v1/profile_store.go @@ -383,7 +383,7 @@ func (ps *ProfileStoreV1) eventHandler() { log.Errorf("error storing new group invite: %v (%v)", err, ev) } case event.SendMessageToPeer: // cache the message till an ack, then it's given to stream store. - // stream store doesn't support updates, so we don't want to commit it till ack'd + // stream store doesn't support updates, so we don't want to commit it till ack'd ps.profile.AddSentMessageToContactTimeline(ev.Data[event.RemotePeer], ev.Data[event.Data], time.Now(), ev.EventID) case event.NewMessageFromPeer: ps.attemptSavePeerMessage(ev.Data[event.RemotePeer], ev.Data[event.Data], ev.Data[event.TimestampReceived], true)