chat

type Connection interface {
	// SendEvent sends event to the receiver.
	// Returns ErrConnectionClosed when connection closed.
	// Returns error when sending failed.
	SendEvent(e Event) error
	// ReadEvent wiats for next Event. Error when reading fails.
	// Returns error ErrConnectionClosed when connection closed.
	ReadEvent() (Event, error)
	// Wait waits until connection is closed.
	// Returns error with which the connection was closed (or nil)
	Wait() error
	// WaitContext waits until connection is closed.
	// Returns error with which the connection was closed (or nil)
	WaitContext(ctx context.Context) error
	// CLose closes connection, if connected.
	// Blocks until disconnected.
	Close(error) error
	// Closed return chan that is closed when connection is closed.
	Closed() bool
	// Err returns the error with which the connection closed, or nil.
	Err() error
}

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

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

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

type Event interface {
	// When returns time of the event.
	// Important we define *something* more than interface{}
	// for static analysis to work on *Struct{} vs Struct{}
	When() time.Time
}

type EventConnected struct {
	EventMeta
	Users []string `json:"users"`
}

type EventMeta struct {
	Time time.Time `json:"time"`
}

type EventNewMessage struct {
	EventMeta
	Sender  string `json:"sender"`
	Message string `json:"message"`
}

type EventSendMessage struct {
	EventMeta
	Message string `json:"message"`
}

type EventUserEnter struct {
	EventMeta
	Name string `json:"name"`
}

type EventUserLeave struct {
	EventMeta
	Name string `json:"name"`
}

type EventUserListUpdate struct {
	EventMeta
	Users []string `json:"users"`
}

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

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

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

type TestConnection struct {
	// EventOutCh is the channel used for sending events.
	EventOutCh chan<- Event
	// EventInCh is the channel used for receiving events.
	EventInCh <-chan Event
	// contains filtered or unexported fields
}