message.go

package message

import "sync"

// Message represents a Blink message and contains raw data object
// linked to the data stream and event.
type Message struct {
	lock       sync.RWMutex
	Event      Event  `json:"event" yaml:"event"`
	SourceType string `json:"sourceType" yaml:"sourceType"`
	Stream     string `json:"stream" yaml:"stream"`
	Data       Data   `json:"data" yaml:"data"`
}

func NewMessage(event Event, sourceType, stream string, data []byte) *Message {
	return &Message{
		Event:      event,
		Stream:     stream,
		SourceType: sourceType,
		Data:       NewData(data),
	}
}

func (m *Message) SetStream(stream string) {
	m.Stream = stream
}

func (m *Message) GetStream() string {
	return m.Stream
}

func (m *Message) GetSourceType() string {
	return m.SourceType
}

func (m *Message) SetEvent(event Event) {
	m.Event = event
}

func (m *Message) GetEvent() Event {
	return m.Event
}

func (m *Message) AsJSONString() string {
	return m.Data.packet.JSON()
}