socket

Documentation

Index

• func SetMQTTChannel(ch chan mqtt.WebSocketMessage)
• func WsProxyHandler(c *gin.Context)
• type ConnectionManager
  • func (cm *ConnectionManager) AddConnection(conn *websocket.Conn, user *UserConnection)
  • func (cm *ConnectionManager) BroadcastMQTTMessage(messageType string, data interface{})
  • func (cm *ConnectionManager) GetAllConnections() map[*websocket.Conn]*UserConnection
  • func (cm *ConnectionManager) GetConnection(conn *websocket.Conn) (*UserConnection, bool)
  • func (cm *ConnectionManager) IsAuthorizedForTranscription(conn *websocket.Conn, ...) bool
  • func (cm *ConnectionManager) RemoveConnection(conn *websocket.Conn)
• type UserConnection

Functions

func SetMQTTChannel

func SetMQTTChannel(ch chan mqtt.WebSocketMessage)

SetMQTTChannel sets the MQTT channel for forwarding messages to WebSocket clients

func WsProxyHandler

func WsProxyHandler(c *gin.Context)

Types

type ConnectionManager

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

ConnectionManager manages all active WebSocket connections

func (*ConnectionManager) AddConnection

func (cm *ConnectionManager) AddConnection(conn *websocket.Conn, user *UserConnection)

AddConnection adds a new connection to the manager

func (*ConnectionManager) BroadcastMQTTMessage

func (cm *ConnectionManager) BroadcastMQTTMessage(messageType string, data interface{})

BroadcastMQTTMessage sends an MQTT message to all authorized connections

func (*ConnectionManager) GetAllConnections

func (cm *ConnectionManager) GetAllConnections() map[*websocket.Conn]*UserConnection

GetAllConnections returns all active connections

func (*ConnectionManager) GetConnection

func (cm *ConnectionManager) GetConnection(conn *websocket.Conn) (*UserConnection, bool)

GetConnection gets connection data for a specific connection

func (*ConnectionManager) IsAuthorizedForTranscription

func (cm *ConnectionManager) IsAuthorizedForTranscription(conn *websocket.Conn, speakerName, speakerNumber, counterpartName, counterpartNumber string) bool

IsAuthorizedForTranscription checks if a user is authorized to receive a transcription

func (*ConnectionManager) RemoveConnection

func (cm *ConnectionManager) RemoveConnection(conn *websocket.Conn)

RemoveConnection removes a connection from the manager

type UserConnection

type UserConnection struct {
	Conn                 *websocket.Conn
	Username             string
	DisplayName          string
	PhoneNumbers         []string
	AccessKeyId          string
	TranscriptionEnabled bool
}

UserConnection represents a WebSocket connection with user data