messageengine

Documentation

Index

• func ConnectActionsToDB()
• func ConnectionHandler(ws *websocket.Conn)
• func GetOnlineUsersFromSlice(userIDs *[]int64) int64
• func SendForceMessage(msg models.ForceMsgToUser)
• func SendMessage(msg models.NewMessageToUser)
• func StartCoreMessenger()
• type SystemMessage

Functions

func ConnectActionsToDB

func ConnectActionsToDB()

ConnectActionsToDB - Bind callbacks

func ConnectionHandler

func ConnectionHandler(ws *websocket.Conn)

ConnectionHandler - handles new WS connection

func GetOnlineUsersFromSlice

func GetOnlineUsersFromSlice(userIDs *[]int64) int64

GetOnlineUsersFromSlice - return count online users in usersID slice

func SendForceMessage

func SendForceMessage(msg models.ForceMsgToUser)

SendForceMessage - send force message

func SendMessage

func SendMessage(msg models.NewMessageToUser)

SendMessage - send message

func StartCoreMessenger

func StartCoreMessenger()

StartCoreMessenger - starting message engine

Types

type SystemMessage

type SystemMessage struct {
	Action  string
	Payload string
}