ChatService

Documentation

Index

• func Chat(rdb *redis.Client, channel string, content string) error
• type ChatService
  • func NewChatService(firebaseApp *firebase.App, rdb *redis.Client, userRepo models.UserRepository, ...) *ChatService
  • func (cs *ChatService) HandleWSError(err error, message string, conn *websocket.Conn)
  • func (cs *ChatService) OnChannelMessage(conn *websocket.Conn, user *models.User)
  • func (cs *ChatService) OnClientMessage(conn *websocket.Conn, user *models.User)
  • func (cs *ChatService) OnConnect(conn *websocket.Conn, user *models.User) error
  • func (cs *ChatService) OnDisconnect(conn *websocket.Conn, user *models.User) chan struct{}
  • func (cs *ChatService) SendNotification(message *models.Message)
• type Client
  • func Connect(rdb *redis.Client, user *models.User) (*Client, error)
  • func (c *Client) Disconnect() error

Functions

func Chat

func Chat(rdb *redis.Client, channel string, content string) error

Types

type ChatService

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

func NewChatService

func NewChatService(firebaseApp *firebase.App,
	rdb *redis.Client,
	userRepo models.UserRepository,
	messageRepo models.MessageRepository,
	chatRepo models.ChatRepository,
) *ChatService

func (*ChatService) HandleWSError

func (cs *ChatService) HandleWSError(err error, message string, conn *websocket.Conn)

func (*ChatService) OnChannelMessage

func (cs *ChatService) OnChannelMessage(conn *websocket.Conn, user *models.User)

func (*ChatService) OnClientMessage

func (cs *ChatService) OnClientMessage(conn *websocket.Conn, user *models.User)

func (*ChatService) OnConnect

func (cs *ChatService) OnConnect(conn *websocket.Conn, user *models.User) error

func (*ChatService) OnDisconnect

func (cs *ChatService) OnDisconnect(conn *websocket.Conn, user *models.User) chan struct{}

func (*ChatService) SendNotification

func (cs *ChatService) SendNotification(message *models.Message)

type Client

type Client struct {
	User *models.User

	MessageChan chan redis.Message
	// contains filtered or unexported fields
}

func Connect

func Connect(rdb *redis.Client, user *models.User) (*Client, error)

Connect connect client to client channels on redis

func (*Client) Disconnect

func (c *Client) Disconnect() error