handlers

Documentation

Index

• type ActiveUsersRepo
• type Chat
  • func NewChat(h *Hub, a ActiveUsersRepo, t TokensRepo, m MessagesRepo) *Chat
  • func (c *Chat) HandleChat(w http.ResponseWriter, r *http.Request, params server.WsRTMStartParams)
  • func (c *Chat) Run()
• type Client
• type Hub
  • func NewHub() *Hub
  • func (h *Hub) Run()
• type Message
• type MessagesRepo
• type TokensRepo
• type Users
  • func NewUsers(u UsersRepo, a ActiveUsersRepo, t TokensRepo) *Users
  • func (u *Users) HandleUserActive(w http.ResponseWriter, r *http.Request)
  • func (u *Users) HandleUserCreate(w http.ResponseWriter, r *http.Request)
  • func (u *Users) HandleUserLogin(w http.ResponseWriter, r *http.Request)
• type UsersRepo

Types

type ActiveUsersRepo

type ActiveUsersRepo interface {
	Add(userId uuid.UUID) error
	Delete(userId uuid.UUID) error
	Count() int
}

type Chat

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

func NewChat

func NewChat(h *Hub, a ActiveUsersRepo, t TokensRepo, m MessagesRepo) *Chat

func (*Chat) HandleChat

func (c *Chat) HandleChat(w http.ResponseWriter, r *http.Request, params server.WsRTMStartParams)

func (*Chat) Run

func (c *Chat) Run()

type Client

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

Client is a middleman between the websocket connection and the hub.

type Hub

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

Hub maintains the set of active clients and broadcasts messages to the clients.

func NewHub

func NewHub() *Hub

func (*Hub) Run

func (h *Hub) Run()

type Message

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

type MessagesRepo

type MessagesRepo interface {
	Create(msg models.Message) (models.Message, error)
	GetAfterDateExcludingUserId(after time.Time, userId uuid.UUID) ([]models.Message, error)
}

type TokensRepo

type TokensRepo interface {
	Create(token models.Token) (models.Token, error)
	Get(id uuid.UUID) (models.Token, error)
	InvalidateByUserId(userId uuid.UUID) error
}

type Users

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

func NewUsers

func NewUsers(u UsersRepo, a ActiveUsersRepo, t TokensRepo) *Users

func (*Users) HandleUserActive

func (u *Users) HandleUserActive(w http.ResponseWriter, r *http.Request)

func (*Users) HandleUserCreate

func (u *Users) HandleUserCreate(w http.ResponseWriter, r *http.Request)

func (*Users) HandleUserLogin

func (u *Users) HandleUserLogin(w http.ResponseWriter, r *http.Request)

type UsersRepo

type UsersRepo interface {
	Create(user models.User) (models.User, error)
	GetByUserName(userName string) (models.User, error)
}