pb

type Channel string

type Entity interface {
	EntityID() string
	EntityName() string
	EntityObject() string
	EntityImage() *sdkcm.Image
}

type EntityDetail struct {
	Id     string       `json:"id"`
	Name   string       `json:"name"`
	Object string       `json:"object"`
	Image  *sdkcm.Image `json:"image"`
}

type Event struct {
	Id         string        `json:"id"`
	Title      string        `json:"title"`
	Author     *EntityDetail `json:"author"`
	Receiver   *EntityDetail `json:"receiver"`
	Channel    Channel       `json:"channel"`
	Data       interface{}   `json:"data"`
	Ack        func()
	CreatedAt  time.Time `json:"created_at"`
	RemoteData []byte    `json:"remote_data"`
}

type Opt func(*composer)

type Provider interface {
	Publish(ctx context.Context, channel Channel, data *Event) error
	Subscribe(ctx context.Context, channel Channel) (c <-chan *Event, close func())
}