events

type Config struct {
	TTL    time.Duration `default:"168h"` // 1 week
	Prefix string        `default:"filharmonic:ws:"`
}

type Event struct {
	Type    EventType `json:"type"`
	Payload Payload   `json:"payload"`
}

type EventType string

type EventsManager interface {
	DispatchUpdatedResources(ctx *domain.UserContext, resource string) error
	DispatchUpdatedResource(ctx *domain.UserContext, resource string, id int64) error
	DispatchUpdatedResourcesToUsers(resources string, userIds []int64) error
	HandleRequest(w http.ResponseWriter, r *http.Request) error
}

type Payload struct {
	// connect / disconnect
	UserId int64 `json:"user_id,omitempty"`

	// subscribe / unsubscribe / resource_updated
	Resource   string `json:"resource,omitempty"`
	ResourceId int64  `json:"resource_id,omitempty"`
}

type RedisEventsManager struct {
	// contains filtered or unexported fields
}

type StubEventsManager struct {
	// contains filtered or unexported fields
}